cc-5709: Airtime Analyzer

airtime_mvc/application/configs/airtime-conf.php

@@ -1,6 +1,6 @@
 <?php
 // This file generated by Propel 1.5.2 convert-conf target
-// from XML runtime conf file /home/denise/airtime/airtime_mvc/build/runtime-conf.xml
+// from XML runtime conf file /home/ubuntu/airtime/airtime_mvc/build/runtime-conf.xml
 $conf = array (
   'datasources' => 
   array (
@@ -12,6 +12,14 @@
         'dsn' => 'pgsql:host=localhost;port=5432;dbname=airtime;user=airtime;password=airtime',
       ),
     ),
+    'airtime_test' => 
+    array (
+      'adapter' => 'pgsql',
+      'connection' => 
+      array (
+        'dsn' => 'pgsql:host=localhost;port=5432;dbname=airtime_test;user=airtime;password=airtime',
+      ),
+    ),
     'default' => 'airtime',
   ),
   'generator_version' => '1.5.2',

airtime_mvc/application/configs/application.ini

@@ -6,6 +6,10 @@ bootstrap.class = "Bootstrap"
 appnamespace = "Application"
 resources.frontController.controllerDirectory = APPLICATION_PATH "/controllers"
 resources.frontController.params.displayExceptions = 0
+resources.frontController.moduleDirectory = APPLICATION_PATH "/modules"
+resources.frontController.plugins.putHandler = "Zend_Controller_Plugin_PutHandler"
+;load everything in the modules directory including models
+resources.modules[] = ""
 resources.layout.layoutPath = APPLICATION_PATH "/layouts/scripts/"
 resources.view[] =
 resources.db.adapter = "Pdo_Pgsql"

airtime_mvc/application/controllers/ApiController.php

@@ -453,6 +453,8 @@ public function recordedShowsAction()
 
     public function uploadFileAction()
     {
+        Logging::error("FIXME: Change the show recorder to use the File Upload API and remove this function."); // Albert - April 3, 2014
+        /**
         $upload_dir = ini_get("upload_tmp_dir");
         $tempFilePath = Application_Model_StoredFile::uploadFile($upload_dir);
         $tempFileName = basename($tempFilePath);
@@ -464,7 +466,7 @@ public function uploadFileAction()
             $this->_helper->json->sendJson(
                 array("jsonrpc" => "2.0", "error" => array("code" => $result['code'], "message" => $result['message']))
             );
-        }
+        }*/
     }
 
     public function uploadRecordedAction()

airtime_mvc/application/controllers/LoginController.php

@@ -65,7 +65,7 @@ public function indexAction()
 
                         Application_Model_LoginAttempts::resetAttempts($_SERVER['REMOTE_ADDR']);
                         Application_Model_Subjects::resetLoginAttempts($username);
-
+                        
                         $tempSess = new Zend_Session_Namespace("referrer");
                         $tempSess->referrer = 'login';
 

airtime_mvc/application/controllers/PluploadController.php

@@ -2,12 +2,11 @@
 
 class PluploadController extends Zend_Controller_Action
 {
-
     public function init()
     {
         $ajaxContext = $this->_helper->getHelper('AjaxContext');
-        $ajaxContext->addActionContext('upload', 'json')
-                    ->addActionContext('copyfile', 'json')
+        $ajaxContext->addActionContext('upload',            'json')
+                    ->addActionContext('recent-uploads',     'json')
                     ->initContext();
     }
 
@@ -18,33 +17,62 @@ public function indexAction()
         $baseUrl = Application_Common_OsPath::getBaseDir();
         $locale = Application_Model_Preference::GetLocale();
 
+        $this->view->headScript()->appendFile($baseUrl.'js/datatables/js/jquery.dataTables.js?'.$CC_CONFIG['airtime_version'], 'text/javascript');
         $this->view->headScript()->appendFile($baseUrl.'js/plupload/plupload.full.min.js?'.$CC_CONFIG['airtime_version'],'text/javascript');
         $this->view->headScript()->appendFile($baseUrl.'js/plupload/jquery.plupload.queue.min.js?'.$CC_CONFIG['airtime_version'],'text/javascript');
         $this->view->headScript()->appendFile($baseUrl.'js/airtime/library/plupload.js?'.$CC_CONFIG['airtime_version'],'text/javascript');
         $this->view->headScript()->appendFile($baseUrl.'js/plupload/i18n/'.$locale.'.js?'.$CC_CONFIG['airtime_version'],'text/javascript');
 
         $this->view->headLink()->appendStylesheet($baseUrl.'css/plupload.queue.css?'.$CC_CONFIG['airtime_version']);
+        $this->view->headLink()->appendStylesheet($baseUrl.'css/addmedia.css?'.$CC_CONFIG['airtime_version']);
     }
 
