Merge pull request #36 from drift-labs/gpa-catch

catch gpa error

src/index.ts

@@ -289,11 +289,19 @@ const main = async () => {
 		const recursiveFetch = (delay = WS_FALLBACK_FETCH_INTERVAL) => {
 			setTimeout(() => {
 				const startFetch = Date.now();
-				dlobProvider.fetch().then(() => {
+				dlobProvider
-					gpaFetchDurationHistogram.record(Date.now() - startFetch);
+					.fetch()
-					// eslint-disable-next-line @typescript-eslint/no-unused-vars
+					.then(() => {
-					recursiveFetch();
+						gpaFetchDurationHistogram.record(Date.now() - startFetch);
-				});
+					})
+					.catch((e) => {
+						logger.error('Failed to fetch GPA');
+						console.log(e);
+					})
+					.finally(() => {
+						// eslint-disable-next-line @typescript-eslint/no-unused-vars
+						recursiveFetch();
+					});
 			}, delay);
 		};
 		recursiveFetch();

src/publishers/dlobPublisher.ts

@@ -30,6 +30,7 @@ import {
 	getDLOBProviderFromOrderSubscriber,
 	getDLOBProviderFromUserMap,
 } from '../dlobProvider';
+import FEATURE_FLAGS from '../utils/featureFlags';
 
 require('dotenv').config();
 const stateCommitment: Commitment = 'processed';
@@ -229,10 +230,22 @@ const main = async () => {
 		spotMarketSubscribers: MARKET_SUBSCRIBERS,
 	});
 	await dlobSubscriber.subscribe();
-	if (useWebsocket) {
+	if (useWebsocket && !FEATURE_FLAGS.DISABLE_GPA_REFRESH) {
-		setInterval(async () => {
+		const recursiveFetch = (delay = WS_FALLBACK_FETCH_INTERVAL) => {
-			await dlobProvider.fetch();
+			setTimeout(() => {
-		}, WS_FALLBACK_FETCH_INTERVAL);
+				dlobProvider
+					.fetch()
+					.catch((e) => {
+						logger.error('Failed to fetch GPA');
+						console.log(e);
+					})
+					.finally(() => {
+						// eslint-disable-next-line @typescript-eslint/no-unused-vars
+						recursiveFetch();
+					});
+			}, delay);
+		};
+		recursiveFetch();
 	}
 
 	console.log('DLOBSubscriber Publishing Messages');