OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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 part of application; | 5 part of application; |
6 | 6 |
7 class _ApplicationImpl extends application_mojom.Application { | 7 class _ApplicationImpl implements application_mojom.Application { |
| 8 application_mojom.ApplicationStub _stub; |
8 shell_mojom.ShellProxy shell; | 9 shell_mojom.ShellProxy shell; |
9 Application _application; | 10 Application _application; |
10 | 11 |
11 _ApplicationImpl( | 12 _ApplicationImpl(Application application, |
12 Application application, core.MojoMessagePipeEndpoint endpoint) | 13 core.MojoMessagePipeEndpoint endpoint) { |
13 : _application = application, super(endpoint) { | 14 _application = application; |
14 super.delegate = this; | 15 _stub = new application_mojom.ApplicationStub.fromEndpoint(endpoint) |
| 16 ..delegate = this |
| 17 ..listen(); |
15 } | 18 } |
16 | 19 |
17 _ApplicationImpl.fromHandle(Application application, core.MojoHandle handle) | 20 _ApplicationImpl.fromHandle(Application application, core.MojoHandle handle) { |
18 : _application = application, super.fromHandle(handle) { | 21 _application = application; |
19 super.delegate = this; | 22 _stub = new application_mojom.ApplicationStub.fromHandle(handle) |
| 23 ..delegate = this |
| 24 ..listen(); |
20 } | 25 } |
21 | 26 |
22 void initialize( | 27 void initialize(bindings.Proxy shellProxy, List<String> args, String url) { |
23 shell_mojom.ShellProxy shellProxy, List<String> args, String url) { | |
24 assert(shell == null); | 28 assert(shell == null); |
25 shell = shellProxy; | 29 shell = new shell_mojom.ShellProxy(shellProxy); |
26 _application.initialize(args, url); | 30 _application.initialize(args, url); |
27 } | 31 } |
28 | 32 |
29 void acceptConnection( | 33 void acceptConnection(String requestorUrl, |
30 String requestorUrl, | 34 ServiceProviderStub services, |
31 ServiceProviderStub services, | 35 bindings.Proxy exposedServices) { |
32 ServiceProviderProxy exposedServices) => | 36 var serviceProviderProxy = exposedServices == null |
33 _application._acceptConnection(requestorUrl, services, exposedServices); | 37 ? null : new ServiceProviderProxy(exposedServices); |
| 38 _application._acceptConnection( |
| 39 requestorUrl, services, serviceProviderProxy); |
| 40 } |
34 | 41 |
35 void requestQuit() => _application._requestQuitAndClose(); | 42 void requestQuit() => _application._requestQuitAndClose(); |
36 | 43 |
37 void close({bool nodefer: false}) => shell.close(); | 44 void close({bool nodefer: false}) => |
| 45 shell_mojom.ShellProxyClose(shell); |
38 } | 46 } |
39 | 47 |
40 // TODO(zra): Better documentation and examples. | 48 // TODO(zra): Better documentation and examples. |
41 // To implement, do the following: | 49 // To implement, do the following: |
42 // - Optionally override initialize() to process command-line args. | 50 // - Optionally override initialize() to process command-line args. |
43 // - Optionally override acceptConnection() if services are to be provided. | 51 // - Optionally override acceptConnection() if services are to be provided. |
44 // - Optionally override close() to clean up application resources. | 52 // - Optionally override close() to clean up application resources. |
45 abstract class Application { | 53 abstract class Application { |
46 _ApplicationImpl _applicationImpl; | 54 _ApplicationImpl _applicationImpl; |
47 List<ApplicationConnection> _applicationConnections; | 55 List<ApplicationConnection> _applicationConnections; |
48 | 56 |
49 Application(core.MojoMessagePipeEndpoint endpoint) { | 57 Application(core.MojoMessagePipeEndpoint endpoint) { |
50 _applicationConnections = []; | 58 _applicationConnections = []; |
51 _applicationImpl = new _ApplicationImpl(this, endpoint); | 59 _applicationImpl = new _ApplicationImpl(this, endpoint); |
52 } | 60 } |
53 | 61 |
54 Application.fromHandle(core.MojoHandle appHandle) { | 62 Application.fromHandle(core.MojoHandle appHandle) { |
55 _applicationConnections = []; | 63 _applicationConnections = []; |
56 _applicationImpl = new _ApplicationImpl.fromHandle(this, appHandle); | 64 _applicationImpl = new _ApplicationImpl.fromHandle(this, appHandle); |
57 } | 65 } |
58 | 66 |
59 void initialize(List<String> args, String url) {} | 67 void initialize(List<String> args, String url) {} |
60 | 68 |
61 // TODO(skydart): This is a temporary fix to allow sky application to consume | 69 // TODO(skydart): This is a temporary fix to allow sky application to consume |
62 // mojo services. Do not use for any other purpose. | 70 // mojo services. Do not use for any other purpose. |
63 void initializeFromShellProxy(shell_mojom.ShellProxy shellProxy, | 71 void initializeFromShellProxy(shell_mojom.ShellProxy shellProxy, |
64 List<String> args, String url) { | 72 List<String> args, String url) { |
65 _applicationImpl.initialize(shellProxy, args, url); | 73 _applicationImpl.initialize( |
| 74 shell_mojom.ShellGetProxyImpl(shellProxy), args, url); |
66 } | 75 } |
67 | 76 |
68 // Returns a connection to the app at |url|. | 77 // Returns a connection to the app at |url|. |
69 ApplicationConnection connectToApplication(String url) { | 78 ApplicationConnection connectToApplication(String url) { |
70 var proxy = new ServiceProviderProxy.unbound(); | 79 var proxy = new ServiceProviderProxy.unbound(); |
71 var stub = new ServiceProviderStub.unbound(); | 80 var stub = new ServiceProviderStub.unbound(); |
72 _applicationImpl.shell.connectToApplication(url, proxy, stub); | 81 _applicationImpl.shell.connectToApplication( |
| 82 url, ServiceProviderRequest(proxy), stub); |
73 var connection = new ApplicationConnection(stub, proxy); | 83 var connection = new ApplicationConnection(stub, proxy); |
74 _applicationConnections.add(connection); | 84 _applicationConnections.add(connection); |
75 return connection; | 85 return connection; |
76 } | 86 } |
77 | 87 |
78 void connectToService(String url, bindings.Proxy proxy) { | 88 void connectToService(String url, bindings.Proxy proxy) { |
79 connectToApplication(url).requestService(proxy); | 89 connectToApplication(url).requestService(proxy); |
80 } | 90 } |
81 | 91 |
82 void requestQuit() {} | 92 void requestQuit() {} |
83 | 93 |
84 listen() => _applicationImpl.listen(); | |
85 | |
86 void _requestQuitAndClose() { | 94 void _requestQuitAndClose() { |
87 requestQuit(); | 95 requestQuit(); |
88 close(); | 96 close(); |
89 } | 97 } |
90 | 98 |
91 void close() { | 99 void close() { |
92 assert(_applicationImpl != null); | 100 assert(_applicationImpl != null); |
93 _applicationConnections.forEach((c) => c.close()); | 101 _applicationConnections.forEach((c) => c.close()); |
94 _applicationConnections.clear(); | 102 _applicationConnections.clear(); |
95 _applicationImpl.close(); | 103 _applicationImpl.close(); |
96 } | 104 } |
97 | 105 |
98 void _acceptConnection( | 106 void _acceptConnection( |
99 String requestorUrl, | 107 String requestorUrl, |
100 ServiceProviderStub services, | 108 ServiceProviderStub services, |
101 ServiceProviderProxy exposedServices) { | 109 ServiceProviderProxy exposedServices) { |
102 var connection = new ApplicationConnection(services, exposedServices); | 110 var connection = new ApplicationConnection(services, exposedServices); |
103 _applicationConnections.add(connection); | 111 _applicationConnections.add(connection); |
104 acceptConnection(requestorUrl, connection); | 112 acceptConnection(requestorUrl, connection); |
105 } | 113 } |
106 | 114 |
107 // Override this method to provide services on |connection|. | 115 // Override this method to provide services on |connection|. |
108 // If you provide at least one service or set fallbackServiceProvider, | 116 // If you provide at least one service or set fallbackServiceProvider, |
109 // then you must invoke connection.listen(). | 117 // then you must invoke connection.listen(). |
110 void acceptConnection(String requestorUrl, ApplicationConnection connection) { | 118 void acceptConnection(String requestorUrl, ApplicationConnection connection) { |
111 } | 119 } |
112 } | 120 } |
OLD | NEW |