summaryrefslogtreecommitdiffstats
path: root/bluetooth.py
diff options
context:
space:
mode:
authorEdi Feschiyan <edi.feschiyan@konsulko.com>2020-03-09 17:57:09 +0200
committerEdi Feschiyan <edi.feschiyan@konsulko.com>2020-03-09 17:57:09 +0200
commitba673345466a365adb107a32dc4143390d4032eb (patch)
tree783e6e32b4e1e946199445664d9ac50f04d57320 /bluetooth.py
parent5ef7f0b592e609775352ad41c3fd656b10f86d24 (diff)
Began work for bluetooth binding
Diffstat (limited to 'bluetooth.py')
-rw-r--r--bluetooth.py65
1 files changed, 65 insertions, 0 deletions
diff --git a/bluetooth.py b/bluetooth.py
new file mode 100644
index 0000000..13ab0c9
--- /dev/null
+++ b/bluetooth.py
@@ -0,0 +1,65 @@
+import asyncio
+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']
+
+BTEventType = ['adapter_changes', 'device_changes', 'media', 'agent']
+
+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 unsubscribe(self, event='location'):
+ 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)
+ await self.send(msg)
+ return await self.receive()
+
+ async def adapter_state(self, param = None, value = None):
+ verb = 'adapter_state'
+ msgid = randint(0, 999999)
+ if param:
+ p = str({'adapter': param})
+ # msg = f'[2,"{msgid}","{self.api}/{verb}","{param}": {value if value is not None else ""}]'
+ msg = f'[2,"{msgid}","{self.api}/{verb}", {p}]'
+ else:
+ msg = f'[2,"{msgid}","{self.api}/{verb}", ""]'
+
+ print(msg)
+ await self.send(msg)
+ return await self.receive()
+
+ async def default_adapter(self):
+ verb = 'default_adapter'
+ msgid = randint(0, 999999)
+ msg = f'[2,"{msgid}","{self.api}/{verb}",""]'
+ print(msg)
+ await self.send(msg)
+ return await self.receive()
+
+ async def avrcp_controls(self):
+ pass
+
+
+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', '""'))
+
+if __name__ == '__main__':
+ loop = asyncio.get_event_loop()
+ loop.run_until_complete(main(loop)) \ No newline at end of file