diff options
Diffstat (limited to 'bluetooth.py')
| -rw-r--r-- | bluetooth.py | 64 |
1 files changed, 48 insertions, 16 deletions
diff --git a/bluetooth.py b/bluetooth.py index 13ab0c9..c5394bb 100644 --- a/bluetooth.py +++ b/bluetooth.py @@ -1,10 +1,12 @@ import asyncio +import json +import os from random import randint from aglbaseservice import AGLBaseService Verbs = ['subscribe', 'unsubscribe', 'managed_objects', 'adapter_state', 'default_adapter', 'avrcp_controls', 'connect', 'disconnect', 'pair', 'cancel_pairing', 'confirm_pairing', 'remove_device'] - +AdapterStateParams = ['discovery', 'discoverable', 'powered', ] BTEventType = ['adapter_changes', 'device_changes', 'media', 'agent'] class BluetoothService(AGLBaseService): @@ -12,27 +14,30 @@ class BluetoothService(AGLBaseService): def __init__(self, ip, port): super().__init__(api='Bluetooth-Manager', ip=ip, port=port) - async def subscribe(self, event='location'): - super().subscribe(event=event) + async def subscribe(self, event='device_changes'): + await super().subscribe(event=event) - async def unsubscribe(self, event='location'): - super().unsubscribe(event=event) + async def unsubscribe(self, event='device_changes'): + await super().unsubscribe(event=event) async def managed_objects(self): verb = 'managed_objects' msgid = randint(0, 999999) msg = f'[2,"{msgid}","{self.api}/{verb}",""]' - print(msg) + # print(msg) await self.send(msg) return await self.receive() - async def adapter_state(self, param = None, value = None): + async def adapter_state(self, param=None, value=None): verb = 'adapter_state' msgid = randint(0, 999999) if param: - p = str({'adapter': param}) + p = {'adapter': param} + if isinstance(value, dict): + p = {**p, **value} + # msg = f'[2,"{msgid}","{self.api}/{verb}","{param}": {value if value is not None else ""}]' - msg = f'[2,"{msgid}","{self.api}/{verb}", {p}]' + msg = f'[2,"{msgid}","{self.api}/{verb}", {json.dumps(p)}]' else: msg = f'[2,"{msgid}","{self.api}/{verb}", ""]' @@ -44,21 +49,48 @@ class BluetoothService(AGLBaseService): verb = 'default_adapter' msgid = randint(0, 999999) msg = f'[2,"{msgid}","{self.api}/{verb}",""]' - print(msg) + # print(msg) await self.send(msg) return await self.receive() async def avrcp_controls(self): pass + async def connect(self, device): + verb = 'connect' + msgid = randint(0, 999999) + d = {'device': device} + msg = f'[2,"{msgid}","{self.api}/{verb}","{json.dumps(d)}"]' + + async def disconnect(self, device): + verb = 'disconnect' + msgid = randint(0, 999999) + d = {'device': device} + msg = f'[2,"{msgid}","{self.api}/{verb}","{json.dumps(d)}"]' + + async def pair(self, device): + verb = 'pair' + msgid = randint(0, 999999) + d = {'device': device} + msg = f'[2,"{msgid}","{self.api}/{verb}","{json.dumps(d)}"]' + + async def cancel_pairing(self): + verb = 'cancel_pairing' + msgid = randint(0, 999999) + msg = f'[2,"{msgid}","{self.api}/{verb}",""]' + + async def confirm_pairing(self, pincode): + verb = 'confirm_pairing' + msgid = randint(0, 999999) + d = {'pincode': pincode} + msg = f'[2,"{msgid}","{self.api}/{verb}","{json.dumps(d)}"]' async def main(loop): - BTS = await BluetoothService(ip='192.168.234.202', port='30005') - #print(await BTS.managed_objects()) - print(await BTS.adapter_state('hci0', '{"discoverable": true}')) - await asyncio.sleep(delay=1) - print(await BTS.adapter_state('hci0')) - print(await BTS.adapter_state('hci1', '""')) + addr = os.environ.get('AGL_TGT_IP', 'localhost') + port = os.environ.get('AGL_TGT_PORT', '30005') + + BTS = await BluetoothService(ip=addr, port=port) + print(await BTS.adapter_state('hci1', {'uuids': ['0000110e-0000-1000-8000-00805f9b34fb']})) if __name__ == '__main__': loop = asyncio.get_event_loop() |