diff options
Diffstat (limited to 'components/script/dom/bluetooth/bluetoothremotegattserver.rs')
| -rw-r--r-- | components/script/dom/bluetooth/bluetoothremotegattserver.rs | 186 |
1 files changed, 186 insertions, 0 deletions
diff --git a/components/script/dom/bluetooth/bluetoothremotegattserver.rs b/components/script/dom/bluetooth/bluetoothremotegattserver.rs new file mode 100644 index 00000000000..1df7fc3bd4c --- /dev/null +++ b/components/script/dom/bluetooth/bluetoothremotegattserver.rs @@ -0,0 +1,186 @@ +/* This Source Code Form is subject to the terms of the Mozilla Public + * License, v. 2.0. If a copy of the MPL was not distributed with this + * file, You can obtain one at https://mozilla.org/MPL/2.0/. */ + +use std::cell::Cell; +use std::rc::Rc; + +use bluetooth_traits::{BluetoothRequest, BluetoothResponse, GATTType}; +use dom_struct::dom_struct; +use ipc_channel::ipc::IpcSender; + +use crate::dom::bindings::codegen::Bindings::BluetoothDeviceBinding::BluetoothDeviceMethods; +use crate::dom::bindings::codegen::Bindings::BluetoothRemoteGATTServerBinding::BluetoothRemoteGATTServerMethods; +use crate::dom::bindings::error::{Error, ErrorResult}; +use crate::dom::bindings::reflector::{reflect_dom_object, DomGlobal, Reflector}; +use crate::dom::bindings::root::{Dom, DomRoot}; +use crate::dom::bluetooth::{get_gatt_children, response_async, AsyncBluetoothListener}; +use crate::dom::bluetoothdevice::BluetoothDevice; +use crate::dom::bluetoothuuid::{BluetoothServiceUUID, BluetoothUUID}; +use crate::dom::globalscope::GlobalScope; +use crate::dom::promise::Promise; +use crate::realms::InRealm; +use crate::script_runtime::CanGc; + +// https://webbluetoothcg.github.io/web-bluetooth/#bluetoothremotegattserver +#[dom_struct] +pub(crate) struct BluetoothRemoteGATTServer { + reflector_: Reflector, + device: Dom<BluetoothDevice>, + connected: Cell<bool>, +} + +impl BluetoothRemoteGATTServer { + pub(crate) fn new_inherited(device: &BluetoothDevice) -> BluetoothRemoteGATTServer { + BluetoothRemoteGATTServer { + reflector_: Reflector::new(), + device: Dom::from_ref(device), + connected: Cell::new(false), + } + } + + pub(crate) fn new( + global: &GlobalScope, + device: &BluetoothDevice, + ) -> DomRoot<BluetoothRemoteGATTServer> { + reflect_dom_object( + Box::new(BluetoothRemoteGATTServer::new_inherited(device)), + global, + CanGc::note(), + ) + } + + fn get_bluetooth_thread(&self) -> IpcSender<BluetoothRequest> { + self.global().as_window().bluetooth_thread() + } + + pub(crate) fn set_connected(&self, connected: bool) { + self.connected.set(connected); + } +} + +impl BluetoothRemoteGATTServerMethods<crate::DomTypeHolder> for BluetoothRemoteGATTServer { + // https://webbluetoothcg.github.io/web-bluetooth/#dom-bluetoothremotegattserver-device + fn Device(&self) -> DomRoot<BluetoothDevice> { + DomRoot::from_ref(&self.device) + } + + // https://webbluetoothcg.github.io/web-bluetooth/#dom-bluetoothremotegattserver-connected + fn Connected(&self) -> bool { + self.connected.get() + } + + // https://webbluetoothcg.github.io/web-bluetooth/#dom-bluetoothremotegattserver-connect + #[allow(unsafe_code)] + fn Connect(&self, comp: InRealm, can_gc: CanGc) -> Rc<Promise> { + // Step 1. + let p = Promise::new_in_current_realm(comp, can_gc); + let sender = response_async(&p, self); + + // TODO: Step 3: Check if the UA is currently using the Bluetooth system. + + // TODO: Step 4: Implement activeAlgorithms internal slot for BluetoothRemoteGATTServer. + + // TODO: Step 5.1 - 5.2: Implement activeAlgorithms internal slot for BluetoothRemoteGATTServer. + + // Note: Steps 2, 5.1.1 and 5.1.3 are in components/bluetooth/lib.rs in the gatt_server_connect function. + // Steps 5.2.3 - 5.2.5 are in response function. + self.get_bluetooth_thread() + .send(BluetoothRequest::GATTServerConnect( + String::from(self.Device().Id()), + sender, + )) + .unwrap(); + // Step 5: return promise. + p + } + + // https://webbluetoothcg.github.io/web-bluetooth/#dom-bluetoothremotegattserver-disconnect + fn Disconnect(&self, can_gc: CanGc) -> ErrorResult { + // TODO: Step 1: Implement activeAlgorithms internal slot for BluetoothRemoteGATTServer. + + // Step 2. + if !self.Connected() { + return Ok(()); + } + + // Step 3. + self.Device().clean_up_disconnected_device(can_gc); + + // Step 4 - 5: + self.Device().garbage_collect_the_connection() + } + + // https://webbluetoothcg.github.io/web-bluetooth/#dom-bluetoothremotegattserver-getprimaryservice + fn GetPrimaryService(&self, service: BluetoothServiceUUID, can_gc: CanGc) -> Rc<Promise> { + // Step 1 - 2. + get_gatt_children( + self, + true, + BluetoothUUID::service, + Some(service), + String::from(self.Device().Id()), + self.Device().get_gatt().Connected(), + GATTType::PrimaryService, + can_gc, + ) + } + + // https://webbluetoothcg.github.io/web-bluetooth/#dom-bluetoothremotegattserver-getprimaryservices + fn GetPrimaryServices( + &self, + service: Option<BluetoothServiceUUID>, + can_gc: CanGc, + ) -> Rc<Promise> { + // Step 1 - 2. + get_gatt_children( + self, + false, + BluetoothUUID::service, + service, + String::from(self.Device().Id()), + self.Connected(), + GATTType::PrimaryService, + can_gc, + ) + } +} + +impl AsyncBluetoothListener for BluetoothRemoteGATTServer { + fn handle_response(&self, response: BluetoothResponse, promise: &Rc<Promise>, _can_gc: CanGc) { + match response { + // https://webbluetoothcg.github.io/web-bluetooth/#dom-bluetoothremotegattserver-connect + BluetoothResponse::GATTServerConnect(connected) => { + // Step 5.2.3 + if self.Device().is_represented_device_null() { + if let Err(e) = self.Device().garbage_collect_the_connection() { + return promise.reject_error(e); + } + return promise.reject_error(Error::Network); + } + + // Step 5.2.4. + self.connected.set(connected); + + // Step 5.2.5. + promise.resolve_native(self); + }, + // https://webbluetoothcg.github.io/web-bluetooth/#getgattchildren + // Step 7. + BluetoothResponse::GetPrimaryServices(services_vec, single) => { + let device = self.Device(); + if single { + promise.resolve_native(&device.get_or_create_service(&services_vec[0], self)); + return; + } + let mut services = vec![]; + for service in services_vec { + let bt_service = device.get_or_create_service(&service, self); + services.push(bt_service); + } + promise.resolve_native(&services); + }, + _ => promise.reject_error(Error::Type("Something went wrong...".to_owned())), + } + } +} |