Implement onEvent callback framework for UDP

chrome/browser/extensions/api/socket/socket_api.cc

 // Copyright (c) 2011 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/socket/socket_api.h"
 
 #include "base/bind.h"
 #include "base/values.h"
 #include "chrome/browser/extensions/api/socket/socket_api_controller.h"
 #include "chrome/browser/extensions/extension_service.h"
@@ skipping 31 matching lines @@
       BrowserThread::UI, FROM_HERE,
       base::Bind(&SocketApiFunction::RespondOnUIThread, this));
   DCHECK(rv);
 }
 
 void SocketApiFunction::RespondOnUIThread() {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
   SendResponse(Respond());
 }
 
+SocketCreateFunction::SocketCreateFunction()
+    : src_id_(-1) {}
+
 bool SocketCreateFunction::Prepare() {
   std::string socket_type;
   EXTENSION_FUNCTION_VALIDATE(args_->GetString(0, &socket_type));
 
+  scoped_ptr<DictionaryValue> options(new DictionaryValue());
+  if (args_->GetSize() >= 2) {
+    DictionaryValue* temp_options = NULL;
+    if (args_->GetDictionary(1, &temp_options))
+      options.reset(temp_options->DeepCopy());
+  }
+
+  // If we tacked on a srcId to the options object, pull it out here to provide
+  // to the Socket.
+  if (options->HasKey(kSrcIdKey)) {
+    EXTENSION_FUNCTION_VALIDATE(options->GetInteger(kSrcIdKey, &src_id_));
+  }
+
   // TODO(miket): this constitutes a second form of truth as to the enum
   // validity. But our unit-test framework skips the enum validation. So in
   // order to get an invalid-enum test to pass, we need duplicative
   // value-checking. Too bad. Fix this if/when the argument validation code is
   // moved to C++ rather than its current JavaScript form.
   if (socket_type != kUDPSocketType) {
     return false;
   }
   return true;
 }
 
 void SocketCreateFunction::Work() {
   DictionaryValue* result = new DictionaryValue();
-  int socket_id = controller()->CreateUdp(profile(), extension_id(),
+  int socket_id = controller()->CreateUdp(profile(), extension_id(), src_id_,
                                           source_url());
   result->SetInteger(kSocketIdKey, socket_id);
   result_.reset(result);
 
 }
 
 bool SocketCreateFunction::Respond() {
   return true;
 }
 
@@ skipping 52 matching lines @@
   DictionaryValue* result = new DictionaryValue();
   result->SetInteger(kBytesWrittenKey, bytesWritten);
   result_.reset(result);
 }
 
 bool SocketWriteFunction::Respond() {
   return true;
 }
 
 }  // namespace extensions