-    public function uploadAction()
-    {
-        $upload_dir = ini_get("upload_tmp_dir") . DIRECTORY_SEPARATOR . "plupload";
-        $tempFilePath = Application_Model_StoredFile::uploadFile($upload_dir);
-        $tempFileName = basename($tempFilePath);
-
-        $this->_helper->json->sendJson(array("jsonrpc" => "2.0", "tempfilepath" => $tempFileName));
-    }
-
-    public function copyfileAction()
+    public function recentUploadsAction()
     {
-        $upload_dir = ini_get("upload_tmp_dir") . DIRECTORY_SEPARATOR . "plupload";
-        $filename = $this->_getParam('name');
-        $tempname = $this->_getParam('tempname');
-        $result = Application_Model_StoredFile::copyFileToStor($upload_dir,
-            $filename, $tempname);
-        if (!is_null($result))
-           $this->_helper->json->sendJson(array("jsonrpc" => "2.0", "error" => $result));
+        if (isset($_GET['uploadFilter'])) {
+            $filter = $_GET['uploadFilter'];
+        } else {
+            $filter = "all";
+        }
+
+        $limit = isset($_GET['iDisplayLength']) ? $_GET['iDisplayLength'] : 10;
+        $rowStart = isset($_GET['iDisplayStart']) ? $_GET['iDisplayStart'] : 0;
+
+        $recentUploadsQuery = CcFilesQuery::create()->filterByDbUtime(array('min' => time() - 30 * 24 * 60 * 60))
+                            ->orderByDbUtime(Criteria::DESC);
+
+        $numTotalRecentUploads = $recentUploadsQuery->find()->count();
+
+        if ($filter == "pending") {
+            $recentUploadsQuery->filterByDbImportStatus("1");
+        } else if ($filter == "failed") {
+            $recentUploadsQuery->filterByDbImportStatus(array('min' => 100));
+        }
+
+        $recentUploads = $recentUploadsQuery->offset($rowStart)->limit($limit)->find();
+
+        $numRecentUploads = $limit;
+        //CcFilesQuery::create()->filterByDbUtime(array('min' => time() - 30 * 24 * 60 * 60))
+
+        //$this->_helper->json->sendJson(array("jsonrpc" => "2.0", "tempfilepath" => $tempFileName));
+
+        $uploadsArray = array();
+
+        foreach ($recentUploads as $upload)
+        {
+            $upload->toArray(BasePeer::TYPE_FIELDNAME);
+            //array_push($uploadsArray, $upload); //TODO: $this->sanitizeResponse($upload));
+
+            //$this->_helper->json->sendJson($upload->asJson());
+            //TODO: Invoke sanitization here
+            array_push($uploadsArray, $upload->toArray(BasePeer::TYPE_FIELDNAME));
+        }
+
 
-        $this->_helper->json->sendJson(array("jsonrpc" => "2.0"));
+        $this->view->sEcho = intval($this->getRequest()->getParam('sEcho'));
+        $this->view->iTotalDisplayRecords = $numTotalRecentUploads;
+        //$this->view->iTotalDisplayRecords = $numRecentUploads; //$r["iTotalDisplayRecords"];
+        $this->view->iTotalRecords = $numTotalRecentUploads; //$r["iTotalRecords"];
+        $this->view->files = $uploadsArray; //$r["aaData"];
     }
 }

airtime_mvc/application/controllers/plugins/Acl_plugin.php

