blob: 9c3b3775fff5c5334be291e023b94f41b418b0ba [file] [log] [blame]
library dart.dom.indexed_db;
import 'dart:async';
import 'dart:html';
import 'dart:html_common';
import 'dart:_js_helper' show Creates, Returns, JSName, Null;
import 'dart:_foreign_helper' show 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 - unless you are editing documentation as per:
// https://code.google.com/p/dart/wiki/ContributingHTMLDocumentation
// Auto-generated dart:svg library.
class _KeyRangeFactoryProvider {
static KeyRange createKeyRange_only(/*Key*/ value) =>
_only(_class(), _translateKey(value));
static KeyRange createKeyRange_lowerBound(
/*Key*/ bound, [bool open = false]) =>
_lowerBound(_class(), _translateKey(bound), open);
static KeyRange createKeyRange_upperBound(
/*Key*/ bound, [bool open = false]) =>
_upperBound(_class(), _translateKey(bound), open);
static KeyRange createKeyRange_bound(/*Key*/ lower, /*Key*/ upper,
[bool lowerOpen = false, bool upperOpen = false]) =>
_bound(_class(), _translateKey(lower), _translateKey(upper),
lowerOpen, upperOpen);
static var _cachedClass;
static _class() {
if (_cachedClass != null) return _cachedClass;
return _cachedClass = _uncachedClass();
}
static _uncachedClass() =>
JS('var',
'''window.webkitIDBKeyRange || window.mozIDBKeyRange ||
window.msIDBKeyRange || window.IDBKeyRange''');
static _translateKey(idbkey) => idbkey; // TODO: fixme.
static KeyRange _only(cls, value) =>
JS('KeyRange', '#.only(#)', cls, value);
static KeyRange _lowerBound(cls, bound, open) =>
JS('KeyRange', '#.lowerBound(#, #)', cls, bound, open);
static KeyRange _upperBound(cls, bound, open) =>
JS('KeyRange', '#.upperBound(#, #)', cls, bound, open);
static KeyRange _bound(cls, lower, upper, lowerOpen, upperOpen) =>
JS('KeyRange', '#.bound(#, #, #, #)',
cls, lower, upper, lowerOpen, upperOpen);
}
// Conversions for IDBKey.
//
// 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 (isJavaScriptDate(object)) 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 (containsDate(nativeKey)) {
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);
}
const String _idbKey = '=List|=Object|num|String'; // TODO(sra): Add DateTime.
const _annotation_Creates_IDBKey = const Creates(_idbKey);
const _annotation_Returns_IDBKey = const Returns(_idbKey);
// 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')
class Cursor native "*IDBCursor" {
@DomName('IDBCursor.delete')
Future delete() {
try {
return _completeRequest($dom_delete());
} catch (e, stacktrace) {
return new Future.immediateError(e, stacktrace);
}
}
@DomName('IDBCursor.value')
Future update(value) {
try {
return _completeRequest($dom_update(value));
} catch (e, stacktrace) {
return new Future.immediateError(e, stacktrace);
}
}
@DomName('IDBCursor.direction')
@DocsEditable
final String direction;
@DomName('IDBCursor.key')
@DocsEditable
@_annotation_Creates_IDBKey
@_annotation_Returns_IDBKey
final Object key;
@DomName('IDBCursor.primaryKey')
@DocsEditable
final Object primaryKey;
@DomName('IDBCursor.source')
@DocsEditable
final dynamic source;
@DomName('IDBCursor.advance')
@DocsEditable
void advance(int count) native;
@JSName('continue')
@DomName('IDBCursor.continue')
@DocsEditable
void next([Object key]) native;
@JSName('delete')
@DomName('IDBCursor.delete')
@DocsEditable
Request $dom_delete() native;
@DomName('IDBCursor.update')
@DocsEditable
Request $dom_update(/*any*/ value) {
var value_1 = convertDartToNative_SerializedScriptValue(value);
return _$dom_update_1(value_1);
}
@JSName('update')
@DomName('IDBCursor.update')
@DocsEditable
Request _$dom_update_1(value) native;
}
// 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.
@DocsEditable
@DomName('IDBCursorWithValue')
class CursorWithValue extends Cursor native "*IDBCursorWithValue" {
dynamic get value => _convertNativeToDart_IDBAny(this._get_value);
@JSName('value')
@DomName('IDBCursorWithValue.value')
@DocsEditable
@annotation_Creates_SerializedScriptValue
@annotation_Returns_SerializedScriptValue
final dynamic _get_value;
}
// 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
@DomName('IDBDatabase')
@SupportedBrowser(SupportedBrowser.CHROME)
@SupportedBrowser(SupportedBrowser.FIREFOX, '15')
@SupportedBrowser(SupportedBrowser.IE, '10')
@Experimental
class Database extends EventTarget native "*IDBDatabase" {
@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 $dom_createObjectStore(name, options);
}
Transaction transaction(storeName_OR_storeNames, String mode) {
if (mode != 'readonly' && mode != 'readwrite') {
throw new ArgumentError(mode);
}
// TODO(sra): Ensure storeName_OR_storeNames is a string or List<String>,
// and copy to JavaScript array if necessary.
// Try and create a transaction with a string mode. Browsers that expect a
// numeric mode tend to convert the string into a number. This fails
// silently, resulting in zero ('readonly').
return _transaction(storeName_OR_storeNames, mode);
}
@JSName('transaction')
Transaction _transaction(stores, mode) native;
@DomName('IDBDatabase.abortEvent')
@DocsEditable
static const EventStreamProvider<Event> abortEvent = const EventStreamProvider<Event>('abort');
@DomName('IDBDatabase.errorEvent')
@DocsEditable
static const EventStreamProvider<Event> errorEvent = const EventStreamProvider<Event>('error');
@DomName('IDBDatabase.versionchangeEvent')
@DocsEditable
static const EventStreamProvider<VersionChangeEvent> versionChangeEvent = const EventStreamProvider<VersionChangeEvent>('versionchange');
@DomName('IDBDatabase.name')
@DocsEditable
final String name;
@DomName('IDBDatabase.objectStoreNames')
@DocsEditable
@Returns('DomStringList')
@Creates('DomStringList')
final List<String> objectStoreNames;
@DomName('IDBDatabase.version')
@DocsEditable
final dynamic version;
@JSName('addEventListener')
@DomName('IDBDatabase.addEventListener')
@DocsEditable
void $dom_addEventListener(String type, EventListener listener, [bool useCapture]) native;
@DomName('IDBDatabase.close')
@DocsEditable
void close() native;
@DomName('IDBDatabase.createObjectStore')
@DocsEditable
ObjectStore $dom_createObjectStore(String name, [Map options]) {
if (?options) {
var options_1 = convertDartToNative_Dictionary(options);
return _$dom_createObjectStore_1(name, options_1);
}
return _$dom_createObjectStore_2(name);
}
@JSName('createObjectStore')
@DomName('IDBDatabase.createObjectStore')
@DocsEditable
ObjectStore _$dom_createObjectStore_1(name, options) native;
@JSName('createObjectStore')
@DomName('IDBDatabase.createObjectStore')
@DocsEditable
ObjectStore _$dom_createObjectStore_2(name) native;
@DomName('IDBDatabase.deleteObjectStore')
@DocsEditable
void deleteObjectStore(String name) native;
@DomName('IDBDatabase.dispatchEvent')
@DocsEditable
bool dispatchEvent(Event evt) native;
@JSName('removeEventListener')
@DomName('IDBDatabase.removeEventListener')
@DocsEditable
void $dom_removeEventListener(String type, EventListener listener, [bool useCapture]) native;
@DomName('IDBDatabase.onabort')
@DocsEditable
Stream<Event> get onAbort => abortEvent.forTarget(this);
@DomName('IDBDatabase.onerror')
@DocsEditable
Stream<Event> get onError => errorEvent.forTarget(this);
@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
class IdbFactory native "*IDBFactory" {
/**
* Checks to see if Indexed DB is supported on the current platform.
*/
static bool get supported {
return JS('bool',
'!!(window.indexedDB || '
'window.webkitIndexedDB || '
'window.mozIndexedDB)');
}
@DomName('IDBFactory.open')
Future<Database> open(String name,
{int version, void onUpgradeNeeded(VersionChangeEvent),
void onBlocked(Event)}) {
if ((version == null) != (onUpgradeNeeded == null)) {
return new Future.immediateError(new ArgumentError(
'version and onUpgradeNeeded must be specified together'));
}
try {
var request;
if (version != null) {
request = $dom_open(name, version);
} else {
request = $dom_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.immediateError(e, stacktrace);
}
}
@DomName('IDBFactory.deleteDatabase')
Future<IdbFactory> deleteDatabase(String name,
{void onBlocked(Event)}) {
try {
var request = $dom_deleteDatabase(name);
if (onBlocked != null) {
request.onBlocked.listen(onBlocked);
}
return _completeRequest(request);
} catch (e, stacktrace) {
return new Future.immediateError(e, stacktrace);
}
}
@DomName('IDBFactory.getDatabaseNames')
@SupportedBrowser(SupportedBrowser.CHROME)
@Experimental
Future<List<String>> getDatabaseNames() {
try {
var request = $dom_webkitGetDatabaseNames();
return _completeRequest(request);
} catch (e, stacktrace) {
return new Future.immediateError(e, stacktrace);
}
}
/**
* Checks to see if getDatabaseNames is supported by the current platform.
*/
bool get supportsDatabaseNames {
return supported && JS('bool',
'!!(#.getDatabaseNames || #.webkitGetDatabaseNames)', this, this);
}
@DomName('IDBFactory.cmp')
@DocsEditable
int cmp(Object first, Object second) native;
@JSName('deleteDatabase')
@DomName('IDBFactory.deleteDatabase')
@DocsEditable
OpenDBRequest $dom_deleteDatabase(String name) native;
@JSName('open')
@DomName('IDBFactory.open')
@DocsEditable
@Returns('Request')
@Creates('Request')
@Creates('Database')
OpenDBRequest $dom_open(String name, [int version]) native;
@JSName('webkitGetDatabaseNames')
@DomName('IDBFactory.webkitGetDatabaseNames')
@DocsEditable
@SupportedBrowser(SupportedBrowser.CHROME)
@SupportedBrowser(SupportedBrowser.SAFARI)
@Experimental
@Returns('Request')
@Creates('Request')
@Creates('DomStringList')
Request $dom_webkitGetDatabaseNames() native;
}
/**
* 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) {
var completer = new Completer();
// TODO: make sure that completer.complete is synchronous as transactions
// may be committed if the result is not processed immediately.
request.onSuccess.listen((e) {
completer.complete(request.result);
});
request.onError.listen((e) {
completer.completeError(e);
});
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')
class Index native "*IDBIndex" {
@DomName('IDBIndex.count')
Future<int> count([key_OR_range]) {
try {
var request;
if (key_OR_range != null) {
request = $dom_count(key_OR_range);
} else {
request = $dom_count();
}
return _completeRequest(request);
} catch (e, stacktrace) {
return new Future.immediateError(e, stacktrace);
}
}
@DomName('IDBIndex.get')
Future get(key) {
try {
var request = $dom_get(key);
return _completeRequest(request);
} catch (e, stacktrace) {
return new Future.immediateError(e, stacktrace);
}
}
@DomName('IDBIndex.getKey')
Future getKey(key) {
try {
var request = $dom_getKey(key);
return _completeRequest(request);
} catch (e, stacktrace) {
return new Future.immediateError(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) {
request = $dom_openCursor(key_OR_range);
} else {
request = $dom_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) {
request = $dom_openKeyCursor(key_OR_range);
} else {
request = $dom_openKeyCursor(key_OR_range, direction);
}
return ObjectStore._cursorStreamFromResult(request, autoAdvance);
}
@DomName('IDBIndex.keyPath')
@DocsEditable
final dynamic keyPath;
@DomName('IDBIndex.multiEntry')
@DocsEditable
final bool multiEntry;
@DomName('IDBIndex.name')
@DocsEditable
final String name;
@DomName('IDBIndex.objectStore')
@DocsEditable
final ObjectStore objectStore;
@DomName('IDBIndex.unique')
@DocsEditable
final bool unique;
@JSName('count')
@DomName('IDBIndex.count')
@DocsEditable
Request $dom_count([key_OR_range]) native;
@JSName('get')
@DomName('IDBIndex.get')
@DocsEditable
@Returns('Request')
@Creates('Request')
@annotation_Creates_SerializedScriptValue
Request $dom_get(key) native;
@JSName('getKey')
@DomName('IDBIndex.getKey')
@DocsEditable
@Returns('Request')
@Creates('Request')
@annotation_Creates_SerializedScriptValue
@Creates('ObjectStore')
Request $dom_getKey(key) native;
@JSName('openCursor')
@DomName('IDBIndex.openCursor')
@DocsEditable
@Returns('Request')
@Creates('Request')
@Creates('Cursor')
Request $dom_openCursor([key_OR_range, String direction]) native;
@JSName('openKeyCursor')
@DomName('IDBIndex.openKeyCursor')
@DocsEditable
@Returns('Request')
@Creates('Request')
@Creates('Cursor')
Request $dom_openKeyCursor([key_OR_range, String direction]) native;
}
// 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')
class KeyRange native "*IDBKeyRange" {
@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);
@DomName('IDBKeyRange.lower')
@DocsEditable
final Object lower;
@DomName('IDBKeyRange.lowerOpen')
@DocsEditable
final bool lowerOpen;
@DomName('IDBKeyRange.upper')
@DocsEditable
final Object upper;
@DomName('IDBKeyRange.upperOpen')
@DocsEditable
final bool upperOpen;
@JSName('bound')
@DomName('IDBKeyRange.bound')
@DocsEditable
static KeyRange bound_(Object lower, Object upper, [bool lowerOpen, bool upperOpen]) native;
@JSName('lowerBound')
@DomName('IDBKeyRange.lowerBound')
@DocsEditable
static KeyRange lowerBound_(Object bound, [bool open]) native;
@JSName('only')
@DomName('IDBKeyRange.only')
@DocsEditable
static KeyRange only_(Object value) native;
@JSName('upperBound')
@DomName('IDBKeyRange.upperBound')
@DocsEditable
static KeyRange upperBound_(Object bound, [bool open]) native;
}
// 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')
class ObjectStore native "*IDBObjectStore" {
@DomName('IDBObjectStore.add')
Future add(value, [key]) {
try {
var request;
if (key != null) {
request = $dom_add(value, key);
} else {
request = $dom_add(value);
}
return _completeRequest(request);
} catch (e, stacktrace) {
return new Future.immediateError(e, stacktrace);
}
}
@DomName('IDBObjectStore.clear')
Future clear() {
try {
return _completeRequest($dom_clear());
} catch (e, stacktrace) {
return new Future.immediateError(e, stacktrace);
}
}
@DomName('IDBObjectStore.delete')
Future delete(key_OR_keyRange){
try {
return _completeRequest($dom_delete(key_OR_keyRange));
} catch (e, stacktrace) {
return new Future.immediateError(e, stacktrace);
}
}
@DomName('IDBObjectStore.count')
Future<int> count([key_OR_range]) {
try {
var request;
if (key_OR_range != null) {
request = $dom_count(key_OR_range);
} else {
request = $dom_count();
}
return _completeRequest(request);
} catch (e, stacktrace) {
return new Future.immediateError(e, stacktrace);
}
}
@DomName('IDBObjectStore.put')
Future put(value, [key]) {
try {
var request;
if (key != null) {
request = $dom_put(value, key);
} else {
request = $dom_put(value);
}
return _completeRequest(request);
} catch (e, stacktrace) {
return new Future.immediateError(e, stacktrace);
}
}
@DomName('IDBObjectStore.getObject')
Future getObject(key) {
try {
var request = $dom_getObject(key);
return _completeRequest(request);
} catch (e, stacktrace) {
return new Future.immediateError(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 = $dom_openCursor(key_OR_range);
} else {
request = $dom_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 $dom_createIndex(name, keyPath, options);
}
@DomName('IDBObjectStore.autoIncrement')
@DocsEditable
final bool autoIncrement;
@DomName('IDBObjectStore.indexNames')
@DocsEditable
@Returns('DomStringList')
@Creates('DomStringList')
final List<String> indexNames;
@DomName('IDBObjectStore.keyPath')
@DocsEditable
final dynamic keyPath;
@DomName('IDBObjectStore.name')
@DocsEditable
final String name;
@DomName('IDBObjectStore.transaction')
@DocsEditable
final Transaction transaction;
@DomName('IDBObjectStore.add')
@DocsEditable
@Returns('Request')
@Creates('Request')
@_annotation_Creates_IDBKey
Request $dom_add(/*any*/ value, [/*any*/ key]) {
if (?key) {
var value_1 = convertDartToNative_SerializedScriptValue(value);
var key_2 = convertDartToNative_SerializedScriptValue(key);
return _$dom_add_1(value_1, key_2);
}
var value_3 = convertDartToNative_SerializedScriptValue(value);
return _$dom_add_2(value_3);
}
@JSName('add')
@DomName('IDBObjectStore.add')
@DocsEditable
@Returns('Request')
@Creates('Request')
@_annotation_Creates_IDBKey
Request _$dom_add_1(value, key) native;
@JSName('add')
@DomName('IDBObjectStore.add')
@DocsEditable
@Returns('Request')
@Creates('Request')
@_annotation_Creates_IDBKey
Request _$dom_add_2(value) native;
@JSName('clear')
@DomName('IDBObjectStore.clear')
@DocsEditable
Request $dom_clear() native;
@JSName('count')
@DomName('IDBObjectStore.count')
@DocsEditable
Request $dom_count([key_OR_range]) native;
@DomName('IDBObjectStore.createIndex')
@DocsEditable
Index $dom_createIndex(String name, keyPath, [Map options]) {
if ((keyPath is List<String> || keyPath == null) && !?options) {
List keyPath_1 = convertDartToNative_StringArray(keyPath);
return _$dom_createIndex_1(name, keyPath_1);
}
if ((keyPath is List<String> || keyPath == null)) {
List keyPath_2 = convertDartToNative_StringArray(keyPath);
var options_3 = convertDartToNative_Dictionary(options);
return _$dom_createIndex_2(name, keyPath_2, options_3);
}
if ((keyPath is String || keyPath == null) && !?options) {
return _$dom_createIndex_3(name, keyPath);
}
if ((keyPath is String || keyPath == null)) {
var options_4 = convertDartToNative_Dictionary(options);
return _$dom_createIndex_4(name, keyPath, options_4);
}
throw new ArgumentError("Incorrect number or type of arguments");
}
@JSName('createIndex')
@DomName('IDBObjectStore.createIndex')
@DocsEditable
Index _$dom_createIndex_1(name, List keyPath) native;
@JSName('createIndex')
@DomName('IDBObjectStore.createIndex')
@DocsEditable
Index _$dom_createIndex_2(name, List keyPath, options) native;
@JSName('createIndex')
@DomName('IDBObjectStore.createIndex')
@DocsEditable
Index _$dom_createIndex_3(name, String keyPath) native;
@JSName('createIndex')
@DomName('IDBObjectStore.createIndex')
@DocsEditable
Index _$dom_createIndex_4(name, String keyPath, options) native;
@JSName('delete')
@DomName('IDBObjectStore.delete')
@DocsEditable
Request $dom_delete(key_OR_keyRange) native;
@DomName('IDBObjectStore.deleteIndex')
@DocsEditable
void deleteIndex(String name) native;
@JSName('get')
@DomName('IDBObjectStore.get')
@DocsEditable
@Returns('Request')
@Creates('Request')
@annotation_Creates_SerializedScriptValue
Request $dom_getObject(key) native;
@DomName('IDBObjectStore.index')
@DocsEditable
Index index(String name) native;
@JSName('openCursor')
@DomName('IDBObjectStore.openCursor')
@DocsEditable
@Returns('Request')
@Creates('Request')
@Creates('Cursor')
Request $dom_openCursor([key_OR_range, String direction]) native;
@DomName('IDBObjectStore.put')
@DocsEditable
@Returns('Request')
@Creates('Request')
@_annotation_Creates_IDBKey
Request $dom_put(/*any*/ value, [/*any*/ key]) {
if (?key) {
var value_1 = convertDartToNative_SerializedScriptValue(value);
var key_2 = convertDartToNative_SerializedScriptValue(key);
return _$dom_put_1(value_1, key_2);
}
var value_3 = convertDartToNative_SerializedScriptValue(value);
return _$dom_put_2(value_3);
}
@JSName('put')
@DomName('IDBObjectStore.put')
@DocsEditable
@Returns('Request')
@Creates('Request')
@_annotation_Creates_IDBKey
Request _$dom_put_1(value, key) native;
@JSName('put')
@DomName('IDBObjectStore.put')
@DocsEditable
@Returns('Request')
@Creates('Request')
@_annotation_Creates_IDBKey
Request _$dom_put_2(value) native;
/**
* Helper for iterating over cursors in a request.
*/
static Stream<Cursor> _cursorStreamFromResult(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();
request.onError.listen((e) {
//TODO: Report stacktrace once issue 4061 is resolved.
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.
@DocsEditable
@DomName('IDBOpenDBRequest')
class OpenDBRequest extends Request implements EventTarget native "*IDBOpenDBRequest" {
@DomName('IDBOpenDBRequest.blockedEvent')
@DocsEditable
static const EventStreamProvider<Event> blockedEvent = const EventStreamProvider<Event>('blocked');
@DomName('IDBOpenDBRequest.upgradeneededEvent')
@DocsEditable
static const EventStreamProvider<VersionChangeEvent> upgradeNeededEvent = const EventStreamProvider<VersionChangeEvent>('upgradeneeded');
@DomName('IDBOpenDBRequest.onblocked')
@DocsEditable
Stream<Event> get onBlocked => blockedEvent.forTarget(this);
@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.
@DocsEditable
@DomName('IDBRequest')
class Request extends EventTarget native "*IDBRequest" {
@DomName('IDBRequest.errorEvent')
@DocsEditable
static const EventStreamProvider<Event> errorEvent = const EventStreamProvider<Event>('error');
@DomName('IDBRequest.successEvent')
@DocsEditable
static const EventStreamProvider<Event> successEvent = const EventStreamProvider<Event>('success');
@DomName('IDBRequest.error')
@DocsEditable
final DomError error;
@DomName('IDBRequest.readyState')
@DocsEditable
final String readyState;
dynamic get result => _convertNativeToDart_IDBAny(this._get_result);
@JSName('result')
@DomName('IDBRequest.result')
@DocsEditable
@Creates('Null')
final dynamic _get_result;
@DomName('IDBRequest.source')
@DocsEditable
@Creates('Null')
final dynamic source;
@DomName('IDBRequest.transaction')
@DocsEditable
final Transaction transaction;
@JSName('webkitErrorMessage')
@DomName('IDBRequest.webkitErrorMessage')
@DocsEditable
@SupportedBrowser(SupportedBrowser.CHROME)
@SupportedBrowser(SupportedBrowser.SAFARI)
@Experimental
final String errorMessage;
@JSName('addEventListener')
@DomName('IDBRequest.addEventListener')
@DocsEditable
void $dom_addEventListener(String type, EventListener listener, [bool useCapture]) native;
@DomName('IDBRequest.dispatchEvent')
@DocsEditable
bool dispatchEvent(Event evt) native;
@JSName('removeEventListener')
@DomName('IDBRequest.removeEventListener')
@DocsEditable
void $dom_removeEventListener(String type, EventListener listener, [bool useCapture]) native;
@DomName('IDBRequest.onerror')
@DocsEditable
Stream<Event> get onError => errorEvent.forTarget(this);
@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')
class Transaction extends EventTarget native "*IDBTransaction" {
/**
* 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) {
completer.completeError(e);
});
return completer.future;
}
@DomName('IDBTransaction.abortEvent')
@DocsEditable
static const EventStreamProvider<Event> abortEvent = const EventStreamProvider<Event>('abort');
@DomName('IDBTransaction.completeEvent')
@DocsEditable
static const EventStreamProvider<Event> completeEvent = const EventStreamProvider<Event>('complete');
@DomName('IDBTransaction.errorEvent')
@DocsEditable
static const EventStreamProvider<Event> errorEvent = const EventStreamProvider<Event>('error');
@DomName('IDBTransaction.db')
@DocsEditable
final Database db;
@DomName('IDBTransaction.error')
@DocsEditable
final DomError error;
@DomName('IDBTransaction.mode')
@DocsEditable
final String mode;
@JSName('webkitErrorMessage')
@DomName('IDBTransaction.webkitErrorMessage')
@DocsEditable
@SupportedBrowser(SupportedBrowser.CHROME)
@SupportedBrowser(SupportedBrowser.SAFARI)
@Experimental
final String errorMessage;
@DomName('IDBTransaction.abort')
@DocsEditable
void abort() native;
@JSName('addEventListener')
@DomName('IDBTransaction.addEventListener')
@DocsEditable
void $dom_addEventListener(String type, EventListener listener, [bool useCapture]) native;
@DomName('IDBTransaction.dispatchEvent')
@DocsEditable
bool dispatchEvent(Event evt) native;
@DomName('IDBTransaction.objectStore')
@DocsEditable
ObjectStore objectStore(String name) native;
@JSName('removeEventListener')
@DomName('IDBTransaction.removeEventListener')
@DocsEditable
void $dom_removeEventListener(String type, EventListener listener, [bool useCapture]) native;
@DomName('IDBTransaction.onabort')
@DocsEditable
Stream<Event> get onAbort => abortEvent.forTarget(this);
@DomName('IDBTransaction.oncomplete')
@DocsEditable
Stream<Event> get onComplete => completeEvent.forTarget(this);
@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.
@DocsEditable
@DomName('IDBVersionChangeEvent')
class VersionChangeEvent extends Event native "*IDBVersionChangeEvent" {
@DomName('IDBVersionChangeEvent.newVersion')
@DocsEditable
final dynamic newVersion;
@DomName('IDBVersionChangeEvent.oldVersion')
@DocsEditable
final dynamic oldVersion;
}
// 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.
@DocsEditable
@DomName('IDBAny')
class _IDBAny native "*IDBAny" {
}