sdk.js 2.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596
  1. var router = require('koa-router')();
  2. var moralis = require('../model/moralis_sdk.js')
  3. var utils = require('../model/utils.js');
  4. router.prefix('/sdk');
  5. /**
  6. * 获取代币价格
  7. * @param {*} ctx
  8. */
  9. async function getAllTotkenPrice(ctx) {
  10. console.log("body", typeof (ctx.request.body), ctx);
  11. const obj = ctx.request.body;
  12. console.log("obj", obj);
  13. // if (obj.address != null && obj.chain != null) {
  14. await moralis.getAllTotkenPrice(obj.address, obj.chain).then((result) => {
  15. console.log('getTotkenPrice result:', result)
  16. ctx.body = result;
  17. })
  18. // } else {
  19. // ctx.body = utils.toJson(-1, null, "please check address or chain parameter is ok ? ");
  20. // }
  21. }
  22. /**
  23. * 获取交易记录
  24. * @param {*} ctx
  25. */
  26. async function getTransfers(ctx) {
  27. console.log("body", ctx);
  28. const obj = ctx.request.body;
  29. console.log("obj", obj);
  30. if (!obj.chain)//默认 bsc 币安链
  31. obj.chain = 'bsc'
  32. await moralis.getTokenTransfers(obj).then((result) => {
  33. ctx.body = result;
  34. })
  35. }
  36. /**
  37. * 出金,入金交易
  38. * @param {*} ctx
  39. * @returns
  40. */
  41. async function transfer(ctx) {
  42. if (ctx.request == null || ctx.request.body == null) {
  43. ctx.body = utils.toJson(-1, null, "request error. ");
  44. return
  45. }
  46. const obj = ctx.request.body;
  47. await moralis.transfer(obj).then((result) => {
  48. ctx.body = result;
  49. });
  50. }
  51. async function getAllTokenWithdrawInfoLists(ctx) {
  52. if (ctx.request == null || ctx.request.body == null) {
  53. ctx.body = utils.toJson(-1, null, "request error. ");
  54. return
  55. }
  56. ctx.body = await moralis.getAllTokenWithdrawInfoLists(ctx);
  57. }
  58. //获取交易记录
  59. router.post('/getTransfers', getTransfers)
  60. // 获取所有代币价格
  61. router.post('/getAllTotkenPrice', getAllTotkenPrice)
  62. //归集 and 提现
  63. router.post('/transfer', transfer)
  64. //获取所有地址的所要消耗的最低提取费
  65. router.post('/getAllTokenWithdrawInfoLists', getAllTokenWithdrawInfoLists)
  66. async function crypto_test(ctx) {
  67. if (ctx.request == null || ctx.request.body == null) {
  68. ctx.body = utils.toJson(-1, null, "request error. ");
  69. return;
  70. }
  71. const obj = ctx.request.body;
  72. var crypt_key = obj.key;
  73. var message = obj.privateKey;
  74. //process.env.NODE_ENV
  75. console.log("NDK_HOME", process.env.NDK_HOME);
  76. var de_message = utils.decryptPrivityKey(crypt_key, message);
  77. console.log("decrypt message:", message);
  78. ctx.body = {
  79. decrypt: de_message
  80. }
  81. }
  82. router.post('/crypto_test', crypto_test)
  83. module.exports = router;