diff options
author | Kyomotoi <[email protected]> | 2022-06-18 00:24:13 +0800 |
---|---|---|
committer | Kyomotoi <[email protected]> | 2022-06-18 00:24:13 +0800 |
commit | c1576c50f5acf1dd7f5d6730eae9d3d251fed954 (patch) | |
tree | 5c9d4304ff07a3b91cc0ea65d3e27310ec8abb5c /ATRI/plugins/bilibili_dynamic/data_source.py | |
parent | f6b5e9aec639fe279c5c5ab70f5c4e534ddc3b45 (diff) | |
download | ATRI-c1576c50f5acf1dd7f5d6730eae9d3d251fed954.tar.gz ATRI-c1576c50f5acf1dd7f5d6730eae9d3d251fed954.tar.bz2 ATRI-c1576c50f5acf1dd7f5d6730eae9d3d251fed954.zip |
♿️💩 优化用户体验, 优化代码
Diffstat (limited to 'ATRI/plugins/bilibili_dynamic/data_source.py')
-rw-r--r-- | ATRI/plugins/bilibili_dynamic/data_source.py | 25 |
1 files changed, 14 insertions, 11 deletions
diff --git a/ATRI/plugins/bilibili_dynamic/data_source.py b/ATRI/plugins/bilibili_dynamic/data_source.py index 3327179..64045e3 100644 --- a/ATRI/plugins/bilibili_dynamic/data_source.py +++ b/ATRI/plugins/bilibili_dynamic/data_source.py @@ -18,7 +18,6 @@ _OUTPUT_FORMAT = """ {up_nickname} 的{up_dy_type}更新了! (限制 {limit_content} 字) {up_dy_content} -{up_dy_media} 链接: {up_dy_link} """.strip() @@ -38,21 +37,21 @@ class BilibiliDynamicSubscriptor(Service): try: async with DB() as db: await db.add_sub(uid, group_id) - except BilibiliDynamicError: + except Exception: raise BilibiliDynamicError("添加订阅失败") async def update_sub(self, uid: int, group_id: int, update_map: dict): try: async with DB() as db: await db.update_sub(uid, group_id, update_map) - except BilibiliDynamicError: + except Exception: raise BilibiliDynamicError("更新订阅失败") async def del_sub(self, uid: int, group_id: int): try: async with DB() as db: await db.del_sub({"uid": uid, "group_id": group_id}) - except BilibiliDynamicError: + except Exception: raise BilibiliDynamicError("删除订阅失败") async def get_sub_list(self, uid: int = int(), group_id: int = int()) -> list: @@ -64,14 +63,14 @@ class BilibiliDynamicSubscriptor(Service): try: async with DB() as db: return await db.get_sub_list(query_map) - except BilibiliDynamicError: + except Exception: raise BilibiliDynamicError("获取订阅列表失败") async def get_all_subs(self) -> list: try: async with DB() as db: return await db.get_all_subs() - except BilibiliDynamicError: + except Exception: raise BilibiliDynamicError("获取全部订阅列表失败") async def get_up_nickname(self, uid: int) -> str: @@ -147,23 +146,27 @@ class BilibiliDynamicSubscriptor(Service): result.append(pattern) return sorted(result, key=itemgetter("timestamp")) - def gen_output(self, data: dict, limit_content: int = 100) -> str: + def gen_output(self, data: dict, content_limit) -> str: """生成动态信息 Args: data (dict): dict形式的动态数据. - limit_content (int, optional): 内容字数限制. 默认 100. + limit_content (int, optional): 内容字数限制. Returns: str: 动态信息 """ + if not content_limit: + content = data["content"] + else: + content = data["content"][:content_limit] + return _OUTPUT_FORMAT.format( up_nickname=data["name"], up_dy_type=data["type_zh"], - limit_content=limit_content, - up_dy_content=str(data["content"][:limit_content]) + limit_content=content_limit, + up_dy_content=str(content) .replace("https://", str()) .replace("http://", str()), - up_dy_media=MessageSegment.image(data["pic"]) if data.get("pic") else str(), up_dy_link="https://t.bilibili.com/" + str(data["dynamic_id"]), ) |