add volume source queries to synthetix-data - WIP - need to update the api endpoint once the volume graph PR is merged

Author: david-defi-uf

README.md

@@ -39,6 +39,7 @@ The below all return a Promise that resolves with the requested results.
 27. `snx.aggregateActiveStakers({ max, timeSeries })` Get the number of active stakers across various time series.
 28. `snx.totalActiveStakers()` Get the current number of active stakers.
 29. `rate.dailyRateChange({ synths })` get the rate change over the past 24 hours for any synth. Can pass in a list to retrieve multiple synths.
+30. `exchanger.exchangeSourceData({ timeSeries, partner })` Get the list of volume from all or specific sources.
 
 ## Supported subscriptions
 

bin.js

@@ -474,6 +474,18 @@ program
 			.then(showResultCount({ max }));
 	});
 
+program
+	.command('exchanger.exchangeSourceData')
+	.option('-t, --timeSeries <value>', 'The type of timeSeries - 7d, 30d, 1mo, 365d, 12mo, 1y', '1mo')
+	.option('-p, --partner <value>', 'Partner to filter on, if any')
+
+	.action(async ({ timeSeries, partner }) => {
+		exchanger
+			.exchangeSourceData({ timeSeries, partner })
+			.then(logResults())
+			.then(showResultCount({ max: 'n/a' }));
+	});
+
 program.command('exchanges.observe').action(async () => {
 	exchanges.observe().subscribe({
 		next(val) {

index.js

@@ -16,6 +16,8 @@ const graphAPIEndpoints = {
 	exchanger: 'https://api.thegraph.com/subgraphs/name/synthetixio-team/synthetix-exchanger',
 };
 
+const tempEndpoint = 'https://api.thegraph.com/subgraphs/name/dvd-schwrtz/exchanger';
+
 const graphWSEndpoints = {
 	exchanges: 'wss://api.thegraph.com/subgraphs/name/synthetixio-team/synthetix-exchanges',
 	rates: 'wss://api.thegraph.com/subgraphs/name/synthetixio-team/synthetix-rates',
@@ -1242,5 +1244,41 @@ module.exports = {
 				)
 				.catch(err => console.error(err));
 		},
+		exchangeSourceData({ timeSeries = '1mo', partner = undefined }) {
+			const now = new Date();
+			const currentDayID = Math.floor(now.getTime() / 86400 / 1000);
+			let searchFromDayID;
+			if (timeSeries === '7d') {
+				searchFromDayID = currentDayID - 7;
+			} else if (timeSeries === '1mo' || timeSeries === '30d') {
+				searchFromDayID = currentDayID - 30;
+			} else if (timeSeries === '1y' || timeSeries === '365d' || timeSeries === '12mo') {
+				searchFromDayID = currentDayID - 365;
+			}
+			return pageResults({
+				api: tempEndpoint,
+				max: 10000,
+				query: {
+					entity: 'dailyExchangePartners',
+					selection: {
+						orderBy: 'id',
+						orderDirection: 'desc',
+						where: {
+							dayID_gt: searchFromDayID ? `\\"${searchFromDayID}\\"` : undefined,
+							partner: partner ? `\\"${partner}\\"` : undefined,
+						},
+					},
+					properties: ['trades', 'usdVolume', 'usdFees', 'partner', 'dayID'],
+				},
+			}).then(results =>
+				results.map(({ dayID, partner, trades, usdFees, usdVolume }) => ({
+					dayID: Number(dayID),
+					partner,
+					trades: Number(trades),
+					usdFees: Math.round(Number(usdFees) * 100) / 100,
+					usdVolume: Math.round(Number(usdVolume) * 100) / 100,
+				})),
+			);
+		},
 	},
 };