Requests

conjurer_musician/conjurer_musician.py

@@ -390,7 +390,11 @@ def add_request():
         record["lista_slow"], 0, app.logger, False
     )
 
-    #push to queue item[1]
+    with open(
+        "/home/pi/Conjurer/request.playlist", "a", encoding="utf-8"
+    ) as s_file:
+        for item in return_data:
+            s_file.write(item[1] + "\n")
     return_data = (
         jsonify(isError=False, message="Success", statusCode=200, data={"status": "OK"}),
         200,
@@ -398,6 +402,7 @@ def add_request():
     return return_data
 
 
+
 @app.route("/add_to_priority", methods=["POST"])
 def add_to_priority():
     """

conjurer_musician/radio_conjurer.liq

@@ -22,7 +22,13 @@ let json.parse credentials  = file.contents("/home/pi/Conjurer/icecast_credentia
     s1 = replaygain(playlist(reload_mode="watch", check_next=check, "/home/pi/Conjurer/all_playlist.playlist"))
     s2 = replaygain(playlist(reload_mode="watch", check_next=check, "/home/pi/Conjurer/priority_queue.playlist"))
     s3 = replaygain(playlist(reload_mode="watch", check_next=check, "/home/pi/Conjurer/hit.playlist"))
-    #requests_queue = request.queue()
+    requests_queue = request.queue()
+    def queue_processing()
+        requests_queue.push.uri("/home/pi/Conjurer/request.playlist"),
+        file.remove("/home/pi/Conjurer/requests_queue.playlist"),
+        file.touch("/home/pi/Conjurer/requests_queue.playlist")
+    end
+    thread.run(every=60., {queue_processing()})
 
     # Randomly select a playlist with weights
     s = random(id="randomizer", weights=[1, 3, 2], [s1, s2, s3])

install_music_bot.sh

@@ -16,6 +16,8 @@ touch /home/pi/Conjurer/all_playlist.playlist
 touch /home/pi/Conjurer/priority_queue.playlist
 touch /home/pi/Conjurer/hit.playlist
 touch /home/pi/Conjurer/request.playlist
+touch /home/pi/Conjurer/persistence.log
+echo "[]" > /home/pi/Conjurer/persistence.log
 
 touch /home/pi/Conjurer/radio_log.log
 ./env/bin/python3 -m pip install --upgrade pip