crowetic/protocol
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Changed Maps to EdpsWrappers

Browse Source
This commit is contained in:
askeluv
2019-02-14 15:30:58 +08:00
parent c36e1ad056
commit ab286d851d
4 changed files with 29 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
packages/pipeline/src/scripts/pull_slippage.ts
View File

@@ -22,6 +22,7 @@ const USD_AMOUNTS = [10, 100, 1000, 10000];
// TODO: fetch from database
const TOKENS = ['BAT', 'DAI', 'FUN', 'MANA', 'OMG', 'REP', 'TUSD', 'ZRX', 'MKR', 'BNB', 'USDC', 'LOOM', 'DNT', 'CVC'];
//const TOKENS = ['BAT', 'DNT', 'CVC', 'MANA'];
let connection: Connection;
@@ -37,12 +38,18 @@ let connection: Connection;
return Promise.all(
USD_AMOUNTS.map(async usdAmount => {
const amount = usdAmount / usdPrice;
const buyEdps = await edpsSource.getEdpsAsync('buy', symbol, amount);
const sellEdps = await edpsSource.getEdpsAsync('sell', symbol, amount);
return Array.from(buyEdps.keys()).map(exchange => {
const slippage: Slippage = calculateSlippage(usdAmount, exchange, buyEdps, sellEdps);
return slippage;
});
try {
const buyEdps = await edpsSource.getEdpsAsync('buy', symbol, amount);
const sellEdps = await edpsSource.getEdpsAsync('sell', symbol, amount);
return Object.keys(buyEdps).map(exchange => {
const slippage: Slippage = calculateSlippage(usdAmount, exchange, buyEdps, sellEdps);
return slippage;
});
} catch (e) {
logUtils.log(`Error getting data for symbol=${symbol}, amount=${amount}`);
logUtils.log(e);
return [new Slippage()];
}
}),
);
}),