Skip to content

Commit

Permalink
Merge pull request #78 from ryanplusplus/patch-1
Browse files Browse the repository at this point in the history
Allow group feeds to be subscribed to and unsubscribed from
  • Loading branch information
brentru committed Jul 19, 2021
2 parents 5efcef4 + 8749175 commit d7b1d96
Showing 1 changed file with 6 additions and 2 deletions.
8 changes: 6 additions & 2 deletions adafruit_io/adafruit_io.py
Original file line number Diff line number Diff line change
Expand Up @@ -253,12 +253,14 @@ def subscribe(self, feed_key=None, group_key=None, shared_user=None):
client.subscribe([('temperature'), ('humidity')])
"""
validate_feed_key(feed_key)
if shared_user is not None and feed_key is not None:
validate_feed_key(feed_key)
self._client.subscribe("{0}/f/{1}".format(shared_user, feed_key))
elif group_key is not None:
validate_feed_key(group_key)
self._client.subscribe("{0}/g/{1}".format(self._user, group_key))
elif feed_key is not None:
validate_feed_key(feed_key)
self._client.subscribe("{0}/f/{1}".format(self._user, feed_key))
else:
raise AdafruitIO_MQTTError("Must provide a feed_key or group_key.")
Expand Down Expand Up @@ -333,12 +335,14 @@ def unsubscribe(self, feed_key=None, group_key=None, shared_user=None):
client.unsubscribe('temperature', shared_user='adabot')
"""
validate_feed_key(feed_key)
if shared_user is not None and feed_key is not None:
validate_feed_key(feed_key)
self._client.unsubscribe("{0}/f/{1}".format(shared_user, feed_key))
elif group_key is not None:
validate_feed_key(group_key)
self._client.unsubscribe("{0}/g/{1}".format(self._user, feed_key))
elif feed_key is not None:
validate_feed_key(feed_key)
self._client.unsubscribe("{0}/f/{1}".format(self._user, feed_key))
else:
raise AdafruitIO_MQTTError("Must provide a feed_key or group_key.")
Expand Down

0 comments on commit d7b1d96

Please sign in to comment.