Garrick Evans | 0884393 | 2019-09-17 14:41:08 +0900 | [diff] [blame] | 1 | // Copyright 2019 The Chromium OS 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 | |
Jason Jeremy Iman | adffbcb | 2020-08-31 13:21:36 +0900 | [diff] [blame] | 5 | #ifndef PATCHPANEL_DBUS_CLIENT_H_ |
| 6 | #define PATCHPANEL_DBUS_CLIENT_H_ |
Garrick Evans | 0884393 | 2019-09-17 14:41:08 +0900 | [diff] [blame] | 7 | |
| 8 | #include <memory> |
Jason Jeremy Iman | adffbcb | 2020-08-31 13:21:36 +0900 | [diff] [blame] | 9 | #include <set> |
Jason Jeremy Iman | 6f1f3e7 | 2020-07-06 13:04:03 +0900 | [diff] [blame] | 10 | #include <string> |
Garrick Evans | 0884393 | 2019-09-17 14:41:08 +0900 | [diff] [blame] | 11 | #include <utility> |
| 12 | #include <vector> |
| 13 | |
Hugo Benichi | cc6850f | 2020-01-17 13:26:06 +0900 | [diff] [blame] | 14 | #include "base/files/scoped_file.h" |
Garrick Evans | 0884393 | 2019-09-17 14:41:08 +0900 | [diff] [blame] | 15 | #include <brillo/brillo_export.h> |
| 16 | #include <dbus/bus.h> |
| 17 | #include <dbus/object_proxy.h> |
Hugo Benichi | 8135e56 | 2019-12-12 15:56:36 +0900 | [diff] [blame] | 18 | #include <patchpanel/proto_bindings/patchpanel_service.pb.h> |
Garrick Evans | 0884393 | 2019-09-17 14:41:08 +0900 | [diff] [blame] | 19 | |
| 20 | namespace patchpanel { |
| 21 | |
Hugo Benichi | 51ff71b | 2020-08-19 00:55:15 +0900 | [diff] [blame] | 22 | // Simple wrapper around patchpanel DBus API. All public functions are blocking |
Jie Jiang | 0a70acf | 2020-10-02 11:57:32 +0900 | [diff] [blame] | 23 | // DBus calls to patchpaneld (asynchronous calls are mentioned explicitly). The |
| 24 | // method names and protobuf schema used by patchpanel DBus API are defined in |
| 25 | // platform2/system_api/dbus/patchpanel. Access control for clients is defined |
| 26 | // in platform2/patchpanel/dbus. |
Garrick Evans | 0884393 | 2019-09-17 14:41:08 +0900 | [diff] [blame] | 27 | class BRILLO_EXPORT Client { |
| 28 | public: |
Jie Jiang | 0a70acf | 2020-10-02 11:57:32 +0900 | [diff] [blame] | 29 | using GetTrafficCountersCallback = |
| 30 | base::OnceCallback<void(const std::vector<TrafficCounter>&)>; |
Jie Jiang | 25c1b97 | 2020-11-12 15:42:53 +0900 | [diff] [blame] | 31 | using NeighborReachabilityEventHandler = |
| 32 | base::RepeatingCallback<void(const NeighborReachabilityEventSignal&)>; |
Jie Jiang | 0a70acf | 2020-10-02 11:57:32 +0900 | [diff] [blame] | 33 | |
Garrick Evans | 0884393 | 2019-09-17 14:41:08 +0900 | [diff] [blame] | 34 | static std::unique_ptr<Client> New(); |
| 35 | |
Jie Jiang | 81c84db | 2020-09-29 17:40:16 +0900 | [diff] [blame] | 36 | // Only used in tests. |
| 37 | static std::unique_ptr<Client> New(const scoped_refptr<dbus::Bus>& bus, |
| 38 | dbus::ObjectProxy* proxy); |
Garrick Evans | 0884393 | 2019-09-17 14:41:08 +0900 | [diff] [blame] | 39 | |
Jie Jiang | 81c84db | 2020-09-29 17:40:16 +0900 | [diff] [blame] | 40 | virtual ~Client() = default; |
Garrick Evans | 27b7403 | 2019-11-19 13:33:47 +0900 | [diff] [blame] | 41 | |
Jie Jiang | 81c84db | 2020-09-29 17:40:16 +0900 | [diff] [blame] | 42 | virtual bool NotifyArcStartup(pid_t pid) = 0; |
| 43 | virtual bool NotifyArcShutdown() = 0; |
Garrick Evans | 0884393 | 2019-09-17 14:41:08 +0900 | [diff] [blame] | 44 | |
Jie Jiang | 81c84db | 2020-09-29 17:40:16 +0900 | [diff] [blame] | 45 | virtual std::vector<NetworkDevice> NotifyArcVmStartup(uint32_t cid) = 0; |
| 46 | virtual bool NotifyArcVmShutdown(uint32_t cid) = 0; |
Garrick Evans | 27b7403 | 2019-11-19 13:33:47 +0900 | [diff] [blame] | 47 | |
Jie Jiang | 81c84db | 2020-09-29 17:40:16 +0900 | [diff] [blame] | 48 | virtual bool NotifyTerminaVmStartup(uint32_t cid, |
| 49 | NetworkDevice* device, |
| 50 | IPv4Subnet* container_subnet) = 0; |
| 51 | virtual bool NotifyTerminaVmShutdown(uint32_t cid) = 0; |
| 52 | |
| 53 | virtual bool NotifyPluginVmStartup(uint64_t vm_id, |
| 54 | int subnet_index, |
| 55 | NetworkDevice* device) = 0; |
| 56 | virtual bool NotifyPluginVmShutdown(uint64_t vm_id) = 0; |
Garrick Evans | 376f067 | 2020-01-07 15:31:50 +0900 | [diff] [blame] | 57 | |
Hugo Benichi | 7d9d8db | 2020-03-30 15:56:56 +0900 | [diff] [blame] | 58 | // Reset the VPN routing intent mark on a socket to the default policy for |
| 59 | // the current uid. This is in general incorrect to call this method for |
| 60 | // a socket that is already connected. |
Jie Jiang | 81c84db | 2020-09-29 17:40:16 +0900 | [diff] [blame] | 61 | virtual bool DefaultVpnRouting(int socket) = 0; |
Hugo Benichi | 7d9d8db | 2020-03-30 15:56:56 +0900 | [diff] [blame] | 62 | |
| 63 | // Mark a socket to be always routed through a VPN if there is one. |
| 64 | // Must be called before the socket is connected. |
Jie Jiang | 81c84db | 2020-09-29 17:40:16 +0900 | [diff] [blame] | 65 | virtual bool RouteOnVpn(int socket) = 0; |
Hugo Benichi | 7d9d8db | 2020-03-30 15:56:56 +0900 | [diff] [blame] | 66 | |
| 67 | // Mark a socket to be always routed through the physical network. |
| 68 | // Must be called before the socket is connected. |
Jie Jiang | 81c84db | 2020-09-29 17:40:16 +0900 | [diff] [blame] | 69 | virtual bool BypassVpn(int socket) = 0; |
Hugo Benichi | 7d9d8db | 2020-03-30 15:56:56 +0900 | [diff] [blame] | 70 | |
Hugo Benichi | cc6850f | 2020-01-17 13:26:06 +0900 | [diff] [blame] | 71 | // Sends a ConnectNamespaceRequest for the given namespace pid. Returns a |
| 72 | // pair with a valid ScopedFD and the ConnectNamespaceResponse proto message |
| 73 | // received if the request succeeded. Closing the ScopedFD will teardown the |
| 74 | // veth and routing setup and free the allocated IPv4 subnet. |
Jie Jiang | 81c84db | 2020-09-29 17:40:16 +0900 | [diff] [blame] | 75 | virtual std::pair<base::ScopedFD, patchpanel::ConnectNamespaceResponse> |
Hugo Benichi | cc6850f | 2020-01-17 13:26:06 +0900 | [diff] [blame] | 76 | ConnectNamespace(pid_t pid, |
| 77 | const std::string& outbound_ifname, |
Jie Jiang | 81c84db | 2020-09-29 17:40:16 +0900 | [diff] [blame] | 78 | bool forward_user_traffic) = 0; |
Hugo Benichi | cc6850f | 2020-01-17 13:26:06 +0900 | [diff] [blame] | 79 | |
Jie Jiang | 0a70acf | 2020-10-02 11:57:32 +0900 | [diff] [blame] | 80 | // Gets the traffic counters kept by patchpanel asynchronously, |callback| |
| 81 | // will be called with the counters once they are ready, or with an empty |
| 82 | // vector when an error happen. |devices| is the set of interfaces (shill |
| 83 | // devices) for which counters should be returned, any unknown interfaces will |
| 84 | // be ignored. If |devices| is empty, counters for all known interfaces will |
| 85 | // be returned. |
Jie Jiang | 81c84db | 2020-09-29 17:40:16 +0900 | [diff] [blame] | 86 | virtual void GetTrafficCounters(const std::set<std::string>& devices, |
| 87 | GetTrafficCountersCallback callback) = 0; |
Jie Jiang | e02d120 | 2020-07-27 16:57:04 +0900 | [diff] [blame] | 88 | |
Jason Jeremy Iman | 6f1f3e7 | 2020-07-06 13:04:03 +0900 | [diff] [blame] | 89 | // Sends a ModifyPortRuleRequest to modify iptables ingress rules. |
| 90 | // This should only be called by permission_broker's 'devbroker'. |
Jie Jiang | 81c84db | 2020-09-29 17:40:16 +0900 | [diff] [blame] | 91 | virtual bool ModifyPortRule(patchpanel::ModifyPortRuleRequest::Operation op, |
| 92 | patchpanel::ModifyPortRuleRequest::RuleType type, |
| 93 | patchpanel::ModifyPortRuleRequest::Protocol proto, |
| 94 | const std::string& input_ifname, |
| 95 | const std::string& input_dst_ip, |
| 96 | uint32_t input_dst_port, |
| 97 | const std::string& dst_ip, |
| 98 | uint32_t dst_port) = 0; |
Jason Jeremy Iman | 6f1f3e7 | 2020-07-06 13:04:03 +0900 | [diff] [blame] | 99 | |
Garrick Evans | 9e63798 | 2020-11-30 11:59:27 +0900 | [diff] [blame^] | 100 | // Obtains a list of NetworkDevices currently managed by patchpanel. |
| 101 | virtual std::vector<NetworkDevice> GetDevices() = 0; |
| 102 | |
Jie Jiang | 25c1b97 | 2020-11-12 15:42:53 +0900 | [diff] [blame] | 103 | // Registers a handler that will be called on receiving a neighbor |
| 104 | // reachability event. Currently these events are generated only for WiFi |
Jie Jiang | e2e4c0b | 2020-09-16 18:48:43 +0900 | [diff] [blame] | 105 | // devices. The handler is registered for as long as this patchpanel::Client |
| 106 | // instance is alive. |
Jie Jiang | 25c1b97 | 2020-11-12 15:42:53 +0900 | [diff] [blame] | 107 | virtual void RegisterNeighborReachabilityEventHandler( |
| 108 | NeighborReachabilityEventHandler handler) = 0; |
Jie Jiang | e2e4c0b | 2020-09-16 18:48:43 +0900 | [diff] [blame] | 109 | |
Jie Jiang | 81c84db | 2020-09-29 17:40:16 +0900 | [diff] [blame] | 110 | protected: |
| 111 | Client() = default; |
Garrick Evans | 0884393 | 2019-09-17 14:41:08 +0900 | [diff] [blame] | 112 | }; |
| 113 | |
| 114 | } // namespace patchpanel |
| 115 | |
Jason Jeremy Iman | adffbcb | 2020-08-31 13:21:36 +0900 | [diff] [blame] | 116 | #endif // PATCHPANEL_DBUS_CLIENT_H_ |