aboutsummaryrefslogtreecommitdiff
path: root/interact/a2dp.py
diff options
context:
space:
mode:
Diffstat (limited to 'interact/a2dp.py')
-rw-r--r--interact/a2dp.py51
1 files changed, 51 insertions, 0 deletions
diff --git a/interact/a2dp.py b/interact/a2dp.py
new file mode 100644
index 0000000..66d46de
--- /dev/null
+++ b/interact/a2dp.py
@@ -0,0 +1,51 @@
+from grpc import Channel
+
+from blueberry.a2dp_grpc import A2DP
+from blueberry.host_grpc import Host
+
+from blueberry.a2dp_pb2 import Sink, Source
+from blueberry.host_pb2 import Connection
+
+_connection: Connection = None;
+_sink: Sink = None;
+_source: Source = None;
+
+def interact(channel: Channel, interaction_id: str, test: str, pts_addr: bytes):
+ global _connection, _sink, _source;
+ a2dp = A2DP(channel)
+ host = Host(channel)
+ if interaction_id == "TSC_AVDTP_mmi_iut_accept_connect":
+ host.SetConnectable(connectable=True)
+ elif interaction_id == "TSC_AVDTP_mmi_iut_initiate_start":
+ _connection = host.Connect(address=pts_addr).connection
+ if "SNK" in test:
+ _sink = a2dp.OpenSink(connection=_connection).sink
+ elif interaction_id == "TSC_AVDTP_mmi_iut_initiate_out_of_range":
+ if not _connection:
+ _connection = Connection(cookie=pts_addr)
+ host.Disconnect(connection=_connection)
+ _connection = None
+ _sink = None
+ _source = None
+ elif interaction_id == "TSC_AVDTP_mmi_iut_accept_discover":
+ pass
+ elif interaction_id == "TSC_AVDTP_mmi_iut_initiate_set_configuration":
+ _connection = host.Connect(address=pts_addr).connection
+ if "SRC" in test:
+ _source = a2dp.OpenSource(connection=_connection).source
+ elif interaction_id == "TSC_AVDTP_mmi_iut_accept_close_stream":
+ pass
+ elif interaction_id == "TSC_AVDTP_mmi_iut_accept_get_capabilities":
+ pass
+ elif interaction_id == "TSC_AVDTP_mmi_iut_accept_set_configuration":
+ pass
+ elif interaction_id == "TSC_AVDTP_mmi_iut_accept_open_stream":
+ pass
+ elif interaction_id == "TSC_AVDTP_mmi_iut_accept_start":
+ pass
+ elif interaction_id == "TSC_AVDTP_mmi_iut_confirm_streaming":
+ pass
+ elif interaction_id == "TSC_AVDTP_mmi_iut_accept_reconnect":
+ pass
+ else:
+ print(f'MMI NOT IMPLEMENTED: {interaction_id}') \ No newline at end of file