| OLD | NEW |
| 1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 library pingpong_apptests; | 5 library pingpong_apptests; |
| 6 | 6 |
| 7 import 'dart:async'; | 7 import 'dart:async'; |
| 8 | 8 |
| 9 import 'package:mojo_apptest/apptest.dart'; | 9 import 'package:mojo_apptest/apptest.dart'; |
| 10 import 'package:mojo/application.dart'; | 10 import 'package:mojo/application.dart'; |
| 11 import 'package:mojo/bindings.dart'; | 11 import 'package:mojo/bindings.dart'; |
| 12 import 'package:mojo/core.dart'; | 12 import 'package:mojo/core.dart'; |
| 13 import 'package:_mojo_for_test_only/test/pingpong_service.mojom.dart'; | 13 import 'package:_mojo_for_test_only/test/pingpong_service.mojom.dart'; |
| 14 | 14 |
| 15 class _TestingPingPongClient extends PingPongClient { | 15 class _TestingPingPongClient extends PingPongClient { |
| 16 final PingPongClientStub stub; | 16 PingPongClientInterface client; |
| 17 Completer _completer; | 17 Completer _completer; |
| 18 | 18 |
| 19 _TestingPingPongClient.unbound() : stub = new PingPongClientStub.unbound() { | 19 _TestingPingPongClient() { |
| 20 stub.impl = this; | 20 client = new PingPongClientInterface(this); |
| 21 } | 21 } |
| 22 | 22 |
| 23 waitForPong() async { | 23 waitForPong() async { |
| 24 _completer = new Completer(); | 24 _completer = new Completer(); |
| 25 return _completer.future; | 25 return _completer.future; |
| 26 } | 26 } |
| 27 | 27 |
| 28 void pong(int pongValue) { | 28 void pong(int pongValue) { |
| 29 _completer.complete(pongValue); | 29 _completer.complete(pongValue); |
| 30 _completer = null; | 30 _completer = null; |
| 31 } | 31 } |
| 32 } | 32 } |
| 33 | 33 |
| 34 pingpongApptests(Application application, String url) { | 34 pingpongApptests(Application application, String url) { |
| 35 group('Ping-Pong Service Apptests', () { | 35 group('Ping-Pong Service Apptests', () { |
| 36 // Verify that "pingpong.dart" implements the PingPongService interface | 36 // Verify that "pingpong.dart" implements the PingPongService interface |
| 37 // and sends responses to our client. | 37 // and sends responses to our client. |
| 38 test('Ping Service To Pong Client', () async { | 38 test('Ping Service To Pong Client', () async { |
| 39 var pingPongServiceProxy = new PingPongServiceProxy.unbound(); | 39 var pingPongService = new PingPongServiceInterfaceRequest(); |
| 40 pingPongServiceProxy.ctrl.errorFuture.then((e) => fail('$e')); | 40 pingPongService.ctrl.errorFuture.then((e) => fail('$e')); |
| 41 application.connectToService( | 41 application.connectToService("mojo:dart_pingpong", pingPongService); |
| 42 "mojo:dart_pingpong", pingPongServiceProxy); | |
| 43 | 42 |
| 44 var pingPongClient = new _TestingPingPongClient.unbound(); | 43 var pingPongClient = new _TestingPingPongClient(); |
| 45 pingPongServiceProxy.setClient(pingPongClient.stub); | 44 pingPongService.setClient(pingPongClient.client); |
| 46 | 45 |
| 47 pingPongServiceProxy.ping(1); | 46 pingPongService.ping(1); |
| 48 var pongValue = await pingPongClient.waitForPong(); | 47 var pongValue = await pingPongClient.waitForPong(); |
| 49 expect(pongValue, equals(2)); | 48 expect(pongValue, equals(2)); |
| 50 | 49 |
| 51 pingPongServiceProxy.ping(100); | 50 pingPongService.ping(100); |
| 52 pongValue = await pingPongClient.waitForPong(); | 51 pongValue = await pingPongClient.waitForPong(); |
| 53 expect(pongValue, equals(101)); | 52 expect(pongValue, equals(101)); |
| 54 | 53 |
| 55 await pingPongClient.stub.close(); | 54 await pingPongClient.client.close(); |
| 56 await pingPongServiceProxy.close(); | 55 await pingPongService.close(); |
| 57 }); | 56 }); |
| 58 | 57 |
| 59 // Verify that "pingpong.dart" can connect to "pingpong_target.dart", act as | 58 // Verify that "pingpong.dart" can connect to "pingpong_target.dart", act as |
| 60 // its client, and return a Future that only resolves after the | 59 // its client, and return a Future that only resolves after the |
| 61 // target.ping() => client.pong() methods have executed 9 times. | 60 // target.ping() => client.pong() methods have executed 9 times. |
| 62 test('Ping Target URL', () async { | 61 test('Ping Target URL', () async { |
| 63 var pingPongServiceProxy = new PingPongServiceProxy.unbound(); | 62 var pingPongService = new PingPongServiceInterfaceRequest(); |
| 64 pingPongServiceProxy.ctrl.errorFuture.then((e) => fail('$e')); | 63 pingPongService.ctrl.errorFuture.then((e) => fail('$e')); |
| 65 application.connectToService( | 64 application.connectToService("mojo:dart_pingpong", pingPongService); |
| 66 "mojo:dart_pingpong", pingPongServiceProxy); | |
| 67 | 65 |
| 68 var r = await pingPongServiceProxy.pingTargetUrl( | 66 var r = await pingPongService.pingTargetUrl( |
| 69 "mojo:dart_pingpong_target", 9); | 67 "mojo:dart_pingpong_target", 9); |
| 70 expect(r.ok, equals(true)); | 68 expect(r.ok, equals(true)); |
| 71 | 69 |
| 72 await pingPongServiceProxy.close(); | 70 await pingPongService.close(); |
| 73 }); | 71 }); |
| 74 | 72 |
| 75 // Same as the previous test except that instead of providing the | 73 // Same as the previous test except that instead of providing the |
| 76 // pingpong_target.dart URL, we provide a connection to its PingPongService. | 74 // pingpong_target.dart URL, we provide a connection to its PingPongService. |
| 77 test('Ping Target Service', () async { | 75 test('Ping Target Service', () async { |
| 78 var pingPongServiceProxy = new PingPongServiceProxy.unbound(); | 76 var pingPongService = new PingPongServiceInterfaceRequest(); |
| 79 pingPongServiceProxy.ctrl.errorFuture.then((e) => fail('$e')); | 77 pingPongService.ctrl.errorFuture.then((e) => fail('$e')); |
| 80 application.connectToService( | 78 application.connectToService("mojo:dart_pingpong", pingPongService); |
| 81 "mojo:dart_pingpong", pingPongServiceProxy); | |
| 82 | 79 |
| 83 var targetServiceProxy = new PingPongServiceProxy.unbound(); | 80 var targetService = new PingPongServiceInterfaceRequest(); |
| 84 targetServiceProxy.ctrl.errorFuture.then((e) => fail('$e')); | 81 targetService.ctrl.errorFuture.then((e) => fail('$e')); |
| 85 application.connectToService( | 82 application.connectToService("mojo:dart_pingpong_target", targetService); |
| 86 "mojo:dart_pingpong_target", targetServiceProxy); | |
| 87 | 83 |
| 88 var r = await pingPongServiceProxy.pingTargetService( | 84 var r = await pingPongService.pingTargetService(targetService, 9); |
| 89 targetServiceProxy, 9); | |
| 90 expect(r.ok, equals(true)); | 85 expect(r.ok, equals(true)); |
| 91 // This side no longer has access to the pipe. | 86 // This side no longer has access to the pipe. |
| 92 expect(targetServiceProxy.ctrl.isOpen, equals(false)); | 87 expect(targetService.ctrl.isOpen, equals(false)); |
| 93 expect(targetServiceProxy.ctrl.isBound, equals(false)); | 88 expect(targetService.ctrl.isBound, equals(false)); |
| 94 | 89 |
| 95 await pingPongServiceProxy.close(); | 90 await pingPongService.close(); |
| 96 }); | 91 }); |
| 97 | 92 |
| 98 // Verify that Dart can implement an interface "request" parameter. | 93 // Verify that Dart can implement an interface "request" parameter. |
| 99 test('Get Target Service', () async { | 94 test('Get Target Service', () async { |
| 100 var pingPongServiceProxy = new PingPongServiceProxy.unbound(); | 95 var pingPongService = new PingPongServiceInterfaceRequest(); |
| 101 pingPongServiceProxy.ctrl.errorFuture.then((e) => fail('$e')); | 96 pingPongService.ctrl.errorFuture.then((e) => fail('$e')); |
| 102 application.connectToService( | 97 application.connectToService("mojo:dart_pingpong", pingPongService); |
| 103 "mojo:dart_pingpong", pingPongServiceProxy); | |
| 104 | 98 |
| 105 var targetServiceProxy = new PingPongServiceProxy.unbound(); | 99 var targetService = new PingPongServiceInterfaceRequest(); |
| 106 targetServiceProxy.ctrl.errorFuture.then((e) => fail('$e')); | 100 targetService.ctrl.errorFuture.then((e) => fail('$e')); |
| 107 pingPongServiceProxy.getPingPongService(targetServiceProxy); | 101 pingPongService.getPingPongService(targetService); |
| 108 | 102 |
| 109 var pingPongClient = new _TestingPingPongClient.unbound(); | 103 var pingPongClient = new _TestingPingPongClient(); |
| 110 targetServiceProxy.setClient(pingPongClient.stub); | 104 targetService.setClient(pingPongClient.client); |
| 111 | 105 |
| 112 targetServiceProxy.ping(1); | 106 targetService.ping(1); |
| 113 var pongValue = await pingPongClient.waitForPong(); | 107 var pongValue = await pingPongClient.waitForPong(); |
| 114 expect(pongValue, equals(2)); | 108 expect(pongValue, equals(2)); |
| 115 | 109 |
| 116 targetServiceProxy.ping(100); | 110 targetService.ping(100); |
| 117 pongValue = await pingPongClient.waitForPong(); | 111 pongValue = await pingPongClient.waitForPong(); |
| 118 expect(pongValue, equals(101)); | 112 expect(pongValue, equals(101)); |
| 119 | 113 |
| 120 await pingPongClient.stub.close(); | 114 await pingPongClient.client.close(); |
| 121 await targetServiceProxy.close(); | 115 await targetService.close(); |
| 122 await pingPongServiceProxy.close(); | 116 await pingPongService.close(); |
| 123 }); | 117 }); |
| 124 | 118 |
| 125 // Verify that Dart can implement an interface "request" parameter that | 119 // Verify that Dart can implement an interface "request" parameter that |
| 126 // isn't hooked up to an actual service implementation until after some | 120 // isn't hooked up to an actual service implementation until after some |
| 127 // delay. | 121 // delay. |
| 128 test('Get Target Service Delayed', () async { | 122 test('Get Target Service Delayed', () async { |
| 129 var pingPongServiceProxy = new PingPongServiceProxy.unbound(); | 123 var pingPongService = new PingPongServiceInterfaceRequest(); |
| 130 pingPongServiceProxy.ctrl.errorFuture.then((e) => fail('$e')); | 124 pingPongService.ctrl.errorFuture.then((e) => fail('$e')); |
| 131 application.connectToService( | 125 application.connectToService("mojo:dart_pingpong", pingPongService); |
| 132 "mojo:dart_pingpong", pingPongServiceProxy); | |
| 133 | 126 |
| 134 var targetServiceProxy = new PingPongServiceProxy.unbound(); | 127 var targetService = new PingPongServiceInterfaceRequest(); |
| 135 targetServiceProxy.ctrl.errorFuture.then((e) => fail('$e')); | 128 targetService.ctrl.errorFuture.then((e) => fail('$e')); |
| 136 pingPongServiceProxy.getPingPongServiceDelayed(targetServiceProxy); | 129 pingPongService.getPingPongServiceDelayed(targetService); |
| 137 | 130 |
| 138 var pingPongClient = new _TestingPingPongClient.unbound(); | 131 var pingPongClient = new _TestingPingPongClient(); |
| 139 targetServiceProxy.setClient(pingPongClient.stub); | 132 targetService.setClient(pingPongClient.client); |
| 140 | 133 |
| 141 targetServiceProxy.ping(1); | 134 targetService.ping(1); |
| 142 var pongValue = await pingPongClient.waitForPong(); | 135 var pongValue = await pingPongClient.waitForPong(); |
| 143 expect(pongValue, equals(2)); | 136 expect(pongValue, equals(2)); |
| 144 | 137 |
| 145 targetServiceProxy.ping(100); | 138 targetService.ping(100); |
| 146 pongValue = await pingPongClient.waitForPong(); | 139 pongValue = await pingPongClient.waitForPong(); |
| 147 expect(pongValue, equals(101)); | 140 expect(pongValue, equals(101)); |
| 148 | 141 |
| 149 await pingPongClient.stub.close(); | 142 await pingPongClient.client.close(); |
| 150 await targetServiceProxy.close(); | 143 await targetService.close(); |
| 151 await pingPongServiceProxy.close(); | 144 await pingPongService.close(); |
| 152 }); | 145 }); |
| 153 }); | 146 }); |
| 154 } | 147 } |
| OLD | NEW |