Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(59)

Side by Side Diff: android_webview/native/aw_message_port_service_impl.cc

Issue 831523004: Enable posting a message from JS to Android webview. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: minor fixes Created 5 years, 11 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
(Empty)
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
3 // found in the LICENSE file.
4
5 #include "android_webview/native/aw_message_port_service_impl.h"
6
7 #include "android_webview/browser/aw_browser_context.h"
8 #include "android_webview/browser/aw_message_port_message_filter.h"
9 #include "android_webview/native/aw_contents.h"
10 #include "base/android/jni_array.h"
11 #include "base/android/jni_string.h"
12 #include "base/bind.h"
13 #include "content/public/browser/browser_thread.h"
14 #include "content/public/browser/message_port_provider.h"
15 #include "jni/AwMessagePortService_jni.h"
16
17 namespace android_webview {
18
19 using base::android::AttachCurrentThread;
20 using base::android::ConvertUTF16ToJavaString;
21 using base::android::ScopedJavaGlobalRef;
22 using base::android::ScopedJavaLocalRef;
23 using base::android::ToJavaIntArray;
24 using content::BrowserThread;
25 using content::MessagePortProvider;
26
27 namespace {
28
29 void PostMessageOnUIThread(ScopedJavaGlobalRef<jobject>* jobj,
30 int message_port_id,
31 ScopedJavaGlobalRef<jstring>* jmsg,
32 ScopedJavaGlobalRef<jintArray>* jports) {
33 JNIEnv* env = AttachCurrentThread();
34 Java_AwMessagePortService_onPostMessage(env,
35 jobj->obj(),
36 message_port_id,
37 jmsg->obj(),
38 jports->obj());
39 }
40
41 }
42
43 //static
44 AwMessagePortServiceImpl* AwMessagePortServiceImpl::GetInstance() {
45 return static_cast<AwMessagePortServiceImpl*>(
46 AwBrowserContext::GetDefault()->GetMessagePortService());
47 }
48
49 AwMessagePortServiceImpl::AwMessagePortServiceImpl() {
50 }
51
52 AwMessagePortServiceImpl::~AwMessagePortServiceImpl() {
53 JNIEnv* env = AttachCurrentThread();
54 ScopedJavaLocalRef<jobject> obj = java_ref_.get(env);
55 if (obj.is_null())
56 return;
57 Java_AwMessagePortService_unregisterNativeAwMessagePortService(env,
58 obj.obj());
59 }
60
61 void AwMessagePortServiceImpl::Init(JNIEnv* env, jobject obj) {
62 java_ref_ = JavaObjectWeakGlobalRef(env, obj);
63 }
64
65 void AwMessagePortServiceImpl::OnMessageChannelCreated(
66 AwMessagePortMessageFilter* filter,
67 ScopedJavaGlobalRef<jobject>* callback,
68 int* port1,
69 int* port2) {
70 // TODO(sgurun) if filter is closed return.
71
72 AddPort(*port1, filter);
73 AddPort(*port2, filter);
74
75 JNIEnv* env = AttachCurrentThread();
76 ScopedJavaLocalRef<jobject> obj = java_ref_.get(env);
77 if (obj.is_null())
78 return;
79 Java_AwMessagePortService_onMessageChannelCreated(env, obj.obj(), *port1,
80 *port2, callback->obj());
81 }
82
83 void AwMessagePortServiceImpl::OnConvertedMessage(
84 int message_port_id,
85 const base::ListValue& message,
86 const std::vector<int>& sent_message_port_ids) {
87 JNIEnv* env = AttachCurrentThread();
88 ScopedJavaGlobalRef<jobject>* jobj = new ScopedJavaGlobalRef<jobject>();
89 jobj->Reset(java_ref_.get(env));
90
91 if (message.GetSize() != 1) {
92 NOTREACHED();
93 return;
94 }
95
96 base::string16 value;
97 if (!message.GetString(0, &value)) {
98 LOG(WARNING) << "Converting post message to a string failed for port "
99 << message_port_id;
100 return;
101 }
102 ScopedJavaGlobalRef<jstring>* jmsg = new ScopedJavaGlobalRef<jstring>();
103 jmsg->Reset(ConvertUTF16ToJavaString(env, value));
104
105 ScopedJavaGlobalRef<jintArray>* jports = new ScopedJavaGlobalRef<jintArray>();
106 jports->Reset(ToJavaIntArray(env, sent_message_port_ids));
107
108 BrowserThread::PostTask(
109 BrowserThread::UI,
110 FROM_HERE,
111 base::Bind(&PostMessageOnUIThread, base::Owned(jobj),
112 message_port_id,
113 base::Owned(jmsg),
114 base::Owned(jports)));
115 }
116
117 void AwMessagePortServiceImpl::OnMessagePortMessageFilterClosing(
118 AwMessagePortMessageFilter* filter) {
119 for (MessagePorts::iterator iter = ports_.begin();
120 iter != ports_.end(); iter++) {
121 if (iter->second == filter) {
122 ports_.erase(iter);
123 }
124 }
125 }
126
127 void AwMessagePortServiceImpl::AddPort(int message_port_id,
128 AwMessagePortMessageFilter* filter) {
129 // TODO(sgurun) seems like we are accessing ports_ from both UI and IO thread.
mnaganov (inactive) 2015/01/07 11:43:54 What do we use |ports_| for?
sgurun-gerrit only 2015/01/10 02:36:29 This will be used when posting the messages from J
130 if (ports_.count(message_port_id)) {
131 NOTREACHED();
132 return;
133 }
134 ports_[message_port_id] = filter;
135 }
136
137 bool RegisterAwMessagePortService(JNIEnv* env) {
138 return RegisterNativesImpl(env);
139 }
140
141 // static
142 jlong InitAwMessagePortService(JNIEnv* env, jobject obj) {
143 AwMessagePortServiceImpl* service = AwMessagePortServiceImpl::GetInstance();
144 service->Init(env, obj);
145 return reinterpret_cast<intptr_t>(service);
146 }
147
148 } // namespace android_webview
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698