Skip to content

Commit bcf97e3

Browse files
committed
Enhance message retrieval: update receive_text and get_message functions to support additional parameters for improved flexibility
1 parent c255da6 commit bcf97e3

3 files changed

Lines changed: 13 additions & 8 deletions

File tree

StealthIM/apis/message.py

Lines changed: 8 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -100,12 +100,15 @@ async def get_message(
100100
session: str,
101101
groupid: int,
102102
from_id: int,
103-
direction: int
103+
old_to_new: bool,
104+
sync: bool,
105+
limit: int = 128,
104106
):
105-
# noinspection PyStatementEffect
106-
direction # currently unused
107-
108-
api_address = f'{url}/api/v1/message/{groupid}?msgid={from_id}'
107+
assert 0 <= limit <= 256, "Limit must be between 0 and 256"
108+
api_address = (
109+
f'{url}/api/v1/message/{groupid}?'
110+
f'msgid={from_id}&prev={"false" if old_to_new else "true"}&sync={"true" if sync else "false"}&limit={limit}'
111+
)
109112
logger.debug(f"Called API get_message with url {api_address}")
110113
headers = {
111114
"Authorization": f"Bearer {session}",

StealthIM/group.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -88,13 +88,15 @@ async def send_text(self, message: str) -> SendMessageResult:
8888
StealthIM.apis.message.MessageType.Text
8989
)
9090

91-
async def receive_text(self, from_id: int = 0):
91+
async def receive_text(self, from_id: int = 0, old_to_new: bool = True, sync: bool = True, limit: int = 128):
9292
gen = StealthIM.apis.message.get_message(
9393
self.user.server.url,
9494
self.user.session,
9595
self.group_id,
9696
from_id,
97-
0
97+
old_to_new,
98+
sync,
99+
limit
98100
)
99101
async for data in gen:
100102
yield data

pyproject.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta"
44

55
[project]
66
name = "stealthimpysdk" # pip 安装名
7-
version = "0.1.3" # 版本
7+
version = "0.1.4" # 版本
88
description = "The SDK for StealthIM"
99
readme = "README.md"
1010
license = {file = "LICENSE"}

0 commit comments

Comments
 (0)