1 // Copyright (c) 2014,2015 Samsung Electronics. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file.
5 #include "wrt_widget_host.h"
7 #include "base/lazy_instance.h"
8 #include "common/render_messages_ewk.h"
9 #include "content/public/browser/browser_message_filter.h"
10 #include "content/public/browser/render_process_host.h"
11 #include "ipc/ipc_message_macros.h"
12 #include "ipc_message_start_ewk.h"
13 #include "net/url_request/url_request.h"
17 // TODO(z.kostrzewa) I would prefer not make it a singleton, check out
18 // if it can't be a member of ContentMainDelegateEfl (but keep the static
20 base::LazyInstance<std::unique_ptr<WrtWidgetHost> > g_wrt_widget_host =
21 LAZY_INSTANCE_INITIALIZER;
23 bool SendToAllRenderers(IPC::Message* message) {
25 content::RenderProcessHost::iterator it =
26 content::RenderProcessHost::AllHostsIterator();
27 while (!it.IsAtEnd()) {
28 if (it.GetCurrentValue()->Send(new IPC::Message(*message)))
36 bool SendToRenderer(int renderer_id, IPC::Message* message) {
37 content::RenderProcessHost* host =
38 content::RenderProcessHost::FromID(renderer_id);
42 return host->Send(message);
46 class WrtWidgetHostMessageFilter : public content::BrowserMessageFilter {
48 explicit WrtWidgetHostMessageFilter(WrtWidgetHost* wrt_widget_host);
51 bool OnMessageReceived(const IPC::Message& message) override;
53 WrtWidgetHost* wrt_widget_host_;
56 WrtWidgetHostMessageFilter::WrtWidgetHostMessageFilter(
57 WrtWidgetHost* wrt_widget_host)
58 : content::BrowserMessageFilter(EwkMsgStart),
59 wrt_widget_host_(wrt_widget_host) {
62 bool WrtWidgetHostMessageFilter::OnMessageReceived(const IPC::Message& message) {
64 IPC_BEGIN_MESSAGE_MAP(WrtWidgetHostMessageFilter, message)
65 IPC_MESSAGE_FORWARD(WrtMsg_ParseUrlResponse, wrt_widget_host_, WrtWidgetHost::OnUrlRetrieved)
66 IPC_MESSAGE_UNHANDLED(handled = false)
71 WrtWidgetHost* WrtWidgetHost::Get() {
72 // TODO(z.kostrzewa) LazyInstance is thread-safe but creating
73 // WrtWidgetHost is not - make it thread-safe.
74 #if !defined(EWK_BRINGUP) // FIXME: m67 bringup
75 // FIXME: ‘New’ is not a member of
76 // ‘base::internal::ErrorMustSelectLazyOrDestructorAtExitForLazyInstance<std::unique_ptr<WrtWidgetHost>
78 if (!g_wrt_widget_host.Get().get())
79 g_wrt_widget_host.Get().reset(new WrtWidgetHost);
80 return g_wrt_widget_host.Get().get();
86 WrtWidgetHost::WrtWidgetHost()
87 : message_filter_(new WrtWidgetHostMessageFilter(this)) {
90 void WrtWidgetHost::GetUrlForRequest(
91 net::URLRequest* request,
92 base::OnceCallback<void(const GURL&)> callback) {
93 // TODO(z.kostrzewa) Check on which thread(s) callbacks_ is touched
94 // and provide synchronization if required (either via a lock or
95 // by assuring that it is referenced only on one thread)
96 int callback_id = callback_id_generator_.GetNext();
97 callbacks_[callback_id] = std::move(callback);
99 #if !defined(EWK_BRINGUP) // FIXME: m85 bringup
100 int renderer_id, frame_id;
101 if (content::ResourceRequestInfo::GetRenderFrameForRequest(request, &renderer_id,
103 if (SendToRenderer(renderer_id, new WrtMsg_ParseUrl(callback_id, request->url())))
107 std::move(callbacks_[callback_id]).Run(GURL());
108 callbacks_.erase(callback_id);
111 void WrtWidgetHost::SendWrtMessage(
112 const Ewk_Wrt_Message_Data& message) {
113 SendToAllRenderers(new WrtMsg_SendWrtMessage(message));
116 // It's only used by the wrt_file_protocol_handler which is not going to be used in the future
117 // Candidate for deletion.
118 bool WrtWidgetHost::InWrt() const {
122 // It's only used by the wrt_file_protocol_handler which is not going to be used in the future
123 // Candidate for deletion.
124 std::string WrtWidgetHost::TizenAppId() const {
125 return std::string();
128 void WrtWidgetHost::OnUrlRetrieved(int callback_id, const GURL& url) {
129 auto it = callbacks_.find(callback_id);
130 if (callbacks_.end() == it)
133 std::move(it->second).Run(url);
134 callbacks_.erase(it);