Revert Base transfer sync from BitQuery back to CDP

Reverts PRs #954 and #956. BitQuery sync was fetching data but all
transfers were rejected as duplicates due to the unique constraint
(tx_hash, log_index, chain, block_timestamp) colliding with existing
CDP rows. The resumeOverlapMs caused the cursor to go backwards 60s
into CDP territory every run, creating an infinite loop of zero saves.

CDP resumes from its last transfer at 2026-06-05T17:45:31Z. No data
gap — CDP will backfill from that point to now via Coinbase.

Author: onchainlu

sync/transfers/trigger/chains/evm/base/bitquery/config.ts

@@ -16,7 +16,7 @@ export const baseCdpConfig: SyncConfig = {
   facilitators: FACILITATORS_BY_CHAIN(Network.BASE),
   buildQuery,
   transformResponse,
-  enabled: false,
+  enabled: true,
   machine: 'medium-1x',
   splitSyncByFacilitator: true,
 };

sync/transfers/trigger/chains/evm/base/bitquery/query.ts

@@ -14,8 +14,7 @@ export async function fetchWithOffsetPagination(
   facilitator: Facilitator,
   facilitatorConfig: FacilitatorConfig,
   since: Date,
-  now: Date,
-  onBatchFetched?: (batch: TransferEventData[]) => Promise<void>
+  now: Date
 ): Promise<TransferEventData[]> {
   const allTransfers = [];
   let offset = 0;
@@ -40,10 +39,6 @@ export async function fetchWithOffsetPagination(
 
     allTransfers.push(...transfers);
 
-    if (onBatchFetched && transfers.length > 0) {
-      await onBatchFetched(transfers);
-    }
-
     if (transfers.length < config.limit) {
       hasMore = false;
     } else {

sync/transfers/trigger/chains/evm/base/bitquery/sync.ts

@@ -137,10 +137,13 @@ async function fetchWithOffset(
       facilitator,
       facilitatorConfig,
       since,
-      now,
-      onBatchFetched
+      now
     );
 
+    if (onBatchFetched && results.length > 0) {
+      await onBatchFetched(results);
+    }
+
     return { totalFetched: results.length };
   }
 

sync/transfers/trigger/chains/evm/base/cdp/config.ts

@@ -5,55 +5,6 @@ import { fetchTransfers } from './fetch/fetch';
 
 import type { Facilitator, SyncConfig } from './types';
 
-type ResumeTransfer = Awaited<ReturnType<typeof getTransferEvents>>[number];
-
-function normalizeTransactionFrom(chain: string, address: string): string {
-  return chain === Network.SOLANA.toString() ? address : address.toLowerCase();
-}
-
-function getResumeSince(
-  latestTimestamp: Date | undefined,
-  syncConfig: SyncConfig,
-  syncStartDate: Date
-): Date {
-  if (!latestTimestamp) {
-    return syncStartDate;
-  }
-
-  const resumeTimestamp =
-    syncConfig.resumeOverlapMs !== undefined
-      ? latestTimestamp.getTime() - syncConfig.resumeOverlapMs
-      : latestTimestamp.getTime() + 1000;
-
-  return new Date(Math.max(resumeTimestamp, syncStartDate.getTime()));
-}
-
-async function getMostRecentTransferForResume(
-  syncConfig: SyncConfig,
-  transactionFrom: string,
-  resumeFromProviders: string[]
-): Promise<ResumeTransfer | undefined> {
-  const results = await Promise.all(
-    resumeFromProviders.map(provider =>
-      getTransferEvents({
-        orderBy: { block_timestamp: 'desc' },
-        take: 1,
-        where: {
-          chain: syncConfig.chain,
-          transaction_from: transactionFrom,
-          provider,
-        },
-      })
-    )
-  );
-
-  return results
-    .flat()
-    .sort(
-      (a, b) => b.block_timestamp.getTime() - a.block_timestamp.getTime()
-    )[0];
-}
-
 async function syncFacilitator(
   syncConfig: SyncConfig,
   facilitator: Facilitator,
@@ -73,29 +24,27 @@ async function syncFacilitator(
       `[${syncConfig.chain}] Getting most recent transfer for ${facilitator.id}:${facilitatorConfig.address}`
     );
 
-    const resumeFromProviders = syncConfig.resumeFromProviders ?? [
-      syncConfig.provider,
-    ];
-    const transactionFrom = normalizeTransactionFrom(
-      syncConfig.chain,
-      facilitatorConfig.address
-    );
-
-    const mostRecentTransfer = await getMostRecentTransferForResume(
-      syncConfig,
-      transactionFrom,
-      resumeFromProviders
-    );
+    const mostRecentTransfer = await getTransferEvents({
+      orderBy: { block_timestamp: 'desc' },
+      take: 1,
+      where: {
+        chain: syncConfig.chain,
+        transaction_from:
+          syncConfig.chain === Network.SOLANA.toString()
+            ? facilitatorConfig.address
+            : facilitatorConfig.address.toLowerCase(),
+        provider: syncConfig.provider,
+      },
+    });
 
     logger.log(
-      `[${syncConfig.chain}] Most recent transfer from ${resumeFromProviders.join(',')}: ${mostRecentTransfer?.block_timestamp?.toISOString()}`
+      `[${syncConfig.chain}] Most recent transfer: ${mostRecentTransfer[0]?.block_timestamp?.toISOString()}`
     );
 
-    const since = getResumeSince(
-      mostRecentTransfer?.block_timestamp,
-      syncConfig,
-      facilitatorConfig.syncStartDate
-    );
+    // Start from 1 second after the most recent transfer to avoid re-fetching it
+    const since = mostRecentTransfer[0]?.block_timestamp
+      ? new Date(mostRecentTransfer[0].block_timestamp.getTime() + 1000)
+      : facilitatorConfig.syncStartDate;
 
     logger.log(
       `[${syncConfig.chain}] Syncing ${facilitator.id}:${facilitatorConfig.address} from ${since.toISOString()} to ${now.toISOString()}`

sync/transfers/trigger/fetch/bitquery/fetch.ts

@@ -80,8 +80,6 @@ export type SyncConfig = QueryConfig & {
   enabled: boolean;
   machine: 'small-1x' | 'medium-1x' | 'large-2x';
   splitSyncByFacilitator?: boolean;
-  resumeFromProviders?: QueryProvider[];
-  resumeOverlapMs?: number;
 };
 
 export interface EvmChainConfig {
@@ -149,35 +147,3 @@ export interface BitQueryTransferRowStream {
     From: string;
   };
 }
-
-export interface EvmBitQueryTransferRow {
-  Transfer: {
-    Amount: string;
-    Sender: string;
-    Receiver: string;
-    Index: number;
-    Type: string;
-    Success: boolean;
-    Currency: {
-      Name: string;
-      SmartContract: string;
-      Symbol: string;
-      Decimals: number;
-    };
-  };
-  Block: {
-    Time: string;
-    Number: string;
-  };
-  Transaction: {
-    Hash: string;
-    From: string;
-    Index: number;
-  };
-  Log?: {
-    Index: number | null;
-  };
-  Call?: {
-    Index: number | null;
-  };
-}