From 51ae6a5969a39ada3dbf4c12b95e597f9fe54cad Mon Sep 17 00:00:00 2001 From: Yuyang Huang Date: Fri, 24 Mar 2023 11:16:10 -0700 Subject: [PATCH] Add connection into event emit --- bumble/profiles/asha_service.py | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/bumble/profiles/asha_service.py b/bumble/profiles/asha_service.py index c44e8a04..60278fc7 100644 --- a/bumble/profiles/asha_service.py +++ b/bumble/profiles/asha_service.py @@ -60,12 +60,12 @@ class AshaService(TemplateService): self.psm = psm # a non-zero psm is mainly for testing purpose # Handler for volume control - def on_volume_write(_connection, value): + def on_volume_write(connection, value): logger.info(f'--- VOLUME Write:{value[0]}') - self.emit('volume', value[0]) + self.emit('volume', connection, value[0]) # 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()}') opcode = value[0] if opcode == AshaService.OPCODE_START: @@ -79,6 +79,7 @@ class AshaService(TemplateService): ) self.emit( 'start', + connection, { 'codec': value[1], 'audiotype': value[2], @@ -88,7 +89,7 @@ class AshaService(TemplateService): ) elif opcode == AshaService.OPCODE_STOP: logger.info('### STOP') - self.emit('stop') + self.emit('stop', connection) elif opcode == AshaService.OPCODE_STATUS: logger.info(f'### STATUS: connected={value[1]}') @@ -141,7 +142,7 @@ class AshaService(TemplateService): def on_data(data): logging.debug(f'<<< data received:{data}') - self.emit('data', data) + self.emit('data', channel.connection, data) self.audio_out_data += data channel.sink = on_data