tursom/blivedm
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

update

Browse Source
This commit is contained in:
tursom 2024-10-12 13:53:23 +08:00
parent 61e2cc76fd
commit e74ff10238
1 changed files with 18 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
live_status_ntf.py
View File

@ -84,13 +84,16 @@ class MyHandler(FileSystemEventHandler):
room: Room = get_room(event.src_path) room: Room = get_room(event.src_path)
room.position = os.path.getsize(event.src_path) room.position = os.path.getsize(event.src_path)
with open(event.src_path, "r", encoding="utf-8") as f: try:
for line in f: with open(event.src_path, "r", encoding="utf-8") as f:
try: for line in f:
data = json.loads(line) try:
except json.decoder.JSONDecodeError: data = json.loads(line)
continue except json.decoder.JSONDecodeError:
self._handle_data(data) continue
self._handle_data(data)
except UnicodeDecodeError:
pass
self._check_room_state_change(room) self._check_room_state_change(room)
@ -124,11 +127,17 @@ class MyHandler(FileSystemEventHandler):
room.state_changed = False room.state_changed = False
if room.state == 1: if room.state == 1:
msg = f"{room.db_room.liver_name} 开锅了！\nhttps://live.bilibili.com/{room.room_id}" msg = "\n".join([
f"{room.db_room.liver_name} 开锅了！",
f"https://live.bilibili.com/{room.room_id}"
])
requests.post("http://turntf:18846/notify", json={"msg": msg}) requests.post("http://turntf:18846/notify", json={"msg": msg})
elif room.state == 2: elif room.state == 2:
msg = f"{room.db_room.liver_name} 下锅了！\nhttps://live.bilibili.com/{room.room_id}" msg = "\n".join([
f"{room.db_room.liver_name} 下锅了！",
f"https://live.bilibili.com/{room.room_id}"
])
requests.post("http://turntf:18846/notify", json={"msg": msg}) requests.post("http://turntf:18846/notify", json={"msg": msg})