The Tor Browser / file comparison
comparison: services/sync/tests/unit/test_collection_inc_get.js
services/sync/tests/unit/test_collection_inc_get.js
- branch
- TOR_BUG_9701
- changeset 15
- b8a032363ba2
equal
deleted
inserted
replaced
| -1:000000000000 | 0:8795b0008cb6 |
|---|---|
| 1 /* Any copyright is dedicated to the Public Domain. | |
| 2 http://creativecommons.org/publicdomain/zero/1.0/ */ | |
| 3 | |
| 4 _("Make sure Collection can correctly incrementally parse GET requests"); | |
| 5 Cu.import("resource://services-sync/record.js"); | |
| 6 Cu.import("resource://services-sync/service.js"); | |
| 7 | |
| 8 function run_test() { | |
| 9 let base = "http://fake/"; | |
| 10 let coll = new Collection("http://fake/uri/", WBORecord, Service); | |
| 11 let stream = { _data: "" }; | |
| 12 let called, recCount, sum; | |
| 13 | |
| 14 _("Not-JSON, string payloads are strings"); | |
| 15 called = false; | |
| 16 stream._data = '{"id":"hello","payload":"world"}\n'; | |
| 17 coll.recordHandler = function(rec) { | |
| 18 called = true; | |
| 19 _("Got record:", JSON.stringify(rec)); | |
| 20 rec.collection = "uri"; // This would be done by an engine, so do it here. | |
| 21 do_check_eq(rec.collection, "uri"); | |
| 22 do_check_eq(rec.id, "hello"); | |
| 23 do_check_eq(rec.uri(base).spec, "http://fake/uri/hello"); | |
| 24 do_check_eq(rec.payload, "world"); | |
| 25 }; | |
| 26 coll._onProgress.call(stream); | |
| 27 do_check_eq(stream._data, ''); | |
| 28 do_check_true(called); | |
| 29 _("\n"); | |
| 30 | |
| 31 | |
| 32 _("Parse record with payload"); | |
| 33 called = false; | |
| 34 stream._data = '{"payload":"{\\"value\\":123}"}\n'; | |
| 35 coll.recordHandler = function(rec) { | |
| 36 called = true; | |
| 37 _("Got record:", JSON.stringify(rec)); | |
| 38 do_check_eq(rec.payload.value, 123); | |
| 39 }; | |
| 40 coll._onProgress.call(stream); | |
| 41 do_check_eq(stream._data, ''); | |
| 42 do_check_true(called); | |
| 43 _("\n"); | |
| 44 | |
| 45 | |
| 46 _("Parse multiple records in one go"); | |
| 47 called = false; | |
| 48 recCount = 0; | |
| 49 sum = 0; | |
| 50 stream._data = '{"id":"hundred","payload":"{\\"value\\":100}"}\n{"id":"ten","payload":"{\\"value\\":10}"}\n{"id":"one","payload":"{\\"value\\":1}"}\n'; | |
| 51 coll.recordHandler = function(rec) { | |
| 52 called = true; | |
| 53 _("Got record:", JSON.stringify(rec)); | |
| 54 recCount++; | |
| 55 sum += rec.payload.value; | |
| 56 _("Incremental status: count", recCount, "sum", sum); | |
| 57 rec.collection = "uri"; | |
| 58 switch (recCount) { | |
| 59 case 1: | |
| 60 do_check_eq(rec.id, "hundred"); | |
| 61 do_check_eq(rec.uri(base).spec, "http://fake/uri/hundred"); | |
| 62 do_check_eq(rec.payload.value, 100); | |
| 63 do_check_eq(sum, 100); | |
| 64 break; | |
| 65 case 2: | |
| 66 do_check_eq(rec.id, "ten"); | |
| 67 do_check_eq(rec.uri(base).spec, "http://fake/uri/ten"); | |
| 68 do_check_eq(rec.payload.value, 10); | |
| 69 do_check_eq(sum, 110); | |
| 70 break; | |
| 71 case 3: | |
| 72 do_check_eq(rec.id, "one"); | |
| 73 do_check_eq(rec.uri(base).spec, "http://fake/uri/one"); | |
| 74 do_check_eq(rec.payload.value, 1); | |
| 75 do_check_eq(sum, 111); | |
| 76 break; | |
| 77 default: | |
| 78 do_throw("unexpected number of record counts", recCount); | |
| 79 break; | |
| 80 } | |
| 81 }; | |
| 82 coll._onProgress.call(stream); | |
| 83 do_check_eq(recCount, 3); | |
| 84 do_check_eq(sum, 111); | |
| 85 do_check_eq(stream._data, ''); | |
| 86 do_check_true(called); | |
| 87 _("\n"); | |
| 88 | |
| 89 | |
| 90 _("Handle incremental data incoming"); | |
| 91 called = false; | |
| 92 recCount = 0; | |
| 93 sum = 0; | |
| 94 stream._data = '{"payl'; | |
| 95 coll.recordHandler = function(rec) { | |
| 96 called = true; | |
| 97 do_throw("shouldn't have gotten a record.."); | |
| 98 }; | |
| 99 coll._onProgress.call(stream); | |
| 100 _("shouldn't have gotten anything yet"); | |
| 101 do_check_eq(recCount, 0); | |
| 102 do_check_eq(sum, 0); | |
| 103 _("leading array bracket should have been trimmed"); | |
| 104 do_check_eq(stream._data, '{"payl'); | |
| 105 do_check_false(called); | |
| 106 _(); | |
| 107 | |
| 108 _("adding more data enough for one record.."); | |
| 109 called = false; | |
| 110 stream._data += 'oad":"{\\"value\\":100}"}\n'; | |
| 111 coll.recordHandler = function(rec) { | |
| 112 called = true; | |
| 113 _("Got record:", JSON.stringify(rec)); | |
| 114 recCount++; | |
| 115 sum += rec.payload.value; | |
| 116 }; | |
| 117 coll._onProgress.call(stream); | |
| 118 _("should have 1 record with sum 100"); | |
| 119 do_check_eq(recCount, 1); | |
| 120 do_check_eq(sum, 100); | |
| 121 _("all data should have been consumed including trailing comma"); | |
| 122 do_check_eq(stream._data, ''); | |
| 123 do_check_true(called); | |
| 124 _(); | |
| 125 | |
| 126 _("adding more data.."); | |
| 127 called = false; | |
| 128 stream._data += '{"payload":"{\\"value\\":10}"'; | |
| 129 coll.recordHandler = function(rec) { | |
| 130 called = true; | |
| 131 do_throw("shouldn't have gotten a record.."); | |
| 132 }; | |
| 133 coll._onProgress.call(stream); | |
| 134 _("should still have 1 record with sum 100"); | |
| 135 do_check_eq(recCount, 1); | |
| 136 do_check_eq(sum, 100); | |
| 137 _("should almost have a record"); | |
| 138 do_check_eq(stream._data, '{"payload":"{\\"value\\":10}"'); | |
| 139 do_check_false(called); | |
| 140 _(); | |
| 141 | |
| 142 _("add data for two records.."); | |
| 143 called = false; | |
| 144 stream._data += '}\n{"payload":"{\\"value\\":1}"}\n'; | |
| 145 coll.recordHandler = function(rec) { | |
| 146 called = true; | |
| 147 _("Got record:", JSON.stringify(rec)); | |
| 148 recCount++; | |
| 149 sum += rec.payload.value; | |
| 150 switch (recCount) { | |
| 151 case 2: | |
| 152 do_check_eq(rec.payload.value, 10); | |
| 153 do_check_eq(sum, 110); | |
| 154 break; | |
| 155 case 3: | |
| 156 do_check_eq(rec.payload.value, 1); | |
| 157 do_check_eq(sum, 111); | |
| 158 break; | |
| 159 default: | |
| 160 do_throw("unexpected number of record counts", recCount); | |
| 161 break; | |
| 162 } | |
| 163 }; | |
| 164 coll._onProgress.call(stream); | |
| 165 _("should have gotten all 3 records with sum 111"); | |
| 166 do_check_eq(recCount, 3); | |
| 167 do_check_eq(sum, 111); | |
| 168 _("should have consumed all data"); | |
| 169 do_check_eq(stream._data, ''); | |
| 170 do_check_true(called); | |
| 171 _(); | |
| 172 | |
| 173 _("add no extra data"); | |
| 174 called = false; | |
| 175 stream._data += ''; | |
| 176 coll.recordHandler = function(rec) { | |
| 177 called = true; | |
| 178 do_throw("shouldn't have gotten a record.."); | |
| 179 }; | |
| 180 coll._onProgress.call(stream); | |
| 181 _("should still have 3 records with sum 111"); | |
| 182 do_check_eq(recCount, 3); | |
| 183 do_check_eq(sum, 111); | |
| 184 _("should have consumed nothing but still have nothing"); | |
| 185 do_check_eq(stream._data, ""); | |
| 186 do_check_false(called); | |
| 187 _("\n"); | |
| 188 } |
