From c9c90128977c9e63f8151056d9c28ec61e6b717f Mon Sep 17 00:00:00 2001 From: Pinapelz Date: Mon, 14 Apr 2025 12:06:18 -0700 Subject: load news data from last successful fetch in merged when sources are down --- generate.py | 31 +++++++++++++++++++++++++++++++ 1 file changed, 31 insertions(+) (limited to 'generate.py') diff --git a/generate.py b/generate.py index 35df330..d7f8c6f 100644 --- a/generate.py +++ b/generate.py @@ -2,6 +2,7 @@ Generates news JSON files """ import news_feed as feed +import requests import constants import json import os @@ -20,6 +21,11 @@ def create_merged_feed(*news_lists): sorted_feed = sorted(filtered_feed, key=lambda x: x['timestamp'], reverse=True) return sorted_feed +def fetch_json_from_url(url): + response = requests.get(url) + response.raise_for_status() + return response.json() + def attach_news_meta_data(news_data: list): return { "fetch_time": int(datetime.now().timestamp()), @@ -35,30 +41,55 @@ if __name__ == "__main__": if len(iidx_news_data) != 0: with open(OUTPUT_DIR+'/iidx_news.json', 'w') as json_file: json.dump(attach_news_meta_data(iidx_news_data), json_file) + print("IIDX Data fetched and saved.") + elif len(iidx_news_data) == 0 and os.path.exists(OUTPUT_DIR+'/iidx_news.json'): + with open(OUTPUT_DIR+'/iidx_news.json', 'r') as json_file: + iidx_news_data = json.load(json_file)['news_posts'] + print("IIDX Data not fetched, using existing data.") print("Fetching SDVX Data") sdvx_news_data = feed.get_news(constants.SOUND_VOLTEX_EXCEED_GEAR_NEWS_SITE) if len(sdvx_news_data) != 0: with open(OUTPUT_DIR+'/sdvx_news.json', 'w') as json_file: json.dump(attach_news_meta_data(sdvx_news_data), json_file) + print("SDVX Data fetched and saved.") + elif len(sdvx_news_data) == 0 and os.path.exists(OUTPUT_DIR+'/sdvx_news.json'): + with open(OUTPUT_DIR+'/sdvx_news.json', 'r') as json_file: + sdvx_news_data = json.load(json_file)['news_posts'] + print("SDVX Data not fetched, using existing data.") print("Fetching CHUNITHM JPN Data") chunithm_jp_news_data = feed.get_news(constants.CHUNITHM_JP_NEWS_SITE, constants.CHUNITHM_VERSION.VERSE) if len(chunithm_jp_news_data) != 0: with open(OUTPUT_DIR+'/chunithm_jp_news.json', 'w') as json_file: json.dump(attach_news_meta_data(chunithm_jp_news_data), json_file) + print("CHUNITHM JPN Data fetched and saved.") + elif len(chunithm_jp_news_data) == 0 and os.path.exists(OUTPUT_DIR+'/chunithm_jp_news.json'): + with open(OUTPUT_DIR+'/chunithm_jp_news.json', 'r') as json_file: + chunithm_jp_news_data = json.load(json_file)['news_posts'] + print("CHUNITHM JPN Data not fetched, using existing data.") print("Fetching MAIMAI DX JPN Data") maimaidx_jp_news_data = feed.get_news(constants.MAIMAIDX_JP_NEWS_SITE, constants.MAIMAIDX_VERSION.PRISM_PLUS) if len(maimaidx_jp_news_data) != 0: with open(OUTPUT_DIR+'/maimaidx_jp_news.json', 'w') as json_file: json.dump(attach_news_meta_data(maimaidx_jp_news_data), json_file) + print("MAIMAI DX JPN Data fetched and saved.") + elif len(maimaidx_jp_news_data) == 0 and os.path.exists(OUTPUT_DIR+'/maimaidx_jp_news.json'): + with open(OUTPUT_DIR+'/maimaidx_jp_news.json', 'r') as json_file: + maimaidx_jp_news_data = json.load(json_file)['news_posts'] + print("MAIMAI DX JPN Data not fetched, using existing data.") print("Fetching ONGEKI JPN Data") ongeki_jp_news_data = feed.get_news(constants.ONGEKI_JP_NEWS_SITE, constants.ONGEKI_VERSION.REFRESH) if len(ongeki_jp_news_data) != 0: with open(OUTPUT_DIR+'/ongeki_jp_news.json', 'w') as json_file: json.dump(attach_news_meta_data(ongeki_jp_news_data), json_file) + print("ONGEKI JPN Data fetched and saved.") + elif len(ongeki_jp_news_data) == 0 and os.path.exists(OUTPUT_DIR+'/ongeki_jp_news.json'): + with open(OUTPUT_DIR+'/ongeki_jp_news.json', 'r') as json_file: + ongeki_jp_news_data = json.load(json_file)['news_posts'] + print("ONGEKI JPN Data not fetched, using existing data.") news = create_merged_feed(iidx_news_data, sdvx_news_data, chunithm_jp_news_data, maimaidx_jp_news_data, ongeki_jp_news_data) with open(OUTPUT_DIR+'/news.json', 'w') as json_file: -- cgit v1.2.3