historical ohlc support, edit tvWidget to enable.

2024-02-08 12:32:44 -08:00
parent 5465efbd86
commit 4ab0cc9659
4 changed files with 277 additions and 0 deletions
--- a/src/charts/datafeed.js
+++ b/src/charts/datafeed.js
@@ -0,0 +1,166 @@
+// import {
+// 	makeApiRequest,
+// 	generateSymbol,
+// 	parseFullSymbol,
+// } from './helpers.js';
+// import {
+// 	subscribeOnStream,
+// 	unsubscribeFromStream,
+// } from './streaming.js';
+import {jBars} from './jBars.js';
+
+const lastBarsCache = new Map();
+
+// DatafeedConfiguration implementation
+const configurationData = {
+	// Represents the resolutions for bars supported by your datafeed
+	// supported_resolutions: ['1D', '1W', '1M'],
+	supported_resolutions: ['1D'],
+	
+	// The `exchanges` arguments are used for the `searchSymbols` method if a user selects the exchange
+	exchanges: [{
+		value: 'Bitfinex',
+		name: 'Bitfinex',
+		desc: 'Bitfinex',
+	},
+	],
+	// The `symbols_types` arguments are used for the `searchSymbols` method if a user selects this symbol type
+	symbols_types: [{
+		name: 'crypto',
+		value: 'crypto',
+	},
+	],
+};
+
+// Obtains all symbols for all exchanges supported by CryptoCompare API
+async function getAllSymbols() {
+	// const data = await makeApiRequest('data/v3/all/exchanges');
+	// let allSymbols = [];
+	return [{
+		symbol: 'BTC/USD',
+		full_name: 'Bitfinex:BTC/USD',
+		description: 'BTC/USD',
+		exchange: 'Bitfinex',
+		type: 'crypto'}
+	];
+}
+
+export default {
+	onReady: (callback) => {
+		console.log('[onReady]: Method call');
+		setTimeout(() => callback(configurationData));
+	},
+
+	searchSymbols: async (
+		userInput,
+		exchange,
+		symbolType,
+		onResultReadyCallback,
+	) => {
+		console.log('[searchSymbols]: Method call');
+		const symbols = await getAllSymbols();
+		const newSymbols = symbols.filter(symbol => {
+			const isExchangeValid = exchange === '' || symbol.exchange === exchange;
+			const isFullSymbolContainsInput = symbol.full_name
+				.toLowerCase()
+				.indexOf(userInput.toLowerCase()) !== -1;
+			return isExchangeValid && isFullSymbolContainsInput;
+		});
+		onResultReadyCallback(newSymbols);
+	},
+
+	resolveSymbol: async (
+		symbolName,
+		onSymbolResolvedCallback,
+		onResolveErrorCallback,
+		extension
+	) => {
+		console.log('[resolveSymbol]: Method call', symbolName);
+		const symbols = await getAllSymbols();
+		const symbolItem = symbols.find(({
+			full_name,
+		}) => full_name === symbolName);
+		if (!symbolItem) {
+			console.log('[resolveSymbol]: Cannot resolve symbol', symbolName);
+			onResolveErrorCallback('cannot resolve symbol');
+			return;
+		}
+		// Symbol information object
+		const symbolInfo = {
+			ticker: symbolItem.full_name,
+			name: symbolItem.symbol,
+			description: symbolItem.description,
+			type: symbolItem.type,
+			session: '24x7',
+			timezone: 'Etc/UTC',
+			exchange: symbolItem.exchange,
+			minmov: 1,
+			pricescale: 100,
+			has_intraday: false,
+			has_no_volume: true,
+			has_weekly_and_monthly: false,
+			supported_resolutions: configurationData.supported_resolutions,
+			volume_precision: 2,
+			data_status: 'streaming',
+		};
+
+		console.log('[resolveSymbol]: Symbol resolved', symbolName);
+		onSymbolResolvedCallback(symbolInfo);
+	},
+
+	getBars: async (symbolInfo, resolution, periodParams, onHistoryCallback, onErrorCallback) => {
+		const { from, to, firstDataRequest } = periodParams;
+		console.log('[getBars]: Method call', symbolInfo, resolution, from, to);
+
+		// const parsedSymbol = parseFullSymbol(symbolInfo.full_name);
+		// const urlParameters = {
+		// 	e: parsedSymbol.exchange,
+		// 	fsym: parsedSymbol.fromSymbol,
+		// 	tsym: parsedSymbol.toSymbol,
+		// 	toTs: to,
+		// 	limit: 2000,
+		// };
+
+		try {
+			var bars = await jBars(from, to, resolution);
+
+			if (firstDataRequest) {
+				lastBarsCache.set(symbolInfo.full_name, {
+					...bars[bars.length - 1],
+				});
+			}
+			console.log(`[getBars]: returned ${bars.length} bar(s)`);
+			onHistoryCallback(bars, {
+				noData: false,
+			});
+		} catch (error) {
+			console.log('[getBars]: Get error', error);
+			onErrorCallback(error);
+		}
+	},
+
+	subscribeBars: (
+		symbolInfo,
+		resolution,
+		onRealtimeCallback,
+		subscriberUID,
+		onResetCacheNeededCallback,
+	) => {
+		console.log('[subscribeBars]: Method call with subscriberUID:', subscriberUID);
+		// throw Error('subscribeBars unimplemented');
+		// subscribeOnStream(
+		// 	symbolInfo,
+		// 	resolution,
+		// 	onRealtimeCallback,
+		// 	subscriberUID,
+		// 	onResetCacheNeededCallback,
+		// 	lastBarsCache.get(symbolInfo.full_name),
+		// );
+	},
+
+	unsubscribeBars: (subscriberUID) => {
+		console.log('[unsubscribeBars]: Method call with subscriberUID:', subscriberUID);
+		// throw Error('unsubscribeBars unimplemented');
+		// unsubscribeFromStream(subscriberUID);
+	},
+};