Skip to content

Commit

Permalink
Add update group end point (#84)
Browse files Browse the repository at this point in the history
Allow updating the group data, including the group name, avatar, description and expiration time.
  • Loading branch information
Era-Dorta authored Jan 4, 2025
1 parent 7d7398f commit 6986a82
Show file tree
Hide file tree
Showing 2 changed files with 54 additions and 0 deletions.
37 changes: 37 additions & 0 deletions signalbot/api.py
Original file line number Diff line number Diff line change
Expand Up @@ -185,6 +185,40 @@ async def update_contact(
):
raise ContactUpdateError

async def update_group(
self,
group_id: str,
base64_avatar: Optional[str] = None,
description: Optional[str] = None,
expiration_in_seconds: Optional[int] = None,
name: Optional[str] = None,
) -> None:
uri = self._group_id_uri(group_id)
payload = {}

if base64_avatar is not None:
payload["base64_avatar"] = base64_avatar

if description is not None:
payload["description"] = description

if expiration_in_seconds is not None:
payload["expiration_time"] = expiration_in_seconds

if name is not None:
payload["name"] = name

try:
async with aiohttp.ClientSession() as session:
resp = await session.put(uri, json=payload)
resp.raise_for_status()
return resp
except (
aiohttp.ClientError,
aiohttp.http_exceptions.HttpProcessingError,
):
raise ContactUpdateError

def _attachment_rest_uri(self):
return f"http://{self.signal_service}/v1/attachments"

Expand All @@ -203,6 +237,9 @@ def _typing_indicator_uri(self):
def _groups_uri(self):
return f"http://{self.signal_service}/v1/groups/{self.phone_number}"

def _group_id_uri(self, group_id: str):
return self._groups_uri() + "/" + group_id

def _contacts_uri(self):
return f"http://{self.signal_service}/v1/contacts/{self.phone_number}"

Expand Down
17 changes: 17 additions & 0 deletions signalbot/bot.py
Original file line number Diff line number Diff line change
Expand Up @@ -236,6 +236,23 @@ async def update_contact(
receiver, expiration_in_seconds=expiration_in_seconds, name=name
)

async def update_group(
self,
group_id: str,
base64_avatar: Optional[str] = None,
description: Optional[str] = None,
expiration_in_seconds: Optional[int] = None,
name: Optional[str] = None,
) -> None:
group_id = self._resolve_receiver(group_id)
await self._signal.update_group(
group_id,
base64_avatar=base64_avatar,
description=description,
expiration_in_seconds=expiration_in_seconds,
name=name,
)

async def _detect_groups(self):
# reset group lookups to avoid stale data
self.groups = await self._signal.get_groups()
Expand Down

0 comments on commit 6986a82

Please sign in to comment.