Dart Bindings: ApplicationConnection

mojo/public/dart/src/application.dart

 // Copyright 2014 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 part of application;
 
 class _ApplicationImpl extends application_mojom.Application {
   shell_mojom.ShellProxy shell;
   Application _application;
 
   _ApplicationImpl(
       Application application, core.MojoMessagePipeEndpoint endpoint)
       : _application = application, super(endpoint) {
     super.delegate = this;
   }
 
   _ApplicationImpl.fromHandle(Application application, core.MojoHandle handle)
       : _application = application, super.fromHandle(handle) {
     super.delegate = this;
   }
 
-  void initialize(shell_mojom.ShellProxy shellProxy,
-                  List<String> args,
-                  String url) {
+  void initialize(
+      shell_mojom.ShellProxy shellProxy, List<String> args, String url) {
     assert(shell == null);
     shell = shellProxy;
     _application.initialize(args, url);
   }
 
   void acceptConnection(
       String requestorUrl,
-      service_provider.ServiceProviderStub services,
-      service_provider.ServiceProviderProxy exposedServices) =>
+      ServiceProviderStub services,
+      ServiceProviderProxy exposedServices) =>
       _application._acceptConnection(requestorUrl, services, exposedServices);
 
   void requestQuit() => _application._requestQuitAndClose();
 
   void close({bool nodefer: false}) => shell.close();
 }
 
-// ApplicationConnection represents a single outgoing connection to another app.
-class ApplicationConnection {
-  // ServiceProvider used to obtain services from the remote application.
-  service_provider.ServiceProviderProxy serviceProvider;
-
-  ApplicationConnection(this.serviceProvider);
-
-  // Obtains a service from the remote application.
-  void connectToService(bindings.Proxy proxy) {
-    assert(!proxy.isBound);
-    var applicationPipe = new core.MojoMessagePipe();
-    var proxyEndpoint = applicationPipe.endpoints[0];
-    var applicationEndpoint = applicationPipe.endpoints[1];
-    proxy.bind(proxyEndpoint);
-    serviceProvider.connectToService(proxy.name, applicationEndpoint);
-  }
-}
-
 // TODO(zra): Better documentation and examples.
 // To implement, do the following:
 // - Optionally override acceptConnection() if services are to be provided.

[zra, 2015/02/18 21:45:33]

It looks like this comment is out of date now. Should we keep both this and the
comment above acceptConnection? Maybe just one of them is enough.  I kind of
like this comment up here as guidance for folks who are implementing an app, but
I don't have my heart set on it.

[hansmuller1, 2015/02/18 22:07:24]

I revised the comment and removed the part about "using" an Application.  I'm
not entirely sure what that paragraph was getting at; I thought that the
ApplicationConnection class comment covered the same area.

 //   The override should configure the supplied ServiceProvider and call
 //   listen(). See ServiceProvider for details on how to configure it.
 // - Optionally override initialize() where needed.
 // - Optionally override requestClose() to clean up state specific to your
 //   application.
 // To use an Application:
 // - Call listen() on a newly created Application to begin providing services.
 // - Call connectToService() to request services from the Shell.
 // - Call close() to close connections to any requested ServiceProviders and the
 //   Shell.
 abstract class Application {
   _ApplicationImpl _applicationImpl;
   List<ApplicationConnection> _applicationConnections;
-  List<ServiceProvider> _serviceProviders;
 
   Application(core.MojoMessagePipeEndpoint endpoint) {
     _applicationConnections = [];
-    _serviceProviders = [];
     _applicationImpl = new _ApplicationImpl(this, endpoint);
   }
 
   Application.fromHandle(core.MojoHandle appHandle) {
     _applicationConnections = [];
-    _serviceProviders = [];
     _applicationImpl = new _ApplicationImpl.fromHandle(this, appHandle);
   }
 
   void initialize(List<String> args, String url) {}
 
   // TODO(skydart): This is a temporary fix to allow sky application to consume
   // mojo services. Do not use for any other purpose.
   void initializeFromShellProxy(shell_mojom.ShellProxy shellProxy,
       List<String> args, String url) {
     _applicationImpl.initialize(shellProxy, args, url);
   }
 
-  // Establishes a connection to the app at |url|.
+  // Returns a connection to the app at |url|.
   ApplicationConnection connectToApplication(String url) {
-    var serviceProviderProxy =
-        new service_provider.ServiceProviderProxy.unbound();
-    // TODO: Need to expose ServiceProvider for local services.
-    _applicationImpl.shell.connectToApplication(
-        url, serviceProviderProxy, null);
-    var applicationConnection = new ApplicationConnection(serviceProviderProxy);
-    _applicationConnections.add(applicationConnection);
-    return applicationConnection;
+    var proxy = new ServiceProviderProxy.unbound();
+    var stub = new ServiceProviderStub.unbound();
+    _applicationImpl.shell.connectToApplication(url, proxy, stub);
+    var connection = new ApplicationConnection(stub, proxy);
+    _applicationConnections.add(connection);
+    return connection;
   }
 
   void connectToService(String url, bindings.Proxy proxy) {
-    connectToApplication(url).connectToService(proxy);
+    connectToApplication(url).requestService(proxy);
   }
 
   void requestQuit() {}
 
   listen() => _applicationImpl.listen();
 
   void _requestQuitAndClose() {
     requestQuit();
     close();
   }
 
   void close() {
     assert(_applicationImpl != null);
-    _applicationConnections.forEach((c) => c.serviceProvider.close());
+    _applicationConnections.forEach((c) => c.close());
     _applicationConnections.clear();
-    _serviceProviders.forEach((sp) => sp.close());
-    _serviceProviders.clear();
     _applicationImpl.close();
   }
 
   void _acceptConnection(
       String requestorUrl,
-      service_provider.ServiceProviderStub services,
-      service_provider.ServiceProviderProxy exposedServices) {
-    var serviceProvider = new ServiceProvider(services, exposedServices);
-    _serviceProviders.add(serviceProvider);
-    acceptConnection(requestorUrl, serviceProvider);
+      ServiceProviderStub services,
+      ServiceProviderProxy exposedServices) {
+    var connection = new ApplicationConnection(services, exposedServices);
+    _applicationConnections.add(connection);
+    acceptConnection(requestorUrl, connection);
   }
 
-  // Override to register the necessary set of interface on |serviceProvider|.
-  // If you register at least one interface (or set the fallback), then you
-  // must invoke serviceProvider.listen().
-  void acceptConnection(String requestorUrl, ServiceProvider serviceProvider) {}
+  // Override this method to provide services on |connection|.
+  // If you provide at least one service or set fallbackServiceProvider,
+  // then you must invoke connection.listen().
+  void acceptConnection(String requestorUrl, ApplicationConnection connection) {}

[zra, 2015/02/18 21:45:33]

This curly brace looks out of place.

[hansmuller1, 2015/02/18 22:07:24]

Another long line. Fixed.

 }