Skip to content

Commit

Permalink
feat: enable serialPort.revoke()
Browse files Browse the repository at this point in the history
  • Loading branch information
codebytere committed Aug 30, 2022
1 parent 75f9573 commit 6c038fd
Show file tree
Hide file tree
Showing 7 changed files with 138 additions and 54 deletions.
12 changes: 12 additions & 0 deletions docs/api/session.md
Original file line number Diff line number Diff line change
Expand Up @@ -385,6 +385,18 @@ callback from `select-serial-port` is called. This event is intended for use
when using a UI to ask users to pick a port so that the UI can be updated
to remove the specified port.
#### Event: 'serial-port-revoked'
Returns:
* `event` Event
* `details` Object
* `origin` string (optional) - The origin that the device has been revoked from.
Emitted after `serialPort.forget()` has been called. This event can be used
to help maintain persistent storage of permissions when
`setDevicePermissionHandler` is used.
### Instance Methods
The following methods are available on instances of `Session`:
Expand Down
26 changes: 14 additions & 12 deletions shell/browser/serial/electron_serial_delegate.cc
Original file line number Diff line number Diff line change
Expand Up @@ -61,6 +61,20 @@ bool ElectronSerialDelegate::HasPortPermission(
frame);
}

void ElectronSerialDelegate::RevokePortPermissionWebInitiated(
content::RenderFrameHost* frame,
const base::UnguessableToken& token) {
auto* web_contents = content::WebContents::FromRenderFrameHost(frame);
return GetChooserContext(frame)->RevokePortPermissionWebInitiated(
web_contents->GetPrimaryMainFrame()->GetLastCommittedOrigin(), token);
}

const device::mojom::SerialPortInfo* ElectronSerialDelegate::GetPortInfo(
content::RenderFrameHost* frame,
const base::UnguessableToken& token) {
return GetChooserContext(frame)->GetPortInfo(token);
}

