ipfs-bch-wallet-consumer/src/controllers/rest-api/bch/index.js

/*
  REST API library for /bch route.
*/

// Public npm libraries.
const Router = require('koa-router')

// Local libraries.
const BchRESTControllerLib = require('./controller')
const Validators = require('../middleware/validators')

let _this

class BchRouter {
  constructor (localConfig = {}) {
    // Dependency Injection.
    this.adapters = localConfig.adapters
    if (!this.adapters) {
      throw new Error(
        'Instance of Adapters library required when instantiating BCH REST Controller.'
      )
    }
    this.useCases = localConfig.useCases
    if (!this.useCases) {
      throw new Error(
        'Instance of Use Cases library required when instantiating BCH REST Controller.'
      )
    }

    const dependencies = {
      adapters: this.adapters,
      useCases: this.useCases
    }

    // Encapsulate dependencies.
    this.bchRESTController = new BchRESTControllerLib(dependencies)
    this.validators = new Validators()

    // Instantiate the router and set the base route.
    const baseUrl = '/bch'
    this.router = new Router({ prefix: baseUrl })

    _this = this
  }

  attach (app) {
    if (!app) {
      throw new Error(
        'Must pass app object when attaching REST API controllers.'
      )
    }

    // Define the routes and attach the controller.
    this.router.get('/', this.getStatus)
    this.router.post('/provider', this.postProvider)
    this.router.post('/balance', this.postBalance)
    this.router.post('/utxos', this.postUtxos)
    this.router.post('/broadcast', this.postBroadcast)
    this.router.post('/txHistory', this.postTxHistory)
    this.router.post('/txData', this.postTxData)
    this.router.post('/pubkey', this.postPubKey)
    this.router.post('/utxoIsValid', this.utxoIsValid)
    this.router.post('/getTokenData', this.getTokenData)

    // Attach the Controller routes to the Koa app.
    app.use(this.router.routes())
    app.use(this.router.allowedMethods())
  }

  async getStatus (ctx, next) {
    await _this.bchRESTController.getStatus(ctx, next)
  }

  async postProvider (ctx, next) {
    await _this.bchRESTController.postProvider(ctx, next)
  }

  async postBalance (ctx, next) {
    await _this.bchRESTController.balance(ctx, next)
  }

  async postUtxos (ctx, next) {
    await _this.bchRESTController.utxos(ctx, next)
  }

  async postBroadcast (ctx, next) {
    await _this.bchRESTController.broadcast(ctx, next)
  }

  async postTxHistory (ctx, next) {
    await _this.bchRESTController.txHistory(ctx, next)
  }

  async postTxData (ctx, next) {
    await _this.bchRESTController.txData(ctx, next)
  }

  async postPubKey (ctx, next) {
    await _this.bchRESTController.pubKey(ctx, next)
  }

  async utxoIsValid (ctx, next) {
    await _this.bchRESTController.utxoIsValid(ctx, next)
  }

  async getTokenData (ctx, next) {
    await _this.bchRESTController.getTokenData(ctx, next)
  }
}

module.exports = BchRouter