OLD | NEW |
1 library IndexedDB1Test; | 1 library IndexedDB1Test; |
2 import '../../pkg/unittest/lib/unittest.dart'; | 2 import '../../pkg/unittest/lib/unittest.dart'; |
3 import '../../pkg/unittest/lib/html_config.dart'; | 3 import '../../pkg/unittest/lib/html_config.dart'; |
4 import 'dart:html'; | 4 import 'dart:html' as html; |
| 5 import 'dart:indexed_db' as idb; |
5 | 6 |
6 const String DB_NAME = 'Test'; | 7 const String DB_NAME = 'Test'; |
7 const String STORE_NAME = 'TEST'; | 8 const String STORE_NAME = 'TEST'; |
8 const int VERSION = 1; | 9 const int VERSION = 1; |
9 | 10 |
10 testReadWrite(key, value, matcher, | 11 testReadWrite(key, value, matcher, |
11 [dbName = DB_NAME, | 12 [dbName = DB_NAME, |
12 storeName = STORE_NAME, | 13 storeName = STORE_NAME, |
13 version = VERSION]) => () { | 14 version = VERSION]) => () { |
14 var db; | 15 var db; |
(...skipping 40 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
55 transaction.on.error.add(fail); | 56 transaction.on.error.add(fail); |
56 }) | 57 }) |
57 ); | 58 ); |
58 request.on.error.add(fail); | 59 request.on.error.add(fail); |
59 } else { | 60 } else { |
60 step1(); | 61 step1(); |
61 } | 62 } |
62 } | 63 } |
63 | 64 |
64 openDb(e) { | 65 openDb(e) { |
65 var request = window.indexedDB.open(dbName, version); | 66 var request = html.window.indexedDB.open(dbName, version); |
66 expect(request, isNotNull); | 67 expect(request, isNotNull); |
67 request.on.success.add(expectAsync1(initDb)); | 68 request.on.success.add(expectAsync1(initDb)); |
68 request.on.error.add(fail); | 69 request.on.error.add(fail); |
69 if (request is IDBOpenDBRequest) { | 70 if (request is idb.OpenDBRequest) { |
70 // New upgrade protocol. Old API has no 'upgradeNeeded' and uses | 71 // New upgrade protocol. Old API has no 'upgradeNeeded' and uses |
71 // setVersion instead. This path take by FireFox 15, Chrome 24. | 72 // setVersion instead. This path take by FireFox 15, Chrome 24. |
72 request.on.upgradeNeeded.add((e) { | 73 request.on.upgradeNeeded.add((e) { |
73 guardAsync(() { | 74 guardAsync(() { |
74 createObjectStore(e.target.result); | 75 createObjectStore(e.target.result); |
75 }); | 76 }); |
76 }); | 77 }); |
77 } | 78 } |
78 } | 79 } |
79 | 80 |
80 // Delete any existing DB. | 81 // Delete any existing DB. |
81 var deleteRequest = window.indexedDB.deleteDatabase(dbName); | 82 var deleteRequest = html.window.indexedDB.deleteDatabase(dbName); |
82 deleteRequest.on.success.add(expectAsync1(openDb)); | 83 deleteRequest.on.success.add(expectAsync1(openDb)); |
83 deleteRequest.on.error.add(fail); | 84 deleteRequest.on.error.add(fail); |
84 }; | 85 }; |
85 | 86 |
86 testReadWriteTyped(key, value, matcher, | 87 testReadWriteTyped(key, value, matcher, |
87 [dbName = DB_NAME, | 88 [dbName = DB_NAME, |
88 storeName = STORE_NAME, | 89 storeName = STORE_NAME, |
89 version = VERSION]) => () { | 90 version = VERSION]) => () { |
90 IDBDatabase db; | 91 idb.Database db; |
91 | 92 |
92 fail(e) { | 93 fail(e) { |
93 guardAsync(() { | 94 guardAsync(() { |
94 throw new Exception('IndexedDB failure'); | 95 throw new Exception('IndexedDB failure'); |
95 }); | 96 }); |
96 } | 97 } |
97 | 98 |
98 createObjectStore(db) { | 99 createObjectStore(db) { |
99 IDBObjectStore store = db.createObjectStore(storeName); | 100 idb.ObjectStore store = db.createObjectStore(storeName); |
100 expect(store, isNotNull); | 101 expect(store, isNotNull); |
101 } | 102 } |
102 | 103 |
103 step2(e) { | 104 step2(e) { |
104 IDBTransaction transaction = db.transaction(storeName, 'readonly'); | 105 idb.Transaction transaction = db.transaction(storeName, 'readonly'); |
105 IDBRequest request = transaction.objectStore(storeName).getObject(key); | 106 idb.Request request = transaction.objectStore(storeName).getObject(key); |
106 request.on.success.add(expectAsync1((e) { | 107 request.on.success.add(expectAsync1((e) { |
107 var object = e.target.result; | 108 var object = e.target.result; |
108 db.close(); | 109 db.close(); |
109 expect(object, matcher); | 110 expect(object, matcher); |
110 })); | 111 })); |
111 request.on.error.add(fail); | 112 request.on.error.add(fail); |
112 } | 113 } |
113 | 114 |
114 step1() { | 115 step1() { |
115 IDBTransaction transaction = db.transaction([storeName], 'readwrite'); | 116 idb.Transaction transaction = db.transaction([storeName], 'readwrite'); |
116 IDBRequest request = transaction.objectStore(storeName).put(value, key); | 117 idb.Request request = transaction.objectStore(storeName).put(value, key); |
117 request.on.success.add(expectAsync1(step2)); | 118 request.on.success.add(expectAsync1(step2)); |
118 request.on.error.add(fail); | 119 request.on.error.add(fail); |
119 } | 120 } |
120 | 121 |
121 initDb(e) { | 122 initDb(e) { |
122 db = e.target.result; | 123 db = e.target.result; |
123 if (version != db.version) { | 124 if (version != db.version) { |
124 // Legacy 'setVersion' upgrade protocol. | 125 // Legacy 'setVersion' upgrade protocol. |
125 IDBRequest request = db.setVersion('$version'); | 126 idb.Request request = db.setVersion('$version'); |
126 request.on.success.add( | 127 request.on.success.add( |
127 expectAsync1((e) { | 128 expectAsync1((e) { |
128 createObjectStore(db); | 129 createObjectStore(db); |
129 IDBTransaction transaction = e.target.result; | 130 idb.Transaction transaction = e.target.result; |
130 transaction.on.complete.add(expectAsync1((e) => step1())); | 131 transaction.on.complete.add(expectAsync1((e) => step1())); |
131 transaction.on.error.add(fail); | 132 transaction.on.error.add(fail); |
132 }) | 133 }) |
133 ); | 134 ); |
134 request.on.error.add(fail); | 135 request.on.error.add(fail); |
135 } else { | 136 } else { |
136 step1(); | 137 step1(); |
137 } | 138 } |
138 } | 139 } |
139 | 140 |
140 openDb(e) { | 141 openDb(e) { |
141 IDBRequest request = window.indexedDB.open(dbName, version); | 142 idb.Request request = html.window.indexedDB.open(dbName, version); |
142 expect(request, isNotNull); | 143 expect(request, isNotNull); |
143 request.on.success.add(expectAsync1(initDb)); | 144 request.on.success.add(expectAsync1(initDb)); |
144 request.on.error.add(fail); | 145 request.on.error.add(fail); |
145 if (request is IDBOpenDBRequest) { | 146 if (request is idb.OpenDBRequest) { |
146 // New upgrade protocol. Old API has no 'upgradeNeeded' and uses | 147 // New upgrade protocol. Old API has no 'upgradeNeeded' and uses |
147 // setVersion instead. | 148 // setVersion instead. |
148 request.on.upgradeNeeded.add((e) { | 149 request.on.upgradeNeeded.add((e) { |
149 guardAsync(() { | 150 guardAsync(() { |
150 createObjectStore(e.target.result); | 151 createObjectStore(e.target.result); |
151 }); | 152 }); |
152 }); | 153 }); |
153 } | 154 } |
154 } | 155 } |
155 | 156 |
156 // Delete any existing DB. | 157 // Delete any existing DB. |
157 IDBRequest deleteRequest = window.indexedDB.deleteDatabase(dbName); | 158 idb.Request deleteRequest = html.window.indexedDB.deleteDatabase(dbName); |
158 deleteRequest.on.success.add(expectAsync1(openDb)); | 159 deleteRequest.on.success.add(expectAsync1(openDb)); |
159 deleteRequest.on.error.add(fail); | 160 deleteRequest.on.error.add(fail); |
160 }; | 161 }; |
161 | 162 |
162 tests_dynamic() { | 163 tests_dynamic() { |
163 test('test1', testReadWrite(123, 'Hoot!', equals('Hoot!'))); | 164 test('test1', testReadWrite(123, 'Hoot!', equals('Hoot!'))); |
164 test('test2', testReadWrite(123, 12345, equals(12345))); | 165 test('test2', testReadWrite(123, 12345, equals(12345))); |
165 test('test3', testReadWrite(123, [1, 2, 3], equals([1, 2, 3]))); | 166 test('test3', testReadWrite(123, [1, 2, 3], equals([1, 2, 3]))); |
166 test('test4', testReadWrite(123, [2, 3, 4], equals([2, 3, 4]))); | 167 test('test4', testReadWrite(123, [2, 3, 4], equals([2, 3, 4]))); |
167 } | 168 } |
168 | 169 |
169 tests_typed() { | 170 tests_typed() { |
170 test('test1', testReadWriteTyped(123, 'Hoot!', equals('Hoot!'))); | 171 test('test1', testReadWriteTyped(123, 'Hoot!', equals('Hoot!'))); |
171 test('test2', testReadWriteTyped(123, 12345, equals(12345))); | 172 test('test2', testReadWriteTyped(123, 12345, equals(12345))); |
172 test('test3', testReadWriteTyped(123, [1, 2, 3], equals([1, 2, 3]))); | 173 test('test3', testReadWriteTyped(123, [1, 2, 3], equals([1, 2, 3]))); |
173 test('test4', testReadWriteTyped(123, [2, 3, 4], equals([2, 3, 4]))); | 174 test('test4', testReadWriteTyped(123, [2, 3, 4], equals([2, 3, 4]))); |
174 } | 175 } |
175 | 176 |
176 main() { | 177 main() { |
177 useHtmlConfiguration(); | 178 useHtmlConfiguration(); |
178 | 179 |
179 tests_dynamic(); | 180 tests_dynamic(); |
180 tests_typed(); | 181 tests_typed(); |
181 } | 182 } |
OLD | NEW |