get recording streamers

main
oscar 1 month ago
parent 81a79f7305
commit cb1cb6a494

@ -7,6 +7,10 @@ from config import get_local_db_connection
api = Blueprint("api", __name__) api = Blueprint("api", __name__)
import requests
SESSION = requests.Session()
SESSION.trust_env = False # ignore system proxies
@api.route('/open-folder', methods=['POST']) @api.route('/open-folder', methods=['POST'])
def open_folder(): def open_folder():
data = request.json data = request.json
@ -52,7 +56,7 @@ def delete_file():
os.remove(file_path) os.remove(file_path)
conn, cur = get_local_db_connection() 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() conn.commit()
cur.close(); conn.close() cur.close(); conn.close()
@ -81,15 +85,9 @@ def api_add_moment(video_id):
@api.route("/api/get_recording/", methods=["GET"]) @api.route("/api/get_recording/", methods=["GET"])
def get_online(): def get_online():
url = 'http://localhost:8000/get_streamers' url = "http://127.0.0.1:8000/get_streamers" # force IPv4
r = SESSION.get(url, timeout=1) # small timeout
import requests streamers = r.json().get("streamers", [])
r = requests.get(url) for s in streamers:
streamers = r.json()['streamers'] s["is_online"] = (s.get("status") == "Channel online")
return jsonify(streamers)
parsed_streamers = []
for streamer in streamers:
streamer['is_online'] = streamer['status'] == 'Channel online'
parsed_streamers.append(streamer)
return jsonify(parsed_streamers)

Loading…
Cancel
Save