| Index: mojo/public/js/connection.js
|
| diff --git a/mojo/public/js/connection.js b/mojo/public/js/connection.js
|
| deleted file mode 100644
|
| index 3976efd92c76c6c9b0c4de1009d79bd29d757774..0000000000000000000000000000000000000000
|
| --- a/mojo/public/js/connection.js
|
| +++ /dev/null
|
| @@ -1,125 +0,0 @@
|
| -// 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.
|
| -
|
| -define("mojo/public/js/connection", [
|
| - "mojo/public/js/bindings",
|
| - "mojo/public/js/connector",
|
| - "mojo/public/js/core",
|
| - "mojo/public/js/router",
|
| -], function(bindings, connector, core, router) {
|
| -
|
| - var Router = router.Router;
|
| - var EmptyProxy = bindings.EmptyProxy;
|
| - var EmptyStub = bindings.EmptyStub;
|
| - var ProxyBindings = bindings.ProxyBindings;
|
| - var StubBindings = bindings.StubBindings;
|
| - var TestConnector = connector.TestConnector;
|
| - var TestRouter = router.TestRouter;
|
| -
|
| - // TODO(hansmuller): the proxy receiver_ property should be receiver$
|
| -
|
| - function BaseConnection(localStub, remoteProxy, router) {
|
| - this.router_ = router;
|
| - this.local = localStub;
|
| - this.remote = remoteProxy;
|
| -
|
| - this.router_.setIncomingReceiver(localStub);
|
| - if (this.remote)
|
| - this.remote.receiver_ = router;
|
| -
|
| - // Validate incoming messages: remote responses and local requests.
|
| - var validateRequest = localStub && localStub.validator;
|
| - var validateResponse = remoteProxy && remoteProxy.validator;
|
| - var payloadValidators = [];
|
| - if (validateRequest)
|
| - payloadValidators.push(validateRequest);
|
| - if (validateResponse)
|
| - payloadValidators.push(validateResponse);
|
| - this.router_.setPayloadValidators(payloadValidators);
|
| - }
|
| -
|
| - BaseConnection.prototype.close = function() {
|
| - this.router_.close();
|
| - this.router_ = null;
|
| - this.local = null;
|
| - this.remote = null;
|
| - };
|
| -
|
| - BaseConnection.prototype.encounteredError = function() {
|
| - return this.router_.encounteredError();
|
| - };
|
| -
|
| - function Connection(
|
| - handle, localFactory, remoteFactory, routerFactory, connectorFactory) {
|
| - var routerClass = routerFactory || Router;
|
| - var router = new routerClass(handle, connectorFactory);
|
| - var remoteProxy = remoteFactory && new remoteFactory(router);
|
| - var localStub = localFactory && new localFactory(remoteProxy);
|
| - BaseConnection.call(this, localStub, remoteProxy, router);
|
| - }
|
| -
|
| - Connection.prototype = Object.create(BaseConnection.prototype);
|
| -
|
| - // The TestConnection subclass is only intended to be used in unit tests.
|
| - function TestConnection(handle, localFactory, remoteFactory) {
|
| - Connection.call(this,
|
| - handle,
|
| - localFactory,
|
| - remoteFactory,
|
| - TestRouter,
|
| - TestConnector);
|
| - }
|
| -
|
| - TestConnection.prototype = Object.create(Connection.prototype);
|
| -
|
| - function createOpenConnection(
|
| - messagePipeHandle, client, localInterface, remoteInterface) {
|
| - var stubClass = (localInterface && localInterface.stubClass) || EmptyStub;
|
| - var proxyClass =
|
| - (remoteInterface && remoteInterface.proxyClass) || EmptyProxy;
|
| - var proxy = new proxyClass;
|
| - var stub = new stubClass;
|
| - var router = new Router(messagePipeHandle);
|
| - var connection = new BaseConnection(stub, proxy, router);
|
| -
|
| - ProxyBindings(proxy).connection = connection;
|
| - ProxyBindings(proxy).local = connection.local;
|
| - StubBindings(stub).connection = connection;
|
| - StubBindings(proxy).remote = connection.remote;
|
| -
|
| - var clientImpl = client instanceof Function ? client(proxy) : client;
|
| - if (clientImpl)
|
| - StubBindings(stub).delegate = clientImpl;
|
| -
|
| - return connection;
|
| - }
|
| -
|
| - // Return a message pipe handle.
|
| - function bindProxyClient(clientImpl, localInterface, remoteInterface) {
|
| - var messagePipe = core.createMessagePipe();
|
| - if (messagePipe.result != core.RESULT_OK)
|
| - throw new Error("createMessagePipe failed " + messagePipe.result);
|
| -
|
| - createOpenConnection(
|
| - messagePipe.handle0, clientImpl, localInterface, remoteInterface);
|
| - return messagePipe.handle1;
|
| - }
|
| -
|
| - // Return a proxy.
|
| - function bindProxyHandle(proxyHandle, localInterface, remoteInterface) {
|
| - if (!core.isHandle(proxyHandle))
|
| - throw new Error("Not a handle " + proxyHandle);
|
| -
|
| - var connection = createOpenConnection(
|
| - proxyHandle, undefined, localInterface, remoteInterface);
|
| - return connection.remote;
|
| - }
|
| -
|
| - var exports = {};
|
| - exports.Connection = Connection;
|
| - exports.TestConnection = TestConnection;
|
| - exports.bindProxyHandle = bindProxyHandle;
|
| - exports.bindProxyClient = bindProxyClient;
|
| - return exports;
|
| -});
|
|
|