Implement apeswap pricefetcher (#7)

* create bakeryswap price fetching script

* create ape swap price fetching script

* cleanup

Author: DrMaxis

program/lib/interactive/market/actions.js

@@ -26,6 +26,10 @@ const pairs = [
 ];
 
 const exchanges = [
+  {
+    name: 'Apeswap',
+    description: 'Apeswap Decentralized Exchange'
+  },
   {
     name: 'Uniswap',
     description: 'Uniswap Decentralized Exchange'

program/lib/interactive/market/index.js

@@ -30,11 +30,12 @@ function startInteractiveMarketFetcher() {
         case 'Bakeryswap':
           fetcher.fetchBakeryswapPairPrice(answers.pair);
           break;
+        case 'Apeswap':
+          fetcher.fetchApeswapPairPrice(answers.pair);
+          break;
         default:
       }
     });
-
-
 }
 
 exports.init = () => {

program/utils/marketfetcher/apeswap/apeswapPriceFetcher.js

@@ -0,0 +1,72 @@
+const Web3 = require('web3');
+const { mainnet } = require('../../addresses');
+const web3 = new Web3(new Web3.providers.WebsocketProvider(process.env.MORALIAS_BSC_MAINNET_WSS_URL));
+const _ = require("lodash");
+const BigNumber = require("bignumber.js");
+
+const apeswap = {
+  factory: new web3.eth.Contract(mainnet.apeswap.factory.ABI, mainnet.apeswap.factory.address),
+  router: new web3.eth.Contract(mainnet.apeswap.router.ABI, mainnet.apeswap.router.address),
+}
+
+const baseAmount = 1;
+
+process.on('message', function (data) {
+  if (data === false) {
+    process.exit(1);
+  } else {
+    fetchData(data);
+  }
+});
+
+async function fetchData(data) {
+  let stableToken = {
+    name: mainnet.tokenPairs.Binance[data.pair].stableToken.name,
+    address: mainnet.tokenPairs.Binance[data.pair].stableToken.address,
+    decimals: mainnet.tokenPairs.Binance[data.pair].stableToken.decimals,
+  }
+
+  let tradingToken = {
+    name: mainnet.tokenPairs.Binance[data.pair].tradingToken.name,
+    address: mainnet.tokenPairs.Binance[data.pair].tradingToken.address,
+    decimals: mainnet.tokenPairs.Binance[data.pair].tradingToken.decimals,
+  }
+
+
+  console.log(`Fetching Ape Swap Prices...`)
+  web3.eth.subscribe('newBlockHeaders', (error, result) => {
+    if (!error) {
+      return;
+    }
+    console.error(error);
+  })
+    .on("Connected To Binance SmartChain", subscriptionId => {
+      console.log(`You are connected on ${subscriptionId}`);
+    })
+    .on('data', async block => {
+      console.log('-------------------------------------------------------------');
+      console.log(`Trading ${tradingToken.name}/${stableToken.name} ...`);
+      const exchangeAmount = await new BigNumber(baseAmount);
+      const shiftedExchangeAmount = await new BigNumber(exchangeAmount).shiftedBy(tradingToken.decimals);
+      let tokenIn = tradingToken.address
+      let tokenOut = stableToken.address;
+      const rawValue = await apeswap.router.methods.getAmountsOut(shiftedExchangeAmount, [tokenIn, tokenOut]).call();
+      const shiftedValue = await new BigNumber(rawValue[1]).shiftedBy(-stableToken.decimals);
+
+
+      process.send({
+        tokenIn: {
+          name: tradingToken.name,
+          value: exchangeAmount.toString(),
+        },
+        tokenOut: {
+          name: stableToken.name,
+          value: shiftedValue.toString()
+        }
+      });
+
+    })
+    .on('error', error => {
+      console.log(error);
+    });
+}

program/utils/marketfetcher/apeswap/index.js

@@ -0,0 +1,46 @@
+require("dotenv").config()
+
+const fetchProcess = require('child_process');
+const pad = require("pad");
+const colors = require("colors");
+
+async function fetchData(data) {
+  const process = fetchProcess.fork(__dirname+'/apeswapPriceFetcher.js', [], {silent: true});
+  process.send(data)
+  process.stdout.on('data', function(standardOutData) {
+    console.log(standardOutData.toString());
+  });
+
+  process.stderr.on('data', function(standardErrorData) {
+    if(standardErrorData.toString().includes('Warning:')) {
+    } else {
+      console.log('Error: ' + standardErrorData );
+    }
+  });
+
+  process.on('message', function(response) {
+
+
+    console.log(
+      pad(colors.red('Token In:'), 30), response.tokenIn.name,
+      pad(colors.red('Value: '), 30), response.tokenIn.value
+    );
+    console.log(
+      pad(colors.green('Token Out: '), 30), response.tokenOut.name,
+      pad(colors.green('Value Out: '), 30), response.tokenOut.value)
+    ;
+
+
+    process.send(data = false);
+  });
+
+  process.on('close', function(code, data) {
+    console.log('Done. Closing ' + code);
+  });
+}
+
+module.exports = {
+  getAssetInfo: function(data) {
+    return  fetchData(data);
+  }
+}

program/utils/marketfetcher/bakeryswap/bakeryswapPriceFetcher.js

@@ -33,7 +33,6 @@ async function fetchData(data) {
   }
 
 
-  //console.log(mainnet.tokenPairs.Binance[data.pair].stableToken.name);
   console.log(`Fetching Bakery Swap Prices...`)
   web3.eth.subscribe('newBlockHeaders', (error, result) => {
     if (!error) {
@@ -51,7 +50,6 @@ async function fetchData(data) {
       const shiftedExchangeAmount = await new BigNumber(exchangeAmount).shiftedBy(tradingToken.decimals);
       let tokenIn = tradingToken.address
       let tokenOut = stableToken.address;
-      // call getAmountsOut in PancakeSwap
       const rawValue = await bakeryswap.router.methods.getAmountsOut(shiftedExchangeAmount, [tokenIn, tokenOut]).call();
       const shiftedValue = await new BigNumber(rawValue[1]).shiftedBy(-stableToken.decimals);
 

program/utils/marketfetcher/index.js

@@ -1,12 +1,17 @@
 require('dotenv').config();
-const _ = require('lodash');
+const ApeswapService = require('../marketfetcher/apeswap');
+const BakeryswapService = require('../marketfetcher/bakeryswap');
 const CMKService = require('../marketfetcher/cmk');
 const DyDxService = require('../marketfetcher/dydx');
-const UniswapService = require('../marketfetcher/uniswap');
 const KyberService = require('../marketfetcher/kyber');
 const SushiswapService = require('../marketfetcher/sushiswap');
-const PancakeswapService = require('../marketfetcher/pancakeswap');
-const BakeryswapService = require('../marketfetcher/bakeryswap')
+const UniswapService = require('../marketfetcher/uniswap');
+
+
+function fetchApeswapPairPrice(pair) {
+  let data = {pair:pair};
+  return ApeswapService.getAssetInfo(data);
+}
 
 function fetchBakeryswapPairPrice(pair) {
   let data = {pair:pair};
@@ -59,6 +64,9 @@ module.exports = {
     },
     fetchBakeryswapPairPrice: function(pair) {
       return fetchBakeryswapPairPrice(pair);
+    },
+    fetchApeswapPairPrice: function(pair) {
+      return fetchApeswapPairPrice(pair);
     }
   }
 }