@@ -110,6 +110,13 @@ public function preDispatch(Zend_Controller_Request_Abstract $request)
     {
         $controller = strtolower($request->getControllerName());
 
+        //Ignore authentication for all access to the rest API. We do auth via API keys for this
+        //and/or by OAuth.
+        if (strtolower($request->getModuleName()) == "rest")
+        {
+            return;
+        }
+
         if (in_array($controller, array("api", "auth", "locale"))) {
 
             $this->setRoleName("G");

airtime_mvc/application/models/MusicDir.php

@@ -301,7 +301,9 @@ public static function addWatchedDir($p_path, $userAddedWatchedDir=true, $nested
     public static function getDirByPK($pk)
     {
         $dir = CcMusicDirsQuery::create()->findPK($pk);
-
+        if (!$dir) {
+            return null;
+        }
         $mus_dir = new Application_Model_MusicDir($dir);
 
         return $mus_dir;

airtime_mvc/application/models/Preference.php

@@ -1415,4 +1415,24 @@ public static function SetHistoryFileTemplate($value) {
     public static function GetHistoryFileTemplate() {
     	return self::getValue("history_file_template");
     }
+
+    public static function getDiskUsage()
+    {
+        return self::getValue("disk_usage");
+    }
+
+    public static function setDiskUsage($value)
+    {
+        self::setValue("disk_usage", $value);
+    }
+
+    public static function updateDiskUsage($filesize)
+    {
+        $currentDiskUsage = self::getDiskUsage();
+        if (empty($currentDiskUsage)) {
+            $currentDiskUsage = 0;
+        }
+
+        self::setDiskUsage($currentDiskUsage + $filesize);
+    }
 }

airtime_mvc/application/models/RabbitMq.php

@@ -13,7 +13,7 @@ public static function PushSchedule()
         self::$doPush = true;
     }
 
-    private static function sendMessage($exchange, $data)
+    private static function sendMessage($exchange, $exchangeType, $autoDeleteExchange, $data, $queue="")
     {
         $CC_CONFIG = Config::getConfig();
 
@@ -31,7 +31,9 @@ private static function sendMessage($exchange, $data)
         $channel->access_request($CC_CONFIG["rabbitmq"]["vhost"], false, false,
             true, true);
 
-        $channel->exchange_declare($exchange, 'direct', false, true);
+        //I'm pretty sure we DON'T want to autodelete ANY exchanges but I'm keeping the code
+        //the way it is just so I don't accidentally break anything when I add the Analyzer code in. -- Albert, March 13, 2014
+        $channel->exchange_declare($exchange, $exchangeType, false, true, $autoDeleteExchange);
 
         $msg = new AMQPMessage($data, array('content_type' => 'text/plain'));
 
@@ -46,7 +48,7 @@ public static function SendMessageToPypo($event_type, $md)
 
         $exchange = 'airtime-pypo';
         $data = json_encode($md, JSON_FORCE_OBJECT);
-        self::sendMessage($exchange, $data);
+        self::sendMessage($exchange, 'direct', true, $data);
     }
 
     public static function SendMessageToMediaMonitor($event_type, $md)
@@ -55,7 +57,7 @@ public static function SendMessageToMediaMonitor($event_type, $md)
 
         $exchange = 'airtime-media-monitor';
         $data = json_encode($md);
-        self::sendMessage($exchange, $data);
+        self::sendMessage($exchange, 'direct', true, $data);
     }
 
     public static function SendMessageToShowRecorder($event_type)
@@ -74,6 +76,20 @@ public static function SendMessageToShowRecorder($event_type)
         }
         $data = json_encode($temp);
 
-        self::sendMessage($exchange, $data);
+        self::sendMessage($exchange, 'direct', true, $data);
+    }
+
+    public static function SendMessageToAnalyzer($tmpFilePath, $importedStorageDirectory, $originalFilename,
+                                                $callbackUrl, $apiKey)
+    {
+        $exchange = 'airtime-uploads';
+        $data['tmp_file_path'] = $tmpFilePath;
+        $data['import_directory'] = $importedStorageDirectory;
+        $data['original_filename'] = $originalFilename;
+        $data['callback_url'] = $callbackUrl;
+        $data['api_key'] = $apiKey;
+
+        $jsonData = json_encode($data);
+        self::sendMessage($exchange, 'topic', false, $jsonData, 'airtime-uploads');
     }
 }