pstruebi/bumble_fork
1
0
Fork 0
forked from auracaster/bumble_mirror
Code Pull Requests Activity

Add connection into event emit

Browse Source
This commit is contained in:
Yuyang Huang
2023-03-24 11:16:10 -07:00
parent 4c6320f98a
commit 51ae6a5969
1 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
bumble/profiles/asha_service.py
View File

@@ -60,12 +60,12 @@ class AshaService(TemplateService):
self.psm = psm # a non-zero psm is mainly for testing purpose self.psm = psm # a non-zero psm is mainly for testing purpose
# Handler for volume control # Handler for volume control
def on_volume_write(_connection, value): def on_volume_write(connection, value):
logger.info(f'--- VOLUME Write:{value[0]}') logger.info(f'--- VOLUME Write:{value[0]}')
self.emit('volume', value[0]) self.emit('volume', connection, value[0])
# Handler for audio control commands # Handler for audio control commands
def on_audio_control_point_write(_connection, value): def on_audio_control_point_write(connection, value):
logger.info(f'--- AUDIO CONTROL POINT Write:{value.hex()}') logger.info(f'--- AUDIO CONTROL POINT Write:{value.hex()}')
opcode = value[0] opcode = value[0]
if opcode == AshaService.OPCODE_START: if opcode == AshaService.OPCODE_START:
@@ -79,6 +79,7 @@ class AshaService(TemplateService):
) )
self.emit( self.emit(
'start', 'start',
connection,
{ {
'codec': value[1], 'codec': value[1],
'audiotype': value[2], 'audiotype': value[2],
@@ -88,7 +89,7 @@ class AshaService(TemplateService):
) )
elif opcode == AshaService.OPCODE_STOP: elif opcode == AshaService.OPCODE_STOP:
logger.info('### STOP') logger.info('### STOP')
self.emit('stop') self.emit('stop', connection)
elif opcode == AshaService.OPCODE_STATUS: elif opcode == AshaService.OPCODE_STATUS:
logger.info(f'### STATUS: connected={value[1]}') logger.info(f'### STATUS: connected={value[1]}')
@@ -141,7 +142,7 @@ class AshaService(TemplateService):
def on_data(data): def on_data(data):
logging.debug(f'<<< data received:{data}') logging.debug(f'<<< data received:{data}')
self.emit('data', data) self.emit('data', channel.connection, data)
self.audio_out_data += data self.audio_out_data += data
channel.sink = on_data channel.sink = on_data