CC-4114: separate Liquidsoap into its own init.d script

if liquidsoap restarts, automatically notify pypo

python_apps/api_clients/api_client.cfg

@@ -117,3 +117,6 @@ get_files_without_replay_gain = 'get-files-without-replay-gain/api_key/%%api_key
 update_replay_gain_value = 'update-replay-gain-value/api_key/%%api_key%%'
 
 notify_webstream_data = 'notify-webstream-data/api_key/%%api_key%%/media_id/%%media_id%%/format/json'
+
+notify_liquidsoap_started = 'rabbitmq-do-push/api_key/%%api_key%%/format/json'
+

python_apps/api_clients/api_client.py

@@ -229,6 +229,22 @@ class AirtimeApiClient():
         except Exception, e:
             logger.error("%s", e)
 
+    def notify_liquidsoap_started(self):
+        logger = self.logger
+
+        try:
+            url = "http://%s:%s/%s/%s" % (self.config["base_url"], \
+                    str(self.config["base_port"]), \
+                    self.config["api_base"], \
+                    self.config["notify_liquidsoap_started"])
+
+            url = url.replace("%%api_key%%", self.config["api_key"])
+
+            self.get_response_from_server(url)
+        except Exception, e:
+            logger.error("Exception: %s", str(e))
+
+
     """
     This is a callback from liquidsoap, we use this to notify about the
     currently playing *song*.  We get passed a JSON string which we handed to

python_apps/pypo/airtime-liquidsoap-init-d

@@ -55,6 +55,18 @@ case "${1:-''}" in
            start
            echo "Done."
         ;;
+
+  'status')
+        if [ -f "/var/run/airtime-liquidsoap.pid" ]; then
+            pid=`cat /var/run/airtime-liquidsoap.pid`
+            if [ -d "/proc/$pid" ]; then
+                echo "Liquidsoap is running"
+                exit 0
+            fi
+        fi
+        echo "Liquidsoap is not running"
+        exit 1
+        ;;
   'start-no-monit')
            # restart commands here
            echo -n "Starting $NAME: "

python_apps/pypo/airtime-playout

@@ -25,6 +25,18 @@ export PYTHONPATH=${api_client_path}:$PYTHONPATH
 export LC_ALL=`cat /etc/default/locale | grep "LANG=" | cut -d= -f2 | tr -d "\n\""`
 export TERM=xterm
 
+
+#If Pypo is starting from scratch let's restart Liquidsoap as well. This is so
+#that the Liquidsoap queue #is emptied and we can start from a known state.
+/etc/init.d/airtime-liquidsoap status
+status="$?"
+
+if [ "$status" == "0" ]; then
+    /etc/init.d/airtime-liquidsoap restart
+else
+    /etc/init.d/airtime-liquidsoap start
+fi
+
 exec python ${pypo_path}${pypo_script} > /var/log/airtime/pypo/py-interpreter.log 2>&1
 
 # EOF

python_apps/pypo/liquidsoap_scripts/ls_script.liq

@@ -323,4 +323,6 @@ if s3_enable == true then
     output_to(s3_output, s3_type, s3_bitrate, s3_host, s3_port, s3_pass, s3_mount, s3_url, s3_description, s3_genre, s3_user, s, "3", s3_connected, s3_description)
 end
 
-#ignore(output.dummy(blank()))
+command = "/usr/lib/airtime/pypo/bin/liquidsoap_scripts/notify.sh --liquidsoap-started &"
+log(command)
+system(command)

python_apps/pypo/pyponotify.py

@@ -42,6 +42,8 @@ parser.add_option("-t", "--time", help="Liquidsoap boot up time", action="store"
 parser.add_option("-x", "--source-name", help="source connection name", metavar="source_name")
 parser.add_option("-y", "--source-status", help="source connection status", metavar="source_status")
 parser.add_option("-w", "--webstream", help="JSON metadata associated with webstream", metavar="json_data")
+parser.add_option("-n", "--liquidsoap-started", help="notify liquidsoap started", metavar="json_data", action="store_true", default=True)
+
 
 # parse options
 (options, args) = parser.parse_args()
@@ -67,6 +69,11 @@ class Notify:
     def __init__(self):
         self.api_client = api_client.AirtimeApiClient()
 
+    def notify_liquidsoap_started(self):
+        logger = logging.getLogger("notify")
+        logger.debug("Notifying server that Liquidsoap has started")
+        self.api_client.notify_liquidsoap_started()
+
     def notify_media_start_playing(self, data, media_id):
         logger = logging.getLogger("notify")
 
@@ -105,7 +112,6 @@ class Notify:
         logger.debug('#################################################')
         response = self.api_client.notify_webstream_data(data, media_id)
 
-        pass
 
 if __name__ == '__main__':
     print
@@ -140,6 +146,12 @@ if __name__ == '__main__':
             n.notify_webstream_data(options.webstream, options.media_id)
         except Exception, e:
             print e
+    elif options.liquidsoap_started:
+        try:
+            n = Notify()
+            n.notify_liquidsoap_started()
+        except Exception, e:
+            print e
     else:
         if not options.data:
             print "NOTICE: 'data' command-line argument not given."