Fix issue in IndexedDB payload driver, other tests.

src/store/storage/payload_drivers/indexeddb.ts

@@ -1,3 +1,4 @@
+import { delay } from "https://deno.land/[email protected]/async/delay.ts";
 import { concat, deferred } from "../../../../deps.ts";
 import { ValidationError, WillowError } from "../../../errors.ts";
 import { Payload, PayloadScheme } from "../../types.ts";
@@ -198,12 +199,12 @@ export class PayloadDriverIndexedDb<PayloadDigest>
         PAYLOAD_STORE,
       );
 
-    const request = payloadStore.put(bytes, key);
-
     const didSet = deferred<
       { digest: PayloadDigest; length: bigint; payload: Payload }
     >();
 
+    const request = payloadStore.put(bytes, key);
+
     request.onsuccess = () => {
       didSet.resolve({
         digest,
@@ -261,20 +262,20 @@ export class PayloadDriverIndexedDb<PayloadDigest>
 
     const finalBytes = concat(existingBytes, receivedBytes);
 
-    const payloadStore2 = db.transaction([PAYLOAD_STORE], "readwrite")
+    const digest = await this.payloadScheme.fromBytes(
+      new Uint8Array(finalBytes),
+    );
+
+    const payloadStore = db.transaction([PAYLOAD_STORE], "readwrite")
       .objectStore(
         PAYLOAD_STORE,
       );
 
-    const request = payloadStore2.put(finalBytes, key);
-
     const didSet = deferred<
       { digest: PayloadDigest; length: bigint }
     >();
 
-    const digest = await this.payloadScheme.fromBytes(
-      new Uint8Array(finalBytes),
-    );
+    const request = payloadStore.put(finalBytes, key);
 
     request.onsuccess = () => {
       didSet.resolve({

src/wgps/encoding.test.ts

@@ -810,7 +810,7 @@ Deno.test("Encoding roundtrip test", async () => {
       aoiHandlesToRange3d: () => {
         return Promise.resolve(defaultRange3d(TestSubspace.Alfie));
       },
-      getCap: (handle) => {
+      getTheirCap: (handle) => {
         if (handle === BigInt(23)) {
           return Promise.resolve({
             namespace: TestNamespace.Bookclub,

src/wgps/wgps_messenger.test.ts

@@ -70,15 +70,15 @@ const scenarioMemory: WgpsScenario = {
       payloadDriver,
     });
   },
-  timeMultiplier: 10,
+  timeMultiplier: 20,
   dispose: () => Promise.resolve(),
 };
 
 testWgpsMessenger(scenarioMemory);
 
 class ScenarioPersisted implements WgpsScenario {
   name = "Filesystem";
-  timeMultiplier = 50;
+  timeMultiplier = 80;
 
   kvs: Deno.Kv[] = [];