| // 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'] |
| ])); |
| } |
| ; |
| }); |
| }); |
| } |