Skip to content

Commit

Permalink
requestDevice update
Browse files Browse the repository at this point in the history
  • Loading branch information
zakorgy committed Sep 14, 2016
1 parent 057b93f commit 359548f
Show file tree
Hide file tree
Showing 5 changed files with 136 additions and 34 deletions.
15 changes: 10 additions & 5 deletions components/net/bluetooth_thread.rs
Expand Up @@ -114,7 +114,8 @@ fn matches_filter(device: &BluetoothDevice, filter: &BluetoothScanfilter) -> boo
}
}
}
return true;

true
}

fn matches_filters(device: &BluetoothDevice, filters: &BluetoothScanfilterSequence) -> bool {
Expand Down Expand Up @@ -437,10 +438,14 @@ impl BluetoothManager {
}
let _ = session.stop_discovery();
}
let devices = self.get_and_cache_devices(&mut adapter);
let matched_devices: Vec<BluetoothDevice> = devices.into_iter()
.filter(|d| matches_filters(d, options.get_filters()))
.collect();

let mut matched_devices = self.get_and_cache_devices(&mut adapter);
if !options.is_accepting_all_devices() {
matched_devices = matched_devices.into_iter()
.filter(|d| matches_filters(d, options.get_filters()))
.collect();
}

if let Some(address) = self.select_device(matched_devices) {
let device_id = match self.address_to_id.get(&address) {
Some(id) => id.clone(),
Expand Down
34 changes: 31 additions & 3 deletions components/net_traits/bluetooth_scanfilter.rs
Expand Up @@ -28,14 +28,23 @@ pub struct BluetoothScanfilter {
name: String,
name_prefix: String,
services: ServiceUUIDSequence,
manufacturer_id: Option<u16>,
service_data_uuid: String,
}

impl BluetoothScanfilter {
pub fn new(name: String, name_prefix: String, services: Vec<String>) -> BluetoothScanfilter {
pub fn new(name: String,
name_prefix: String,
services: Vec<String>,
manufacturer_id: Option<u16>,
service_data_uuid: String)
-> BluetoothScanfilter {
BluetoothScanfilter {
name: name,
name_prefix: name_prefix,
services: ServiceUUIDSequence::new(services),
manufacturer_id: manufacturer_id,
service_data_uuid: service_data_uuid,
}
}

Expand All @@ -51,8 +60,20 @@ impl BluetoothScanfilter {
&self.services.0
}

pub fn get_manufacturer_id(&self) -> Option<u16> {
self.manufacturer_id
}

pub fn get_service_data_uuid(&self) -> &str {
&self.service_data_uuid
}

pub fn is_empty_or_invalid(&self) -> bool {
(self.name.is_empty() && self.name_prefix.is_empty() && self.get_services().is_empty()) ||
(self.name.is_empty() &&
self.name_prefix.is_empty() &&
self.get_services().is_empty() &&
self.manufacturer_id.is_none() &&
self.service_data_uuid.is_empty()) ||
self.name.len() > MAX_NAME_LENGTH ||
self.name_prefix.len() > MAX_NAME_LENGTH
}
Expand All @@ -67,7 +88,6 @@ impl BluetoothScanfilterSequence {
}

pub fn has_empty_or_invalid_filter(&self) -> bool {
self.0.is_empty() ||
self.0.iter().any(BluetoothScanfilter::is_empty_or_invalid)
}

Expand All @@ -78,6 +98,10 @@ impl BluetoothScanfilterSequence {
fn get_services_set(&self) -> HashSet<String> {
self.iter().flat_map(|filter| filter.services.get_services_set()).collect()
}

fn is_empty(&self) -> bool {
self.0.is_empty()
}
}

#[derive(Deserialize, Serialize)]
Expand All @@ -103,4 +127,8 @@ impl RequestDeviceoptions {
pub fn get_services_set(&self) -> HashSet<String> {
&self.filters.get_services_set() | &self.optional_services.get_services_set()
}

pub fn is_accepting_all_devices(&self) -> bool {
self.filters.is_empty()
}
}
76 changes: 55 additions & 21 deletions components/script/dom/bluetooth.rs
Expand Up @@ -4,8 +4,7 @@

use bluetooth_blacklist::{Blacklist, uuid_is_blacklisted};
use core::clone::Clone;
use dom::bindings::codegen::Bindings::BluetoothBinding;
use dom::bindings::codegen::Bindings::BluetoothBinding::{BluetoothMethods, BluetoothScanFilter};
use dom::bindings::codegen::Bindings::BluetoothBinding::{self, BluetoothMethods, BluetoothRequestDeviceFilter};
use dom::bindings::codegen::Bindings::BluetoothBinding::RequestDeviceOptions;
use dom::bindings::error::Error::{self, Security, Type};
use dom::bindings::error::Fallible;
Expand All @@ -21,7 +20,7 @@ use net_traits::bluetooth_scanfilter::{BluetoothScanfilter, BluetoothScanfilterS
use net_traits::bluetooth_scanfilter::{RequestDeviceoptions, ServiceUUIDSequence};
use net_traits::bluetooth_thread::{BluetoothError, BluetoothMethodMsg};

const FILTER_EMPTY_ERROR: &'static str = "'filters' member must be nonempty to find any devices.";
const FILTER_EMPTY_ERROR: &'static str = "'filters' member, if present, must be nonempty to find any devices.";
const FILTER_ERROR: &'static str = "A filter must restrict the devices in some way.";
const FILTER_NAME_TOO_LONG_ERROR: &'static str = "A 'name' or 'namePrefix' can't be longer then 29 bytes.";
// 248 is the maximum number of UTF-8 code units in a Bluetooth Device Name.
Expand All @@ -34,6 +33,8 @@ const MAX_FILTER_NAME_LENGTH: usize = 29;
const NAME_PREFIX_ERROR: &'static str = "'namePrefix', if present, must be nonempty.";
const NAME_TOO_LONG_ERROR: &'static str = "A device name can't be longer than 248 bytes.";
const SERVICE_ERROR: &'static str = "'services', if present, must contain at least one service.";
const OPTIONS_ERROR: &'static str = "Fields of 'options' conflict with each other.
Either 'acceptAllDevices' member must be true, or 'filters' member must be set to a value.";

// https://webbluetoothcg.github.io/web-bluetooth/#bluetooth
#[dom_struct]
Expand Down Expand Up @@ -62,7 +63,7 @@ impl Bluetooth {

// https://webbluetoothcg.github.io/web-bluetooth/#request-bluetooth-devices
fn request_bluetooth_devices(&self,
filters: &[BluetoothScanFilter],
filters: &Option<Vec<BluetoothRequestDeviceFilter>>,
optional_services: &Option<Vec<BluetoothServiceUUID>>)
-> Fallible<Root<BluetoothDevice>> {
let option = try!(convert_request_device_options(self.global().r(), filters, optional_services));
Expand All @@ -84,39 +85,46 @@ impl Bluetooth {
Err(Error::from(error))
},
}

}
}

fn convert_request_device_options(global: GlobalRef,
filters: &[BluetoothScanFilter],
filters: &Option<Vec<BluetoothRequestDeviceFilter>>,
optional_services: &Option<Vec<BluetoothServiceUUID>>)
-> Fallible<RequestDeviceoptions> {
if filters.is_empty() {
return Err(Type(FILTER_EMPTY_ERROR.to_owned()));
}

let mut filters_vec = vec!();
for filter in filters {
filters_vec.push(try!(canonicalize_filter(&filter, global)));
let mut uuid_filters = vec!();
if let &Some(ref filters) = filters {
if filters.is_empty() {
return Err(Type(FILTER_EMPTY_ERROR.to_owned()));
}
for filter in filters {
uuid_filters.push(try!(canonicalize_filter(&filter, global)));
}
}

let mut optional_services_vec = vec!();
let mut optional_services_uuids = vec!();
if let &Some(ref opt_services) = optional_services {
for opt_service in opt_services {
let uuid = try!(BluetoothUUID::GetService(global, opt_service.clone())).to_string();

if !uuid_is_blacklisted(uuid.as_ref(), Blacklist::All) {
optional_services_vec.push(uuid);
optional_services_uuids.push(uuid);
}
}
}

Ok(RequestDeviceoptions::new(BluetoothScanfilterSequence::new(filters_vec),
ServiceUUIDSequence::new(optional_services_vec)))
Ok(RequestDeviceoptions::new(BluetoothScanfilterSequence::new(uuid_filters),
ServiceUUIDSequence::new(optional_services_uuids)))
}

fn canonicalize_filter(filter: &BluetoothScanFilter, global: GlobalRef) -> Fallible<BluetoothScanfilter> {
if filter.services.is_none() && filter.name.is_none() && filter.namePrefix.is_none() {
return Err(Type(FILTER_ERROR.to_owned()));
fn canonicalize_filter(filter: &BluetoothRequestDeviceFilter, global: GlobalRef) -> Fallible<BluetoothScanfilter> {
if filter.services.is_none() &&
filter.name.is_none() &&
filter.namePrefix.is_none() &&
filter.manufacturerId.is_none() &&
filter.serviceDataUUID.is_none() {
return Err(Type(FILTER_ERROR.to_owned()));
}

let services_vec = match filter.services {
Expand Down Expand Up @@ -167,7 +175,24 @@ fn canonicalize_filter(filter: &BluetoothScanFilter, global: GlobalRef) -> Falli
None => String::new(),
};

Ok(BluetoothScanfilter::new(name, name_prefix, services_vec))
let manufacturer_id = filter.manufacturerId;

let service_data_uuid = match filter.serviceDataUUID {
Some(ref service_data_uuid) => {
let uuid = try!(BluetoothUUID::GetService(global, service_data_uuid.clone())).to_string();
if uuid_is_blacklisted(uuid.as_ref(), Blacklist::All) {
return Err(Security)
}
uuid
},
None => String::new(),
};

Ok(BluetoothScanfilter::new(name,
name_prefix,
services_vec,
manufacturer_id,
service_data_uuid))
}

impl From<BluetoothError> for Error {
Expand All @@ -185,6 +210,15 @@ impl From<BluetoothError> for Error {
impl BluetoothMethods for Bluetooth {
// https://webbluetoothcg.github.io/web-bluetooth/#dom-bluetooth-requestdevice
fn RequestDevice(&self, option: &RequestDeviceOptions) -> Fallible<Root<BluetoothDevice>> {
self.request_bluetooth_devices(&option.filters, &option.optionalServices)
if (option.filters.is_some() && option.acceptAllDevices) ||
(option.filters.is_none() && !option.acceptAllDevices) {
return Err(Type(OPTIONS_ERROR.to_owned()));
}

if !option.acceptAllDevices {
return self.request_bluetooth_devices(&option.filters, &option.optionalServices);
}

self.request_bluetooth_devices(&None, &option.optionalServices)
}
}
17 changes: 12 additions & 5 deletions components/script/dom/webidls/Bluetooth.webidl
Expand Up @@ -4,24 +4,31 @@

// https://webbluetoothcg.github.io/web-bluetooth/#bluetooth

dictionary BluetoothScanFilter {
dictionary BluetoothRequestDeviceFilter {
sequence<BluetoothServiceUUID> services;
DOMString name;
DOMString namePrefix;
unsigned short manufacturerId;
BluetoothServiceUUID serviceDataUUID;
};

dictionary RequestDeviceOptions {
required sequence<BluetoothScanFilter> filters;
sequence<BluetoothRequestDeviceFilter> filters;
sequence<BluetoothServiceUUID> optionalServices /*= []*/;
boolean acceptAllDevices = false;
};

[Pref="dom.bluetooth.enabled", Exposed=(Window,Worker)]
interface Bluetooth {
// Promise<BluetoothDevice> requestDevice(RequestDeviceOptions options);
[Throws]
BluetoothDevice requestDevice(RequestDeviceOptions options);
// [SecureContext]
// readonly attribute BluetoothDevice? referringDevice;
// [SecureContext]
// Promise<BluetoothDevice> requestDevice(RequestDeviceOptions options);
[Throws]
BluetoothDevice requestDevice(optional RequestDeviceOptions options);
};

// Bluetooth implements EventTarget;
// Bluetooth implements BluetoothDeviceEventHandlers;
// Bluetooth implements CharacteristicEventHandlers;
// Bluetooth implements ServiceEventHandlers;
28 changes: 28 additions & 0 deletions tests/html/bluetooth/bluetooth_request_all_devices.html
@@ -0,0 +1,28 @@
<!DOCTYPE html>
<html>
<title>Request All Devices</title>
<body>
<button type="button" onclick="onButtonClick()">Request All Devices</button>
<pre id="log"></pre>
<script src="bluetooth_functions.js"></script>
<script>
function onButtonClick() {
clear();
var options = {optionalServices: ['generic_access'], acceptAllDevices:true};
try {
log('Requesting Bluetooth Device...');
var bluetooth = window.navigator.bluetooth;
var device = bluetooth.requestDevice(options);

log('Connecting to GATT Server on device...');
var server = device.gatt.connect();

log('Getting Generic Access Service...');
var service = server.getPrimaryService('generic_access');
} catch(err) {
log(err);
}
}
</script>
</body>
</html>

0 comments on commit 359548f

Please sign in to comment.