blob: 2835aaf02a6debfb7d238d52139b1dee4f8ad7fb [file] [log] [blame]
// Copyright (c) 2020, the Dart project authors. Please see the AUTHORS file
// for details. All rights reserved. Use of this source code is governed by a
// BSD-style license that can be found in the LICENSE file.
library IndexedDB3Test;
import 'package:async_helper/async_helper.dart';
import 'package:async_helper/async_minitest.dart';
import 'dart:async';
import 'dart:html' as html;
import 'dart:indexed_db';
// Read with cursor.
const String DB_NAME = 'Test3';
const String STORE_NAME = 'TEST';
const int VERSION = 1;
Future<Database> createAndOpenDb() {
return html.window.indexedDB!.deleteDatabase(DB_NAME).then((_) {
return html.window.indexedDB!.open(DB_NAME, version: VERSION,
onUpgradeNeeded: (VersionChangeEvent e) {
var db = e.target.result;
db.createObjectStore(STORE_NAME);
});
});
}
Future<Database> writeItems(Database db) {
Future<Object> write(index) {
var transaction = db.transaction(STORE_NAME, 'readwrite');
transaction.objectStore(STORE_NAME).put('Item $index', index);
return transaction.completed;
}
var future = write(0);
for (var i = 1; i < 100; ++i) {
future = future.then((_) => write(i));
}
// Chain on the DB so we return it at the end.
return future.then((_) => db);
}
Future<Database> setupDb() {
return createAndOpenDb().then(writeItems);
}
Future<Database> readAllViaCursor(Database db) {
Transaction txn = db.transaction(STORE_NAME, 'readonly');
ObjectStore objectStore = txn.objectStore(STORE_NAME);
int itemCount = 0;
int sumKeys = 0;
var lastKey = null;
var cursors = objectStore.openCursor().asBroadcastStream();
cursors.listen((cursor) {
++itemCount;
lastKey = cursor.key;
sumKeys += cursor.key as int;
expect(cursor.value, 'Item ${cursor.key}');
cursor.next();
});
cursors.last.then((cursor) {
expect(lastKey, 99);
expect(sumKeys, (100 * 99) ~/ 2);
expect(itemCount, 100);
});
return cursors.last.then((_) => db);
}
Future<Database> readAllReversedViaCursor(Database db) {
Transaction txn = db.transaction(STORE_NAME, 'readonly');
ObjectStore objectStore = txn.objectStore(STORE_NAME);
int itemCount = 0;
int sumKeys = 0;
var lastKey = null;
var cursors = objectStore.openCursor(direction: 'prev').asBroadcastStream();
cursors.listen((cursor) {
++itemCount;
lastKey = cursor.key;
sumKeys += cursor.key as int;
expect(cursor.value, 'Item ${cursor.key}');
cursor.next();
});
cursors.last.then((cursor) {
expect(lastKey, 0);
expect(sumKeys, (100 * 99) ~/ 2);
expect(itemCount, 100);
});
return cursors.last.then((_) => db);
}
main() {
// Don't bother with these tests if it's unsupported.
// Support is tested in indexeddb_1_test
if (IdbFactory.supported) {
asyncTest(() async {
var db = await setupDb();
await readAllViaCursor(db);
await readAllReversedViaCursor(db);
});
}
}