Add relay service

babel.config.js

@@ -0,0 +1,3 @@
+module.exports = {
+  presets: ['@babel/preset-env']
+}

lerna.json

@@ -0,0 +1,8 @@
+{
+  "packages": [
+    "packages/*"
+  ],
+  "version": "0.0.0",
+  "npmClient": "yarn",
+  "useWorkspaces": true
+}

package.json

@@ -1,22 +1,27 @@
 {
-  "name": "linkdrop-sdk",
+  "name": "@linkdrop/binance",
   "version": "1.0.0",
-  "description": "Linkdrop SDK",
+  "description": "Linkdrop Binance Monorepo",
   "main": "index.js",
   "repository": "https://github.com/LinkdropProtocol/linkdrop-sdk",
   "author": "Amir Jumaniyazov <[email protected]>",
   "license": "MIT",
-  "dependencies": {
-    "@binance-chain/javascript-sdk": "https://github.com/Dobrokhvalov/javascript-sdk",
-    "axios": "^0.19.0",
-    "ethers": "^4.0.31"
+  "private": true,
+  "workspaces": {
+    "packages": [
+      "packages/*"
+    ]
+  },
+  "scripts": {
+    "server": "npx babel-node packages/server/index"
   },
   "devDependencies": {
     "@babel/cli": "^7.4.4",
     "@babel/core": "^7.4.5",
     "@babel/node": "^7.4.5",
     "@babel/polyfill": "^7.4.4",
     "@babel/preset-env": "^7.4.5",
-    "@babel/register": "^7.4.4"
+    "@babel/register": "^7.4.4",
+    "lerna": "^3.16.4"
   }
 }

binance/index.js → packages/sdk/index.js

@@ -42,7 +42,7 @@ const signLinkParams = async ({ privateKey, asset, amount, linkId }) => {
   )
   let message = ethers.utils.arrayify(hash)
 
-  return await signer.signMessage(message)
+  return signer.signMessage(message)
 }
 
 /**
@@ -55,7 +55,7 @@ const signReceiverAddress = async ({ privateKey, receiverAddress }) => {
   const signer = new ethers.Wallet(privateKey)
   const hash = ethers.utils.solidityKeccak256(['string'], [receiverAddress])
   const message = ethers.utils.arrayify(hash)
-  return await signer.signMessage(message)
+  return signer.signMessage(message)
 }
 
 /**

packages/sdk/package.json

@@ -0,0 +1,25 @@
+{
+    "name": "@linkdrop/binance-sdk",
+    "version": "1.0.0",
+    "description": "Linkdrop Binance SDK",
+    "main": "index.js",
+    "repository": "https://github.com/LinkdropProtocol/linkdrop-sdk",
+    "author": "Amir Jumaniyazov <[email protected]>",
+    "license": "MIT",
+    "dependencies": {
+        "@binance-chain/javascript-sdk": "https://github.com/Dobrokhvalov/javascript-sdk",
+        "axios": "^0.19.0",
+        "ethers": "^4.0.31"
+    },
+    "devDependencies": {
+        "@babel/cli": "^7.4.4",
+        "@babel/core": "^7.4.5",
+        "@babel/node": "^7.4.5",
+        "@babel/polyfill": "^7.4.4",
+        "@babel/preset-env": "^7.4.5",
+        "@babel/register": "^7.4.4"
+    },
+    "babel": {
+        "extends": "../../babel.config.js"
+    }
+}

binance/utils/index.js → packages/sdk/utils/index.js

@@ -2,10 +2,10 @@ const axios = require('axios')
 const BncClient = require('@binance-chain/javascript-sdk')
 const { crypto } = BncClient
 
-const apiHost = 'https://dex.binance.org'
-const prefix = 'bnb'
-const network = 'mainnet'
-const transferFee = 37500
+const API_HOST = 'https://dex.binance.org'
+const PREFIX = 'bnb'
+const NETWORK = 'mainnet'
+const TRANSFER_FEE = 37500
 
 /**
  * @dev Function to retrieve balance of a given address
@@ -19,7 +19,7 @@ const getBalance = async ({ address, asset }) => {
       throw new Error('Please provide valid address')
     }
 
-    const result = await axios.get(`${apiHost}/api/v1/account/${address}`)
+    const result = await axios.get(`${API_HOST}/api/v1/account/${address}`)
     const balances = result.data.balances
 
     const balance = balances.find(
@@ -48,15 +48,15 @@ const getBalance = async ({ address, asset }) => {
  * @return {String} Address corresponding to `privateKey`
  */
 const getAddressFromPrivateKey = privateKey =>
