avoid context leakage in start() method

nocturne-xyz · Sep 2, 2023 · ba9d6e9 · ba9d6e9
1 parent 5baf719
commit ba9d6e9
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/actors/insertion-writer/src/index.ts b/actors/insertion-writer/src/index.ts
@@ -30,10 +30,12 @@ export class InsertionWriter {
   }
 
   async start(queryThrottleMs?: number): Promise<ActorHandle> {
-    const logTip = (await this.insertionLog.getTip()) ?? "0-0";
+    const logTip = await this.insertionLog.getTip();
     this.logger.debug(`current log tip: ${logTip}`);
 
-    const logTipMerkleIndex = merkleIndexFromRedisStreamId(logTip);
+    const logTipMerkleIndex = logTip
+      ? merkleIndexFromRedisStreamId(logTip)
+      : undefined;
     this.logger.debug("starting iterator");
     const newInsertionBatches = this.adapter.iterInsertions(
       logTipMerkleIndex ?? 0,