Index: tests/html/xhr_task2_test.dart |
diff --git a/tests/html/xhr_task2_test.dart b/tests/html/xhr_task2_test.dart |
deleted file mode 100644 |
index 6dee69e984547e5aa31b36f9776db19e7541d197..0000000000000000000000000000000000000000 |
--- a/tests/html/xhr_task2_test.dart |
+++ /dev/null |
@@ -1,280 +0,0 @@ |
-// Copyright (c) 2016, 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. |
- |
-library XHRTask2Test; |
- |
-import 'dart:async'; |
-import 'dart:convert'; |
-import 'dart:html'; |
-import 'dart:typed_data'; |
-import 'package:unittest/html_individual_config.dart'; |
-import 'package:unittest/unittest.dart'; |
- |
-class MockProgressEvent implements ProgressEvent { |
- final target; |
- MockProgressEvent(this.target); |
- |
- noSuchMethod(Invocation invocation) { |
- throw "missing function in MockProgressEvent"; |
- } |
-} |
- |
-class MockHttpRequestTask implements Future<HttpRequest> { |
- final Completer completer = new Completer<HttpRequest>(); |
- final HttpRequestTaskSpecification spec; |
- final Zone zone; |
- |
- MockHttpRequestTask(this.spec, this.zone); |
- |
- void trigger(response) { |
- var xhr = new MockHttpRequest(spec, response); |
- var arg; |
- if (spec.url == "NonExistingFile") { |
- arg = new MockProgressEvent(xhr); |
- } else { |
- arg = xhr; |
- } |
- zone.runTask(run, this, arg); |
- } |
- |
- then(onData, {onError}) => completer.future.then(onData, onError: onError); |
- catchError(f, {test}) => completer.future.catchError(f, test: test); |
- whenComplete(f) => completer.future.whenComplete(f); |
- asStream() => completer.future.asStream(); |
- timeout(timeLimit, {onTimeout}) => |
- completer.future.timeout(timeLimit, onTimeout: onTimeout); |
- |
- static create(HttpRequestTaskSpecification spec, Zone zone) { |
- return new MockHttpRequestTask(spec, zone); |
- } |
- |
- static run(MockHttpRequestTask task, value) { |
- if (value is HttpRequest) { |
- task.completer.complete(value); |
- } else { |
- task.completer.completeError(value); |
- } |
- } |
-} |
- |
-class MockHttpRequest implements HttpRequest { |
- final HttpRequestTaskSpecification spec; |
- final response; |
- |
- MockHttpRequest(this.spec, this.response); |
- |
- noSuchMethod(Invocation invocation) { |
- print("isGetter: ${invocation.isGetter}"); |
- print("isMethod: ${invocation.isMethod}"); |
- print("memberName: ${invocation.memberName}"); |
- } |
- |
- int get status => spec.url == "NonExistingFile" ? 404 : 200; |
- |
- get readyState => HttpRequest.DONE; |
- get responseText => "$response"; |
- |
- Map get responseHeaders => {'content-type': 'text/plain; charset=utf-8',}; |
-} |
- |
-main() { |
- useHtmlIndividualConfiguration(); |
- unittestConfiguration.timeout = const Duration(milliseconds: 800); |
- |
- var urlExpando = new Expando(); |
- |
- var url = 'some/url.html'; |
- |
- Function buildCreateTaskHandler(List log, List tasks) { |
- Object createTaskHandler(Zone self, ZoneDelegate parent, Zone zone, |
- TaskCreate create, TaskSpecification spec) { |
- if (spec is HttpRequestTaskSpecification) { |
- var url = spec.url; |
- var method = spec.method; |
- var withCredentials = spec.withCredentials; |
- var responseType = spec.responseType; |
- var mimeType = spec.mimeType; |
- var data = spec.sendData; |
- |
- log.add("request $url"); |
- var dataLog = data is List<int> ? "binary ${data.length}" : "$data"; |
- log.add(" method: $method withCredentials: $withCredentials " |
- "responseType: $responseType mimeType: $mimeType data: $dataLog"); |
- var task = parent.createTask(zone, MockHttpRequestTask.create, spec); |
- urlExpando[task] = url; |
- tasks.add(task); |
- return task; |
- } |
- if (spec is EventSubscriptionSpecification) { |
- EventSubscriptionSpecification eventSpec = spec; |
- if (eventSpec.target is HttpRequest) { |
- HttpRequest target = eventSpec.target; |
- log.add("event listener on http-request ${eventSpec.eventType}"); |
- if (eventSpec.eventType == "readystatechange") { |
- var oldOnData = eventSpec.onData; |
- spec = eventSpec.replace(onData: (event) { |
- oldOnData(event); |
- if (target.readyState == HttpRequest.DONE) { |
- log.add("unknown request done"); |
- } |
- }); |
- } |
- } |
- } |
- return parent.createTask(zone, create, spec); |
- } |
- |
- return createTaskHandler; |
- } |
- |
- Function buildRunTaskHandler(List log, List tasks) { |
- void runTaskHandler(Zone self, ZoneDelegate parent, Zone zone, TaskRun run, |
- Object task, Object arg) { |
- if (tasks.contains(task)) { |
- var url = urlExpando[task]; |
- if (arg is Error || arg is Exception) { |
- log.add("failed $url"); |
- } else { |
- if (arg is ProgressEvent) { |
- log.add("success $url with progress-event"); |
- } else if (arg is HttpRequest) { |
- log.add("success $url with http-request"); |
- } else { |
- log.add("success $url (unknown arg)"); |
- } |
- } |
- } |
- parent.runTask(zone, run, task, arg); |
- } |
- |
- return runTaskHandler; |
- } |
- |
- Future<List> runMocked(response, fun) async { |
- var log = []; |
- var tasks = []; |
- var future = runZoned(fun, |
- zoneSpecification: new ZoneSpecification( |
- createTask: buildCreateTaskHandler(log, tasks), |
- runTask: buildRunTaskHandler(log, tasks))); |
- // Wait a full cycle to make sure things settle. |
- await new Future(() {}); |
- var beforeTriggerLog = log.toList(); |
- log.clear(); |
- expect(tasks.length, 1); |
- tasks.single.trigger(response); |
- await future; |
- return [beforeTriggerLog, log]; |
- } |
- |
- void validate200Response(xhr) { |
- expect(xhr.status, equals(200)); |
- var data = JSON.decode(xhr.responseText); |
- expect(data, contains('feed')); |
- expect(data['feed'], contains('entry')); |
- expect(data, isMap); |
- } |
- |
- void validate404(xhr) { |
- expect(xhr.status, equals(404)); |
- // We cannot say much about xhr.responseText, most HTTP servers will |
- // include an HTML page explaining the error to a human. |
- String responseText = xhr.responseText; |
- expect(responseText, isNotNull); |
- } |
- |
- group('xhr', () { |
- test('XHR.request No file', () async { |
- var log = await runMocked("404", () { |
- var completer = new Completer(); |
- HttpRequest.request('NonExistingFile').then((_) { |
- fail('Request should not have succeeded.'); |
- }, onError: expectAsync((error) { |
- var xhr = error.target; |
- expect(xhr.readyState, equals(HttpRequest.DONE)); |
- validate404(xhr); |
- completer.complete('done'); |
- })); |
- return completer.future; |
- }); |
- expect( |
- log, |
- equals([ |
- [ |
- 'request NonExistingFile', |
- ' method: null withCredentials: null responseType: null ' |
- 'mimeType: null data: null', |
- ], |
- ['success NonExistingFile with progress-event'] |
- ])); |
- }); |
- |
- test('XHR.request file', () async { |
- var log = await runMocked('{"feed": {"entry": 499}}', () { |
- var completer = new Completer(); |
- HttpRequest.request(url).then(expectAsync((xhr) { |
- expect(xhr.readyState, equals(HttpRequest.DONE)); |
- validate200Response(xhr); |
- completer.complete('done'); |
- })); |
- return completer.future; |
- }); |
- expect( |
- log, |
- equals([ |
- [ |
- 'request $url', |
- ' method: null withCredentials: null responseType: null ' |
- 'mimeType: null data: null' |
- ], |
- ['success $url with http-request'] |
- ])); |
- }); |
- |
- test('XHR.getString file', () async { |
- var log = await runMocked("foo", () { |
- return HttpRequest.getString(url).then(expectAsync((str) {})); |
- }); |
- expect( |
- log, |
- equals([ |
- [ |
- 'request $url', |
- ' method: null withCredentials: null responseType: null ' |
- 'mimeType: null data: null' |
- ], |
- ['success $url with http-request'] |
- ])); |
- }); |
- |
- test('XHR.request responseType arraybuffer', () async { |
- if (Platform.supportsTypedData) { |
- var data = new Uint8List(128); |
- var log = await runMocked(data.buffer, () { |
- return HttpRequest.request(url, |
- responseType: 'arraybuffer', |
- requestHeaders: { |
- 'Content-Type': 'text/xml' |
- }).then(expectAsync((xhr) { |
- expect(xhr.status, equals(200)); |
- var byteBuffer = xhr.response; |
- expect(byteBuffer, new isInstanceOf<ByteBuffer>()); |
- expect(byteBuffer, isNotNull); |
- })); |
- }); |
- expect( |
- log, |
- equals([ |
- [ |
- 'request $url', |
- ' method: null withCredentials: null responseType: arraybuffer' |
- ' mimeType: null data: null' |
- ], |
- ['success $url with http-request'] |
- ])); |
- } |
- ; |
- }); |
- }); |
-} |