Merge pull request #55 from radiorabe/feature/autodj

Robbs AutoDJ

airtime_mvc/application/common/AutoPlaylistManager.php

@@ -0,0 +1,92 @@
+<?php
+
+class AutoPlaylistManager {
+    /**
+     * @var int how often, in seconds, to check for and ingest new podcast episodes
+     */
+    private static $_AUTOPLAYLIST_POLL_INTERVAL_SECONDS = 60;  // 10 minutes
+    
+    /**
+     * Check whether $_AUTOPLAYLIST_POLL_INTERVAL_SECONDS have passed since the last call to
+     * buildAutoPlaylist
+     *
+     * @return bool true if $_AUTOPLAYLIST_POLL_INTERVAL_SECONDS has passed since the last check
+     */
+    public static function hasAutoPlaylistPollIntervalPassed() {
+        Logging::info("Checking autoplaylist poll");
+        $lastPolled = Application_Model_Preference::getAutoPlaylistPollLock();
+        return empty($lastPolled) || (microtime(true) > $lastPolled + self::$_AUTOPLAYLIST_POLL_INTERVAL_SECONDS);
+    }
+
+    /*
+     * This function is copied from the TestUser class and is used to instantiate a user so that
+     * the Scheduler model can be utilized by buildAutoPlaylist.
+     * Not sure if this is the best strategy but it works.
+    */    
+    public static function loginUser()
+    {
+        $authAdapter = Application_Model_Auth::getAuthAdapter();
+
+        //pass to the adapter the submitted username and password
+        $authAdapter->setIdentity('admin')
+                    ->setCredential('admin');
+
+        $auth = Zend_Auth::getInstance();
+        $result = $auth->authenticate($authAdapter);
+        if ($result->isValid()) {
+            //all info about this user from the login table omit only the password
+            $userInfo = $authAdapter->getResultRowObject(null, 'password');
+
+            //the default storage is a session with namespace Zend_Auth
+            $authStorage = $auth->getStorage();
+            $authStorage->write($userInfo);
+        }
+    }
+     
+     /**
+     * Find all shows with autoplaylists who have yet to have their playlists built and added to the schedule
+     *
+     */
+    public static function buildAutoPlaylist() {
+        // Starting a session so that the User can be created
+	Zend_Session::start();
+        static::loginUser();
+	Logging::info("Checking to run Auto Playlist");
+        $autoPlaylists = static::_upcomingAutoPlaylistShows();
+       foreach ($autoPlaylists as $autoplaylist) {
+       	    // creates a ShowInstance object to build the playlist in from the ShowInstancesQuery Object     
+	    $si = new Application_Model_ShowInstance($autoplaylist->getDbId());
+	    $playlistid = $si->GetAutoPlaylistId();
+            Logging::info("Scheduling $playlistid");
+            // call the addPlaylist to show function and don't check for user permission to avoid call to non-existant user object
+            $si->addPlaylistToShow($playlistid, false);
+            $si->setAutoPlaylistBuilt(true);
+
+            }
+        Application_Model_Preference::setAutoPlaylistPollLock(microtime(true));
+	Zend_Session::stop();
+    }
+
+    /**
+     * Find all show instances starting in the next hour with autoplaylists not yet added to the schedule
+     *
+     * @return PropelObjectCollection collection of ShowInstance objects
+     *                                that have unbuilt autoplaylists
+     */
+    protected static function _upcomingAutoPlaylistShows() {
+	    //setting now so that past shows aren't referenced
+            $now = new DateTime("now", new DateTimeZone("UTC"));
+	    // only build playlists for shows that start up to an hour from now
+	    $future = clone $now;
+	    $future->add(new DateInterval('PT1H'));
+	    
+        return CcShowInstancesQuery::create()
+            ->filterByDbStarts($now,Criteria::GREATER_THAN) 
+          ->filterByDbStarts($future,Criteria::LESS_THAN)
+            ->useCcShowQuery('a', 'left join')
+                ->filterByDbHasAutoPlaylist(true)
+            ->endUse()
+            ->filterByDbAutoPlaylistBuilt(false)
+            ->find();
+    }
+}

airtime_mvc/application/common/TaskManager.php

@@ -222,6 +222,33 @@ class CeleryTask implements AirtimeTask {
 
 }
 
+/**
+ * Class AutoPlaylistTask
+ *
+ * Checks for shows with an autoplaylist that needs to be filled in
+ * 
+ */
+class AutoPlaylistTask implements AirtimeTask
+{
+    /**
+     * Checks whether or not the autoplaylist polling interval has passed
+     *
+     * @return bool true if the autoplaylist polling interval has passed
+     */
+    public function shouldBeRun()
+    {
+        return AutoPlaylistManager::hasAutoPlaylistPollIntervalPassed();
+    }
+
+    /**
+     *  Schedule the autoplaylist for the shows
+     */
+    public function run()
+    {
+        AutoPlaylistManager::buildAutoPlaylist();
+    }
+}
+
 /**
  * Class PodcastTask
  *
@@ -350,7 +377,7 @@ class TaskFactory {
      * @return bool true if the class $c implements AirtimeTask
      */
     private static function _isTask($c) {
-        return is_a('AirtimeTask', $c, true);
+        return array_key_exists('AirtimeTask', class_implements($c));
     }
 
     /**