device::mojom::SerialPortManager* ElectronSerialDelegate::GetPortManager(
content::RenderFrameHost* frame) {
return GetChooserContext(frame)->GetPortManager();
Expand All @@ -79,18 +93,6 @@ void ElectronSerialDelegate::RemoveObserver(content::RenderFrameHost* frame,
observer_list_.RemoveObserver(observer);
}

void ElectronSerialDelegate::RevokePortPermissionWebInitiated(
content::RenderFrameHost* frame,
const base::UnguessableToken& token) {
// TODO(nornagon/jkleinsc): pass this on to the chooser context
}

const device::mojom::SerialPortInfo* ElectronSerialDelegate::GetPortInfo(
content::RenderFrameHost* frame,
const base::UnguessableToken& token) {
return GetChooserContext(frame)->GetPortInfo(token);
}

SerialChooserController* ElectronSerialDelegate::ControllerForFrame(
content::RenderFrameHost* render_frame_host) {
auto mapping = controller_map_.find(render_frame_host);
Expand Down
12 changes: 6 additions & 6 deletions shell/browser/serial/electron_serial_delegate.h
Original file line number Diff line number Diff line change
Expand Up @@ -35,18 +35,18 @@ class ElectronSerialDelegate : public content::SerialDelegate,
bool CanRequestPortPermission(content::RenderFrameHost* frame) override;
bool HasPortPermission(content::RenderFrameHost* frame,
const device::mojom::SerialPortInfo& port) override;
device::mojom::SerialPortManager* GetPortManager(
content::RenderFrameHost* frame) override;
void AddObserver(content::RenderFrameHost* frame,
Observer* observer) override;
void RemoveObserver(content::RenderFrameHost* frame,
Observer* observer) override;
void RevokePortPermissionWebInitiated(
content::RenderFrameHost* frame,
const base::UnguessableToken& token) override;
const device::mojom::SerialPortInfo* GetPortInfo(
content::RenderFrameHost* frame,
const base::UnguessableToken& token) override;
device::mojom::SerialPortManager* GetPortManager(
content::RenderFrameHost* frame) override;
void AddObserver(content::RenderFrameHost* frame,
Observer* observer) override;
void RemoveObserver(content::RenderFrameHost* frame,
Observer* observer) override;

void DeleteControllerForFrame(content::RenderFrameHost* render_frame_host);

Expand Down
97 changes: 77 additions & 20 deletions shell/browser/serial/serial_chooser_context.cc
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,6 @@ namespace electron {

constexpr char kPortNameKey[] = "name";
constexpr char kTokenKey[] = "token";

#if BUILDFLAG(IS_WIN)
const char kDeviceInstanceIdKey[] = "device_instance_id";
#else
Expand Down Expand Up @@ -56,35 +55,35 @@ base::UnguessableToken DecodeToken(base::StringPiece input) {
}

base::Value PortInfoToValue(const device::mojom::SerialPortInfo& port) {
base::Value value(base::Value::Type::DICTIONARY);
base::Value::Dict value;
if (port.display_name && !port.display_name->empty())
value.SetStringKey(kPortNameKey, *port.display_name);
value.Set(kPortNameKey, *port.display_name);
else
value.SetStringKey(kPortNameKey, port.path.LossyDisplayName());
value.Set(kPortNameKey, port.path.LossyDisplayName());

if (!SerialChooserContext::CanStorePersistentEntry(port)) {
value.SetStringKey(kTokenKey, EncodeToken(port.token));
return value;
value.Set(kTokenKey, EncodeToken(port.token));
return base::Value(std::move(value));
}

#if BUILDFLAG(IS_WIN)
// Windows provides a handy device identifier which we can rely on to be
// sufficiently stable for identifying devices across restarts.
value.SetStringKey(kDeviceInstanceIdKey, port.device_instance_id);
value.Set(kDeviceInstanceIdKey, port.device_instance_id);
#else
DCHECK(port.has_vendor_id);
value.SetIntKey(kVendorIdKey, port.vendor_id);
value.Set(kVendorIdKey, port.vendor_id);
DCHECK(port.has_product_id);
value.SetIntKey(kProductIdKey, port.product_id);
value.Set(kProductIdKey, port.product_id);
DCHECK(port.serial_number);
value.SetStringKey(kSerialNumberKey, *port.serial_number);
value.Set(kSerialNumberKey, *port.serial_number);

#if BUILDFLAG(IS_MAC)
DCHECK(port.usb_driver_name && !port.usb_driver_name->empty());
value.SetStringKey(kUsbDriverKey, *port.usb_driver_name);
value.Set(kUsbDriverKey, *port.usb_driver_name);
#endif // BUILDFLAG(IS_MAC)
#endif // BUILDFLAG(IS_WIN)
return value;
return base::Value(std::move(value));
}

SerialChooserContext::SerialChooserContext(ElectronBrowserContext* context)
Expand All @@ -105,18 +104,33 @@ void SerialChooserContext::GrantPortPermission(
content::RenderFrameHost* render_frame_host) {
port_info_.insert({port.token, port.Clone()});

auto* permission_manager = static_cast<ElectronPermissionManager*>(
browser_context_->GetPermissionControllerDelegate());
return permission_manager->GrantDevicePermission(
static_cast<blink::PermissionType>(
WebContentsPermissionHelper::PermissionType::SERIAL),
origin, PortInfoToValue(port), browser_context_);
if (CanStorePersistentEntry(port)) {
auto* permission_manager = static_cast<ElectronPermissionManager*>(
browser_context_->GetPermissionControllerDelegate());
permission_manager->GrantDevicePermission(
static_cast<blink::PermissionType>(
WebContentsPermissionHelper::PermissionType::SERIAL),
origin, PortInfoToValue(port), browser_context_);
return;
}

ephemeral_ports_[origin].insert(port.token);
}

bool SerialChooserContext::HasPortPermission(
const url::Origin& origin,
const device::mojom::SerialPortInfo& port,
content::RenderFrameHost* render_frame_host) {
auto it = ephemeral_ports_.find(origin);
if (it != ephemeral_ports_.end()) {
const std::set<base::UnguessableToken> ports = it->second;
if (base::Contains(ports, port.token))
return true;
}

if (!CanStorePersistentEntry(port))
return false;

auto* permission_manager = static_cast<ElectronPermissionManager*>(
browser_context_->GetPermissionControllerDelegate());
return permission_manager->CheckDevicePermission(
Expand All @@ -129,8 +143,23 @@ void SerialChooserContext::RevokePortPermissionWebInitiated(
const url::Origin& origin,
const base::UnguessableToken& token) {
auto it = port_info_.find(token);
if (it == port_info_.end())
return;
if (it != port_info_.end()) {
auto* permission_manager = static_cast<ElectronPermissionManager*>(
browser_context_->GetPermissionControllerDelegate());
permission_manager->RevokeDevicePermission(
static_cast<blink::PermissionType>(
WebContentsPermissionHelper::PermissionType::SERIAL),
origin, PortInfoToValue(*it->second), browser_context_);
}

auto ephemeral = ephemeral_ports_.find(origin);
if (ephemeral != ephemeral_ports_.end()) {
std::set<base::UnguessableToken>& ports = ephemeral->second;
ports.erase(token);
}

for (auto& observer : port_observer_list_)
observer.OnPermissionRevoked(origin);
}

// static
Expand Down Expand Up @@ -204,7 +233,21 @@ void SerialChooserContext::OnPortRemoved(
for (auto& observer : port_observer_list_)
observer.OnPortRemoved(*port);

std::vector<url::Origin> revoked_origins;
for (auto& map_entry : ephemeral_ports_) {
std::set<base::UnguessableToken>& ports = map_entry.second;
if (ports.erase(port->token) > 0) {
revoked_origins.push_back(map_entry.first);
}
}

port_info_.erase(port->token);

for (auto& observer : port_observer_list_) {
for (const auto& origin : revoked_origins) {
observer.OnPermissionRevoked(origin);
}
}
}

void SerialChooserContext::EnsurePortManagerConnection() {
Expand Down Expand Up @@ -239,6 +282,20 @@ void SerialChooserContext::OnGetDevices(
void SerialChooserContext::OnPortManagerConnectionError() {
port_manager_.reset();
client_receiver_.reset();

port_info_.clear();

std::vector<url::Origin> revoked_origins;
revoked_origins.reserve(ephemeral_ports_.size());
for (const auto& map_entry : ephemeral_ports_)
revoked_origins.push_back(map_entry.first);
ephemeral_ports_.clear();

// Notify observers that all ephemeral permissions have been revoked.
for (auto& observer : port_observer_list_) {
for (const auto& origin : revoked_origins)
observer.OnPermissionRevoked(origin);
}
}

} // namespace electron
31 changes: 16 additions & 15 deletions shell/browser/serial/serial_chooser_context.h
Original file line number Diff line number Diff line change
Expand Up @@ -67,41 +67,42 @@ class SerialChooserContext : public KeyedService,
bool HasPortPermission(const url::Origin& origin,
const device::mojom::SerialPortInfo& port,
content::RenderFrameHost* render_frame_host);
void RevokePortPermissionWebInitiated(const url::Origin& origin,
const base::UnguessableToken& token);
static bool CanStorePersistentEntry(
const device::mojom::SerialPortInfo& port);

// Only call this if you're sure |port_info_| has been initialized
// before-hand. The returned raw pointer is owned by |port_info_| and will be
// destroyed when the port is removed.
const device::mojom::SerialPortInfo* GetPortInfo(
const base::UnguessableToken& token);

device::mojom::SerialPortManager* GetPortManager();

void AddPortObserver(PortObserver* observer);
void RemovePortObserver(PortObserver* observer);

base::WeakPtr<SerialChooserContext> AsWeakPtr();

bool is_initialized_ = false;

// Map from port token to port info.
std::map<base::UnguessableToken, device::mojom::SerialPortInfoPtr> port_info_;

// SerialPortManagerClient implementation.
void OnPortAdded(device::mojom::SerialPortInfoPtr port) override;
void OnPortRemoved(device::mojom::SerialPortInfoPtr port) override;
void RevokePortPermissionWebInitiated(const url::Origin& origin,
const base::UnguessableToken& token);
// Only call this if you're sure |port_info_| has been initialized
// before-hand. The returned raw pointer is owned by |port_info_| and will be
// destroyed when the port is removed.
const device::mojom::SerialPortInfo* GetPortInfo(
const base::UnguessableToken& token);

private:
void EnsurePortManagerConnection();
void SetUpPortManagerConnection(
mojo::PendingRemote<device::mojom::SerialPortManager> manager);
void OnGetDevices(std::vector<device::mojom::SerialPortInfoPtr> ports);
void OnPortManagerConnectionError();
void RevokeObjectPermissionInternal(const url::Origin& origin,
const base::Value& object,
bool revoked_by_website);

bool is_initialized_ = false;

// Tracks the set of ports to which an origin has access to.
std::map<url::Origin, std::set<base::UnguessableToken>> ephemeral_ports_;

// Map from port token to port info.
std::map<base::UnguessableToken, device::mojom::SerialPortInfoPtr> port_info_;

mojo::Remote<device::mojom::SerialPortManager> port_manager_;
mojo::Receiver<device::mojom::SerialPortManagerClient> client_receiver_{this};
Expand Down
12 changes: 12 additions & 0 deletions shell/browser/serial/serial_chooser_controller.cc
Original file line number Diff line number Diff line change
Expand Up @@ -114,6 +114,18 @@ void SerialChooserController::OnPortRemoved(
}
}

void SerialChooserController::OnPermissionRevoked(const url::Origin& origin) {
api::Session* session = GetSession();
if (session) {
v8::Isolate* isolate = JavascriptEnvironment::GetIsolate();
v8::HandleScope scope(isolate);
gin_helper::Dictionary details =
gin_helper::Dictionary::CreateEmpty(isolate);
details.Set("origin", origin.Serialize());
session->Emit("serial-port-revoked", details);
}
}

void SerialChooserController::OnPortManagerConnectionError() {
observation_.Reset();
}
Expand Down
2 changes: 1 addition & 1 deletion shell/browser/serial/serial_chooser_controller.h
Original file line number Diff line number Diff line change
Expand Up @@ -47,7 +47,7 @@ class SerialChooserController final : public SerialChooserContext::PortObserver,
void OnPortAdded(const device::mojom::SerialPortInfo& port) override;
void OnPortRemoved(const device::mojom::SerialPortInfo& port) override;
void OnPortManagerConnectionError() override;
void OnPermissionRevoked(const url::Origin& origin) override {}
void OnPermissionRevoked(const url::Origin& origin) override;
void OnSerialChooserContextShutdown() override;

private:
Expand Down

0 comments on commit 6c038fd

Please sign in to comment.