diff --git a/routes/api.py b/routes/api.py index de6d7b8..e2ebeac 100644 --- a/routes/api.py +++ b/routes/api.py @@ -7,6 +7,10 @@ from config import get_local_db_connection api = Blueprint("api", __name__) +import requests +SESSION = requests.Session() +SESSION.trust_env = False # ignore system proxies + @api.route('/open-folder', methods=['POST']) def open_folder(): data = request.json @@ -52,7 +56,7 @@ def delete_file(): os.remove(file_path) conn, cur = get_local_db_connection() - cur.execute("UPDATE videos SET status = 'missing' WHERE video_id = %s", (video_id,)) + cur.execute("UPDATE videos SET status = 'deleted' WHERE video_id = %s", (video_id,)) conn.commit() cur.close(); conn.close() @@ -81,15 +85,9 @@ def api_add_moment(video_id): @api.route("/api/get_recording/", methods=["GET"]) def get_online(): - url = 'http://localhost:8000/get_streamers' - - import requests - r = requests.get(url) - streamers = r.json()['streamers'] - - parsed_streamers = [] - for streamer in streamers: - streamer['is_online'] = streamer['status'] == 'Channel online' - parsed_streamers.append(streamer) - - return jsonify(parsed_streamers) \ No newline at end of file + url = "http://127.0.0.1:8000/get_streamers" # force IPv4 + r = SESSION.get(url, timeout=1) # small timeout + streamers = r.json().get("streamers", []) + for s in streamers: + s["is_online"] = (s.get("status") == "Channel online") + return jsonify(streamers)