Call .sync on every synced document every 24 hours

Author: peachbits

src/v3/providers/coingecko/coingecko.ts

@@ -20,6 +20,7 @@ import {
   wasExistingMappings
 } from '../../types'
 import {
+  create24HourSyncInterval,
   createTokenId,
   expandReturnedCryptoRates,
   isCurrent,
@@ -110,15 +111,9 @@ const platformIdMappingSyncDoc = syncedDocument(
   'coingecko:platforms',
   asStringNullMap
 )
-manualTokenMappingsSyncDoc.sync(dbSettings).catch(e => {
-  console.error('manualTokenMappingsSyncDoc sync error', e)
-})
-automatedTokenMappingsSyncDoc.sync(dbSettings).catch(e => {
-  console.error('automatedTokenMappingsSyncDoc sync error', e)
-})
-platformIdMappingSyncDoc.sync(dbSettings).catch(e => {
-  console.error('platformIdMappingSyncDoc sync error', e)
-})
+create24HourSyncInterval(manualTokenMappingsSyncDoc, dbSettings)
+create24HourSyncInterval(automatedTokenMappingsSyncDoc, dbSettings)
+create24HourSyncInterval(platformIdMappingSyncDoc, dbSettings)
 manualTokenMappingsSyncDoc.onChange(manualMappings => {
   coingeckoTokenIdMap = {
     ...automatedTokenMappingsSyncDoc.doc,

src/v3/providers/coinmarketcap/coinmarketcap.ts

@@ -22,6 +22,7 @@ import {
   wasExistingMappings
 } from '../../types'
 import {
+  create24HourSyncInterval,
   createTokenId,
   expandReturnedCryptoRates,
   isCurrent,
@@ -144,15 +145,9 @@ const platformIdMappingSyncDoc = syncedDocument(
   'coinmarketcap:platforms',
   asStringNullMap
 )
-userTokenMappingsSyncDoc.sync(dbSettings).catch(e => {
-  console.error('manualTokenMappingsSyncDoc sync error', e)
-})
-automatedTokenMappingsSyncDoc.sync(dbSettings).catch(e => {
-  console.error('automatedTokenMappingsSyncDoc sync error', e)
-})
-platformIdMappingSyncDoc.sync(dbSettings).catch(e => {
-  console.error('platformIdMappingSyncDoc sync error', e)
-})
+create24HourSyncInterval(userTokenMappingsSyncDoc, dbSettings)
+create24HourSyncInterval(automatedTokenMappingsSyncDoc, dbSettings)
+create24HourSyncInterval(platformIdMappingSyncDoc, dbSettings)
 userTokenMappingsSyncDoc.onChange(userMappings => {
   coinmarketcapTokenIdMap = {
     ...automatedTokenMappingsSyncDoc.doc,

src/v3/providers/constantRates.ts

@@ -2,14 +2,15 @@ import { asNumber, asObject } from 'cleaners'
 import { syncedDocument } from 'edge-server-tools'
 
 import type { NumberMap, RateBuckets, RateProvider } from '../types'
-import { expandReturnedCryptoRates, reduceRequestedCryptoRates } from '../utils'
+import {
+  create24HourSyncInterval,
+  expandReturnedCryptoRates,
+  reduceRequestedCryptoRates
+} from '../utils'
 import { dbSettings } from './couch'
 
 const constantRateSyncDoc = syncedDocument('constantrates', asObject(asNumber))
-
-constantRateSyncDoc.sync(dbSettings).catch(e => {
-  console.error('constantRateSyncDoc sync error', e)
-})
+create24HourSyncInterval(constantRateSyncDoc, dbSettings)
 
 export const constantRates: RateProvider = {
   providerId: 'constantRates',

src/v3/router.ts

@@ -15,7 +15,7 @@ import {
   type GetRatesParams,
   type IncomingGetRatesParams
 } from './types'
-import { toCryptoKey } from './utils'
+import { create24HourSyncInterval, toCryptoKey } from './utils'
 
 const fixIncomingGetRatesParams = (
   rawParams: IncomingGetRatesParams,
@@ -99,12 +99,8 @@ const automatedCrossChainSyncDoc = syncedDocument(
   'crosschain:automated',
   asCrossChainMapping
 )
-defaultCrossChainSyncDoc.sync(dbSettings).catch(e => {
-  console.error('defaultCrossChainSyncDoc sync error', e)
-})
-automatedCrossChainSyncDoc.sync(dbSettings).catch(e => {
-  console.error('automatedCrossChainSyncDoc sync error', e)
-})
+create24HourSyncInterval(defaultCrossChainSyncDoc, dbSettings)
+create24HourSyncInterval(automatedCrossChainSyncDoc, dbSettings)
 defaultCrossChainSyncDoc.onChange(defaultMappings => {
   crosschainMappings = {
     ...automatedCrossChainSyncDoc.doc,

src/v3/utils.ts

@@ -1,3 +1,6 @@
+import type { SyncedDocument } from 'edge-server-tools'
+import type nano from 'nano'
+
 import { FIVE_MINUTES, ONE_MINUTE, TWENTY_FOUR_HOURS } from './constants'
 import type {
   CryptoRateMap,
@@ -304,3 +307,26 @@ export const isCurrent = (
 }
 export const isCurrentFiat = (isoDate: Date, rightNow: Date): boolean =>
   isCurrent(isoDate, rightNow, TWENTY_FOUR_HOURS)
+
+/**
+ * Create an interval to manually refresh the synced document.
+ * This is a workaround in case we lose the connection to the CouchDB changes feed.
+ */
+export const create24HourSyncInterval = (
+  syncedDocument: SyncedDocument<unknown>,
+  db: nano.DocumentScope<any>,
+  label: string = ''
+): void => {
+  syncedDocument
+    .sync(db)
+    .then(() => {
+      setInterval(() => {
+        syncedDocument.sync(db).catch(e => {
+          console.error('interval sync error', e)
+        })
+      }, TWENTY_FOUR_HOURS)
+    })
+    .catch(e => {
+      console.error('create24HourSyncInterval error', e)
+    })
+}