OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 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 | 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/chromeos/file_system_provider/operations/operation.h" | 5 #include "chrome/browser/chromeos/file_system_provider/operations/operation.h" |
6 | 6 |
| 7 #include "chrome/browser/chromeos/file_system_provider/file_system_plugin/plugin
_operation_router.h" |
7 #include "chrome/browser/chromeos/file_system_provider/provided_file_system_info
.h" | 8 #include "chrome/browser/chromeos/file_system_provider/provided_file_system_info
.h" |
| 9 #include "chrome/browser/chromeos/file_system_provider/file_system_plugin/provid
ed_file_system_adapter.h" |
8 #include "extensions/browser/event_router.h" | 10 #include "extensions/browser/event_router.h" |
9 | 11 |
10 namespace chromeos { | 12 namespace chromeos { |
11 namespace file_system_provider { | 13 namespace file_system_provider { |
12 namespace operations { | 14 namespace operations { |
13 namespace { | 15 namespace { |
14 | |
15 // Default implementation for dispatching an event. Can be replaced for unit | 16 // Default implementation for dispatching an event. Can be replaced for unit |
16 // tests by Operation::SetDispatchEventImplForTest(). | 17 // tests by Operation::SetDispatchEventImplForTest(). |
17 bool DispatchEventImpl(extensions::EventRouter* event_router, | 18 template <class DestinationPolicy=ExtensionDestination> |
18 const std::string& extension_id, | 19 bool DispatchEventImpl( |
19 scoped_ptr<extensions::Event> event) { | 20 typename DestinationPolicy::EventRouterType* event_router, |
| 21 const std::string& extension_id, |
| 22 scoped_ptr<extensions::Event> event) { |
20 if (!event_router->ExtensionHasEventListener(extension_id, event->event_name)) | 23 if (!event_router->ExtensionHasEventListener(extension_id, event->event_name)) |
21 return false; | 24 return false; |
22 | 25 |
23 event_router->DispatchEventToExtension(extension_id, event.Pass()); | 26 event_router->DispatchEventToExtension(extension_id, event.Pass()); |
24 return true; | 27 return true; |
25 } | 28 } |
26 | 29 |
| 30 template <> |
| 31 bool DispatchEventImpl<PluginDestination>( |
| 32 typename PluginDestination::EventRouterType* |
| 33 event_router, |
| 34 const std::string& source_id, |
| 35 scoped_ptr<extensions::Event> event) { |
| 36 if (!event_router->PluginHasOperationListener( |
| 37 ProvidedFileSystemAdapter::OperationTypeFromExtensionEvent( |
| 38 event->event_name), |
| 39 source_id)) |
| 40 return false; |
| 41 |
| 42 event_router->DispatchOperationToPlugin(source_id, event.Pass()); |
| 43 return true; |
| 44 } |
| 45 |
27 } // namespace | 46 } // namespace |
28 | 47 |
29 Operation::Operation(extensions::EventRouter* event_router, | 48 template <class DestinationPolicy> |
30 const ProvidedFileSystemInfo& file_system_info) | 49 Operation<DestinationPolicy>::Operation( |
| 50 typename DestinationPolicy::EventRouterType* event_router, |
| 51 const ProvidedFileSystemInfo& file_system_info) |
31 : file_system_info_(file_system_info), | 52 : file_system_info_(file_system_info), |
32 dispatch_event_impl_(base::Bind(&DispatchEventImpl, | 53 dispatch_event_impl_(base::Bind(&DispatchEventImpl<DestinationPolicy>, |
33 event_router, | 54 event_router, |
34 file_system_info_.extension_id())) { | 55 file_system_info_.source_id())) { |
| 56 } |
| 57 template <class DestinationPolicy> |
| 58 Operation<DestinationPolicy>::~Operation() { |
35 } | 59 } |
36 | 60 |
37 Operation::~Operation() { | 61 template <class DestinationPolicy> |
38 } | 62 void Operation<DestinationPolicy>::SetDispatchEventImplForTesting( |
39 | |
40 void Operation::SetDispatchEventImplForTesting( | |
41 const DispatchEventImplCallback& callback) { | 63 const DispatchEventImplCallback& callback) { |
42 dispatch_event_impl_ = callback; | 64 dispatch_event_impl_ = callback; |
43 } | 65 } |
44 | 66 |
45 bool Operation::SendEvent(int request_id, | 67 template <class DestinationPolicy> |
46 const std::string& event_name, | 68 bool Operation<DestinationPolicy>::SendEvent(int request_id, |
47 scoped_ptr<base::ListValue> event_args) { | 69 const std::string& event_name, |
| 70 scoped_ptr<base::ListValue> event_args) { |
48 return dispatch_event_impl_.Run( | 71 return dispatch_event_impl_.Run( |
49 make_scoped_ptr(new extensions::Event(event_name, event_args.Pass()))); | 72 make_scoped_ptr(new extensions::Event(event_name, event_args.Pass()))); |
50 } | 73 } |
51 | 74 |
| 75 FOR_EACH_DESTINATION_SPECIALIZE(Operation) |
| 76 |
52 } // namespace operations | 77 } // namespace operations |
53 } // namespace file_system_provider | 78 } // namespace file_system_provider |
54 } // namespace chromeos | 79 } // namespace chromeos |
OLD | NEW |