summaryrefslogtreecommitdiff
path: root/packages/idb-bridge/src/idb-wpt-ported/transaction-requestqueue.test.ts
blob: 707bb5255959a61838052c43c17289d8e8e0d607 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
import test from "ava";
import { createdb } from "./wptsupport";

// Transactions have a request queue
test("transaction-requestqueue.htm", async (t) => {
  await new Promise<void>((resolve, reject) => {
    var db: any;
    let keys = { txn: [], txn2: [] };
    let open_rq = createdb(t);

    open_rq.onupgradeneeded = function (e: any) {
      var i, os;
      db = e.target.result;

      for (i = 1; i < 6; i++) {
        os = db.createObjectStore("os" + i, {
          autoIncrement: true,
          keyPath: "k",
        });
        os.add({ os: "os" + i });
        os.put({ os: "os" + i, k: i });
        os.add({ os: "os" + i });
      }
    };

    open_rq.onsuccess = function (e: any) {
      var txn = db.transaction(["os2", "os1", "os3", "os5"]);
      txn.objectStore("os1").openCursor().onsuccess = reg("txn");
      txn.objectStore("os3").openCursor().onsuccess = reg("txn");
      txn.objectStore("os1").get(2).onsuccess = reg("txn");
      txn.objectStore("os2").get(3).onsuccess = reg("txn");

      var txn2 = db.transaction(["os4", "os3", "os1", "os5"]);
      var os4 = txn2.objectStore("os4");

      for (var i = 0; i < 3; i++) {
        os4.openCursor().onsuccess = reg("txn2");
        os4.get(5).onsuccess = reg("txn2");
        os4.get(4).onsuccess = reg("txn2");
        txn.objectStore("os2").get(1).onsuccess = reg("txn");
        txn2.objectStore("os3").get(1).onsuccess = reg("txn2");
      }

      txn2.objectStore("os1").get(2).onsuccess = reg("txn2");
      txn.objectStore("os1").openCursor(null, "prev").onsuccess = reg("txn");
      os4.openCursor(null, "prev").onsuccess = reg("txn2");

      txn.oncomplete = finish;
      txn2.oncomplete = finish;
    };

    function reg(n: string) {
      return function (e: any) {
        var v = e.target.result;
        if (v.value) v = v.value;
        (keys as any)[n].push(v.os + ": " + v.k);
      };
    }

    var finish_to_go = 2;
    function finish() {
      if (--finish_to_go) return;

      t.deepEqual(
        keys["txn"],
        [
          "os1: 1",
          "os3: 1",
          "os1: 2",
          "os2: 3",
          "os2: 1",
          "os2: 1",
          "os2: 1",
          "os1: 2",
        ],
        "transaction keys",
      );

      t.deepEqual(
        keys["txn2"],
        [
          "os4: 1",
          "os4: 5",
          "os4: 4",
          "os3: 1",
          "os4: 1",
          "os4: 5",
          "os4: 4",
          "os3: 1",
          "os4: 1",
          "os4: 5",
          "os4: 4",
          "os3: 1",
          "os1: 2",
          "os4: 5",
        ],
        "transaction 2 keys",
      );

      resolve();
    }
  });
  t.pass();
});