Skip to content

Commit

Permalink
feat: add support for show_deleted_message in getMessage
Browse files Browse the repository at this point in the history
  • Loading branch information
guerinoni committed Mar 4, 2024
1 parent debd699 commit f5c1da6
Show file tree
Hide file tree
Showing 3 changed files with 14 additions and 3 deletions.
6 changes: 5 additions & 1 deletion stream_chat/async_chat/client.py
Original file line number Diff line number Diff line change
Expand Up @@ -332,7 +332,11 @@ async def update_message_partial(
async def delete_message(self, message_id: str, **options: Any) -> StreamResponse:
return await self.delete(f"messages/{message_id}", options)

async def get_message(self, message_id: str) -> StreamResponse:
async def get_message(
self, message_id: str, show_deleted_message: bool = False
) -> StreamResponse:
if show_deleted_message:
return await self.get(f"messages/{message_id}?show_deleted_message=true")
return await self.get(f"messages/{message_id}")

async def query_users(
Expand Down
5 changes: 4 additions & 1 deletion stream_chat/base/client.py
Original file line number Diff line number Diff line change
Expand Up @@ -516,10 +516,13 @@ def delete_message(

@abc.abstractmethod
def get_message(
self, message_id: str
self,
message_id: str,
show_deleted_message: bool = False,
) -> Union[StreamResponse, Awaitable[StreamResponse]]:
"""
Returns a single message.
If the msg is deleted and you want to retrieve it, you can pass the show_deleted_message.
"""
pass

Expand Down
6 changes: 5 additions & 1 deletion stream_chat/client.py
Original file line number Diff line number Diff line change
Expand Up @@ -321,7 +321,11 @@ def update_message_partial(
def delete_message(self, message_id: str, **options: Any) -> StreamResponse:
return self.delete(f"messages/{message_id}", options)

def get_message(self, message_id: str) -> StreamResponse:
def get_message(
self, message_id: str, show_deleted_message=False
) -> StreamResponse:
if show_deleted_message:
return self.get(f"messages/{message_id}?show_deleted_message=true")
return self.get(f"messages/{message_id}")

def query_users(
Expand Down

0 comments on commit f5c1da6

Please sign in to comment.