mirror of
https://github.com/flutter/flutter.git
synced 2026-02-20 02:29:02 +08:00
dddf8f294f
Instead of mojo.Shell and mojo.Application being clients of each other they are now separate interfaces. An implementation of mojo.Application receives a handle to the shell in its Initialize call, as described in this doc: https://docs.google.com/document/d/1xjt_TPjTu0elix8fNdBgWmnjJdJAtqSr1XDS_C-Ct8E/edit?usp=sharing An analogous change is made to the content handler definition. In C++, this is handled by the mojo::ApplicationImpl class which stores shell handle in its implementation of Initialize. Thus the only change for most C++ applications is the meaning of the handle in MojoMain is different, although mains that use the ApplicationRunners do the same thing with it. Connecting to other apps is largely the same although instead of grabbing the ApplicationImpl's client() to talk to the shell code must now use the ApplicationImpl::shell() getter. In JavaScript, the initialization sequence is a bit different although this is hidden mostly in the Application class which calls initialize() on its subclass with the same set of parameters. Connecting to another application looks different, especially for sky code using the shell proxy handle exposed via internals. Hans has some ideas about how to make this a bit nicer. Python apps similarly need to change their startup sequence a bit. I didn't find a common library to take care of this dance, although it's possible I just missed it. Other languages probably a bit of reworking - I fixed everything here that is covered by mojob.py test but some might be missing. This patch also uses typed handles (i.e. InterfacePtr<> or InterfaceRequest<> or their type aliases) wherever possible instead of ScopedMessagePipeHandle for clarity. R=davemoore@chromium.org Review URL: https://codereview.chromium.org/868463008
92 lines
3.2 KiB
C++
92 lines
3.2 KiB
C++
// 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.
|
|
|
|
#include "sky/viewer/content_handler_impl.h"
|
|
|
|
#include "base/bind.h"
|
|
#include "mojo/public/cpp/application/connect.h"
|
|
#include "mojo/public/cpp/bindings/strong_binding.h"
|
|
#include "mojo/public/cpp/utility/run_loop.h"
|
|
#include "mojo/services/network/public/interfaces/network_service.mojom.h"
|
|
#include "sky/viewer/document_view.h"
|
|
|
|
namespace sky {
|
|
|
|
class SkyApplication : public mojo::Application {
|
|
public:
|
|
SkyApplication(mojo::InterfaceRequest<mojo::Application> application,
|
|
mojo::URLResponsePtr response)
|
|
: url_(response->url),
|
|
binding_(this, application.Pass()),
|
|
initial_response_(response.Pass()) {}
|
|
|
|
void Initialize(mojo::ShellPtr shell,
|
|
mojo::Array<mojo::String> args) override {
|
|
shell_ = shell.Pass();
|
|
mojo::ServiceProviderPtr service_provider;
|
|
shell_->ConnectToApplication("mojo:network_service",
|
|
mojo::GetProxy(&service_provider), nullptr);
|
|
mojo::ConnectToService(service_provider.get(), &network_service_);
|
|
}
|
|
|
|
void AcceptConnection(const mojo::String& requestor_url,
|
|
mojo::InterfaceRequest<mojo::ServiceProvider> services,
|
|
mojo::ServiceProviderPtr exposed_services) override {
|
|
if (initial_response_) {
|
|
OnResponseReceived(mojo::URLLoaderPtr(), services.Pass(),
|
|
exposed_services.Pass(), initial_response_.Pass());
|
|
} else {
|
|
mojo::URLLoaderPtr loader;
|
|
network_service_->CreateURLLoader(mojo::GetProxy(&loader));
|
|
mojo::URLRequestPtr request(mojo::URLRequest::New());
|
|
request->url = url_;
|
|
request->auto_follow_redirects = true;
|
|
|
|
// |loader| will be pass to the OnResponseReceived method through a
|
|
// callback. Because order of evaluation is undefined, a reference to the
|
|
// raw pointer is needed.
|
|
mojo::URLLoader* raw_loader = loader.get();
|
|
raw_loader->Start(
|
|
request.Pass(),
|
|
base::Bind(&SkyApplication::OnResponseReceived,
|
|
base::Unretained(this), base::Passed(&loader),
|
|
base::Passed(&services), base::Passed(&exposed_services)));
|
|
}
|
|
}
|
|
|
|
void RequestQuit() override {
|
|
mojo::RunLoop::current()->Quit();
|
|
}
|
|
|
|
private:
|
|
void OnResponseReceived(
|
|
mojo::URLLoaderPtr loader,
|
|
mojo::InterfaceRequest<mojo::ServiceProvider> services,
|
|
mojo::ServiceProviderPtr exposed_services,
|
|
mojo::URLResponsePtr response) {
|
|
new DocumentView(services.Pass(), exposed_services.Pass(), response.Pass(),
|
|
shell_.get());
|
|
}
|
|
|
|
mojo::String url_;
|
|
mojo::StrongBinding<mojo::Application> binding_;
|
|
mojo::ShellPtr shell_;
|
|
mojo::NetworkServicePtr network_service_;
|
|
mojo::URLResponsePtr initial_response_;
|
|
};
|
|
|
|
ContentHandlerImpl::ContentHandlerImpl() {
|
|
}
|
|
|
|
ContentHandlerImpl::~ContentHandlerImpl() {
|
|
}
|
|
|
|
void ContentHandlerImpl::StartApplication(
|
|
mojo::InterfaceRequest<mojo::Application> application,
|
|
mojo::URLResponsePtr response) {
|
|
new SkyApplication(application.Pass(), response.Pass());
|
|
}
|
|
|
|
} // namespace sky
|