from components.subscriptions.main import Subscription from components.subscriptions.typing import SubsDict from components.videos import VideoTuple from components.ytdlp import obtain_vid_info from pymongo.collection import Collection def analyse_video(vid_tuple: VideoTuple) -> VideoTuple: info = obtain_vid_info(vid_tuple.link) return vid_tuple._replace(analysed=True, duration_string=info["duration_string"]) def analyse_subscription(sub: Subscription) -> bool: updated = False for i, vid in enumerate(sub.videos): if not vid.analysed: sub.videos[i] = analyse_video(vid) updated = True return updated def analyse_collection(subs_collection: Collection[SubsDict]) -> int: num_updated = 0 for sub_dict in subs_collection.find(): sub = Subscription(**sub_dict) sub._collection = subs_collection if analyse_subscription(sub): sub.update_videos() num_updated += 1 return num_updated