Updated dwn-sdk-js and dwn-sql-store dependencies + v0.1.8 (#95)

Updated dependencies + v0.1.8

package.json

@@ -1,7 +1,7 @@
 {
   "name": "@web5/dwn-server",
   "type": "module",
-  "version": "0.1.7",
+  "version": "0.1.8",
   "files": [
     "dist",
     "src"
@@ -26,8 +26,8 @@
     "url": "https://github.com/TBD54566975/dwn-server/issues"
   },
   "dependencies": {
-    "@tbd54566975/dwn-sdk-js": "0.2.8",
-    "@tbd54566975/dwn-sql-store": "0.2.4",
+    "@tbd54566975/dwn-sdk-js": "0.2.9",
+    "@tbd54566975/dwn-sql-store": "0.2.5",
     "better-sqlite3": "^8.5.0",
     "bytes": "3.1.2",
     "cors": "2.8.5",

src/json-rpc-handlers/dwn/process-message.ts

@@ -1,5 +1,4 @@
 import type { RecordsReadReply } from '@tbd54566975/dwn-sdk-js';
-import { DwnInterfaceName, DwnMethodName } from '@tbd54566975/dwn-sdk-js';
 
 import type { Readable as IsomorphicReadable } from 'readable-stream';
 import { v4 as uuidv4 } from 'uuid';
@@ -23,26 +22,11 @@ export const handleDwnProcessMessage: JsonRpcHandler = async (
   const requestId = dwnRequest.id ?? uuidv4();
 
   try {
-    let reply;
-    const messageType =
-      message?.descriptor?.interface + message?.descriptor?.method;
-
-    // When a record is deleted via `RecordsDelete`, the initial RecordsWrite is kept as a tombstone _in addition_
-    // to the RecordsDelete message. the data associated to that initial RecordsWrite is deleted. If a record was written
-    // _and_ deleted before it ever got to dwn-server, we end up in a situation where we still need to process the tombstone
-    // so that we can process the RecordsDelete.
-    if (
-      messageType === DwnInterfaceName.Records + DwnMethodName.Write &&
-      !dataStream
-    ) {
-      reply = await dwn.synchronizePrunedInitialRecordsWrite(target, message);
-    } else {
-      reply = (await dwn.processMessage(
-        target,
-        message,
-        dataStream as IsomorphicReadable,
-      )) as RecordsReadReply;
-    }
+    const reply = (await dwn.processMessage(
+      target,
+      message,
+      dataStream as IsomorphicReadable,
+    )) as RecordsReadReply;
 
     // RecordsRead messages return record data as a stream to for accommodate large amounts of data
     let recordDataStream;