From 7dc53ef6b434d68c097e204bed425142c415dc4b Mon Sep 17 00:00:00 2001 From: Migatu Date: Thu, 18 Apr 2024 01:34:16 +0200 Subject: [PATCH] Formatting of conjurer_musician --- conjurer_musician/conjurer_musician.py | 32 +++++++++++++++----------- 1 file changed, 19 insertions(+), 13 deletions(-) diff --git a/conjurer_musician/conjurer_musician.py b/conjurer_musician/conjurer_musician.py index 4b8b815..fc0742e 100644 --- a/conjurer_musician/conjurer_musician.py +++ b/conjurer_musician/conjurer_musician.py @@ -41,6 +41,7 @@ if platform in ("linux", "linux2"): music_file_list = [] priority_list = [] + def create_playlist(): """ Reads a JSON file containing a playlist and writes the playlist items to a text file. @@ -65,9 +66,7 @@ def create_playlist(): pass with open("/home/pi/Conjurer/prio_playlist.json", "r+", encoding="utf-8") as r_file: - with open( - "/home/pi/Conjurer/hit.playlist", "w", encoding="utf-8" - ) as w_file: + with open("/home/pi/Conjurer/hit.playlist", "w", encoding="utf-8") as w_file: try: playlist = json.load(r_file) for item in playlist: @@ -228,7 +227,9 @@ def wyszukaj(word_list, how_many, _logger=None, return_to_bot=True): return_list.append(search_weight[itr]) if not return_to_bot: with open( - "/home/pi/Conjurer/priority_queue.playlist", "r+", encoding="utf-8" + "/home/pi/Conjurer/priority_queue.playlist", + "r+", + encoding="utf-8", ) as s_file: s_file.write(search_weight[itr][1]) break @@ -240,7 +241,7 @@ def wyszukaj(word_list, how_many, _logger=None, return_to_bot=True): if not return_to_bot: with open( - "/home/pi/Conjurer/priority_queue.playlist", "a", encoding="utf-8" + "/home/pi/Conjurer/priority_queue.playlist", "a", encoding="utf-8" ) as s_file: for item in return_list: s_file.write(item[1] + "\n") @@ -280,12 +281,13 @@ def stream_music(): """ The function `stream_music` is a route handler for the "/stream" endpoint. It returns a JSON response containing a key "music_file_list" with the value of the variable `music_file_list`. - + :return: A JSON response containing a key "music_file_list" with the value of the variable `music_file_list`. """ return send_from_directory("/tmp/hls", "stream.m3u8") -@app.route('/') + +@app.route("/") def stream(file_name): """ Stream the specified file from the video directory. @@ -296,7 +298,7 @@ def stream(file_name): Returns: Response: The response containing the streamed file. """ - video_dir = '/tmp/hls' + video_dir = "/tmp/hls" return send_from_directory(video_dir, file_name) @@ -320,13 +322,12 @@ def clear_pr_pls(): """ with open( "/home/pi/Conjurer/priority_queue.playlist", "w", encoding="utf-8" - ) as s_file: + ) as s_file: s_file.truncate(0) return_data = jsonify(isError=False, message="Success", statusCode=200, data=[]) return return_data, 200 - @app.route("/mp3", methods=["GET"]) def get_music_list(): """ @@ -374,7 +375,9 @@ def look_for_playlist(): app.logger.info(record["lista_slow"]) app.logger.info(record["UUID"]) app.logger.info(record["dlugosc_plejlisty"]) - return_data = wyszukaj(record["lista_slow"], record["dlugosc_plejlisty"], app.logger, True) + return_data = wyszukaj( + record["lista_slow"], record["dlugosc_plejlisty"], app.logger, True + ) return_data = ( jsonify(isError=False, message="Success", statusCode=200, data=return_data), @@ -382,6 +385,7 @@ def look_for_playlist(): ) return return_data + @app.route("/add_to_priority", methods=["POST"]) def add_to_priority(): """ @@ -398,7 +402,9 @@ def add_to_priority(): app.logger.info(record["lista_slow"]) app.logger.info(record["UUID"]) app.logger.info(record["dlugosc_plejlisty"]) - return_data = wyszukaj(record["lista_slow"], record["dlugosc_plejlisty"], app.logger, False) + return_data = wyszukaj( + record["lista_slow"], record["dlugosc_plejlisty"], app.logger, False + ) return_data = ( jsonify(isError=False, message="Success", statusCode=200, data=return_data), @@ -453,7 +459,7 @@ if __name__ == "__main__": rescan() logger.info("Started") threads = [] - #threads.append(threading.Thread(target=flask_debug)) + # threads.append(threading.Thread(target=flask_debug)) threads.append(threading.Thread(target=waitress_run)) threads.append(threading.Thread(target=thread_rescan))