tubearchivist
/
tubearchivist
mirror of https://github.com/tubearchivist/tubearchivist.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

fix incomplete messages outside of sendprogress task method

This commit is contained in:
Simon 2023-08-31 12:16:42 +07:00
parent 4afb605736
commit 52d6c59f3f
No known key found for this signature in database
GPG Key ID: 2C15AA5E89985DD4
3 changed files with 16 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
tubearchivist/home/src/download/subscriptions.py
View File

@ -12,7 +12,6 @@ from home.src.index.channel import YoutubeChannel
from home.src.index.playlist import YoutubePlaylist from home.src.index.playlist import YoutubePlaylist
from home.src.index.video_constants import VideoTypeEnum from home.src.index.video_constants import VideoTypeEnum
from home.src.ta.config import AppConfig from home.src.ta.config import AppConfig
from home.src.ta.ta_redis import RedisArchivist
from home.src.ta.urlparser import Parser from home.src.ta.urlparser import Parser
@ -197,16 +196,13 @@ class PlaylistSubscription:
thumb = ThumbManager(playlist_id, item_type="playlist") thumb = ThumbManager(playlist_id, item_type="playlist")
thumb.download_playlist_thumb(url) thumb.download_playlist_thumb(url)
# notify if self.task:
message = { self.task.send_progress(
"status": "message:subplaylist", message_lines=[
"level": "info", f"Processing {idx + 1} of {len(new_playlists)}"
"title": "Subscribing to Playlists", ],
"message": f"Processing {idx + 1} of {len(new_playlists)}", progress=(idx + 1) / len(new_playlists),
} )
RedisArchivist().set_message(
"message:subplaylist", message=message, expire=True
)
@staticmethod @staticmethod
def channel_validate(channel_id): def channel_validate(channel_id):

10
tubearchivist/home/src/ta/config.py
View File

@ -205,10 +205,11 @@ class ScheduleBuilder:
except ValueError: except ValueError:
print(f"failed: {key} {value}") print(f"failed: {key} {value}")
mess_dict = { mess_dict = {
"status": self.MSG, "group": "setting:schedule",
"level": "error", "level": "error",
"title": "Scheduler update failed.", "title": "Scheduler update failed.",
"message": "Invalid schedule input", "messages": ["Invalid schedule input"],
"id": "0000",
} }
RedisArchivist().set_message( RedisArchivist().set_message(
self.MSG, mess_dict, expire=True self.MSG, mess_dict, expire=True
@ -227,10 +228,11 @@ class ScheduleBuilder:
RedisArchivist().set_message("config", redis_config, save=True) RedisArchivist().set_message("config", redis_config, save=True)
mess_dict = { mess_dict = {
"status": self.MSG, "group": "setting:schedule",
"level": "info", "level": "info",
"title": "Scheduler changed.", "title": "Scheduler changed.",
"message": "Please restart container for changes to take effect", "messages": ["Restart container for changes to take effect"],
"id": "0000",
} }
RedisArchivist().set_message(self.MSG, mess_dict, expire=True) RedisArchivist().set_message(self.MSG, mess_dict, expire=True)

4
tubearchivist/home/views.py
View File

@ -1104,9 +1104,11 @@ class SettingsApplicationView(MinView):
key = "message:setting" key = "message:setting"
message = { message = {
"status": key, "status": key,
"group": "setting:application",
"level": "error", "level": "error",
"title": "Cookie import failed", "title": "Cookie import failed",
"message": message_line, "messages": [message_line],
"id": "0000",
} }
RedisArchivist().set_message(key, message=message, expire=True) RedisArchivist().set_message(key, message=message, expire=True)