(sync) handle pulling tombstones

TBD54566975 · Jun 6, 2023 · bea54af · bea54af
1 parent d1afd13
commit bea54af
Showing 1 changed file with 11 additions and 2 deletions.
diff --git a/packages/web5-user-agent/src/sync-api.ts b/packages/web5-user-agent/src/sync-api.ts
@@ -314,9 +314,18 @@ export class SyncApi implements SyncManager {
               message   : recordsRead
             }) as RecordsReadReply;
 
-            if (reply.status.code >= 400) {
-              // TODO: handle reply
+            if (recordsReadReply.status.code >= 400) {
               const pruneReply = await this.#dwn.synchronizePrunedInitialRecordsWrite(did, message);
+
+              if (pruneReply.status.code === 202 || pruneReply.status.code === 409) {
+                await this.setWatermark(did, dwnUrl, 'pull', watermark);
+                await this.#addMessage(did, messageCid);
+                delOps.push({ type: 'del', key });
+
+                continue;
+              } else {
+                throw new Error(`Failed to sync tombstone. message cid: ${messageCid}`);
+              }
             } else {
               dataStream = webReadableToIsomorphicNodeReadable(recordsReadReply.record.data as any);
             }