Dartifying some IndexedDB APIs.

sdk/lib/indexed_db/dartium/indexed_db_dartium.dart

 library dart.dom.indexed_db;
 
 import 'dart:async';
 import 'dart:html';
 import 'dart:html_common';
 import 'dart:nativewrappers';
 // 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.
 
@@ skipping 47 matching lines @@
   Object get primaryKey native "IDBCursor_primaryKey_Getter";
 
   @DomName('IDBCursor.source')
   @DocsEditable
   dynamic get source native "IDBCursor_source_Getter";
 
   @DomName('IDBCursor.advance')
   @DocsEditable
   void advance(int count) native "IDBCursor_advance_Callback";
 
-  void continueFunction([Object key]) {
+  void next([Object key]) {
     if (?key) {
       _continue_1(key);
       return;
     }
     _continue_2();
     return;
   }
 
   @DomName('IDBCursor._continue_1')
   @DocsEditable
@@ skipping 164 matching lines @@
 @SupportedBrowser(SupportedBrowser.IE, '10')
 @Experimental
 class IdbFactory extends NativeFieldWrapperClass1 {
   /**
    * 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)}) {
+    try {
+      var request;
+      if (version != null) {
+        request = $dom_open(name, version);
+      } else {
+        request = $dom_open(name);
+      }
+
+      if (onUpgradeNeeded != null) {
+        request.onUpgradeNeeded.listen(onUpgradeNeeded);
+      }
+      return _completeRequest(request, new Completer<Database>());
+    } catch (e) {
+      return new Future.immediateError(e);
+    }
+  }
+
+  @DomName('IDBFactory.open')
+  Future<IdbFactory> deleteDatabase(String name,
+      {void onBlocked(Event)}) {
+    try {
+      var request = $dom_deleteDatabase(name);
+
+      if (onBlocked != null) {
+        request.onBlocked.listen(onBlocked);
+      }
+      _completeRequest(request, new Completer<Database>());
+    } catch (e) {
+      return new Future.immediateError(e);
+    }
+  }
+
   IdbFactory.internal();
 
   @DomName('IDBFactory.cmp')
   @DocsEditable
   int cmp(Object first, Object second) native "IDBFactory_cmp_Callback";
 
   @DomName('IDBFactory.deleteDatabase')
   @DocsEditable
-  VersionChangeRequest deleteDatabase(String name) native "IDBFactory_deleteDatabase_Callback";
+  VersionChangeRequest $dom_deleteDatabase(String name) native "IDBFactory_deleteDatabase_Callback";
 
-  OpenDBRequest open(String name, [int version]) {
+  OpenDBRequest $dom_open(String name, [int version]) {
     if (?version) {
       return _open_1(name, version);
     }
     return _open_2(name);
   }
 
   @DomName('IDBFactory._open_1')
   @DocsEditable
   OpenDBRequest _open_1(name, version) native "IDBFactory__open_1_Callback";
 
   @DomName('IDBFactory._open_2')
   @DocsEditable
   OpenDBRequest _open_2(name) native "IDBFactory__open_2_Callback";
 
   @DomName('IDBFactory.webkitGetDatabaseNames')
   @DocsEditable
   Request webkitGetDatabaseNames() native "IDBFactory_webkitGetDatabaseNames_Callback";
 
 }
+
+
+/**
+ * Ties a request to a completer, so the completer is completed when it succeeds
+ * and errors out when the request errors.
+ */
+Future _completeRequest(Request request, Completer completer) {
+  request.onSuccess.listen((e) {
+    completer.complete(request.result);
+  });
+  request.onError.listen((e) {
+    completer.completeError(e);
+  });
+  return completer.future;
+}
 // 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('IDBIndex')
 class Index extends NativeFieldWrapperClass1 {
@@ skipping 256 matching lines @@
 
   @DomName('IDBKeyRange._upperBound_2')
   @DocsEditable
   static KeyRange _upperBound_2(bound) native "IDBKeyRange__upperBound_2_Callback";
 
 }
 // 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('IDBObjectStore')
 class ObjectStore extends NativeFieldWrapperClass1 {
+
+  @DomName('IDBObjectStore.put')
+  Future<Object> put(value, [key]) {
+    try {
+      var request;
+      if (key != null) {
+        request = $dom_put(value, key);
+      } else {
+        request = $dom_put(value);
+      }
+      return _completeRequest(request, new Completer<Object>());
+    } catch (e) {
+      return new Future.immediateError(e);
+    }
+  }
+
+  @DomName('IDBObjectStore.getObject')
+  Future<Object> getObject(key) {
+    try {
+      var request = $dom_getObject(key);
+
+      return _completeRequest(request, new Completer<Object>());
+    } catch (e) {
+      return new Future.immediateError(e);
+    }
+  }
+
+  /**
+   * 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.
+   *
+   * 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<Cursor> 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 = $dom_openCursor(key_OR_range);
+    } else {
+      request = $dom_openCursor(key_OR_range, direction);
+    }
+    return _cursorStreamFromResult(request, autoAdvance);
+  }
+
   ObjectStore.internal();
 
   @DomName('IDBObjectStore.autoIncrement')
   @DocsEditable
   bool get autoIncrement native "IDBObjectStore_autoIncrement_Getter";
 
   @DomName('IDBObjectStore.indexNames')
   @DocsEditable
   List<String> get indexNames native "IDBObjectStore_indexNames_Getter";
 
@@ skipping 86 matching lines @@
   Request _delete_1(key_OR_keyRange) native "IDBObjectStore__delete_1_Callback";
 
   @DomName('IDBObjectStore._delete_2')
   @DocsEditable
   Request _delete_2(key_OR_keyRange) native "IDBObjectStore__delete_2_Callback";
 
   @DomName('IDBObjectStore.deleteIndex')
   @DocsEditable
   void deleteIndex(String name) native "IDBObjectStore_deleteIndex_Callback";
 
-  Request getObject(key) {
+  Request $dom_getObject(key) {
     if ((key is KeyRange || key == null)) {
       return _get_1(key);
     }
     if (?key) {
       return _get_2(key);
     }
     throw new ArgumentError("Incorrect number or type of arguments");
   }
 
   @DomName('IDBObjectStore._get_1')
   @DocsEditable
   Request _get_1(key) native "IDBObjectStore__get_1_Callback";
 
   @DomName('IDBObjectStore._get_2')
   @DocsEditable
   Request _get_2(key) native "IDBObjectStore__get_2_Callback";
 
   @DomName('IDBObjectStore.index')
   @DocsEditable
   Index index(String name) native "IDBObjectStore_index_Callback";
 
-  Request openCursor([key_OR_range, String direction]) {
+  Request $dom_openCursor([key_OR_range, String direction]) {
     if (!?key_OR_range && !?direction) {
       return _openCursor_1();
     }
     if ((key_OR_range is KeyRange || key_OR_range == null) && !?direction) {
       return _openCursor_2(key_OR_range);
     }
     if ((key_OR_range is KeyRange || key_OR_range == null) && (direction is String || direction == null)) {
       return _openCursor_3(key_OR_range, direction);
     }
     if (?key_OR_range && !?direction) {
@@ skipping 18 matching lines @@
   Request _openCursor_3(key_OR_range, direction) native "IDBObjectStore__openCursor_3_Callback";
 
   @DomName('IDBObjectStore._openCursor_4')
   @DocsEditable
   Request _openCursor_4(key_OR_range) native "IDBObjectStore__openCursor_4_Callback";
 
   @DomName('IDBObjectStore._openCursor_5')
   @DocsEditable
   Request _openCursor_5(key_OR_range, direction) native "IDBObjectStore__openCursor_5_Callback";
 
-  Request put(Object value, [Object key]) {
+  Request $dom_put(Object value, [Object key]) {
     if (?key) {
       return _put_1(value, key);
     }
     return _put_2(value);
   }
 
   @DomName('IDBObjectStore._put_1')
   @DocsEditable
   Request _put_1(value, key) native "IDBObjectStore__put_1_Callback";
 
   @DomName('IDBObjectStore._put_2')
   @DocsEditable
   Request _put_2(value) native "IDBObjectStore__put_2_Callback";
 
+
+  /**
+   * Helper for iterating over cursors in a request.
+   */
+  static Stream<Cursor> _cursorStreamFromResult(Request request,
+      bool autoAdvance) {
+    var controller = new StreamController<Cursor>();
+
+    request.onError.listen((e) {
+      controller.signalError(e);
+    });
+
+    request.onSuccess.listen((e) {
+      Cursor cursor = request.result;
+      if (cursor == null) {
+        controller.close();
+      } else {
+        controller.add(cursor);
+        if (autoAdvance == true) {
+          cursor.next();
+        }
+      }
+    });
+    return controller.stream;
+  }
 }
 // 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')
@@ skipping 296 matching lines @@
 
 // WARNING: Do not edit - generated code.
 
 
 @DocsEditable
 @DomName('IDBAny')
 class _Any extends NativeFieldWrapperClass1 {
   _Any.internal();
 
 }