on replace block

boudra · Apr 24, 2024 · f405786 · f405786
1 parent 751c216
commit f405786
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/src/cache/postgres.ts b/src/cache/postgres.ts
@@ -99,7 +99,13 @@ export function createPostgresCache(args: {
         await client.query(
           `INSERT INTO ${tableName(
             "blocks"
-          )} (chainId, blockNumber, blockHash, timestamp) VALUES ($1, $2, $3, $4)`,
+          )} (chainId, blockNumber, blockHash, timestamp) VALUES ($1, $2, $3, $4)
+            ON CONFLICT (chainId, blockhash) DO UPDATE SET
+              blockHash = EXCLUDED.blockHash,
+              timestamp = EXCLUDED.timestamp,
+              blockNumber = EXCLUDED.blocknumber,
+              chainId = EXCLUDED.chainId
+          `,
           [
             args.chainId,
             args.blockNumber.toString(),