From 22cc362f1c2198530dbbf085ec5701a2822656a2 Mon Sep 17 00:00:00 2001
From: Martin Konecny <martin.konecny@gmail.com>
Date: Sat, 17 Mar 2012 23:51:58 -0400
Subject: [PATCH] CC-3448: Cancel show shouldn't send "cancel show" msg to pypo
 anymore

-done
---
 .../controllers/ScheduleController.php        |  8 +++-----
 airtime_mvc/application/models/Show.php       |  3 ---
 python_apps/pypo/pypofetch.py                 | 20 +------------------
 python_apps/pypo/pypomessagehandler.py        |  3 ---
 python_apps/pypo/pypopush.py                  |  6 ++++--
 5 files changed, 8 insertions(+), 32 deletions(-)

diff --git a/airtime_mvc/application/controllers/ScheduleController.php b/airtime_mvc/application/controllers/ScheduleController.php
index 57c285835..583f97f49 100644
--- a/airtime_mvc/application/controllers/ScheduleController.php
+++ b/airtime_mvc/application/controllers/ScheduleController.php
@@ -778,15 +778,13 @@ class ScheduleController extends Zend_Controller_Action
 
 		    try {
                 $showInstance = new Application_Model_ShowInstance($showInstanceId);
-		    }
-		    catch(Exception $e){
+		    } catch(Exception $e) {
                 $this->view->show_error = true;
                 return false;
             }
             $show = new Application_Model_Show($showInstance->getShowId());
 
             $show->cancelShow($showInstance->getShowInstanceStart());
-
             $this->view->show_id = $showInstance->getShowId();
         }
     }
@@ -806,8 +804,8 @@ class ScheduleController extends Zend_Controller_Action
             }
             $showInstance->clearShow();
             $showInstance->delete();
-            // send 'cancel-current-show' command to pypo
-            Application_Model_RabbitMq::SendMessageToPypo("cancel_current_show", array());
+
+            Application_Model_RabbitMq::PushSchedule();
         }
     }
 
diff --git a/airtime_mvc/application/models/Show.php b/airtime_mvc/application/models/Show.php
index 60549df7a..762ace161 100644
--- a/airtime_mvc/application/models/Show.php
+++ b/airtime_mvc/application/models/Show.php
@@ -199,9 +199,6 @@ class Application_Model_Show {
             ->filterByDbShowId($this->_showId)
             ->update(array('DbLastShow' => $timeinfo[0]));
 
-        //$sql = "DELETE FROM cc_show_instances
-        //            WHERE starts >= '{$day_timestamp}' AND show_id = {$this->_showId}";
-
         $sql = "UPDATE cc_show_instances
                 SET modified_instance = TRUE
                     WHERE starts >= '{$day_timestamp}' AND show_id = {$this->_showId}";
diff --git a/python_apps/pypo/pypofetch.py b/python_apps/pypo/pypofetch.py
index be4bf1625..4bca99a32 100644
--- a/python_apps/pypo/pypofetch.py
+++ b/python_apps/pypo/pypofetch.py
@@ -82,9 +82,6 @@ class PypoFetch(Thread):
             elif command == 'update_station_name':
                 self.logger.info("Updating station name...")
                 self.update_liquidsoap_station_name(m['station_name'])
-            elif command == 'cancel_current_show':
-                self.logger.info("Cancel current show command received...")
-                self.stop_current_show()
             elif command == 'switch_source':
                 self.logger.info("switch_on_source show command received...")
                 self.switch_source(m['sourcename'], m['status'])
@@ -152,22 +149,7 @@ class PypoFetch(Thread):
         self.logger.debug('switch_status:%s',switch_status)
         for k, v in switch_status['status'].iteritems():
             self.switch_source(k, v)
-        
-    def stop_current_show(self):
-        self.logger.debug('Notifying Liquidsoap to stop playback.')
-        
-        self.telnet_lock.acquire()
-        try:
-            tn = telnetlib.Telnet(LS_HOST, LS_PORT)
-            tn.write('source.skip\n')
-            tn.write('exit\n')
-            tn.read_all()
-        except Exception, e:
-            self.logger.debug(e)
-            self.logger.debug('Could not connect to liquidsoap')
-        finally:
-            self.telnet_lock.release()
-    
+            
     def regenerateLiquidsoapConf(self, setting_p):
         existing = {}
         # create a temp file
diff --git a/python_apps/pypo/pypomessagehandler.py b/python_apps/pypo/pypomessagehandler.py
index d3f62777d..2fa11af95 100644
--- a/python_apps/pypo/pypomessagehandler.py
+++ b/python_apps/pypo/pypomessagehandler.py
@@ -70,9 +70,6 @@ class PypoMessageHandler(Thread):
             elif command == 'update_station_name':
                 self.logger.info("Updating station name...")
                 self.pypo_queue.put(message)
-            elif command == 'cancel_current_show':
-                self.logger.info("Cancel current show command received...")
-                self.pypo_queue.put(message)
             elif command == 'switch_source':
                 self.logger.info("switch_source command received...")
                 self.pypo_queue.put(message)
diff --git a/python_apps/pypo/pypopush.py b/python_apps/pypo/pypopush.py
index 67a27337f..52848b1ba 100644
--- a/python_apps/pypo/pypopush.py
+++ b/python_apps/pypo/pypopush.py
@@ -270,6 +270,7 @@ class PypoPush(Thread):
                 self.telnet_lock.acquire()
                 tn = telnetlib.Telnet(LS_HOST, LS_PORT)
                 msg = "queue.remove %s\n" % queue_id
+                self.logger.debug(msg)
                 tn.write(msg)
                 response = tn.read_until("\r\n").strip("\r\n")
                 
@@ -278,8 +279,9 @@ class PypoPush(Thread):
                     Cannot remove because Liquidsoap started playing the item. Need
                     to use source.skip instead
                     """
-                    msg = "source.skip"
-                    tn.write("source.skip")
+                    msg = "source.skip\n"
+                    self.logger.debug(msg)
+                    tn.write(msg)
                     
                 tn.write("exit\n")
                 tn.read_all()