Add radar data source

packages/pipeline/src/data_sources/radar/index.ts

@@ -0,0 +1,34 @@
+import { fetchAsync, logUtils } from '@0x/utils';
+import { RadarBook, RadarMarket } from '@radarrelay/types';
+
+const RADAR_BASE_URL = 'https://api.radarrelay.com/v2/';
+const ACTIVE_MARKETS_URL = `${RADAR_BASE_URL}/markets`;
+const MAX_PER_PAGE = 1000;
+
+export const RADAR_SOURCE = 'radar';
+
+// tslint:disable:prefer-function-over-method
+// ^ Keep consistency with other sources and help logical organization
+export class RadarSource {
+    /**
+     * Call Radar API to find out which markets they are maintaining orderbooks for.
+     */
+    public async getActiveMarketsAsync(): Promise<RadarMarket[]> {
+        logUtils.log('Getting all active Radar markets');
+        const resp = await fetchAsync(`${ACTIVE_MARKETS_URL}?perPage=${MAX_PER_PAGE}`);
+        const markets: RadarMarket[] = await resp.json();
+        logUtils.log(`Got ${markets.length} markets.`);
+        return markets;
+    }
+
+    /**
+     * Retrieve orderbook from Radar API for a given market.
+     * @param marketId String identifying the market we want data for. Eg. 'REP/AUG'
+     */
+    public async getMarketOrderbookAsync(marketId: string): Promise<RadarBook> {
+        logUtils.log(`${marketId}: Retrieving orderbook.`);
+        const marketOrderbookUrl = `${ACTIVE_MARKETS_URL}/${marketId}/book`;
+        const resp = await fetchAsync(marketOrderbookUrl);
+        return resp.json();
+    }
+}