-  crypto.getAddressFromPrivateKey(privateKey, prefix)
+  crypto.getAddressFromPrivateKey(privateKey, PREFIX)
 
 /**
  * @dev Returns a sequence for a given address
  * @param {String} address
  * @return {Number} Sequence
  */
 const getSequence = async address => {
-  const url = `${apiHost}/api/v1/account/${address}/sequence`
+  const url = `${API_HOST}/api/v1/account/${address}/sequence`
   const sequence = (await axios.get(url)).data.sequence || 0
   return Number(sequence)
 }
@@ -85,7 +85,7 @@ const formatUnits = value => {
  * @return {Promise<Object>} Transaction metadata
  */
 const getTransaction = async hash => {
-  const url = `${apiHost()}/api/v1/tx/${hash}?format=json`
+  const url = `${API_HOST()}/api/v1/tx/${hash}?format=json`
   return (await axios.get(url)).data
 }
 
@@ -95,8 +95,8 @@ const getTransaction = async hash => {
  * @return {Object} Binance chain client
  */
 const initBncClient = async privateKey => {
-  const bncClient = new BncClient(apiHost)
-  await bncClient.chooseNetwork(network)
+  const bncClient = new BncClient(API_HOST)
+  await bncClient.chooseNetwork(NETWORK)
   await bncClient.setPrivateKey(privateKey)
   await bncClient.initChain()
   return bncClient
@@ -118,9 +118,9 @@ module.exports = {
   parseUnits,
   getSequence,
   getAddressFromPrivateKey,
-  apiHost,
-  prefix,
-  network,
-  transferFee,
+  API_HOST,
+  PREFIX,
+  NETWORK,
+  TRANSFER_FEE,
   getPrivateKeyFromMnemonic
 }

server/api/controllers/claim.js → packages/server/api/controllers/claim.js

@@ -2,8 +2,7 @@ import ClaimTx from '../models/ClaimTx'
 import { wrapAsync } from '../utils'
 import sdk from '@linkdrop/binance-sdk'
 import Table from 'cli-table'
-
-const config = require('../../config/config.json')
+import config from '../../config/config.json'
 
 /**
  * Function to check whether a `linkId` has already been claimed

packages/server/api/utils/index.js

@@ -0,0 +1,2 @@
+import wrapAsync from './wrapAsync'
+export { wrapAsync }

packages/server/api/utils/wrapAsync.js

@@ -0,0 +1,13 @@
+import boom from '@hapi/boom'
+
+export default fn => (req, res, next) => {
+  fn(req, res, next).catch(err => {
+    if (!err.isBoom) {
+      if (err.name === 'CastError' || err.kind === 'ObjectId') {
+        return next(boom.notFound('No valid entry found'))
+      }
+      return next(boom.badImplementation(err))
+    }
+    next(err)
+  })
+}

server/index.js → packages/server/index.js

@@ -3,12 +3,12 @@ import express from 'express'
 import morgan from 'morgan'
 import mongoose from 'mongoose'
 import boom from '@hapi/boom'
-import claimController from './api/controllers/claim.controller'
+import claimController from './api/controllers/claim'
 
 require('dotenv').config()
 
 const app = express()
-const PORT = process.env.PORT || 5050
+const PORT = process.env.PORT || 5000
 const MONGODB_URI =
   process.env.MONGODB_URI || 'mongodb://localhost:27017/linkdrop-binance'
 
@@ -20,7 +20,7 @@ app.use(morgan('dev'))
 mongoose
   .connect(
     MONGODB_URI,
-    { useNewUrlParser: true, useFindAndModify: false }
+    { useNewUrlParser: true, useFindAndModify: false, useUnifiedTopology: true }
   )
   .then(() => {
     console.log('Connected to database at', MONGODB_URI)

server/package.json → packages/server/package.json

@@ -6,6 +6,9 @@
   "author": "Amir Jumaniyazov - <[email protected]>",
   "license": "MIT",
   "private": true,
+  "scripts": {
+    "start": "npx babel-node index"
+  },
   "dependencies": {
     "@binance-chain/javascript-sdk": "https://github.com/Dobrokhvalov/javascript-sdk",
     "@hapi/boom": "^7.4.2",
@@ -29,6 +32,9 @@
     "@babel/node": "^7.4.5",
     "@babel/polyfill": "^7.4.4",
     "@babel/preset-env": "^7.4.5",
-    "@babel/register": "^7.4.4",
+    "@babel/register": "^7.4.4"
+  },
+  "babel": {
+    "extends": "../../babel.config.js"
   }
 }