| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "chrome/browser/extensions/api/api_resource_event_notifier.h" | 5 #include "chrome/browser/extensions/api/api_resource_event_notifier.h" |
| 6 | 6 |
| 7 #include "base/bind.h" | 7 #include "base/bind.h" |
| 8 #include "base/json/json_writer.h" | 8 #include "base/json/json_writer.h" |
| 9 #include "base/values.h" | 9 #include "base/values.h" |
| 10 #include "chrome/browser/extensions/extension_event_router.h" | 10 #include "chrome/browser/extensions/extension_event_router.h" |
| (...skipping 13 matching lines...) Expand all Loading... |
| 24 const char kEventTypeKey[] = "type"; | 24 const char kEventTypeKey[] = "type"; |
| 25 const char kEventTypeConnectComplete[] = "connectComplete"; | 25 const char kEventTypeConnectComplete[] = "connectComplete"; |
| 26 const char kEventTypeDataRead[] = "dataRead"; | 26 const char kEventTypeDataRead[] = "dataRead"; |
| 27 const char kEventTypeWriteComplete[] = "writeComplete"; | 27 const char kEventTypeWriteComplete[] = "writeComplete"; |
| 28 | 28 |
| 29 const char kSrcIdKey[] = "srcId"; | 29 const char kSrcIdKey[] = "srcId"; |
| 30 const char kIsFinalEventKey[] = "isFinalEvent"; | 30 const char kIsFinalEventKey[] = "isFinalEvent"; |
| 31 | 31 |
| 32 const char kResultCodeKey[] = "resultCode"; | 32 const char kResultCodeKey[] = "resultCode"; |
| 33 const char kDataKey[] = "data"; | 33 const char kDataKey[] = "data"; |
| 34 const char kAddressKey[] = "address"; |
| 35 const char kPortKey[] = "port"; |
| 34 | 36 |
| 35 APIResourceEventNotifier::APIResourceEventNotifier( | 37 APIResourceEventNotifier::APIResourceEventNotifier( |
| 36 ExtensionEventRouter* router, | 38 ExtensionEventRouter* router, |
| 37 Profile* profile, | 39 Profile* profile, |
| 38 const std::string& src_extension_id, | 40 const std::string& src_extension_id, |
| 39 int src_id, | 41 int src_id, |
| 40 const GURL& src_url) | 42 const GURL& src_url) |
| 41 : router_(router), | 43 : router_(router), |
| 42 profile_(profile), | 44 profile_(profile), |
| 43 src_extension_id_(src_extension_id), | 45 src_extension_id_(src_extension_id), |
| 44 src_id_(src_id), | 46 src_id_(src_id), |
| 45 src_url_(src_url) {} | 47 src_url_(src_url) {} |
| 46 | 48 |
| 47 APIResourceEventNotifier::~APIResourceEventNotifier() {} | 49 APIResourceEventNotifier::~APIResourceEventNotifier() {} |
| 48 | 50 |
| 49 void APIResourceEventNotifier::OnConnectComplete(int result_code) { | 51 void APIResourceEventNotifier::OnConnectComplete(int result_code) { |
| 50 SendEventWithResultCode(API_RESOURCE_EVENT_CONNECT_COMPLETE, result_code); | 52 SendEventWithResultCode(API_RESOURCE_EVENT_CONNECT_COMPLETE, result_code); |
| 51 } | 53 } |
| 52 | 54 |
| 53 void APIResourceEventNotifier::OnDataRead(int result_code, | 55 void APIResourceEventNotifier::OnDataRead(int result_code, |
| 54 base::ListValue* data) { | 56 base::ListValue* data, |
| 57 const std::string& address, |
| 58 int port) { |
| 55 // Do we have a destination for this event? There will be one if a source id | 59 // Do we have a destination for this event? There will be one if a source id |
| 56 // was injected by the request handler for the resource's create method in | 60 // was injected by the request handler for the resource's create method in |
| 57 // schema_generated_bindings.js, which will in turn be the case if the caller | 61 // schema_generated_bindings.js, which will in turn be the case if the caller |
| 58 // of the create method provided an onEvent closure. | 62 // of the create method provided an onEvent closure. |
| 59 if (src_id_ < 0) { | 63 if (src_id_ < 0) { |
| 60 delete data; | 64 delete data; |
| 61 return; | 65 return; |
| 62 } | 66 } |
| 63 | 67 |
| 64 DictionaryValue* event = CreateAPIResourceEvent( | 68 DictionaryValue* event = CreateAPIResourceEvent( |
| 65 API_RESOURCE_EVENT_DATA_READ); | 69 API_RESOURCE_EVENT_DATA_READ); |
| 66 event->SetInteger(kResultCodeKey, result_code); | 70 event->SetInteger(kResultCodeKey, result_code); |
| 67 event->Set(kDataKey, data); | 71 event->Set(kDataKey, data); |
| 72 event->SetString(kAddressKey, address); |
| 73 event->SetInteger(kPortKey, port); |
| 68 DispatchEvent(event); | 74 DispatchEvent(event); |
| 69 } | 75 } |
| 70 | 76 |
| 71 void APIResourceEventNotifier::OnWriteComplete(int result_code) { | 77 void APIResourceEventNotifier::OnWriteComplete(int result_code) { |
| 72 SendEventWithResultCode(API_RESOURCE_EVENT_WRITE_COMPLETE, result_code); | 78 SendEventWithResultCode(API_RESOURCE_EVENT_WRITE_COMPLETE, result_code); |
| 73 } | 79 } |
| 74 | 80 |
| 75 void APIResourceEventNotifier::SendEventWithResultCode( | 81 void APIResourceEventNotifier::SendEventWithResultCode( |
| 76 APIResourceEventType event_type, | 82 APIResourceEventType event_type, |
| 77 int result_code) { | 83 int result_code) { |
| (...skipping 51 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 129 return kEventTypeDataRead; | 135 return kEventTypeDataRead; |
| 130 case API_RESOURCE_EVENT_WRITE_COMPLETE: | 136 case API_RESOURCE_EVENT_WRITE_COMPLETE: |
| 131 return kEventTypeWriteComplete; | 137 return kEventTypeWriteComplete; |
| 132 } | 138 } |
| 133 | 139 |
| 134 NOTREACHED(); | 140 NOTREACHED(); |
| 135 return std::string(); | 141 return std::string(); |
| 136 } | 142 } |
| 137 | 143 |
| 138 } // namespace extensions | 144 } // namespace extensions |
| OLD | NEW |