Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(58)

Side by Side Diff: third_party/WebKit/LayoutTests/storage/indexeddb/resources/observer.js

Issue 2459113002: [IDBObservers] Moving options from constructor to .observe call. (Closed)
Patch Set: added more exceptions, fixed tests Created 4 years, 1 month ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
1 if (this.importScripts) { 1 if (this.importScripts) {
2 importScripts('../../../resources/testharness.js'); 2 importScripts('../../../resources/testharness.js');
3 importScripts('generic-idb-operations.js'); 3 importScripts('generic-idb-operations.js');
4 } 4 }
5 5
6 async_test(function(t) { 6 async_test(function(t) {
7 var dbname = location.pathname + ' - ' + 'empty transaction'; 7 var dbname = location.pathname + ' - ' + 'empty transaction';
8 var openRequest = indexedDB.open(dbname); 8 var openRequest = indexedDB.open(dbname);
9 var callback_count = 0; 9 var callback_count = 0;
10 var obs = new IDBObserver(t.step_func(function() { callback_count++; }), {oper ationTypes: ['put']}); 10 var obs = new IDBObserver(t.step_func(function() { callback_count++; }));
11 11
12 openRequest.onupgradeneeded = t.step_func(function() { 12 openRequest.onupgradeneeded = t.step_func(function() {
13 openRequest.result.createObjectStore('store'); 13 openRequest.result.createObjectStore('store');
14 }); 14 });
15 openRequest.onsuccess = t.step_func(function() { 15 openRequest.onsuccess = t.step_func(function() {
16 var db = openRequest.result; 16 var db = openRequest.result;
17 var tx1 = db.transaction('store', 'readwrite'); 17 var tx1 = db.transaction('store', 'readwrite');
18 var tx2 = db.transaction('store', 'readwrite'); 18 var tx2 = db.transaction('store', 'readwrite');
19 obs.observe(db, tx1); 19 obs.observe(db, tx1, {operationTypes: ['put']});
20 tx2.objectStore('store').put(1, 1); 20 tx2.objectStore('store').put(1, 1);
21 tx1.oncomplete = t.step_func(function() { 21 tx1.oncomplete = t.step_func(function() {
22 countCallbacks(callback_count, 0); 22 countCallbacks(callback_count, 0);
23 }); 23 });
24 tx2.oncomplete = t.step_func(function() { 24 tx2.oncomplete = t.step_func(function() {
25 countCallbacks(callback_count, 1); 25 countCallbacks(callback_count, 1);
26 t.done(); 26 t.done();
27 }); 27 });
28 tx1.onerror = t.unreached_func('transaction should not fail'); 28 tx1.onerror = t.unreached_func('transaction should not fail');
29 tx2.onerror = t.unreached_func('transaction should not fail'); 29 tx2.onerror = t.unreached_func('transaction should not fail');
30 }); 30 });
31 }, 'Registering observe call with empty transaction'); 31 }, 'Registering observe call with empty transaction');
32 32
33 async_test(function(t) { 33 async_test(function(t) {
34 var dbname = location.pathname + ' - ' + 'observer in version change'; 34 var dbname = location.pathname + ' - ' + 'observer in version change';
35 var openRequest = indexedDB.open(dbname); 35 var openRequest = indexedDB.open(dbname);
36 var callback_count = 0; 36 var callback_count = 0;
37 var obs; 37 var obs;
38 openRequest.onupgradeneeded = t.step_func(function() { 38 openRequest.onupgradeneeded = t.step_func(function() {
39 openRequest.result.createObjectStore('store'); 39 openRequest.result.createObjectStore('store');
40 obs = new IDBObserver(t.step_func(function(changes) { callback_count++; }) , { operationTypes: ['put'] }); 40 obs = new IDBObserver(t.step_func(function(changes) { callback_count++; }) );
41 }); 41 });
42 openRequest.onsuccess = t.step_func(function() { 42 openRequest.onsuccess = t.step_func(function() {
43 var db = openRequest.result; 43 var db = openRequest.result;
44 var tx1 = db.transaction('store', 'readwrite'); 44 var tx1 = db.transaction('store', 'readwrite');
45 var tx2 = db.transaction('store', 'readwrite'); 45 var tx2 = db.transaction('store', 'readwrite');
46 tx1.objectStore('store').get(1); 46 tx1.objectStore('store').get(1);
47 tx2.objectStore('store').put(1, 1); 47 tx2.objectStore('store').put(1, 1);
48 obs.observe(db, tx1); 48 obs.observe(db, tx1, { operationTypes: ['put'] });
49 tx1.oncomplete = t.step_func(function() { 49 tx1.oncomplete = t.step_func(function() {
50 countCallbacks(callback_count, 0); 50 countCallbacks(callback_count, 0);
51 }); 51 });
52 tx2.oncomplete = t.step_func(function() { 52 tx2.oncomplete = t.step_func(function() {
53 countCallbacks(callback_count, 1); 53 countCallbacks(callback_count, 1);
54 t.done(); 54 t.done();
55 }); 55 });
56 tx1.onerror = t.unreached_func('transaction should not fail'); 56 tx1.onerror = t.unreached_func('transaction should not fail');
57 tx2.onerror = t.unreached_func('transaction should not fail'); 57 tx2.onerror = t.unreached_func('transaction should not fail');
58 }); 58 });
59 }, 'Create IDBObserver during version change'); 59 }, 'Create IDBObserver during version change');
60 60
61 async_test(function(t) { 61 async_test(function(t) {
62 var dbname = location.pathname + ' - ' + 'ignore observe call'; 62 var dbname = location.pathname + ' - ' + 'ignore observe call';
63 var openRequest = indexedDB.open(dbname); 63 var openRequest = indexedDB.open(dbname);
64 var callback_count = 0; 64 var callback_count = 0;
65 var obs = new IDBObserver(t.step_func(function() { callback_count++; }), { ope rationTypes: ['put'] }); 65 var obs = new IDBObserver(t.step_func(function() { callback_count++; }));
66 openRequest.onupgradeneeded = t.step_func(function() { 66 openRequest.onupgradeneeded = t.step_func(function() {
67 var db = openRequest.result; 67 var db = openRequest.result;
68 db.createObjectStore('store'); 68 db.createObjectStore('store');
69 obs.observe(db, openRequest.transaction); 69 obs.observe(db, openRequest.transaction, { operationTypes: ['put'] });
70 }); 70 });
71 openRequest.onsuccess = t.step_func(function() { 71 openRequest.onsuccess = t.step_func(function() {
72 var db = openRequest.result; 72 var db = openRequest.result;
73 var tx = db.transaction('store', 'readwrite'); 73 var tx = db.transaction('store', 'readwrite');
74 tx.objectStore('store').put(1, 1); 74 tx.objectStore('store').put(1, 1);
75 tx.oncomplete = t.step_func(function() { 75 tx.oncomplete = t.step_func(function() {
76 countCallbacks(callback_count, 0); 76 countCallbacks(callback_count, 0);
77 t.done(); 77 t.done();
78 }); 78 });
79 tx.onerror = t.unreached_func('transaction should not fail'); 79 tx.onerror = t.unreached_func('transaction should not fail');
80 }); 80 });
81 }, 'Observe call during version change ignored'); 81 }, 'Observe call during version change ignored');
82 82
83 async_test(function(t) { 83 async_test(function(t) {
84 var dbname = location.pathname + ' - ' + 'abort associated transaction'; 84 var dbname = location.pathname + ' - ' + 'abort associated transaction';
85 var openRequest = indexedDB.open(dbname); 85 var openRequest = indexedDB.open(dbname);
86 var callback_count = 0; 86 var callback_count = 0;
87 var obs = new IDBObserver(t.step_func(function() { callback_count++; }), { ope rationTypes: ['put'] }); 87 var obs = new IDBObserver(t.step_func(function() { callback_count++; }));
88 openRequest.onupgradeneeded = t.step_func(function() { 88 openRequest.onupgradeneeded = t.step_func(function() {
89 openRequest.result.createObjectStore('store'); 89 openRequest.result.createObjectStore('store');
90 }); 90 });
91 openRequest.onsuccess = t.step_func(function() { 91 openRequest.onsuccess = t.step_func(function() {
92 var db = openRequest.result; 92 var db = openRequest.result;
93 var tx1 = db.transaction('store', 'readwrite'); 93 var tx1 = db.transaction('store', 'readwrite');
94 var tx2 = db.transaction('store', 'readwrite'); 94 var tx2 = db.transaction('store', 'readwrite');
95 tx1.objectStore('store').get(1); 95 tx1.objectStore('store').get(1);
96 tx2.objectStore('store').put(1, 1); 96 tx2.objectStore('store').put(1, 1);
97 obs.observe(db, tx1); 97 obs.observe(db, tx1, { operationTypes: ['put'] });
98 tx1.abort(); 98 tx1.abort();
99 99
100 tx1.onabort = t.step_func(function(){ 100 tx1.onabort = t.step_func(function(){
101 countCallbacks(callback_count, 0); 101 countCallbacks(callback_count, 0);
102 }); 102 });
103 tx1.oncomplete = t.unreached_func('transaction should not complete'); 103 tx1.oncomplete = t.unreached_func('transaction should not complete');
104 tx2.oncomplete = t.step_func(function() { 104 tx2.oncomplete = t.step_func(function() {
105 countCallbacks(callback_count, 0); 105 countCallbacks(callback_count, 0);
106 t.done(); 106 t.done();
107 }); 107 });
108 tx2.onerror = t.unreached_func('transaction error should not fail'); 108 tx2.onerror = t.unreached_func('transaction error should not fail');
109 }); 109 });
110 }, 'Abort transaction associated with observer'); 110 }, 'Abort transaction associated with observer');
111 111
112 async_test(function(t) { 112 async_test(function(t) {
113 var dbname = location.pathname + ' - ' + 'abort transaction'; 113 var dbname = location.pathname + ' - ' + 'abort transaction';
114 var openRequest = indexedDB.open(dbname); 114 var openRequest = indexedDB.open(dbname);
115 var callback_count = 0; 115 var callback_count = 0;
116 var obs = new IDBObserver(t.step_func(function() { callback_count++; }), { ope rationTypes: ['put'] }); 116 var obs = new IDBObserver(t.step_func(function() { callback_count++; }));
117 openRequest.onupgradeneeded = t.step_func(function() { 117 openRequest.onupgradeneeded = t.step_func(function() {
118 openRequest.result.createObjectStore('store'); 118 openRequest.result.createObjectStore('store');
119 }); 119 });
120 openRequest.onsuccess = t.step_func(function() { 120 openRequest.onsuccess = t.step_func(function() {
121 var db = openRequest.result; 121 var db = openRequest.result;
122 var tx1 = db.transaction('store', 'readwrite'); 122 var tx1 = db.transaction('store', 'readwrite');
123 var tx2 = db.transaction('store', 'readwrite'); 123 var tx2 = db.transaction('store', 'readwrite');
124 var tx3 = db.transaction('store', 'readwrite'); 124 var tx3 = db.transaction('store', 'readwrite');
125 tx1.objectStore('store').get(1); 125 tx1.objectStore('store').get(1);
126 tx2.objectStore('store').put(1, 1); 126 tx2.objectStore('store').put(1, 1);
127 tx3.objectStore('store').put(1, 1); 127 tx3.objectStore('store').put(1, 1);
128 obs.observe(db, tx1); 128 obs.observe(db, tx1, { operationTypes: ['put'] });
129 tx2.abort(); 129 tx2.abort();
130 tx1.oncomplete = t.step_func(function() { 130 tx1.oncomplete = t.step_func(function() {
131 countCallbacks(callback_count, 0); 131 countCallbacks(callback_count, 0);
132 }); 132 });
133 tx2.oncomplete = t.unreached_func('transaction should not complete'); 133 tx2.oncomplete = t.unreached_func('transaction should not complete');
134 tx2.onabort = t.step_func(function() { 134 tx2.onabort = t.step_func(function() {
135 countCallbacks(callback_count, 0); 135 countCallbacks(callback_count, 0);
136 }); 136 });
137 tx3.oncomplete = t.step_func(function() { 137 tx3.oncomplete = t.step_func(function() {
138 countCallbacks(callback_count, 1); 138 countCallbacks(callback_count, 1);
139 t.done(); 139 t.done();
140 }); 140 });
141 tx1.onerror = t.unreached_func('transaction should not fail'); 141 tx1.onerror = t.unreached_func('transaction should not fail');
142 tx3.onerror = t.unreached_func('transaction should not fail'); 142 tx3.onerror = t.unreached_func('transaction should not fail');
143 }); 143 });
144 }, 'Abort transaction recorded by observer'); 144 }, 'Abort transaction recorded by observer');
145 145
146 done(); 146 done();
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698