ignore non-existent message

decentralized-identity · Jun 8, 2023 · 49f8e7b · 49f8e7b
1 parent dd83cec
commit 49f8e7b
Showing 1 changed file with 10 additions and 1 deletion.
diff --git a/packages/web5-user-agent/src/sync-api.ts b/packages/web5-user-agent/src/sync-api.ts
@@ -291,7 +291,16 @@ export class SyncApi implements SyncManager {
       }
 
       for (let entry of reply.messages) {
-        // TODO: check entry.error
+        if (entry.error || !entry.message) {
+          console.warn(`message ${messageCid} not found. entry: ${JSON.stringify(entry, null, 2)} ignoring..`);
+
+          await this.setWatermark(did, dwnUrl, 'pull', watermark);
+          await this.#addMessage(did, messageCid);
+          delOps.push({ type: 'del', key });
+
+          continue;
+        }
+
         const messageType = this.#getDwnMessageType(entry.message);
         let dataStream;