fix #580

Merge pull request #579 from jmdietrich-gcx/unsubscribe_characteristic_in_gatt_client
Remove characteristic in GATT Client unsubscribe() if it's the last subscriber
2024-11-02 10:29:40 -07:00 · 2024-10-31 04:07:02 -07:00 · 2024-10-31 11:04:25 +00:00 · 2024-10-31 03:44:01 -07:00 · 2024-10-31 18:11:40 +08:00 · 2024-10-30 07:34:22 +01:00
4 changed files with 12 additions and 3 deletions
--- a/bumble/gatt_client.py
+++ b/bumble/gatt_client.py
@@ -898,6 +898,12 @@ class Client:
                ) and subscriber in subscribers:
                    subscribers.remove(subscriber)

+                    # The characteristic itself is added as subscriber. If it is the
+                    # last remaining subscriber, we remove it, such that the clean up
+                    # works correctly. Otherwise the CCCD never is set back to 0.
+                    if len(subscribers) == 1 and characteristic in subscribers:
+                        subscribers.remove(characteristic)
+
                    # Cleanup if we removed the last one
                    if not subscribers:
                        del subscriber_set[characteristic.handle]
--- a/bumble/profiles/bap.py
+++ b/bumble/profiles/bap.py
@@ -102,6 +102,7 @@ class ContextType(enum.IntFlag):

    # fmt: off
    PROHIBITED       = 0x0000
+    UNSPECIFIED      = 0x0001
    CONVERSATIONAL   = 0x0002
    MEDIA            = 0x0004
    GAME             = 0x0008
--- a/bumble/smp.py
+++ b/bumble/smp.py
@@ -1839,7 +1839,7 @@ class Session:
        if self.is_initiator:
            if self.pairing_method == PairingMethod.OOB:
                self.send_pairing_random_command()
-            else:
+            elif self.pairing_method == PairingMethod.PASSKEY:
                self.send_pairing_confirm_command()
        else:
            if self.pairing_method == PairingMethod.PASSKEY:
--- a/bumble/transport/common.py
+++ b/bumble/transport/common.py
@@ -370,11 +370,13 @@ class PumpedPacketSource(ParserSource):
                    self.parser.feed_data(packet)
                except asyncio.CancelledError:
                    logger.debug('source pump task done')
-                    self.terminated.set_result(None)
+                    if not self.terminated.done():
+                        self.terminated.set_result(None)
                    break
                except Exception as error:
                    logger.warning(f'exception while waiting for packet: {error}')
-                    self.terminated.set_exception(error)
+                    if not self.terminated.done():
+                        self.terminated.set_exception(error)
                    break

        self.pump_task = asyncio.create_task(pump_packets())
Author	SHA1	Message	Date
Gilles Boccon-Gibod	b2864dac2d	fix #580	2024-11-02 10:29:40 -07:00
Gilles Boccon-Gibod	b78f895143	Merge pull request #579 from jmdietrich-gcx/unsubscribe_characteristic_in_gatt_client Remove characteristic in GATT Client unsubscribe() if it's the last subscriber	2024-10-31 04:07:02 -07:00
zxzxwu	c4e9726828	Merge pull request #581 from zxzxwu/context [BAP] Add missing Unspecified context type	2024-10-31 11:04:25 +00:00
Gilles Boccon-Gibod	d4b8e8348a	Merge pull request #574 from google/gbg/update-python-versions remove test for deprecated Python 3.8 and add 3.13	2024-10-31 03:44:01 -07:00
Josh Wu	19debaa52e	[BAP] Add missing Unspecified context type	2024-10-31 18:11:40 +08:00
Jan-Marcel Dietrich	73fe564321	Remove characteristic in GATT Client unsubscribe() if it's the last subscriber GATT Client's subscribe() adds the characteristic itself as subscriber. Therefore the characteristic has to be removed in unsubscribe(), if it's the last subscriber. Otherwise the clean up does not work correctly and the CCCD never is set back to 0 in the remote device.	2024-10-30 07:34:22 +01:00