You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
136 lines
3.6 KiB
136 lines
3.6 KiB
/*!
|
|
* accounts/multiaddr-rest-api.js
|
|
* Copyright © 2019 – Katana Cryptographic Ltd. All Rights Reserved.
|
|
*/
|
|
'use strict'
|
|
|
|
const bodyParser = require('body-parser')
|
|
const Logger = require('../lib/logger')
|
|
const errors = require('../lib/errors')
|
|
const walletService = require('../lib/wallet/wallet-service')
|
|
const authMgr = require('../lib/auth/authorizations-manager')
|
|
const HttpServer = require('../lib/http-server/http-server')
|
|
const apiHelper = require('./api-helper')
|
|
|
|
const debugApi = !!(process.argv.indexOf('api-debug') > -1)
|
|
|
|
|
|
/**
|
|
* Multiaddr API endpoints
|
|
*/
|
|
class MultiaddrRestApi {
|
|
|
|
/**
|
|
* Constructor
|
|
* @param {pushtx.HttpServer} httpServer - HTTP server
|
|
*/
|
|
constructor(httpServer) {
|
|
this.httpServer = httpServer
|
|
|
|
// Establish routes
|
|
const urlencodedParser = bodyParser.urlencoded({ extended: true })
|
|
|
|
this.httpServer.app.get(
|
|
'/multiaddr',
|
|
authMgr.checkAuthentication.bind(authMgr),
|
|
apiHelper.validateEntitiesParams.bind(apiHelper),
|
|
this.getMultiaddr.bind(this),
|
|
HttpServer.sendAuthError
|
|
)
|
|
|
|
this.httpServer.app.post(
|
|
'/multiaddr',
|
|
urlencodedParser,
|
|
authMgr.checkAuthentication.bind(authMgr),
|
|
apiHelper.validateEntitiesParams.bind(apiHelper),
|
|
this.postMultiaddr.bind(this),
|
|
HttpServer.sendAuthError
|
|
)
|
|
}
|
|
|
|
/**
|
|
* Handle multiaddr GET request
|
|
* @param {object} req - http request object
|
|
* @param {object} res - http response object
|
|
*/
|
|
async getMultiaddr(req, res) {
|
|
try {
|
|
// Check request params
|
|
if (!apiHelper.checkEntitiesParams(req.query))
|
|
return HttpServer.sendError(res, errors.multiaddr.NOACT)
|
|
|
|
// Parse params
|
|
const entities = apiHelper.parseEntitiesParams(req.query)
|
|
|
|
const result = await walletService.getWalletInfo(
|
|
entities.active,
|
|
entities.legacy,
|
|
entities.bip49,
|
|
entities.bip84,
|
|
entities.pubkey
|
|
)
|
|
|
|
const ret = JSON.stringify(result, null, 2)
|
|
HttpServer.sendRawData(res, ret)
|
|
|
|
} catch(e) {
|
|
HttpServer.sendError(res, e)
|
|
|
|
} finally {
|
|
if (debugApi) {
|
|
const strParams =
|
|
`${req.query.active ? req.query.active : ''} \
|
|
${req.query.new ? req.query.new : ''} \
|
|
${req.query.pubkey ? req.query.pubkey : ''} \
|
|
${req.query.bip49 ? req.query.bip49 : ''} \
|
|
${req.query.bip84 ? req.query.bip84 : ''}`
|
|
|
|
Logger.info(`Completed GET /multiaddr ${strParams}`)
|
|
}
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Handle multiaddr POST request
|
|
* @param {object} req - http request object
|
|
* @param {object} res - http response object
|
|
*/
|
|
async postMultiaddr(req, res) {
|
|
try {
|
|
// Check request params
|
|
if (!apiHelper.checkEntitiesParams(req.body))
|
|
return HttpServer.sendError(res, errors.multiaddr.NOACT)
|
|
|
|
// Parse params
|
|
const entities = apiHelper.parseEntitiesParams(req.body)
|
|
|
|
const result = await walletService.getWalletInfo(
|
|
entities.active,
|
|
entities.legacy,
|
|
entities.bip49,
|
|
entities.bip84,
|
|
entities.pubkey
|
|
)
|
|
|
|
HttpServer.sendOkDataOnly(res, result)
|
|
|
|
} catch(e) {
|
|
HttpServer.sendError(res, e)
|
|
|
|
} finally {
|
|
if (debugApi) {
|
|
const strParams =
|
|
`${req.body.active ? req.body.active : ''} \
|
|
${req.body.new ? req.body.new : ''} \
|
|
${req.body.pubkey ? req.body.pubkey : ''} \
|
|
${req.body.bip49 ? req.body.bip49 : ''} \
|
|
${req.body.bip84 ? req.body.bip84 : ''}`
|
|
|
|
Logger.info(`Completed POST /multiaddr ${strParams}`)
|
|
}
|
|
}
|
|
}
|
|
|
|
}
|
|
|
|
module.exports = MultiaddrRestApi
|
|
|