diff options
author | Florian Dold <florian@dold.me> | 2021-02-19 21:27:49 +0100 |
---|---|---|
committer | Florian Dold <florian@dold.me> | 2021-02-19 21:27:49 +0100 |
commit | e6946694f2e7ae6ff25f490fa76f3da583c44c74 (patch) | |
tree | 892369b87d1f667271e588eef44b0dff1d695774 /packages/idb-bridge/src/idb-wpt-ported/idbcursor-advance-index.test.ts | |
parent | c800e80138358430b924937b2f4fed69376181ce (diff) | |
download | wallet-core-e6946694f2e7ae6ff25f490fa76f3da583c44c74.tar.xz |
idb: more tests, fix DB deletion, exception ordering and transaction active checks
Diffstat (limited to 'packages/idb-bridge/src/idb-wpt-ported/idbcursor-advance-index.test.ts')
-rw-r--r-- | packages/idb-bridge/src/idb-wpt-ported/idbcursor-advance-index.test.ts | 255 |
1 files changed, 255 insertions, 0 deletions
diff --git a/packages/idb-bridge/src/idb-wpt-ported/idbcursor-advance-index.test.ts b/packages/idb-bridge/src/idb-wpt-ported/idbcursor-advance-index.test.ts index a7be31f28..2d449a9ab 100644 --- a/packages/idb-bridge/src/idb-wpt-ported/idbcursor-advance-index.test.ts +++ b/packages/idb-bridge/src/idb-wpt-ported/idbcursor-advance-index.test.ts @@ -1,5 +1,7 @@ import test from "ava"; import { BridgeIDBCursor } from ".."; +import { BridgeIDBRequest } from "../bridge-idb"; +import { InvalidStateError } from "../util/errors"; import { createdb } from "./wptsupport"; test("WPT test idbcursor_advance_index.htm", async (t) => { @@ -34,6 +36,7 @@ test("WPT test idbcursor_advance_index.htm", async (t) => { cursor_rq.onsuccess = function (e: any) { var cursor = e.target.result; t.log(cursor); + t.true(e.target instanceof BridgeIDBRequest); t.true(cursor instanceof BridgeIDBCursor); switch (count) { @@ -51,7 +54,259 @@ test("WPT test idbcursor_advance_index.htm", async (t) => { t.fail("unexpected count"); break; } + }; + }; + }); +}); + +// IDBCursor.advance() - attempt to pass a count parameter that is not a number +test("WPT test idbcursor_advance_index2.htm", async (t) => { + await new Promise<void>((resolve, reject) => { + var db: any; + + const records = [ + { pKey: "primaryKey_0", iKey: "indexKey_0" }, + { pKey: "primaryKey_1", iKey: "indexKey_1" }, + ]; + + var open_rq = createdb(t); + open_rq.onupgradeneeded = function (e: any) { + db = e.target.result; + var objStore = db.createObjectStore("test", { keyPath: "pKey" }); + + objStore.createIndex("index", "iKey"); + + for (var i = 0; i < records.length; i++) objStore.add(records[i]); + }; + + open_rq.onsuccess = function (e) { + var cursor_rq = db + .transaction("test") + .objectStore("test") + .index("index") + .openCursor(); + + cursor_rq.onsuccess = function (e: any) { + var cursor = e.target.result; + + t.true(cursor != null, "cursor exist"); + t.throws( + () => { + // Original test uses "document". + cursor.advance({ foo: 42 }); + }, + { instanceOf: TypeError }, + ); + resolve(); + }; + }; + }); +}); + +// IDBCursor.advance() - index - attempt to advance backwards +test("WPT test idbcursor_advance_index3.htm", async (t) => { + await new Promise<void>((resolve, reject) => { + var db: any; + + const records = [ + { pKey: "primaryKey_0", iKey: "indexKey_0" }, + { pKey: "primaryKey_1", iKey: "indexKey_1" }, + ]; + + var open_rq = createdb(t); + open_rq.onupgradeneeded = function (e: any) { + db = e.target.result; + var objStore = db.createObjectStore("test", { keyPath: "pKey" }); + + objStore.createIndex("index", "iKey"); + + for (var i = 0; i < records.length; i++) objStore.add(records[i]); + }; + + open_rq.onsuccess = function (e) { + var cursor_rq = db + .transaction("test") + .objectStore("test") + .index("index") + .openCursor(); + + cursor_rq.onsuccess = function (e: any) { + var cursor = e.target.result; + + t.true(cursor != null, "cursor exist"); + t.throws( + () => { + cursor.advance(-1); + }, + { instanceOf: TypeError }, + ); + resolve(); + }; + }; + }); +}); + +// IDBCursor.advance() - index - iterate to the next record +test("WPT test idbcursor_advance_index5.htm", async (t) => { + await new Promise<void>((resolve, reject) => { + var db: any; + let count = 0; + const records = [ + { pKey: "primaryKey_0", iKey: "indexKey_0" }, + { pKey: "primaryKey_1", iKey: "indexKey_1" }, + { pKey: "primaryKey_1-2", iKey: "indexKey_1" }, + ], + expected = [ + { pKey: "primaryKey_0", iKey: "indexKey_0" }, + { pKey: "primaryKey_1-2", iKey: "indexKey_1" }, + ]; + + var open_rq = createdb(t); + open_rq.onupgradeneeded = function (e: any) { + db = e.target.result; + var objStore = db.createObjectStore("test", { keyPath: "pKey" }); + + objStore.createIndex("index", "iKey"); + + for (var i = 0; i < records.length; i++) objStore.add(records[i]); + }; + + open_rq.onsuccess = function (e: any) { + var cursor_rq = db + .transaction("test") + .objectStore("test") + .index("index") + .openCursor(); + + cursor_rq.onsuccess = function (e: any) { + var cursor = e.target.result; + if (!cursor) { + t.deepEqual(count, expected.length, "cursor run count"); + resolve(); + } + + var record = cursor.value; + t.deepEqual(record.pKey, expected[count].pKey, "primary key"); + t.deepEqual(record.iKey, expected[count].iKey, "index key"); + + cursor.advance(2); + count++; + }; + }; + }); +}); + +// IDBCursor.advance() - index - throw TransactionInactiveError +test("WPT test idbcursor_advance_index7.htm", async (t) => { + await new Promise<void>((resolve, reject) => { + var db: any; + const records = [ + { pKey: "primaryKey_0", iKey: "indexKey_0" }, + { pKey: "primaryKey_1", iKey: "indexKey_1" }, + ]; + + var open_rq = createdb(t); + open_rq.onupgradeneeded = function (event: any) { + db = event.target.result; + var objStore = db.createObjectStore("store", { keyPath: "pKey" }); + objStore.createIndex("index", "iKey"); + for (var i = 0; i < records.length; i++) { + objStore.add(records[i]); + } + var rq = objStore.index("index").openCursor(); + rq.onsuccess = function (event: any) { + var cursor = event.target.result; + t.true(cursor instanceof BridgeIDBCursor); + + event.target.transaction.abort(); + t.throws( + () => { + cursor.advance(1); + }, + { name: "TransactionInactiveError" }, + "Calling advance() should throws an exception TransactionInactiveError when the transaction is not active.", + ); + resolve(); + }; + }; + }); +}); + +// IDBCursor.advance() - index - throw InvalidStateError +test("WPT test idbcursor_advance_index8.htm", async (t) => { + await new Promise<void>((resolve, reject) => { + var db: any; + const records = [ + { pKey: "primaryKey_0", iKey: "indexKey_0" }, + { pKey: "primaryKey_1", iKey: "indexKey_1" }, + ]; + + var open_rq = createdb(t); + open_rq.onupgradeneeded = function (event: any) { + db = event.target.result; + var objStore = db.createObjectStore("store", { keyPath: "pKey" }); + objStore.createIndex("index", "iKey"); + for (var i = 0; i < records.length; i++) { + objStore.add(records[i]); } + var rq = objStore.index("index").openCursor(); + let called = false; + rq.onsuccess = function (event: any) { + if (called) { + return; + } + called = true; + var cursor = event.target.result; + t.true(cursor instanceof BridgeIDBCursor); + + cursor.advance(1); + t.throws( + () => { + cursor.advance(1); + }, + { name: "InvalidStateError" }, + "Calling advance() should throw DOMException when the cursor is currently being iterated.", + ); + t.pass(); + resolve(); + }; + }; + }); +}); + +// IDBCursor.advance() - index - throw InvalidStateError caused by object store been deleted +test("WPT test idbcursor_advance_index9.htm", async (t) => { + await new Promise<void>((resolve, reject) => { + var db: any; + const records = [ + { pKey: "primaryKey_0", iKey: "indexKey_0" }, + { pKey: "primaryKey_1", iKey: "indexKey_1" }, + ]; + + var open_rq = createdb(t); + open_rq.onupgradeneeded = function (event: any) { + db = event.target.result; + var objStore = db.createObjectStore("store", { keyPath: "pKey" }); + objStore.createIndex("index", "iKey"); + for (var i = 0; i < records.length; i++) { + objStore.add(records[i]); + } + var rq = objStore.index("index").openCursor(); + rq.onsuccess = function (event: any) { + var cursor = event.target.result; + t.true(cursor instanceof BridgeIDBCursor, "cursor exist"); + + db.deleteObjectStore("store"); + t.throws( + () => { + cursor.advance(1); + }, + { name: "InvalidStateError" }, + "If the cursor's source or effective object store has been deleted, the implementation MUST throw a DOMException of type InvalidStateError", + ); + + resolve(); + }; }; }); }); |