Allow platform apps to respond to Web Intents

chrome/browser/extensions/api/app_runtime/app_runtime_api.cc

 // Copyright (c) 2012 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 "chrome/browser/extensions/api/app_runtime/app_runtime_api.h"
 
 #include "base/json/json_writer.h"
 #include "base/string16.h"
 #include "base/string_number_conversions.h"
 #include "base/utf_string_conversions.h"
 #include "base/values.h"
 #include "chrome/browser/extensions/event_router.h"
+#include "chrome/browser/extensions/web_intent_callbacks.h"
 #include "chrome/browser/profiles/profile.h"
 #include "chrome/common/extensions/extension.h"
+#include "content/public/browser/web_contents.h"
+#include "content/public/browser/web_intents_dispatcher.h"
 #include "googleurl/src/gurl.h"
 #include "webkit/glue/web_intent_data.h"
 
 namespace {
 
+const char kIntentIdKey[] = "intentId";
+const char kIntentSuccessKey[] = "success";
+const char kIntentDataKey[] = "data";
 const char kOnLaunchedEvent[] = "app.runtime.onLaunched";
 
+const char kCallbackNotFoundError[] =
+    "WebIntent callback not found; perhaps already responded to";
+
 }  // anonymous namespace
 
 namespace extensions {
 
 // static.
 void AppEventRouter::DispatchOnLaunchedEvent(
     Profile* profile, const Extension* extension) {
   scoped_ptr<ListValue> arguments(new ListValue());
   profile->GetExtensionEventRouter()->DispatchEventToExtension(
       extension->id(), kOnLaunchedEvent, arguments.Pass(), NULL, GURL());
@@ skipping 17 matching lines @@
   // NOTE: This second argument is dropped before being dispatched to the client
   // code.
   args->Append(intent_data);
   profile->GetExtensionEventRouter()->DispatchEventToExtension(
       extension->id(), kOnLaunchedEvent, args.Pass(), NULL, GURL());
 }
 
 // static.
 void AppEventRouter::DispatchOnLaunchedEventWithWebIntent(
     Profile* profile, const Extension* extension,
-    const webkit_glue::WebIntentData web_intent_data) {
+    content::WebIntentsDispatcher* intents_dispatcher,
+    content::WebContents* source) {
+  webkit_glue::WebIntentData web_intent_data = intents_dispatcher->GetIntent();
   scoped_ptr<ListValue> args(new ListValue());
   DictionaryValue* launch_data = new DictionaryValue();
   DictionaryValue* intent = new DictionaryValue();
   intent->SetString("action", UTF16ToUTF8(web_intent_data.action));
   intent->SetString("type", UTF16ToUTF8(web_intent_data.type));
   launch_data->Set("intent", intent);
   args->Append(launch_data);
   DictionaryValue* intent_data;
   switch (web_intent_data.data_type) {
     case webkit_glue::WebIntentData::SERIALIZED:
       intent_data = new DictionaryValue();
       intent_data->SetString("format", "serialized");
       intent_data->SetString("data", UTF16ToUTF8(web_intent_data.data));
       // NOTE: This second argument is dropped before being dispatched to the
       // client code.
       args->Append(intent_data);
       break;
     case webkit_glue::WebIntentData::UNSERIALIZED:
+      args->Append(Value::CreateNullValue());
       intent->SetString("data", UTF16ToUTF8(web_intent_data.unserialized_data));
       break;
     case webkit_glue::WebIntentData::BLOB:
       intent_data = new DictionaryValue();
       intent_data->SetString("format", "blob");
       intent_data->SetString("blobFileName", web_intent_data.blob_file.value());
       intent_data->SetString("blobLength",
                              base::Int64ToString(web_intent_data.blob_length));
       // NOTE: This second argument is dropped before being dispatched to the
       // client code.
       args->Append(intent_data);
       break;
     default:
       NOTREACHED();
       break;
   }
+  DCHECK(args->GetSize() == 2);  // intent_id must be our third argument.
+  WebIntentCallbacks* callbacks = WebIntentCallbacks::Get(profile);
+  int intent_id =
+      callbacks->RegisterCallback(extension, intents_dispatcher, source);
+  args->Append(base::Value::CreateIntegerValue(intent_id));
   profile->GetExtensionEventRouter()->DispatchEventToExtension(
       extension->id(), kOnLaunchedEvent, args.Pass(), NULL, GURL());
 }
 
+bool AppRuntimePostIntentResponseFunction::RunImpl() {
+  DictionaryValue* details = NULL;
+  EXTENSION_FUNCTION_VALIDATE(args_->GetDictionary(0, &details));
+
+  int intent_id = 0;
+  EXTENSION_FUNCTION_VALIDATE(details->GetInteger(kIntentIdKey, &intent_id));
+
+  WebIntentCallbacks* callbacks = WebIntentCallbacks::Get(profile());
+  content::WebIntentsDispatcher* intents_dispatcher =
+      callbacks->RetrieveCallback(GetExtension(), intent_id);
+  if (!intents_dispatcher) {
+    error_ = kCallbackNotFoundError;
+    return false;
+  }
+
+  webkit_glue::WebIntentReplyType reply_type =
+      webkit_glue::WEB_INTENT_REPLY_FAILURE;
+  bool success;
+  EXTENSION_FUNCTION_VALIDATE(details->GetBoolean(kIntentSuccessKey, &success));
+  if (success)
+    reply_type = webkit_glue::WEB_INTENT_REPLY_SUCCESS;
+
+  std::string data;
+  EXTENSION_FUNCTION_VALIDATE(details->GetString(kIntentDataKey, &data));
+
+  intents_dispatcher->SendReplyMessage(reply_type, UTF8ToUTF16(data));
+  return true;
+}
+
 }  // namespace extensions