feat: throw if storing event lower than current

HathorNetwork · Oct 2, 2023 · 59a7bc4 · 59a7bc4
1 parent 70f082d
commit 59a7bc4
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 0 deletions.
diff --git a/src/db/index.ts b/src/db/index.ts
@@ -26,6 +26,7 @@ import { isAuthority } from '../utils';
 import { AddressBalanceRow, AddressTxHistorySumRow, BestBlockRow, LastSyncedEventRow, MinerRow, TokenInformationRow, TransactionRow, TxOutputRow } from './types';
 // @ts-ignore
 import { walletUtils } from '@hathor/wallet-lib';
+import logger from '../logger';
 
 let pool: Pool;
 
@@ -1332,6 +1333,8 @@ export const updateLastSyncedEvent = async (
 ON DUPLICATE KEY
           UPDATE last_event_id = ?`,
   [lastEventId, lastEventId]);
+
+  logger.info('Updated last synced event', lastEventId);
 };
 
 export const getLastSyncedEvent = async ( // OK

diff --git a/src/services/index.ts b/src/services/index.ts
@@ -16,6 +16,7 @@ import {
   Wallet,
   DbTxOutput,
   DbTransaction,
+  LastSyncedEvent,
 } from '../types';
 import {
   prepareOutputs,
@@ -384,8 +385,19 @@ export const handleTxFirstBlock = async (context: Context) => {
 
 export const updateLastSyncedEvent = async (context: Context) => {
   const mysql = await getDbConnection();
+
+  const lastDbSyncedEvent: LastSyncedEvent | null = await getLastSyncedEvent(mysql);
   // @ts-ignore
   const lastEventId = context.event.event.id;
+
+  if (lastDbSyncedEvent
+     && lastDbSyncedEvent.last_event_id > lastEventId) {
+     logger.error('Tried to store an event lower than the one on the database', {
+       lastEventId,
+       lastDbSyncedEvent,
+     });
+     throw new Error('Event lower than stored one.');
+  }
   await dbUpdateLastSyncedEvent(mysql, lastEventId);
 
   mysql.destroy();