@@ -60,7 +60,9 @@ async def new_message(
60
60
app = self .client .app ,
61
61
)
62
62
63
- async def get_messages (self , user_id : int = None ) -> List [Message ]:
63
+ async def get_messages (
64
+ self , user_id : int = None , limit : int = 100 , offset : int = 0
65
+ ) -> List [Message ]:
64
66
"""Get messages for a user
65
67
66
68
Parameters:
@@ -74,8 +76,11 @@ async def get_messages(self, user_id: int = None) -> List[Message]:
74
76
"""
75
77
if user_id is None :
76
78
user_id = self .client .user .id
79
+ data = {"limit" : limit , "offset" : offset }
77
80
log .debug ("Getting messages for user %s" , user_id )
78
- response = await self .client .get (f"{ BASE_PATH } /{ user_id } " )
81
+ response = await self .client .get (
82
+ f"{ BASE_PATH } /personal/{ user_id } ?{ urlencode (data )} "
83
+ )
79
84
return self .client .build_list (Message , response .data )
80
85
81
86
async def send_message (
@@ -341,9 +346,7 @@ async def delete_messages(self, message_ids: List[Union[int, Message]]) -> bool:
341
346
log .debug (response )
342
347
return True
343
348
344
- async def delete_messages_from_user (
345
- self , recipient_id : int , user_id : int = None
346
- ) -> bool :
349
+ async def delete_messages_from_user (self , receiver_id : int ) -> bool :
347
350
"""Delete messages from a user
348
351
349
352
Parameters:
@@ -357,11 +360,10 @@ async def delete_messages_from_user(
357
360
``~switch.error.SwitchError``: If the messages could not be deleted
358
361
359
362
"""
360
- log .debug ("Deleting messages for user %s" , recipient_id )
361
- if user_id is None :
362
- user_id = self .client .user .id
363
-
364
- response = await self .client .delete (f"{ BASE_PATH } /{ user_id } /{ recipient_id } " )
363
+ log .debug ("Deleting messages for user %s" , receiver_id )
364
+ response = await self .client .delete (
365
+ f"{ BASE_PATH } /clear-personal-messages?receiverId={ receiver_id } "
366
+ )
365
367
return True
366
368
367
369
async def get_messages_between_users (
@@ -487,15 +489,12 @@ async def get_group_chat_history(
487
489
log .debug ("Getting group chat history for group %s" , group_id )
488
490
data = {
489
491
"communityId" : community_id ,
490
- "pageOffset " : page_offset ,
491
- "pageLimit " : page_limit ,
492
- "isChannel " : "false" ,
492
+ "offset " : page_offset ,
493
+ "limit " : page_limit ,
494
+ "groupId " : group_id ,
493
495
}
494
- if user_id is None :
495
- user_id = self .client .user .id
496
-
497
496
response = await self .client .get (
498
- f"{ BASE_PATH } /group/ { user_id } / { group_id } ?{ urlencode (data )} "
497
+ f"{ BASE_PATH } /community-messages ?{ urlencode (data )} "
499
498
)
500
499
return self .client .build_object (GroupChatHistory , response .data )
501
500
@@ -528,14 +527,11 @@ async def get_channel_chat_history(
528
527
"communityId" : community_id ,
529
528
"pageOffset" : page_offset ,
530
529
"pageLimit" : page_limit ,
531
- "isChannel " : "true" ,
530
+ "channelId " : channel_id ,
532
531
}
533
532
534
- if user_id is None :
535
- user_id = self .client .user .id
536
-
537
533
response = await self .client .get (
538
- f"{ BASE_PATH } /group/ { user_id } / { channel_id } ?{ urlencode (data )} "
534
+ f"{ BASE_PATH } /community-messages ?{ urlencode (data )} "
539
535
)
540
536
return self .client .build_object (GroupChatHistory , response .data )
541
537
0 commit comments