Archives/tubearchivist
2
0
Fork 0
mirror of https://github.com/tubearchivist/tubearchivist synced 2024-11-02 09:41:07 +00:00
Code Issues Projects Releases Wiki Activity

standardize prints for PostData mapper

Browse Source
This commit is contained in:
simon 2022-05-02 18:39:54 +07:00
parent ca5b00a373
commit 8a4c50779a
No known key found for this signature in database
GPG Key ID: 2C15AA5E89985DD4
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
tubearchivist/home/src/frontend/api_calls.py
View File

@ -111,7 +111,7 @@ class PostData:
def _ignore(self): def _ignore(self):
"""ignore from download queue""" """ignore from download queue"""
video_id = self.exec_val video_id = self.exec_val
print(f"ignore video {video_id}") print(f"{video_id}: ignore video from download queue")
PendingInteract(video_id=video_id, status="ignore").update_status() PendingInteract(video_id=video_id, status="ignore").update_status()
# also clear from redis queue # also clear from redis queue
RedisQueue().clear_item(video_id) RedisQueue().clear_item(video_id)
@ -123,7 +123,7 @@ class PostData:
print("download pending") print("download pending")
running = download_pending.delay() running = download_pending.delay()
task_id = running.id task_id = running.id
print("set task id: " + task_id) print(f"{task_id}: set task id")
RedisArchivist().set_message("dl_queue_id", task_id, expire=False) RedisArchivist().set_message("dl_queue_id", task_id, expire=False)
return {"success": True} return {"success": True}
@ -146,7 +146,7 @@ class PostData:
def _unsubscribe(self): def _unsubscribe(self):
"""unsubscribe from channels or playlists""" """unsubscribe from channels or playlists"""
id_unsub = self.exec_val id_unsub = self.exec_val
print("unsubscribe from " + id_unsub) print(f"{id_unsub}: unsubscribe")
to_unsub_list = UrlListParser(id_unsub).process_list() to_unsub_list = UrlListParser(id_unsub).process_list()
for to_unsub in to_unsub_list: for to_unsub in to_unsub_list:
unsub_type = to_unsub["type"] unsub_type = to_unsub["type"]
@ -167,7 +167,7 @@ class PostData:
def _subscribe(self): def _subscribe(self):
"""subscribe to channel or playlist, called from js buttons""" """subscribe to channel or playlist, called from js buttons"""
id_sub = self.exec_val id_sub = self.exec_val
print("subscribe to " + id_sub) print(f"{id_sub}: subscribe")
subscribe_to.delay(id_sub) subscribe_to.delay(id_sub)
return {"success": True} return {"success": True}
@ -203,7 +203,7 @@ class PostData:
def _dlnow(self): def _dlnow(self):
"""start downloading single vid now""" """start downloading single vid now"""
youtube_id = self.exec_val youtube_id = self.exec_val
print("downloading: " + youtube_id) print(f"{youtube_id}: downloading now")
running = download_single.delay(youtube_id=youtube_id) running = download_single.delay(youtube_id=youtube_id)
task_id = running.id task_id = running.id
print("set task id: " + task_id) print("set task id: " + task_id)
@ -222,14 +222,14 @@ class PostData:
def _forget_ignore(self): def _forget_ignore(self):
"""delete from ta_download index""" """delete from ta_download index"""
video_id = self.exec_val video_id = self.exec_val
print(f"forgetting from download index: {video_id}") print(f"{video_id}: forget from download")
PendingInteract(video_id=video_id).delete_item() PendingInteract(video_id=video_id).delete_item()
return {"success": True} return {"success": True}
def _add_single(self): def _add_single(self):
"""add single youtube_id to download queue""" """add single youtube_id to download queue"""
video_id = self.exec_val video_id = self.exec_val
print(f"add vid to dl queue: {video_id}") print(f"{video_id}: add single vid to download queue")
PendingInteract(video_id=video_id).delete_item() PendingInteract(video_id=video_id).delete_item()
video_ids = UrlListParser(video_id).process_list() video_ids = UrlListParser(video_id).process_list()
extrac_dl.delay(video_ids) extrac_dl.delay(video_ids)