| Index: sdk/lib/indexed_db/dartium/indexed_db_dartium.dart
|
| diff --git a/sdk/lib/indexed_db/dartium/indexed_db_dartium.dart b/sdk/lib/indexed_db/dartium/indexed_db_dartium.dart
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..143f1b662114d90257e2beff062a68e1be88e8bb
|
| --- /dev/null
|
| +++ b/sdk/lib/indexed_db/dartium/indexed_db_dartium.dart
|
| @@ -0,0 +1,1467 @@
|
| +/**
|
| + * A client-side key-value store with support for indexes.
|
| + *
|
| + * Many browsers support IndexedDB—a web standard for
|
| + * an indexed database.
|
| + * By storing data on the client in an IndexedDB,
|
| + * a web app gets some advantages, such as faster performance and persistence.
|
| + * To find out which browsers support IndexedDB,
|
| + * refer to [Can I Use?](http://caniuse.com/#feat=indexeddb)
|
| + *
|
| + * In IndexedDB, each record is identified by a unique index or key,
|
| + * making data retrieval speedy.
|
| + * You can store structured data,
|
| + * such as images, arrays, and maps using IndexedDB.
|
| + * The standard does not specify size limits for individual data items
|
| + * or for the database itself, but browsers may impose storage limits.
|
| + *
|
| + * ## Using indexed_db
|
| + *
|
| + * The classes in this library provide an interface
|
| + * to the browser's IndexedDB, if it has one.
|
| + * To use this library in your code:
|
| + *
|
| + * import 'dart:indexed_db';
|
| + *
|
| + * A web app can determine if the browser supports
|
| + * IndexedDB with [IdbFactory.supported]:
|
| + *
|
| + * if (IdbFactory.supported)
|
| + * // Use indexeddb.
|
| + * else
|
| + * // Find an alternative.
|
| + *
|
| + * Access to the browser's IndexedDB is provided by the app's top-level
|
| + * [Window] object, which your code can refer to with `window.indexedDB`.
|
| + * So, for example,
|
| + * here's how to use window.indexedDB to open a database:
|
| + *
|
| + * Future open() {
|
| + * return window.indexedDB.open('myIndexedDB',
|
| + * version: 1,
|
| + * onUpgradeNeeded: _initializeDatabase)
|
| + * .then(_loadFromDB);
|
| + * }
|
| + * void _initializeDatabase(VersionChangeEvent e) {
|
| + * ...
|
| + * }
|
| + * Future _loadFromDB(Database db) {
|
| + * ...
|
| + * }
|
| + *
|
| + *
|
| + * All data in an IndexedDB is stored within an [ObjectStore].
|
| + * To manipulate the database use [Transaction]s.
|
| + *
|
| + * ## Other resources
|
| + *
|
| + * Other options for client-side data storage include:
|
| + *
|
| + * * [Window.localStorage]—a
|
| + * basic mechanism that stores data as a [Map],
|
| + * and where both the keys and the values are strings.
|
| + *
|
| + * * [dart:web_sql]—a database that can be queried with SQL.
|
| + *
|
| + * For a tutorial about using the indexed_db library with Dart,
|
| + * check out
|
| + * [Use IndexedDB](http://www.dartlang.org/docs/tutorials/indexeddb/).
|
| + *
|
| + * [IndexedDB reference](http://docs.webplatform.org/wiki/apis/indexeddb)
|
| + * provides wiki-style docs about indexedDB
|
| + */
|
| +library dart.dom.indexed_db;
|
| +
|
| +import 'dart:async';
|
| +import 'dart:html';
|
| +import 'dart:html_common';
|
| +import 'dart:nativewrappers';
|
| +import 'dart:_blink' as _blink;
|
| +import 'dart:js' as js;
|
| +// Copyright (c) 2012, 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.
|
| +
|
| +// DO NOT EDIT
|
| +// Auto-generated dart:indexed_db library.
|
| +
|
| +class _KeyRangeFactoryProvider {
|
| + static KeyRange createKeyRange_only(/*IDBKey*/ value) =>
|
| + KeyRange.only_(value);
|
| +
|
| + static KeyRange createKeyRange_lowerBound(
|
| + /*IDBKey*/ bound,
|
| + [bool open = false]) =>
|
| + KeyRange.lowerBound_(bound, open);
|
| +
|
| + static KeyRange createKeyRange_upperBound(
|
| + /*IDBKey*/ bound,
|
| + [bool open = false]) =>
|
| + KeyRange.upperBound_(bound, open);
|
| +
|
| + static KeyRange createKeyRange_bound(
|
| + /*IDBKey*/ lower,
|
| + /*IDBKey*/ upper,
|
| + [bool lowerOpen = false,
|
| + bool upperOpen = false]) =>
|
| + KeyRange.bound_(lower, upper, lowerOpen, upperOpen);
|
| +}
|
| +
|
| +// FIXME: Can we make this private?
|
| +@Deprecated("Internal Use Only")
|
| +final indexed_dbBlinkMap = {
|
| + 'IDBCursor': () => Cursor.instanceRuntimeType,
|
| + 'IDBCursorWithValue': () => CursorWithValue.instanceRuntimeType,
|
| + 'IDBDatabase': () => Database.instanceRuntimeType,
|
| + 'IDBFactory': () => IdbFactory.instanceRuntimeType,
|
| + 'IDBIndex': () => Index.instanceRuntimeType,
|
| + 'IDBKeyRange': () => KeyRange.instanceRuntimeType,
|
| + 'IDBObjectStore': () => ObjectStore.instanceRuntimeType,
|
| + 'IDBOpenDBRequest': () => OpenDBRequest.instanceRuntimeType,
|
| + 'IDBRequest': () => Request.instanceRuntimeType,
|
| + 'IDBTransaction': () => Transaction.instanceRuntimeType,
|
| + 'IDBVersionChangeEvent': () => VersionChangeEvent.instanceRuntimeType,
|
| +};
|
| +
|
| +//
|
| +// Per http://www.w3.org/TR/IndexedDB/#key-construct
|
| +//
|
| +// "A value is said to be a valid key if it is one of the following types: Array
|
| +// JavaScript objects [ECMA-262], DOMString [WEBIDL], Date [ECMA-262] or float
|
| +// [WEBIDL]. However Arrays are only valid keys if every item in the array is
|
| +// defined and is a valid key (i.e. sparse arrays can not be valid keys) and if
|
| +// the Array doesn't directly or indirectly contain itself. Any non-numeric
|
| +// properties are ignored, and thus does not affect whether the Array is a valid
|
| +// key. Additionally, if the value is of type float, it is only a valid key if
|
| +// it is not NaN, and if the value is of type Date it is only a valid key if its
|
| +// [[PrimitiveValue]] internal property, as defined by [ECMA-262], is not NaN."
|
| +
|
| +// What is required is to ensure that an Lists in the key are actually
|
| +// JavaScript arrays, and any Dates are JavaScript Dates.
|
| +
|
| +/**
|
| + * Converts a native IDBKey into a Dart object.
|
| + *
|
| + * May return the original input. May mutate the original input (but will be
|
| + * idempotent if mutation occurs). It is assumed that this conversion happens
|
| + * on native IDBKeys on all paths that return IDBKeys from native DOM calls.
|
| + *
|
| + * If necessary, JavaScript Dates are converted into Dart Dates.
|
| + */
|
| +_convertNativeToDart_IDBKey(nativeKey) {
|
| + containsDate(object) {
|
| + if (object is DateTime) return true;
|
| + if (object is List) {
|
| + for (int i = 0; i < object.length; i++) {
|
| + if (containsDate(object[i])) return true;
|
| + }
|
| + }
|
| + return false; // number, string.
|
| + }
|
| +
|
| + if (nativeKey is DateTime) {
|
| + throw new UnimplementedError('Key containing DateTime');
|
| + }
|
| + // TODO: Cache conversion somewhere?
|
| + return nativeKey;
|
| +}
|
| +
|
| +/**
|
| + * Converts a Dart object into a valid IDBKey.
|
| + *
|
| + * May return the original input. Does not mutate input.
|
| + *
|
| + * If necessary, [dartKey] may be copied to ensure all lists are converted into
|
| + * JavaScript Arrays and Dart Dates into JavaScript Dates.
|
| + */
|
| +_convertDartToNative_IDBKey(dartKey) {
|
| + // TODO: Implement.
|
| + return dartKey;
|
| +}
|
| +
|
| +/// May modify original. If so, action is idempotent.
|
| +_convertNativeToDart_IDBAny(object) {
|
| + return convertNativeToDart_AcceptStructuredClone(object, mustCopy: false);
|
| +} // Copyright (c) 2013, 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.
|
| +
|
| +@DomName('IDBCursor')
|
| +@Unstable()
|
| +class Cursor extends DartHtmlDomObject {
|
| + @DomName('IDBCursor.delete')
|
| + Future delete() {
|
| + try {
|
| + return _completeRequest(_delete());
|
| + } catch (e, stacktrace) {
|
| + return new Future.error(e, stacktrace);
|
| + }
|
| + }
|
| +
|
| + @DomName('IDBCursor.value')
|
| + Future update(value) {
|
| + try {
|
| + return _completeRequest(_update(value));
|
| + } catch (e, stacktrace) {
|
| + return new Future.error(e, stacktrace);
|
| + }
|
| + }
|
| +
|
| + // To suppress missing implicit constructor warnings.
|
| + factory Cursor._() {
|
| + throw new UnsupportedError("Not supported");
|
| + }
|
| +
|
| + @Deprecated("Internal Use Only")
|
| + external static Type get instanceRuntimeType;
|
| +
|
| + @Deprecated("Internal Use Only")
|
| + Cursor.internal_() {}
|
| +
|
| + @DomName('IDBCursor.direction')
|
| + @DocsEditable()
|
| + String get direction =>
|
| + _blink.BlinkIDBCursor.instance.direction_Getter_(this);
|
| +
|
| + @DomName('IDBCursor.key')
|
| + @DocsEditable()
|
| + Object get key => (_blink.BlinkIDBCursor.instance.key_Getter_(this));
|
| +
|
| + @DomName('IDBCursor.primaryKey')
|
| + @DocsEditable()
|
| + Object get primaryKey =>
|
| + (_blink.BlinkIDBCursor.instance.primaryKey_Getter_(this));
|
| +
|
| + @DomName('IDBCursor.source')
|
| + @DocsEditable()
|
| + Object get source => (_blink.BlinkIDBCursor.instance.source_Getter_(this));
|
| +
|
| + @DomName('IDBCursor.advance')
|
| + @DocsEditable()
|
| + void advance(int count) =>
|
| + _blink.BlinkIDBCursor.instance.advance_Callback_1_(this, count);
|
| +
|
| + @DomName('IDBCursor.continuePrimaryKey')
|
| + @DocsEditable()
|
| + @Experimental() // untriaged
|
| + void continuePrimaryKey(Object key, Object primaryKey) =>
|
| + _blink.BlinkIDBCursor.instance
|
| + .continuePrimaryKey_Callback_2_(this, key, primaryKey);
|
| +
|
| + @DomName('IDBCursor.delete')
|
| + @DocsEditable()
|
| + Request _delete() => _blink.BlinkIDBCursor.instance.delete_Callback_0_(this);
|
| +
|
| + void next([Object key]) {
|
| + if (key != null) {
|
| + _blink.BlinkIDBCursor.instance.continue_Callback_1_(this, key);
|
| + return;
|
| + }
|
| + _blink.BlinkIDBCursor.instance.continue_Callback_0_(this);
|
| + return;
|
| + }
|
| +
|
| + @DomName('IDBCursor.update')
|
| + @DocsEditable()
|
| + Request _update(Object value) =>
|
| + _blink.BlinkIDBCursor.instance.update_Callback_1_(
|
| + this, convertDartToNative_SerializedScriptValue(value));
|
| +}
|
| +// Copyright (c) 2012, 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.
|
| +
|
| +// WARNING: Do not edit - generated code.
|
| +
|
| +@DocsEditable()
|
| +@DomName('IDBCursorWithValue')
|
| +@Unstable()
|
| +class CursorWithValue extends Cursor {
|
| + // To suppress missing implicit constructor warnings.
|
| + factory CursorWithValue._() {
|
| + throw new UnsupportedError("Not supported");
|
| + }
|
| +
|
| + @Deprecated("Internal Use Only")
|
| + external static Type get instanceRuntimeType;
|
| +
|
| + @Deprecated("Internal Use Only")
|
| + CursorWithValue.internal_() : super.internal_();
|
| +
|
| + @DomName('IDBCursorWithValue.value')
|
| + @DocsEditable()
|
| + Object get value => _convertNativeToDart_IDBAny(
|
| + _blink.BlinkIDBCursorWithValue.instance.value_Getter_(this));
|
| +}
|
| +// Copyright (c) 2013, 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.
|
| +
|
| +@DocsEditable()
|
| +/**
|
| + * An indexed database object for storing client-side data
|
| + * in web apps.
|
| + */
|
| +@DomName('IDBDatabase')
|
| +@SupportedBrowser(SupportedBrowser.CHROME)
|
| +@SupportedBrowser(SupportedBrowser.FIREFOX, '15')
|
| +@SupportedBrowser(SupportedBrowser.IE, '10')
|
| +@Experimental()
|
| +@Unstable()
|
| +class Database extends EventTarget {
|
| + @DomName('IDBDatabase.createObjectStore')
|
| + @DocsEditable()
|
| + ObjectStore createObjectStore(String name,
|
| + {String keyPath, bool autoIncrement}) {
|
| + var options = {};
|
| + if (keyPath != null) {
|
| + options['keyPath'] = keyPath;
|
| + }
|
| + if (autoIncrement != null) {
|
| + options['autoIncrement'] = autoIncrement;
|
| + }
|
| +
|
| + return _createObjectStore(name, options);
|
| + }
|
| +
|
| + Transaction transaction(storeName_OR_storeNames, String mode) {
|
| + if (mode != 'readonly' && mode != 'readwrite') {
|
| + throw new ArgumentError("Invalid transaction mode $mode");
|
| + }
|
| + var names;
|
| + if (storeName_OR_storeNames == null) {
|
| + throw new ArgumentError("stores may not be null in transaction");
|
| + } else if (storeName_OR_storeNames is String ||
|
| + storeName_OR_storeNames is DomStringList) {
|
| + names = storeName_OR_storeNames;
|
| + } else if (storeName_OR_storeNames is List<String>) {
|
| + names = convertDartToNative_List(storeName_OR_storeNames);
|
| + } else {
|
| + throw new ArgumentError("Invalid store(s) $store_Name_OR_storeNames");
|
| + }
|
| +
|
| + return _blink.BlinkIDBDatabase.instance
|
| + .transaction_Callback_2_(this, names, mode);
|
| + }
|
| +
|
| + Transaction transactionList(List<String> storeNames, String mode) =>
|
| + transaction(storeNames, mode);
|
| + Transaction transactionStores(List<String> storeNames, String mode) =>
|
| + transaction(storeNames, mode);
|
| + Transaction transactionStore(String storeName, String mode) =>
|
| + transaction(storeName, mode);
|
| +
|
| + // To suppress missing implicit constructor warnings.
|
| + factory Database._() {
|
| + throw new UnsupportedError("Not supported");
|
| + }
|
| +
|
| + /**
|
| + * Static factory designed to expose `abort` events to event
|
| + * handlers that are not necessarily instances of [Database].
|
| + *
|
| + * See [EventStreamProvider] for usage information.
|
| + */
|
| + @DomName('IDBDatabase.abortEvent')
|
| + @DocsEditable()
|
| + static const EventStreamProvider<Event> abortEvent =
|
| + const EventStreamProvider<Event>('abort');
|
| +
|
| + /**
|
| + * Static factory designed to expose `close` events to event
|
| + * handlers that are not necessarily instances of [Database].
|
| + *
|
| + * See [EventStreamProvider] for usage information.
|
| + */
|
| + @DomName('IDBDatabase.closeEvent')
|
| + @DocsEditable()
|
| + // https://www.w3.org/Bugs/Public/show_bug.cgi?id=22540
|
| + @Experimental()
|
| + static const EventStreamProvider<Event> closeEvent =
|
| + const EventStreamProvider<Event>('close');
|
| +
|
| + /**
|
| + * Static factory designed to expose `error` events to event
|
| + * handlers that are not necessarily instances of [Database].
|
| + *
|
| + * See [EventStreamProvider] for usage information.
|
| + */
|
| + @DomName('IDBDatabase.errorEvent')
|
| + @DocsEditable()
|
| + static const EventStreamProvider<Event> errorEvent =
|
| + const EventStreamProvider<Event>('error');
|
| +
|
| + /**
|
| + * Static factory designed to expose `versionchange` events to event
|
| + * handlers that are not necessarily instances of [Database].
|
| + *
|
| + * See [EventStreamProvider] for usage information.
|
| + */
|
| + @DomName('IDBDatabase.versionchangeEvent')
|
| + @DocsEditable()
|
| + static const EventStreamProvider<VersionChangeEvent> versionChangeEvent =
|
| + const EventStreamProvider<VersionChangeEvent>('versionchange');
|
| +
|
| + @Deprecated("Internal Use Only")
|
| + external static Type get instanceRuntimeType;
|
| +
|
| + @Deprecated("Internal Use Only")
|
| + Database.internal_() : super.internal_();
|
| +
|
| + @DomName('IDBDatabase.name')
|
| + @DocsEditable()
|
| + String get name => _blink.BlinkIDBDatabase.instance.name_Getter_(this);
|
| +
|
| + @DomName('IDBDatabase.objectStoreNames')
|
| + @DocsEditable()
|
| + List<String> get objectStoreNames =>
|
| + _blink.BlinkIDBDatabase.instance.objectStoreNames_Getter_(this);
|
| +
|
| + @DomName('IDBDatabase.version')
|
| + @DocsEditable()
|
| + int get version => _blink.BlinkIDBDatabase.instance.version_Getter_(this);
|
| +
|
| + @DomName('IDBDatabase.close')
|
| + @DocsEditable()
|
| + void close() => _blink.BlinkIDBDatabase.instance.close_Callback_0_(this);
|
| +
|
| + ObjectStore _createObjectStore(String name, [Map options]) {
|
| + if (options != null) {
|
| + return _blink.BlinkIDBDatabase.instance.createObjectStore_Callback_2_(
|
| + this, name, convertDartToNative_Dictionary(options));
|
| + }
|
| + return _blink.BlinkIDBDatabase.instance
|
| + .createObjectStore_Callback_1_(this, name);
|
| + }
|
| +
|
| + @DomName('IDBDatabase.deleteObjectStore')
|
| + @DocsEditable()
|
| + void deleteObjectStore(String name) => _blink.BlinkIDBDatabase.instance
|
| + .deleteObjectStore_Callback_1_(this, name);
|
| +
|
| + /// Stream of `abort` events handled by this [Database].
|
| + @DomName('IDBDatabase.onabort')
|
| + @DocsEditable()
|
| + Stream<Event> get onAbort => abortEvent.forTarget(this);
|
| +
|
| + /// Stream of `close` events handled by this [Database].
|
| + @DomName('IDBDatabase.onclose')
|
| + @DocsEditable()
|
| + // https://www.w3.org/Bugs/Public/show_bug.cgi?id=22540
|
| + @Experimental()
|
| + Stream<Event> get onClose => closeEvent.forTarget(this);
|
| +
|
| + /// Stream of `error` events handled by this [Database].
|
| + @DomName('IDBDatabase.onerror')
|
| + @DocsEditable()
|
| + Stream<Event> get onError => errorEvent.forTarget(this);
|
| +
|
| + /// Stream of `versionchange` events handled by this [Database].
|
| + @DomName('IDBDatabase.onversionchange')
|
| + @DocsEditable()
|
| + Stream<VersionChangeEvent> get onVersionChange =>
|
| + versionChangeEvent.forTarget(this);
|
| +}
|
| +// Copyright (c) 2012, 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.
|
| +
|
| +@DomName('IDBFactory')
|
| +@SupportedBrowser(SupportedBrowser.CHROME)
|
| +@SupportedBrowser(SupportedBrowser.FIREFOX, '15')
|
| +@SupportedBrowser(SupportedBrowser.IE, '10')
|
| +@Experimental()
|
| +@Unstable()
|
| +class IdbFactory extends DartHtmlDomObject {
|
| + /**
|
| + * Checks to see if Indexed DB is supported on the current platform.
|
| + */
|
| + static bool get supported {
|
| + return true;
|
| + }
|
| +
|
| + @DomName('IDBFactory.open')
|
| + Future<Database> open(String name,
|
| + {int version,
|
| + void onUpgradeNeeded(VersionChangeEvent),
|
| + void onBlocked(Event)}) {
|
| + if ((version == null) != (onUpgradeNeeded == null)) {
|
| + return new Future.error(new ArgumentError(
|
| + 'version and onUpgradeNeeded must be specified together'));
|
| + }
|
| + try {
|
| + var request;
|
| + if (version != null) {
|
| + request = _open(name, version);
|
| + } else {
|
| + request = _open(name);
|
| + }
|
| +
|
| + if (onUpgradeNeeded != null) {
|
| + request.onUpgradeNeeded.listen(onUpgradeNeeded);
|
| + }
|
| + if (onBlocked != null) {
|
| + request.onBlocked.listen(onBlocked);
|
| + }
|
| + return _completeRequest(request);
|
| + } catch (e, stacktrace) {
|
| + return new Future.error(e, stacktrace);
|
| + }
|
| + }
|
| +
|
| + @DomName('IDBFactory.deleteDatabase')
|
| + Future<IdbFactory> deleteDatabase(String name, {void onBlocked(Event e)}) {
|
| + try {
|
| + var request = _deleteDatabase(name);
|
| +
|
| + if (onBlocked != null) {
|
| + request.onBlocked.listen(onBlocked);
|
| + }
|
| + var completer = new Completer<IdbFactory>.sync();
|
| + request.onSuccess.listen((e) {
|
| + completer.complete(this);
|
| + });
|
| + request.onError.listen(completer.completeError);
|
| + return completer.future;
|
| + } catch (e, stacktrace) {
|
| + return new Future.error(e, stacktrace);
|
| + }
|
| + }
|
| +
|
| + @DomName('IDBFactory.getDatabaseNames')
|
| + @SupportedBrowser(SupportedBrowser.CHROME)
|
| + @Experimental()
|
| + Future<List<String>> getDatabaseNames() {
|
| + try {
|
| + var request = _webkitGetDatabaseNames();
|
| +
|
| + return _completeRequest(request);
|
| + } catch (e, stacktrace) {
|
| + return new Future.error(e, stacktrace);
|
| + }
|
| + }
|
| +
|
| + /**
|
| + * Checks to see if getDatabaseNames is supported by the current platform.
|
| + */
|
| + bool get supportsDatabaseNames {
|
| + return true;
|
| + }
|
| +
|
| + // To suppress missing implicit constructor warnings.
|
| + factory IdbFactory._() {
|
| + throw new UnsupportedError("Not supported");
|
| + }
|
| +
|
| + @Deprecated("Internal Use Only")
|
| + external static Type get instanceRuntimeType;
|
| +
|
| + @Deprecated("Internal Use Only")
|
| + IdbFactory.internal_() {}
|
| +
|
| + @DomName('IDBFactory.cmp')
|
| + @DocsEditable()
|
| + int cmp(Object first, Object second) =>
|
| + _blink.BlinkIDBFactory.instance.cmp_Callback_2_(this, first, second);
|
| +
|
| + @DomName('IDBFactory.deleteDatabase')
|
| + @DocsEditable()
|
| + OpenDBRequest _deleteDatabase(String name) =>
|
| + _blink.BlinkIDBFactory.instance.deleteDatabase_Callback_1_(this, name);
|
| +
|
| + OpenDBRequest _open(String name, [int version]) {
|
| + if (version != null) {
|
| + return _blink.BlinkIDBFactory.instance
|
| + .open_Callback_2_(this, name, version);
|
| + }
|
| + return _blink.BlinkIDBFactory.instance.open_Callback_1_(this, name);
|
| + }
|
| +
|
| + @DomName('IDBFactory.webkitGetDatabaseNames')
|
| + @DocsEditable()
|
| + @SupportedBrowser(SupportedBrowser.CHROME)
|
| + @SupportedBrowser(SupportedBrowser.SAFARI)
|
| + @Experimental()
|
| + Request _webkitGetDatabaseNames() =>
|
| + _blink.BlinkIDBFactory.instance.webkitGetDatabaseNames_Callback_0_(this);
|
| +}
|
| +
|
| +/**
|
| + * Ties a request to a completer, so the completer is completed when it succeeds
|
| + * and errors out when the request errors.
|
| + */
|
| +Future/*<T>*/ _completeRequest/*<T>*/(Request request) {
|
| + var completer = new Completer/*<T>*/ .sync();
|
| + // TODO: make sure that completer.complete is synchronous as transactions
|
| + // may be committed if the result is not processed immediately.
|
| + request.onSuccess.listen((e) {
|
| + var result = _cast/*<T>*/(request.result);
|
| + completer.complete(result);
|
| + });
|
| + request.onError.listen(completer.completeError);
|
| + return completer.future;
|
| +}
|
| +// Copyright (c) 2013, 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.
|
| +
|
| +@DomName('IDBIndex')
|
| +@Unstable()
|
| +class Index extends DartHtmlDomObject {
|
| + @DomName('IDBIndex.count')
|
| + Future<int> count([key_OR_range]) {
|
| + try {
|
| + var request = _count(key_OR_range);
|
| + return _completeRequest(request);
|
| + } catch (e, stacktrace) {
|
| + return new Future.error(e, stacktrace);
|
| + }
|
| + }
|
| +
|
| + @DomName('IDBIndex.get')
|
| + Future get(key) {
|
| + try {
|
| + var request = _get(key);
|
| +
|
| + return _completeRequest(request);
|
| + } catch (e, stacktrace) {
|
| + return new Future.error(e, stacktrace);
|
| + }
|
| + }
|
| +
|
| + @DomName('IDBIndex.getKey')
|
| + Future getKey(key) {
|
| + try {
|
| + var request = _getKey(key);
|
| +
|
| + return _completeRequest(request);
|
| + } catch (e, stacktrace) {
|
| + return new Future.error(e, stacktrace);
|
| + }
|
| + }
|
| +
|
| + /**
|
| + * Creates a stream of cursors over the records in this object store.
|
| + *
|
| + * See also:
|
| + *
|
| + * * [ObjectStore.openCursor]
|
| + */
|
| + Stream<CursorWithValue> openCursor(
|
| + {key, KeyRange range, String direction, bool autoAdvance}) {
|
| + var key_OR_range = null;
|
| + if (key != null) {
|
| + if (range != null) {
|
| + throw new ArgumentError('Cannot specify both key and range.');
|
| + }
|
| + key_OR_range = key;
|
| + } else {
|
| + key_OR_range = range;
|
| + }
|
| + var request;
|
| + if (direction == null) {
|
| + // FIXME: Passing in "next" should be unnecessary.
|
| + request = _openCursor(key_OR_range, "next");
|
| + } else {
|
| + request = _openCursor(key_OR_range, direction);
|
| + }
|
| + return ObjectStore._cursorStreamFromResult(request, autoAdvance);
|
| + }
|
| +
|
| + /**
|
| + * Creates a stream of cursors over the records in this object store.
|
| + *
|
| + * See also:
|
| + *
|
| + * * [ObjectStore.openCursor]
|
| + */
|
| + Stream<Cursor> openKeyCursor(
|
| + {key, KeyRange range, String direction, bool autoAdvance}) {
|
| + var key_OR_range = null;
|
| + if (key != null) {
|
| + if (range != null) {
|
| + throw new ArgumentError('Cannot specify both key and range.');
|
| + }
|
| + key_OR_range = key;
|
| + } else {
|
| + key_OR_range = range;
|
| + }
|
| + var request;
|
| + if (direction == null) {
|
| + // FIXME: Passing in "next" should be unnecessary.
|
| + request = _openKeyCursor(key_OR_range, "next");
|
| + } else {
|
| + request = _openKeyCursor(key_OR_range, direction);
|
| + }
|
| + return ObjectStore._cursorStreamFromResult(request, autoAdvance);
|
| + }
|
| +
|
| + // To suppress missing implicit constructor warnings.
|
| + factory Index._() {
|
| + throw new UnsupportedError("Not supported");
|
| + }
|
| +
|
| + @Deprecated("Internal Use Only")
|
| + external static Type get instanceRuntimeType;
|
| +
|
| + @Deprecated("Internal Use Only")
|
| + Index.internal_() {}
|
| +
|
| + @DomName('IDBIndex.keyPath')
|
| + @DocsEditable()
|
| + Object get keyPath => (_blink.BlinkIDBIndex.instance.keyPath_Getter_(this));
|
| +
|
| + @DomName('IDBIndex.multiEntry')
|
| + @DocsEditable()
|
| + bool get multiEntry => _blink.BlinkIDBIndex.instance.multiEntry_Getter_(this);
|
| +
|
| + @DomName('IDBIndex.name')
|
| + @DocsEditable()
|
| + String get name => _blink.BlinkIDBIndex.instance.name_Getter_(this);
|
| +
|
| + @DomName('IDBIndex.objectStore')
|
| + @DocsEditable()
|
| + ObjectStore get objectStore =>
|
| + _blink.BlinkIDBIndex.instance.objectStore_Getter_(this);
|
| +
|
| + @DomName('IDBIndex.unique')
|
| + @DocsEditable()
|
| + bool get unique => _blink.BlinkIDBIndex.instance.unique_Getter_(this);
|
| +
|
| + @DomName('IDBIndex.count')
|
| + @DocsEditable()
|
| + Request _count(Object key) =>
|
| + _blink.BlinkIDBIndex.instance.count_Callback_1_(this, key);
|
| +
|
| + @DomName('IDBIndex.get')
|
| + @DocsEditable()
|
| + Request _get(Object key) =>
|
| + _blink.BlinkIDBIndex.instance.get_Callback_1_(this, key);
|
| +
|
| + Request getAll(Object range, [int maxCount]) {
|
| + if (maxCount != null) {
|
| + return _blink.BlinkIDBIndex.instance
|
| + .getAll_Callback_2_(this, range, maxCount);
|
| + }
|
| + return _blink.BlinkIDBIndex.instance.getAll_Callback_1_(this, range);
|
| + }
|
| +
|
| + Request getAllKeys(Object range, [int maxCount]) {
|
| + if (maxCount != null) {
|
| + return _blink.BlinkIDBIndex.instance
|
| + .getAllKeys_Callback_2_(this, range, maxCount);
|
| + }
|
| + return _blink.BlinkIDBIndex.instance.getAllKeys_Callback_1_(this, range);
|
| + }
|
| +
|
| + @DomName('IDBIndex.getKey')
|
| + @DocsEditable()
|
| + Request _getKey(Object key) =>
|
| + _blink.BlinkIDBIndex.instance.getKey_Callback_1_(this, key);
|
| +
|
| + Request _openCursor(Object range, [String direction]) {
|
| + if (direction != null) {
|
| + return _blink.BlinkIDBIndex.instance
|
| + .openCursor_Callback_2_(this, range, direction);
|
| + }
|
| + return _blink.BlinkIDBIndex.instance.openCursor_Callback_1_(this, range);
|
| + }
|
| +
|
| + Request _openKeyCursor(Object range, [String direction]) {
|
| + if (direction != null) {
|
| + return _blink.BlinkIDBIndex.instance
|
| + .openKeyCursor_Callback_2_(this, range, direction);
|
| + }
|
| + return _blink.BlinkIDBIndex.instance.openKeyCursor_Callback_1_(this, range);
|
| + }
|
| +}
|
| +// Copyright (c) 2012, 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.
|
| +
|
| +@DomName('IDBKeyRange')
|
| +@Unstable()
|
| +class KeyRange extends DartHtmlDomObject {
|
| + @DomName('IDBKeyRange.only')
|
| + factory KeyRange.only(/*Key*/ value) =>
|
| + _KeyRangeFactoryProvider.createKeyRange_only(value);
|
| +
|
| + @DomName('IDBKeyRange.lowerBound')
|
| + factory KeyRange.lowerBound(/*Key*/ bound, [bool open = false]) =>
|
| + _KeyRangeFactoryProvider.createKeyRange_lowerBound(bound, open);
|
| +
|
| + @DomName('IDBKeyRange.upperBound')
|
| + factory KeyRange.upperBound(/*Key*/ bound, [bool open = false]) =>
|
| + _KeyRangeFactoryProvider.createKeyRange_upperBound(bound, open);
|
| +
|
| + @DomName('KeyRange.bound')
|
| + factory KeyRange.bound(/*Key*/ lower, /*Key*/ upper,
|
| + [bool lowerOpen = false, bool upperOpen = false]) =>
|
| + _KeyRangeFactoryProvider.createKeyRange_bound(
|
| + lower, upper, lowerOpen, upperOpen);
|
| +
|
| + // To suppress missing implicit constructor warnings.
|
| + factory KeyRange._() {
|
| + throw new UnsupportedError("Not supported");
|
| + }
|
| +
|
| + @Deprecated("Internal Use Only")
|
| + external static Type get instanceRuntimeType;
|
| +
|
| + @Deprecated("Internal Use Only")
|
| + KeyRange.internal_() {}
|
| +
|
| + @DomName('IDBKeyRange.lower')
|
| + @DocsEditable()
|
| + Object get lower => (_blink.BlinkIDBKeyRange.instance.lower_Getter_(this));
|
| +
|
| + @DomName('IDBKeyRange.lowerOpen')
|
| + @DocsEditable()
|
| + bool get lowerOpen =>
|
| + _blink.BlinkIDBKeyRange.instance.lowerOpen_Getter_(this);
|
| +
|
| + @DomName('IDBKeyRange.upper')
|
| + @DocsEditable()
|
| + Object get upper => (_blink.BlinkIDBKeyRange.instance.upper_Getter_(this));
|
| +
|
| + @DomName('IDBKeyRange.upperOpen')
|
| + @DocsEditable()
|
| + bool get upperOpen =>
|
| + _blink.BlinkIDBKeyRange.instance.upperOpen_Getter_(this);
|
| +
|
| + static KeyRange bound_(Object lower, Object upper,
|
| + [bool lowerOpen, bool upperOpen]) {
|
| + if (upperOpen != null) {
|
| + return _blink.BlinkIDBKeyRange.instance
|
| + .bound_Callback_4_(lower, upper, lowerOpen, upperOpen);
|
| + }
|
| + if (lowerOpen != null) {
|
| + return _blink.BlinkIDBKeyRange.instance
|
| + .bound_Callback_3_(lower, upper, lowerOpen);
|
| + }
|
| + return _blink.BlinkIDBKeyRange.instance.bound_Callback_2_(lower, upper);
|
| + }
|
| +
|
| + static KeyRange lowerBound_(Object bound, [bool open]) {
|
| + if (open != null) {
|
| + return _blink.BlinkIDBKeyRange.instance
|
| + .lowerBound_Callback_2_(bound, open);
|
| + }
|
| + return _blink.BlinkIDBKeyRange.instance.lowerBound_Callback_1_(bound);
|
| + }
|
| +
|
| + @DomName('IDBKeyRange.only_')
|
| + @DocsEditable()
|
| + @Experimental() // non-standard
|
| + static KeyRange only_(Object value) =>
|
| + _blink.BlinkIDBKeyRange.instance.only_Callback_1_(value);
|
| +
|
| + static KeyRange upperBound_(Object bound, [bool open]) {
|
| + if (open != null) {
|
| + return _blink.BlinkIDBKeyRange.instance
|
| + .upperBound_Callback_2_(bound, open);
|
| + }
|
| + return _blink.BlinkIDBKeyRange.instance.upperBound_Callback_1_(bound);
|
| + }
|
| +}
|
| +// Copyright (c) 2012, 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.
|
| +
|
| +@DomName('IDBObjectStore')
|
| +@Unstable()
|
| +class ObjectStore extends DartHtmlDomObject {
|
| + @DomName('IDBObjectStore.add')
|
| + Future add(value, [key]) {
|
| + try {
|
| + var request;
|
| + if (key != null) {
|
| + request = _add(value, key);
|
| + } else {
|
| + request = _add(value);
|
| + }
|
| + return _completeRequest(request);
|
| + } catch (e, stacktrace) {
|
| + return new Future.error(e, stacktrace);
|
| + }
|
| + }
|
| +
|
| + @DomName('IDBObjectStore.clear')
|
| + Future clear() {
|
| + try {
|
| + return _completeRequest(_clear());
|
| + } catch (e, stacktrace) {
|
| + return new Future.error(e, stacktrace);
|
| + }
|
| + }
|
| +
|
| + @DomName('IDBObjectStore.delete')
|
| + Future delete(key_OR_keyRange) {
|
| + try {
|
| + return _completeRequest(_delete(key_OR_keyRange));
|
| + } catch (e, stacktrace) {
|
| + return new Future.error(e, stacktrace);
|
| + }
|
| + }
|
| +
|
| + @DomName('IDBObjectStore.count')
|
| + Future<int> count([key_OR_range]) {
|
| + try {
|
| + var request = _count(key_OR_range);
|
| + return _completeRequest(request);
|
| + } catch (e, stacktrace) {
|
| + return new Future.error(e, stacktrace);
|
| + }
|
| + }
|
| +
|
| + @DomName('IDBObjectStore.put')
|
| + Future put(value, [key]) {
|
| + try {
|
| + var request;
|
| + if (key != null) {
|
| + request = _put(value, key);
|
| + } else {
|
| + request = _put(value);
|
| + }
|
| + return _completeRequest(request);
|
| + } catch (e, stacktrace) {
|
| + return new Future.error(e, stacktrace);
|
| + }
|
| + }
|
| +
|
| + @DomName('IDBObjectStore.get')
|
| + Future getObject(key) {
|
| + try {
|
| + var request = _get(key);
|
| +
|
| + return _completeRequest(request);
|
| + } catch (e, stacktrace) {
|
| + return new Future.error(e, stacktrace);
|
| + }
|
| + }
|
| +
|
| + /**
|
| + * Creates a stream of cursors over the records in this object store.
|
| + *
|
| + * **The stream must be manually advanced by calling [Cursor.next] after
|
| + * each item or by specifying autoAdvance to be true.**
|
| + *
|
| + * var cursors = objectStore.openCursor().listen(
|
| + * (cursor) {
|
| + * // ...some processing with the cursor
|
| + * cursor.next(); // advance onto the next cursor.
|
| + * },
|
| + * onDone: () {
|
| + * // called when there are no more cursors.
|
| + * print('all done!');
|
| + * });
|
| + *
|
| + * Asynchronous operations which are not related to the current transaction
|
| + * will cause the transaction to automatically be committed-- all processing
|
| + * must be done synchronously unless they are additional async requests to
|
| + * the current transaction.
|
| + */
|
| + @DomName('IDBObjectStore.openCursor')
|
| + Stream<CursorWithValue> openCursor(
|
| + {key, KeyRange range, String direction, bool autoAdvance}) {
|
| + var key_OR_range = null;
|
| + if (key != null) {
|
| + if (range != null) {
|
| + throw new ArgumentError('Cannot specify both key and range.');
|
| + }
|
| + key_OR_range = key;
|
| + } else {
|
| + key_OR_range = range;
|
| + }
|
| +
|
| + // TODO: try/catch this and return a stream with an immediate error.
|
| + var request;
|
| + if (direction == null) {
|
| + request = _openCursor(key_OR_range);
|
| + } else {
|
| + request = _openCursor(key_OR_range, direction);
|
| + }
|
| + return _cursorStreamFromResult(request, autoAdvance);
|
| + }
|
| +
|
| + @DomName('IDBObjectStore.createIndex')
|
| + Index createIndex(String name, keyPath, {bool unique, bool multiEntry}) {
|
| + var options = {};
|
| + if (unique != null) {
|
| + options['unique'] = unique;
|
| + }
|
| + if (multiEntry != null) {
|
| + options['multiEntry'] = multiEntry;
|
| + }
|
| +
|
| + return _createIndex(name, keyPath, options);
|
| + }
|
| +
|
| + // To suppress missing implicit constructor warnings.
|
| + factory ObjectStore._() {
|
| + throw new UnsupportedError("Not supported");
|
| + }
|
| +
|
| + @Deprecated("Internal Use Only")
|
| + external static Type get instanceRuntimeType;
|
| +
|
| + @Deprecated("Internal Use Only")
|
| + ObjectStore.internal_() {}
|
| +
|
| + @DomName('IDBObjectStore.autoIncrement')
|
| + @DocsEditable()
|
| + bool get autoIncrement =>
|
| + _blink.BlinkIDBObjectStore.instance.autoIncrement_Getter_(this);
|
| +
|
| + @DomName('IDBObjectStore.indexNames')
|
| + @DocsEditable()
|
| + List<String> get indexNames =>
|
| + _blink.BlinkIDBObjectStore.instance.indexNames_Getter_(this);
|
| +
|
| + @DomName('IDBObjectStore.keyPath')
|
| + @DocsEditable()
|
| + Object get keyPath =>
|
| + (_blink.BlinkIDBObjectStore.instance.keyPath_Getter_(this));
|
| +
|
| + @DomName('IDBObjectStore.name')
|
| + @DocsEditable()
|
| + String get name => _blink.BlinkIDBObjectStore.instance.name_Getter_(this);
|
| +
|
| + @DomName('IDBObjectStore.transaction')
|
| + @DocsEditable()
|
| + Transaction get transaction =>
|
| + _blink.BlinkIDBObjectStore.instance.transaction_Getter_(this);
|
| +
|
| + Request _add(Object value, [Object key]) {
|
| + if (key != null) {
|
| + return _blink.BlinkIDBObjectStore.instance.add_Callback_2_(
|
| + this,
|
| + convertDartToNative_SerializedScriptValue(value),
|
| + convertDartToNative_SerializedScriptValue(key));
|
| + }
|
| + return _blink.BlinkIDBObjectStore.instance.add_Callback_1_(
|
| + this, convertDartToNative_SerializedScriptValue(value));
|
| + }
|
| +
|
| + @DomName('IDBObjectStore.clear')
|
| + @DocsEditable()
|
| + Request _clear() =>
|
| + _blink.BlinkIDBObjectStore.instance.clear_Callback_0_(this);
|
| +
|
| + @DomName('IDBObjectStore.count')
|
| + @DocsEditable()
|
| + Request _count(Object key) =>
|
| + _blink.BlinkIDBObjectStore.instance.count_Callback_1_(this, key);
|
| +
|
| + Index _createIndex(String name, Object keyPath, [Map options]) {
|
| + if (options != null) {
|
| + return _blink.BlinkIDBObjectStore.instance.createIndex_Callback_3_(
|
| + this, name, keyPath, convertDartToNative_Dictionary(options));
|
| + }
|
| + return _blink.BlinkIDBObjectStore.instance
|
| + .createIndex_Callback_2_(this, name, keyPath);
|
| + }
|
| +
|
| + @DomName('IDBObjectStore.delete')
|
| + @DocsEditable()
|
| + Request _delete(Object key) =>
|
| + _blink.BlinkIDBObjectStore.instance.delete_Callback_1_(this, key);
|
| +
|
| + @DomName('IDBObjectStore.deleteIndex')
|
| + @DocsEditable()
|
| + void deleteIndex(String name) =>
|
| + _blink.BlinkIDBObjectStore.instance.deleteIndex_Callback_1_(this, name);
|
| +
|
| + @DomName('IDBObjectStore.get')
|
| + @DocsEditable()
|
| + Request _get(Object key) =>
|
| + _blink.BlinkIDBObjectStore.instance.get_Callback_1_(this, key);
|
| +
|
| + Request getAll(Object range, [int maxCount]) {
|
| + if (maxCount != null) {
|
| + return _blink.BlinkIDBObjectStore.instance
|
| + .getAll_Callback_2_(this, range, maxCount);
|
| + }
|
| + return _blink.BlinkIDBObjectStore.instance.getAll_Callback_1_(this, range);
|
| + }
|
| +
|
| + Request getAllKeys(Object range, [int maxCount]) {
|
| + if (maxCount != null) {
|
| + return _blink.BlinkIDBObjectStore.instance
|
| + .getAllKeys_Callback_2_(this, range, maxCount);
|
| + }
|
| + return _blink.BlinkIDBObjectStore.instance
|
| + .getAllKeys_Callback_1_(this, range);
|
| + }
|
| +
|
| + @DomName('IDBObjectStore.index')
|
| + @DocsEditable()
|
| + Index index(String name) =>
|
| + _blink.BlinkIDBObjectStore.instance.index_Callback_1_(this, name);
|
| +
|
| + Request _openCursor(Object range, [String direction]) {
|
| + if (direction != null) {
|
| + return _blink.BlinkIDBObjectStore.instance
|
| + .openCursor_Callback_2_(this, range, direction);
|
| + }
|
| + return _blink.BlinkIDBObjectStore.instance
|
| + .openCursor_Callback_1_(this, range);
|
| + }
|
| +
|
| + Request openKeyCursor(Object range, [String direction]) {
|
| + if (direction != null) {
|
| + return _blink.BlinkIDBObjectStore.instance
|
| + .openKeyCursor_Callback_2_(this, range, direction);
|
| + }
|
| + return _blink.BlinkIDBObjectStore.instance
|
| + .openKeyCursor_Callback_1_(this, range);
|
| + }
|
| +
|
| + Request _put(Object value, [Object key]) {
|
| + if (key != null) {
|
| + return _blink.BlinkIDBObjectStore.instance.put_Callback_2_(
|
| + this,
|
| + convertDartToNative_SerializedScriptValue(value),
|
| + convertDartToNative_SerializedScriptValue(key));
|
| + }
|
| + return _blink.BlinkIDBObjectStore.instance.put_Callback_1_(
|
| + this, convertDartToNative_SerializedScriptValue(value));
|
| + }
|
| +
|
| + /**
|
| + * Helper for iterating over cursors in a request.
|
| + */
|
| + static Stream/*<T>*/ _cursorStreamFromResult/*<T extends Cursor>*/(
|
| + Request request, bool autoAdvance) {
|
| + // TODO: need to guarantee that the controller provides the values
|
| + // immediately as waiting until the next tick will cause the transaction to
|
| + // close.
|
| + var controller = new StreamController/*<T>*/(sync: true);
|
| +
|
| + //TODO: Report stacktrace once issue 4061 is resolved.
|
| + request.onError.listen(controller.addError);
|
| +
|
| + request.onSuccess.listen((e) {
|
| + var cursor = _cast/*<T>*/(request.result);
|
| + if (cursor == null) {
|
| + controller.close();
|
| + } else {
|
| + controller.add(cursor);
|
| + if (autoAdvance == true && controller.hasListener) {
|
| + cursor.next();
|
| + }
|
| + }
|
| + });
|
| + return controller.stream;
|
| + }
|
| +}
|
| +
|
| +// ignore: STRONG_MODE_DOWN_CAST_COMPOSITE
|
| +/*=To*/ _cast/*<To>*/(dynamic x) => x;
|
| +// Copyright (c) 2012, 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.
|
| +
|
| +// WARNING: Do not edit - generated code.
|
| +
|
| +@DocsEditable()
|
| +@DomName('IDBOpenDBRequest')
|
| +@Unstable()
|
| +class OpenDBRequest extends Request {
|
| + // To suppress missing implicit constructor warnings.
|
| + factory OpenDBRequest._() {
|
| + throw new UnsupportedError("Not supported");
|
| + }
|
| +
|
| + /**
|
| + * Static factory designed to expose `blocked` events to event
|
| + * handlers that are not necessarily instances of [OpenDBRequest].
|
| + *
|
| + * See [EventStreamProvider] for usage information.
|
| + */
|
| + @DomName('IDBOpenDBRequest.blockedEvent')
|
| + @DocsEditable()
|
| + static const EventStreamProvider<Event> blockedEvent =
|
| + const EventStreamProvider<Event>('blocked');
|
| +
|
| + /**
|
| + * Static factory designed to expose `upgradeneeded` events to event
|
| + * handlers that are not necessarily instances of [OpenDBRequest].
|
| + *
|
| + * See [EventStreamProvider] for usage information.
|
| + */
|
| + @DomName('IDBOpenDBRequest.upgradeneededEvent')
|
| + @DocsEditable()
|
| + static const EventStreamProvider<VersionChangeEvent> upgradeNeededEvent =
|
| + const EventStreamProvider<VersionChangeEvent>('upgradeneeded');
|
| +
|
| + @Deprecated("Internal Use Only")
|
| + external static Type get instanceRuntimeType;
|
| +
|
| + @Deprecated("Internal Use Only")
|
| + OpenDBRequest.internal_() : super.internal_();
|
| +
|
| + /// Stream of `blocked` events handled by this [OpenDBRequest].
|
| + @DomName('IDBOpenDBRequest.onblocked')
|
| + @DocsEditable()
|
| + Stream<Event> get onBlocked => blockedEvent.forTarget(this);
|
| +
|
| + /// Stream of `upgradeneeded` events handled by this [OpenDBRequest].
|
| + @DomName('IDBOpenDBRequest.onupgradeneeded')
|
| + @DocsEditable()
|
| + Stream<VersionChangeEvent> get onUpgradeNeeded =>
|
| + upgradeNeededEvent.forTarget(this);
|
| +}
|
| +// Copyright (c) 2012, 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.
|
| +
|
| +// WARNING: Do not edit - generated code.
|
| +
|
| +@DocsEditable()
|
| +@DomName('IDBRequest')
|
| +@Unstable()
|
| +class Request extends EventTarget {
|
| + // To suppress missing implicit constructor warnings.
|
| + factory Request._() {
|
| + throw new UnsupportedError("Not supported");
|
| + }
|
| +
|
| + /**
|
| + * Static factory designed to expose `error` events to event
|
| + * handlers that are not necessarily instances of [Request].
|
| + *
|
| + * See [EventStreamProvider] for usage information.
|
| + */
|
| + @DomName('IDBRequest.errorEvent')
|
| + @DocsEditable()
|
| + static const EventStreamProvider<Event> errorEvent =
|
| + const EventStreamProvider<Event>('error');
|
| +
|
| + /**
|
| + * Static factory designed to expose `success` events to event
|
| + * handlers that are not necessarily instances of [Request].
|
| + *
|
| + * See [EventStreamProvider] for usage information.
|
| + */
|
| + @DomName('IDBRequest.successEvent')
|
| + @DocsEditable()
|
| + static const EventStreamProvider<Event> successEvent =
|
| + const EventStreamProvider<Event>('success');
|
| +
|
| + @Deprecated("Internal Use Only")
|
| + external static Type get instanceRuntimeType;
|
| +
|
| + @Deprecated("Internal Use Only")
|
| + Request.internal_() : super.internal_();
|
| +
|
| + @DomName('IDBRequest.error')
|
| + @DocsEditable()
|
| + DomException get error => _blink.BlinkIDBRequest.instance.error_Getter_(this);
|
| +
|
| + @DomName('IDBRequest.readyState')
|
| + @DocsEditable()
|
| + String get readyState =>
|
| + _blink.BlinkIDBRequest.instance.readyState_Getter_(this);
|
| +
|
| + @DomName('IDBRequest.result')
|
| + @DocsEditable()
|
| + Object get result => _convertNativeToDart_IDBAny(
|
| + _blink.BlinkIDBRequest.instance.result_Getter_(this));
|
| +
|
| + @DomName('IDBRequest.source')
|
| + @DocsEditable()
|
| + Object get source => (_blink.BlinkIDBRequest.instance.source_Getter_(this));
|
| +
|
| + @DomName('IDBRequest.transaction')
|
| + @DocsEditable()
|
| + Transaction get transaction =>
|
| + _blink.BlinkIDBRequest.instance.transaction_Getter_(this);
|
| +
|
| + /// Stream of `error` events handled by this [Request].
|
| + @DomName('IDBRequest.onerror')
|
| + @DocsEditable()
|
| + Stream<Event> get onError => errorEvent.forTarget(this);
|
| +
|
| + /// Stream of `success` events handled by this [Request].
|
| + @DomName('IDBRequest.onsuccess')
|
| + @DocsEditable()
|
| + Stream<Event> get onSuccess => successEvent.forTarget(this);
|
| +}
|
| +// Copyright (c) 2013, 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.
|
| +
|
| +@DomName('IDBTransaction')
|
| +@Unstable()
|
| +class Transaction extends EventTarget {
|
| + /**
|
| + * Provides a Future which will be completed once the transaction has
|
| + * completed.
|
| + *
|
| + * The future will error if an error occurrs on the transaction or if the
|
| + * transaction is aborted.
|
| + */
|
| + Future<Database> get completed {
|
| + var completer = new Completer<Database>();
|
| +
|
| + this.onComplete.first.then((_) {
|
| + completer.complete(db);
|
| + });
|
| +
|
| + this.onError.first.then((e) {
|
| + completer.completeError(e);
|
| + });
|
| +
|
| + this.onAbort.first.then((e) {
|
| + // Avoid completing twice if an error occurs.
|
| + if (!completer.isCompleted) {
|
| + completer.completeError(e);
|
| + }
|
| + });
|
| +
|
| + return completer.future;
|
| + }
|
| +
|
| + // To suppress missing implicit constructor warnings.
|
| + factory Transaction._() {
|
| + throw new UnsupportedError("Not supported");
|
| + }
|
| +
|
| + /**
|
| + * Static factory designed to expose `abort` events to event
|
| + * handlers that are not necessarily instances of [Transaction].
|
| + *
|
| + * See [EventStreamProvider] for usage information.
|
| + */
|
| + @DomName('IDBTransaction.abortEvent')
|
| + @DocsEditable()
|
| + static const EventStreamProvider<Event> abortEvent =
|
| + const EventStreamProvider<Event>('abort');
|
| +
|
| + /**
|
| + * Static factory designed to expose `complete` events to event
|
| + * handlers that are not necessarily instances of [Transaction].
|
| + *
|
| + * See [EventStreamProvider] for usage information.
|
| + */
|
| + @DomName('IDBTransaction.completeEvent')
|
| + @DocsEditable()
|
| + static const EventStreamProvider<Event> completeEvent =
|
| + const EventStreamProvider<Event>('complete');
|
| +
|
| + /**
|
| + * Static factory designed to expose `error` events to event
|
| + * handlers that are not necessarily instances of [Transaction].
|
| + *
|
| + * See [EventStreamProvider] for usage information.
|
| + */
|
| + @DomName('IDBTransaction.errorEvent')
|
| + @DocsEditable()
|
| + static const EventStreamProvider<Event> errorEvent =
|
| + const EventStreamProvider<Event>('error');
|
| +
|
| + @Deprecated("Internal Use Only")
|
| + external static Type get instanceRuntimeType;
|
| +
|
| + @Deprecated("Internal Use Only")
|
| + Transaction.internal_() : super.internal_();
|
| +
|
| + @DomName('IDBTransaction.db')
|
| + @DocsEditable()
|
| + Database get db => _blink.BlinkIDBTransaction.instance.db_Getter_(this);
|
| +
|
| + @DomName('IDBTransaction.error')
|
| + @DocsEditable()
|
| + DomException get error =>
|
| + _blink.BlinkIDBTransaction.instance.error_Getter_(this);
|
| +
|
| + @DomName('IDBTransaction.mode')
|
| + @DocsEditable()
|
| + String get mode => _blink.BlinkIDBTransaction.instance.mode_Getter_(this);
|
| +
|
| + @DomName('IDBTransaction.objectStoreNames')
|
| + @DocsEditable()
|
| + @Experimental() // untriaged
|
| + List<String> get objectStoreNames =>
|
| + _blink.BlinkIDBTransaction.instance.objectStoreNames_Getter_(this);
|
| +
|
| + @DomName('IDBTransaction.abort')
|
| + @DocsEditable()
|
| + void abort() => _blink.BlinkIDBTransaction.instance.abort_Callback_0_(this);
|
| +
|
| + @DomName('IDBTransaction.objectStore')
|
| + @DocsEditable()
|
| + ObjectStore objectStore(String name) =>
|
| + _blink.BlinkIDBTransaction.instance.objectStore_Callback_1_(this, name);
|
| +
|
| + /// Stream of `abort` events handled by this [Transaction].
|
| + @DomName('IDBTransaction.onabort')
|
| + @DocsEditable()
|
| + Stream<Event> get onAbort => abortEvent.forTarget(this);
|
| +
|
| + /// Stream of `complete` events handled by this [Transaction].
|
| + @DomName('IDBTransaction.oncomplete')
|
| + @DocsEditable()
|
| + Stream<Event> get onComplete => completeEvent.forTarget(this);
|
| +
|
| + /// Stream of `error` events handled by this [Transaction].
|
| + @DomName('IDBTransaction.onerror')
|
| + @DocsEditable()
|
| + Stream<Event> get onError => errorEvent.forTarget(this);
|
| +}
|
| +// Copyright (c) 2012, 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.
|
| +
|
| +// WARNING: Do not edit - generated code.
|
| +
|
| +@DocsEditable()
|
| +@DomName('IDBVersionChangeEvent')
|
| +@Unstable()
|
| +class VersionChangeEvent extends Event {
|
| + // To suppress missing implicit constructor warnings.
|
| + factory VersionChangeEvent._() {
|
| + throw new UnsupportedError("Not supported");
|
| + }
|
| +
|
| + @DomName('IDBVersionChangeEvent.IDBVersionChangeEvent')
|
| + @DocsEditable()
|
| + factory VersionChangeEvent(String type, [Map eventInitDict]) {
|
| + if (eventInitDict != null) {
|
| + var eventInitDict_1 = convertDartToNative_Dictionary(eventInitDict);
|
| + return _blink.BlinkIDBVersionChangeEvent.instance
|
| + .constructorCallback_2_(type, eventInitDict_1);
|
| + }
|
| + return _blink.BlinkIDBVersionChangeEvent.instance
|
| + .constructorCallback_1_(type);
|
| + }
|
| +
|
| + @Deprecated("Internal Use Only")
|
| + external static Type get instanceRuntimeType;
|
| +
|
| + @Deprecated("Internal Use Only")
|
| + VersionChangeEvent.internal_() : super.internal_();
|
| +
|
| + @DomName('IDBVersionChangeEvent.dataLoss')
|
| + @DocsEditable()
|
| + @Experimental() // untriaged
|
| + String get dataLoss =>
|
| + _blink.BlinkIDBVersionChangeEvent.instance.dataLoss_Getter_(this);
|
| +
|
| + @DomName('IDBVersionChangeEvent.dataLossMessage')
|
| + @DocsEditable()
|
| + @Experimental() // untriaged
|
| + String get dataLossMessage =>
|
| + _blink.BlinkIDBVersionChangeEvent.instance.dataLossMessage_Getter_(this);
|
| +
|
| + @DomName('IDBVersionChangeEvent.newVersion')
|
| + @DocsEditable()
|
| + int get newVersion =>
|
| + _blink.BlinkIDBVersionChangeEvent.instance.newVersion_Getter_(this);
|
| +
|
| + @DomName('IDBVersionChangeEvent.oldVersion')
|
| + @DocsEditable()
|
| + int get oldVersion =>
|
| + _blink.BlinkIDBVersionChangeEvent.instance.oldVersion_Getter_(this);
|
| +}
|
|
|