sdk/lib/indexed_db/dartium/indexed_db_dartium.dart

/**
 * 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);
}