tubearchivist/tubearchivist-frontend
1
0
Fork 0
mirror of https://github.com/tubearchivist/tubearchivist-frontend.git synced 2024-11-22 20:00:15 +00:00
Code Issues Projects Releases Wiki Activity

add autodelete videos to ignore list, #112

Browse Source
This commit is contained in:
simon 2021-12-17 23:28:53 +07:00
parent f36ae6c4b9
commit ad8d75c3e8
No known key found for this signature in database
GPG Key ID: 2C15AA5E89985DD4
1 changed files with 13 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
tubearchivist/home/src/download.py
View File

@ -75,7 +75,7 @@ class PendingList:
return missing_videos return missing_videos
def add_to_pending(self, missing_videos): def add_to_pending(self, missing_videos, ignore=False):
"""build the bulk json data from pending""" """build the bulk json data from pending"""
# check if channel is indexed # check if channel is indexed
channel_handler = ChannelSubscription() channel_handler = ChannelSubscription()
@ -84,7 +84,7 @@ class PendingList:
# check if already there # check if already there
self.all_downloaded = self.get_all_downloaded() self.all_downloaded = self.get_all_downloaded()
bulk_list, all_videos_added = self.build_bulk(missing_videos) bulk_list, all_videos_added = self.build_bulk(missing_videos, ignore)
# add last newline # add last newline
bulk_list.append("\n") bulk_list.append("\n")
query_str = "\n".join(bulk_list) query_str = "\n".join(bulk_list)
@ -99,7 +99,7 @@ class PendingList:
return all_videos_added return all_videos_added
def build_bulk(self, missing_videos): def build_bulk(self, missing_videos, ignore=False):
"""build the bulk lists""" """build the bulk lists"""
bulk_list = [] bulk_list = []
all_videos_added = [] all_videos_added = []
@ -116,7 +116,10 @@ class PendingList:
channel_indexed = video["channel_id"] in self.all_channel_ids channel_indexed = video["channel_id"] in self.all_channel_ids
video["channel_indexed"] = channel_indexed video["channel_indexed"] = channel_indexed
video["status"] = "pending" if ignore:
video["status"] = "ignore"
else:
video["status"] = "pending"
action = {"create": {"_id": youtube_id, "_index": "ta_download"}} action = {"create": {"_id": youtube_id, "_index": "ta_download"}}
bulk_list.append(json.dumps(action)) bulk_list.append(json.dumps(action))
bulk_list.append(json.dumps(video)) bulk_list.append(json.dumps(video))
@ -790,8 +793,12 @@ class VideoDownloader:
"sort": [{"player.watched_date": {"order": "asc"}}], "sort": [{"player.watched_date": {"order": "asc"}}],
} }
all_to_delete = IndexPaginate("ta_video", data).get_results() all_to_delete = IndexPaginate("ta_video", data).get_results()
all_youtube_ids = [i["youtube_id"] for i in all_to_delete]
for to_delete in all_to_delete: for youtube_id in all_youtube_ids:
youtube_id = to_delete["youtube_id"]
print(f"autodelete {youtube_id}") print(f"autodelete {youtube_id}")
YoutubeVideo(youtube_id).delete_media_file() YoutubeVideo(youtube_id).delete_media_file()
print("add deleted to ignore list")
pending_handler = PendingList()
pending_handler.add_to_pending(all_youtube_ids, ignore=True)