summaryrefslogtreecommitdiffstats
path: root/lib/class/democratic.class.php
diff options
context:
space:
mode:
Diffstat (limited to 'lib/class/democratic.class.php')
-rw-r--r--lib/class/democratic.class.php1040
1 files changed, 520 insertions, 520 deletions
diff --git a/lib/class/democratic.class.php b/lib/class/democratic.class.php
index 0e4fadbb..31913a07 100644
--- a/lib/class/democratic.class.php
+++ b/lib/class/democratic.class.php
@@ -1,5 +1,5 @@
<?php
-/* vim:set tabstop=8 softtabstop=8 shiftwidth=8 noexpandtab: */
+/* vim:set softtabstop=4 shiftwidth=4 expandtab: */
/**
*
* LICENSE: GNU General Public License, version 2 (GPLv2)
@@ -29,610 +29,610 @@
*/
class Democratic extends Tmp_Playlist {
- public $name;
- public $cooldown;
- public $level;
- public $user;
- public $primary;
- public $base_playlist;
+ public $name;
+ public $cooldown;
+ public $level;
+ public $user;
+ public $primary;
+ public $base_playlist;
- // Build local, buy local
- public $tmp_playlist;
- public $object_ids = array();
- public $vote_ids = array();
- public $user_votes = array();
+ // Build local, buy local
+ public $tmp_playlist;
+ public $object_ids = array();
+ public $vote_ids = array();
+ public $user_votes = array();
- /**
- * constructor
- * We need a constructor for this class. It does it's own thing now
- */
- public function __construct($id='') {
+ /**
+ * constructor
+ * We need a constructor for this class. It does it's own thing now
+ */
+ public function __construct($id='') {
- if (!$id) { return false; }
+ if (!$id) { return false; }
- $info = $this->get_info($id);
+ $info = $this->get_info($id);
- foreach ($info as $key=>$value) {
- $this->$key = $value;
- }
+ foreach ($info as $key=>$value) {
+ $this->$key = $value;
+ }
- } // constructor
+ } // constructor
- /**
- * build_vote_cache
- * This builds a vote cache of the objects we've got in the playlist
- */
- public static function build_vote_cache($ids) {
+ /**
+ * build_vote_cache
+ * This builds a vote cache of the objects we've got in the playlist
+ */
+ public static function build_vote_cache($ids) {
- if (!is_array($ids) || !count($ids)) { return false; }
+ if (!is_array($ids) || !count($ids)) { return false; }
- $idlist = '(' . implode(',', $ids) . ')';
+ $idlist = '(' . implode(',', $ids) . ')';
- $sql = 'SELECT `object_id`, COUNT(`user`) AS `count` ' .
- 'FROM `user_vote` ' .
- "WHERE `object_id` IN $idlist GROUP BY `object_id`";
+ $sql = 'SELECT `object_id`, COUNT(`user`) AS `count` ' .
+ 'FROM `user_vote` ' .
+ "WHERE `object_id` IN $idlist GROUP BY `object_id`";
- $db_results = Dba::read($sql);
+ $db_results = Dba::read($sql);
- while ($row = Dba::fetch_assoc($db_results)) {
- parent::add_to_cache('democratic_vote', $row['object_id'], $row['count']);
- }
+ while ($row = Dba::fetch_assoc($db_results)) {
+ parent::add_to_cache('democratic_vote', $row['object_id'], $row['count']);
+ }
- return true;
+ return true;
- } // build_vote_cache
+ } // build_vote_cache
- /**
- * is_enabled
- * This function just returns true / false if the current democratic
- * playlist is currently enabled / configured
- */
- public function is_enabled() {
+ /**
+ * is_enabled
+ * This function just returns true / false if the current democratic
+ * playlist is currently enabled / configured
+ */
+ public function is_enabled() {
- if ($this->tmp_playlist) { return true; }
+ if ($this->tmp_playlist) { return true; }
- return false;
+ return false;
- } // is_enabled
+ } // is_enabled
- /**
- * set_parent
- * This returns the Tmp_Playlist for this democratic play instance
- */
- public function set_parent() {
+ /**
+ * set_parent
+ * This returns the Tmp_Playlist for this democratic play instance
+ */
+ public function set_parent() {
- $demo_id = Dba::escape($this->id);
+ $demo_id = Dba::escape($this->id);
- $sql = "SELECT * FROM `tmp_playlist` WHERE `session`='$demo_id'";
- $db_results = Dba::read($sql);
+ $sql = "SELECT * FROM `tmp_playlist` WHERE `session`='$demo_id'";
+ $db_results = Dba::read($sql);
- $row = Dba::fetch_assoc($db_results);
+ $row = Dba::fetch_assoc($db_results);
- $this->tmp_playlist = $row['id'];
+ $this->tmp_playlist = $row['id'];
- } // set_parent
+ } // set_parent
- /**
- * set_user_preferences
- * This sets up a (or all) user(s) to use democratic play. This sets
- * their play method and playlist method (clear on send) If no user is
- * passed it does it for everyone and also locks down the ability to
- * change to admins only
- */
- public static function set_user_preferences($user = null) {
+ /**
+ * set_user_preferences
+ * This sets up a (or all) user(s) to use democratic play. This sets
+ * their play method and playlist method (clear on send) If no user is
+ * passed it does it for everyone and also locks down the ability to
+ * change to admins only
+ */
+ public static function set_user_preferences($user = null) {
- //FIXME: Code in single user stuff
+ //FIXME: Code in single user stuff
- $preference_id = Preference::id_from_name('play_type');
- Preference::update_level($preference_id,'75');
- Preference::update_all($preference_id,'democratic');
+ $preference_id = Preference::id_from_name('play_type');
+ Preference::update_level($preference_id,'75');
+ Preference::update_all($preference_id,'democratic');
- $allow_demo = Preference::id_from_name('allow_democratic_playback');
- Preference::update_all($allow_demo,'1');
-
- $play_method = Preference::id_from_name('playlist_method');
- Preference::update_all($play_method,'clear');
-
- return true;
+ $allow_demo = Preference::id_from_name('allow_democratic_playback');
+ Preference::update_all($allow_demo,'1');
+
+ $play_method = Preference::id_from_name('playlist_method');
+ Preference::update_all($play_method,'clear');
+
+ return true;
- } // set_user_preferences
+ } // set_user_preferences
- /**
- * format
- * This makes the variables all purrty so that they can be displayed
- */
- public function format() {
+ /**
+ * format
+ * This makes the variables all purrty so that they can be displayed
+ */
+ public function format() {
- $this->f_cooldown = $this->cooldown . ' ' . T_('minutes');
- $this->f_primary = $this->primary ? T_('Primary') : '';
+ $this->f_cooldown = $this->cooldown . ' ' . T_('minutes');
+ $this->f_primary = $this->primary ? T_('Primary') : '';
- switch ($this->level) {
- case '5':
- $this->f_level = T_('Guest');
- break;
- case '25':
- $this->f_level = T_('User');
- break;
- case '50':
- $this->f_level = T_('Content Manager');
- break;
- case '75':
- $this->f_level = T_('Catalog Manager');
- break;
- case '100':
- $this->f_level = T_('Admin');
- break;
- }
+ switch ($this->level) {
+ case '5':
+ $this->f_level = T_('Guest');
+ break;
+ case '25':
+ $this->f_level = T_('User');
+ break;
+ case '50':
+ $this->f_level = T_('Content Manager');
+ break;
+ case '75':
+ $this->f_level = T_('Catalog Manager');
+ break;
+ case '100':
+ $this->f_level = T_('Admin');
+ break;
+ }
- } // format
+ } // format
- /**
- * get_playlists
- * This returns all of the current valid 'Democratic' Playlists
- * that have been created.
- */
- public static function get_playlists() {
+ /**
+ * get_playlists
+ * This returns all of the current valid 'Democratic' Playlists
+ * that have been created.
+ */
+ public static function get_playlists() {
- $sql = "SELECT `id` FROM `democratic` ORDER BY `name`";
- $db_results = Dba::read($sql);
+ $sql = "SELECT `id` FROM `democratic` ORDER BY `name`";
+ $db_results = Dba::read($sql);
- $results = array();
+ $results = array();
- while ($row = Dba::fetch_assoc($db_results)) {
- $results[] = $row['id'];
- }
+ while ($row = Dba::fetch_assoc($db_results)) {
+ $results[] = $row['id'];
+ }
- return $results;
+ return $results;
- } // get_playlists
+ } // get_playlists
- /**
- * get_current_playlist
- * This returns the curren users current playlist, or if specified
- * this current playlist of the user
- */
- public static function get_current_playlist() {
-
- $democratic_id = Config::get('democratic_id');
-
- if (!$democratic_id) {
- $level = Dba::escape($GLOBALS['user']->access);
- $sql = "SELECT `id` FROM `democratic` WHERE `level` <= '$level' " .
- " ORDER BY `level` DESC,`primary` DESC";
- $db_results = Dba::read($sql);
- $row = Dba::fetch_assoc($db_results);
- $democratic_id = $row['id'];
- }
-
- $object = new Democratic($democratic_id);
-
- return $object;
-
- } // get_current_playlist
-
- /**
- * get_items
- * This returns a sorted array of all object_ids in this Tmp_Playlist.
- * The array is multidimensional; the inner array needs to contain the
- * keys 'id', 'object_type' and 'object_id'.
- *
- * Sorting is highest to lowest vote count, then by oldest to newest
- * vote activity.
- */
- public function get_items($limit = null) {
-
- $sql = 'SELECT `tmp_playlist_data`.`object_type`, ' .
- '`tmp_playlist_data`.`object_id`, ' .
- '`tmp_playlist_data`.`id` ' .
- 'FROM `tmp_playlist_data` INNER JOIN `user_vote` ' .
- 'ON `user_vote`.`object_id` = `tmp_playlist_data`.`id` ' .
- "WHERE `tmp_playlist_data`.`tmp_playlist` = '" .
- Dba::escape($this->tmp_playlist) . "' " .
- 'GROUP BY 1, 2 ' .
- 'ORDER BY COUNT(*) DESC, MAX(`user_vote`.`date`) ';
-
- if ($limit) {
- $sql .= 'LIMIT ' . intval($limit);
- }
-
- $db_results = Dba::read($sql);
-
- $results = array();
-
- while ($results[] = Dba::fetch_assoc($db_results)) {
- // Nada
- }
-
- return $results;
-
- } // get_items
-
- /**
- * play_url
- * This returns the special play URL for democratic play, only open to ADMINs
- */
- public function play_url() {
-
- $link = Stream::get_base_url() . 'uid=' . scrub_out($GLOBALS['user']->id) . '&demo_id=' . scrub_out($this->id);
-
- return $link;
-
- } // play_url
-
- /**
- * get_next_object
- * This returns the next object in the tmp_playlist.
- * Most of the time this will just be the top entry, but if there is a
- * base_playlist and no items in the playlist then it returns a random
- * entry from the base_playlist
- */
- public function get_next_object($offset = 0) {
-
- // FIXME: Shouldn't this return object_type?
-
- $offset = intval($offset);
-
- $items = $this->get_items($offset + 1);
-
- if (count($items) > $offset) {
- return $items[$offset]['object_id'];
- }
-
-
- // If nothing was found and this is a voting playlist then get
- // from base_playlist
- if ($this->base_playlist) {
- $base_playlist = new Playlist($this->base_playlist);
- $data = $base_playlist->get_random_items(1);
- return $data[0]['object_id'];
- }
- else {
- $sql = "SELECT `id` FROM `song` WHERE `enabled`='1' ORDER BY RAND() LIMIT 1";
- $db_results = Dba::read($sql);
- $results = Dba::fetch_assoc($db_results);
- return $results['id'];
- }
-
- return null;
-
- } // get_next_object
-
- /**
- * get_uid_from_object_id
- * This takes an object_id and an object type and returns the ID for the row
- */
- public function get_uid_from_object_id($object_id, $object_type = 'song') {
-
- $object_id = Dba::escape($object_id);
- $object_type = Dba::escape($object_type);
- $tmp_id = Dba::escape($this->tmp_playlist);
-
- $sql = 'SELECT `id` FROM `tmp_playlist_data` ' .
- "WHERE `object_type`='$object_type' AND " .
- "`tmp_playlist`='$tmp_id' AND `object_id`='$object_id'";
- $db_results = Dba::read($sql);
-
- $row = Dba::fetch_assoc($db_results);
-
- return $row['id'];
-
- } // get_uid_from_object_id
-
- /**
- * get_cool_songs
- * This returns all of the song_ids for songs that have happened within
- * the last 'cooldown' for this user.
- */
- public function get_cool_songs() {
-
- // Convert cooldown time to a timestamp in the past
- $cool_time = time() - ($this->cooldown * 60);
-
- $song_ids = Stats::get_object_history($GLOBALS['user']->id, $cool_time);
-
- return $song_ids;
-
- } // get_cool_songs
-
- /**
- * vote
- * This function is called by users to vote on a system wide playlist
- * This adds the specified objects to the tmp_playlist and adds a 'vote'
- * by this user, naturally it checks to make sure that the user hasn't
- * already voted on any of these objects
- */
- public function add_vote($items) {
-
- /* Itterate through the objects if no vote, add to playlist and vote */
- foreach ($items as $element) {
- $type = array_shift($element);
- $object_id = array_shift($element);
- if (!$this->has_vote($object_id, $type)) {
- $this->_add_vote($object_id, $type);
- }
- } // end foreach
-
- } // vote
-
- /**
- * has_vote
- * This checks to see if the current user has already voted on this object
- */
- public function has_vote($object_id, $type = 'song') {
-
- $tmp_id = Dba::escape($this->tmp_playlist);
- $object_id = Dba::escape($object_id);
- $type = Dba::escape($type);
- $user_id = Dba::escape($GLOBALS['user']->id);
-
- /* Query vote table */
- $sql = 'SELECT `tmp_playlist_data`.`object_id` ' .
- 'FROM `user_vote` INNER JOIN `tmp_playlist_data` ' .
- 'ON `tmp_playlist_data`.`id`=`user_vote`.`object_id` ' .
- "WHERE `user_vote`.`user`='$user_id' " .
- "AND `tmp_playlist_data`.`object_type`='$type' " .
- "AND `tmp_playlist_data`.`object_id`='$object_id' " .
- "AND `tmp_playlist_data`.`tmp_playlist`='$tmp_id'";
- $db_results = Dba::read($sql);
-
- /* If we find row, they've voted!! */
- if (Dba::num_rows($db_results)) {
- return true;
- }
-
- return false;
-
- } // has_vote
-
- /**
- * _add_vote
- * This takes a object id and user and actually inserts the row
- */
- private function _add_vote($object_id, $object_type = 'song') {
-
- $object_id = Dba::escape($object_id);
- $tmp_playlist = Dba::escape($this->tmp_playlist);
- $object_type = Dba::escape($object_type);
- $media = new $object_type($object_id);
- $track = isset($media->track) ? "'" . intval($media->track) . "'" : "NULL";
+ /**
+ * get_current_playlist
+ * This returns the curren users current playlist, or if specified
+ * this current playlist of the user
+ */
+ public static function get_current_playlist() {
+
+ $democratic_id = Config::get('democratic_id');
+
+ if (!$democratic_id) {
+ $level = Dba::escape($GLOBALS['user']->access);
+ $sql = "SELECT `id` FROM `democratic` WHERE `level` <= '$level' " .
+ " ORDER BY `level` DESC,`primary` DESC";
+ $db_results = Dba::read($sql);
+ $row = Dba::fetch_assoc($db_results);
+ $democratic_id = $row['id'];
+ }
+
+ $object = new Democratic($democratic_id);
+
+ return $object;
+
+ } // get_current_playlist
+
+ /**
+ * get_items
+ * This returns a sorted array of all object_ids in this Tmp_Playlist.
+ * The array is multidimensional; the inner array needs to contain the
+ * keys 'id', 'object_type' and 'object_id'.
+ *
+ * Sorting is highest to lowest vote count, then by oldest to newest
+ * vote activity.
+ */
+ public function get_items($limit = null) {
+
+ $sql = 'SELECT `tmp_playlist_data`.`object_type`, ' .
+ '`tmp_playlist_data`.`object_id`, ' .
+ '`tmp_playlist_data`.`id` ' .
+ 'FROM `tmp_playlist_data` INNER JOIN `user_vote` ' .
+ 'ON `user_vote`.`object_id` = `tmp_playlist_data`.`id` ' .
+ "WHERE `tmp_playlist_data`.`tmp_playlist` = '" .
+ Dba::escape($this->tmp_playlist) . "' " .
+ 'GROUP BY 1, 2 ' .
+ 'ORDER BY COUNT(*) DESC, MAX(`user_vote`.`date`) ';
+
+ if ($limit) {
+ $sql .= 'LIMIT ' . intval($limit);
+ }
+
+ $db_results = Dba::read($sql);
+
+ $results = array();
+
+ while ($results[] = Dba::fetch_assoc($db_results)) {
+ // Nada
+ }
+
+ return $results;
+
+ } // get_items
+
+ /**
+ * play_url
+ * This returns the special play URL for democratic play, only open to ADMINs
+ */
+ public function play_url() {
+
+ $link = Stream::get_base_url() . 'uid=' . scrub_out($GLOBALS['user']->id) . '&demo_id=' . scrub_out($this->id);
+
+ return $link;
+
+ } // play_url
+
+ /**
+ * get_next_object
+ * This returns the next object in the tmp_playlist.
+ * Most of the time this will just be the top entry, but if there is a
+ * base_playlist and no items in the playlist then it returns a random
+ * entry from the base_playlist
+ */
+ public function get_next_object($offset = 0) {
+
+ // FIXME: Shouldn't this return object_type?
+
+ $offset = intval($offset);
+
+ $items = $this->get_items($offset + 1);
+
+ if (count($items) > $offset) {
+ return $items[$offset]['object_id'];
+ }
+
+
+ // If nothing was found and this is a voting playlist then get
+ // from base_playlist
+ if ($this->base_playlist) {
+ $base_playlist = new Playlist($this->base_playlist);
+ $data = $base_playlist->get_random_items(1);
+ return $data[0]['object_id'];
+ }
+ else {
+ $sql = "SELECT `id` FROM `song` WHERE `enabled`='1' ORDER BY RAND() LIMIT 1";
+ $db_results = Dba::read($sql);
+ $results = Dba::fetch_assoc($db_results);
+ return $results['id'];
+ }
+
+ return null;
+
+ } // get_next_object
+
+ /**
+ * get_uid_from_object_id
+ * This takes an object_id and an object type and returns the ID for the row
+ */
+ public function get_uid_from_object_id($object_id, $object_type = 'song') {
+
+ $object_id = Dba::escape($object_id);
+ $object_type = Dba::escape($object_type);
+ $tmp_id = Dba::escape($this->tmp_playlist);
+
+ $sql = 'SELECT `id` FROM `tmp_playlist_data` ' .
+ "WHERE `object_type`='$object_type' AND " .
+ "`tmp_playlist`='$tmp_id' AND `object_id`='$object_id'";
+ $db_results = Dba::read($sql);
+
+ $row = Dba::fetch_assoc($db_results);
+
+ return $row['id'];
+
+ } // get_uid_from_object_id
+
+ /**
+ * get_cool_songs
+ * This returns all of the song_ids for songs that have happened within
+ * the last 'cooldown' for this user.
+ */
+ public function get_cool_songs() {
+
+ // Convert cooldown time to a timestamp in the past
+ $cool_time = time() - ($this->cooldown * 60);
+
+ $song_ids = Stats::get_object_history($GLOBALS['user']->id, $cool_time);
+
+ return $song_ids;
+
+ } // get_cool_songs
+
+ /**
+ * vote
+ * This function is called by users to vote on a system wide playlist
+ * This adds the specified objects to the tmp_playlist and adds a 'vote'
+ * by this user, naturally it checks to make sure that the user hasn't
+ * already voted on any of these objects
+ */
+ public function add_vote($items) {
+
+ /* Itterate through the objects if no vote, add to playlist and vote */
+ foreach ($items as $element) {
+ $type = array_shift($element);
+ $object_id = array_shift($element);
+ if (!$this->has_vote($object_id, $type)) {
+ $this->_add_vote($object_id, $type);
+ }
+ } // end foreach
+
+ } // vote
+
+ /**
+ * has_vote
+ * This checks to see if the current user has already voted on this object
+ */
+ public function has_vote($object_id, $type = 'song') {
+
+ $tmp_id = Dba::escape($this->tmp_playlist);
+ $object_id = Dba::escape($object_id);
+ $type = Dba::escape($type);
+ $user_id = Dba::escape($GLOBALS['user']->id);
+
+ /* Query vote table */
+ $sql = 'SELECT `tmp_playlist_data`.`object_id` ' .
+ 'FROM `user_vote` INNER JOIN `tmp_playlist_data` ' .
+ 'ON `tmp_playlist_data`.`id`=`user_vote`.`object_id` ' .
+ "WHERE `user_vote`.`user`='$user_id' " .
+ "AND `tmp_playlist_data`.`object_type`='$type' " .
+ "AND `tmp_playlist_data`.`object_id`='$object_id' " .
+ "AND `tmp_playlist_data`.`tmp_playlist`='$tmp_id'";
+ $db_results = Dba::read($sql);
+
+ /* If we find row, they've voted!! */
+ if (Dba::num_rows($db_results)) {
+ return true;
+ }
+
+ return false;
+
+ } // has_vote
+
+ /**
+ * _add_vote
+ * This takes a object id and user and actually inserts the row
+ */
+ private function _add_vote($object_id, $object_type = 'song') {
+
+ $object_id = Dba::escape($object_id);
+ $tmp_playlist = Dba::escape($this->tmp_playlist);
+ $object_type = Dba::escape($object_type);
+ $media = new $object_type($object_id);
+ $track = isset($media->track) ? "'" . intval($media->track) . "'" : "NULL";
- /* If it's on the playlist just vote */
- $sql = "SELECT `id` FROM `tmp_playlist_data` " .
- "WHERE `tmp_playlist_data`.`object_id`='$object_id' AND `tmp_playlist_data`.`tmp_playlist`='$tmp_playlist'";
- $db_results = Dba::write($sql);
+ /* If it's on the playlist just vote */
+ $sql = "SELECT `id` FROM `tmp_playlist_data` " .
+ "WHERE `tmp_playlist_data`.`object_id`='$object_id' AND `tmp_playlist_data`.`tmp_playlist`='$tmp_playlist'";
+ $db_results = Dba::write($sql);
- /* If it's not there, add it and pull ID */
- if (!$results = Dba::fetch_assoc($db_results)) {
- $sql = "INSERT INTO `tmp_playlist_data` (`tmp_playlist`,`object_id`,`object_type`,`track`) " .
- "VALUES ('$tmp_playlist','$object_id','$object_type',$track)";
- $db_results = Dba::write($sql);
- $results['id'] = Dba::insert_id();
- }
+ /* If it's not there, add it and pull ID */
+ if (!$results = Dba::fetch_assoc($db_results)) {
+ $sql = "INSERT INTO `tmp_playlist_data` (`tmp_playlist`,`object_id`,`object_type`,`track`) " .
+ "VALUES ('$tmp_playlist','$object_id','$object_type',$track)";
+ $db_results = Dba::write($sql);
+ $results['id'] = Dba::insert_id();
+ }
- /* Vote! */
- $time = time();
- $sql = "INSERT INTO user_vote (`user`,`object_id`,`date`) " .
- "VALUES ('" . Dba::escape($GLOBALS['user']->id) . "','" . $results['id'] . "','$time')";
- $db_results = Dba::write($sql);
+ /* Vote! */
+ $time = time();
+ $sql = "INSERT INTO user_vote (`user`,`object_id`,`date`) " .
+ "VALUES ('" . Dba::escape($GLOBALS['user']->id) . "','" . $results['id'] . "','$time')";
+ $db_results = Dba::write($sql);
- return true;
-
- } // add_vote
-
- /**
- * remove_vote
- * This is called to remove a vote by a user for an object, it uses the object_id
- * As that's what we'll have most the time, no need to check if they've got an existing
- * vote for this, just remove anything that is there
- */
- public function remove_vote($row_id) {
-
- $object_id = Dba::escape($row_id);
- $user_id = Dba::escape($GLOBALS['user']->id);
-
- $sql = "DELETE FROM `user_vote` WHERE `object_id`='$object_id' AND `user`='$user_id'";
- $db_results = Dba::write($sql);
-
- /* Clean up anything that has no votes */
- self::prune_tracks();
-
- return true;
-
- } // remove_vote
-
- /**
- * delete_votes
- * This removes the votes for the specified object on the current playlist
- */
- public function delete_votes($row_id) {
-
- $row_id = Dba::escape($row_id);
-
- $sql = "DELETE FROM `user_vote` WHERE `object_id`='$row_id'";
- $db_results = Dba::write($sql);
-
- $sql = "DELETE FROM `tmp_playlist_data` WHERE `id`='$row_id'";
- $db_results = Dba::write($sql);
-
- return true;
-
- } // delete_votes
-
- /**
- * delete_from_oid
- * This takes an OID and type and removes the object from the democratic playlist
- */
- public function delete_from_oid($oid,$object_type) {
-
- $row_id = $this->get_uid_from_object_id($oid,$object_type);
- if ($row_id) {
- debug_event('Democratic','Removing Votes for ' . $oid . ' of type ' . $object_type,'5');
- $this->delete_votes($row_id);
- }
- else { debug_event('Democratic','Unable to find Votes for ' . $oid . ' of type ' . $object_type,'3'); }
+ return true;
+
+ } // add_vote
+
+ /**
+ * remove_vote
+ * This is called to remove a vote by a user for an object, it uses the object_id
+ * As that's what we'll have most the time, no need to check if they've got an existing
+ * vote for this, just remove anything that is there
+ */
+ public function remove_vote($row_id) {
+
+ $object_id = Dba::escape($row_id);
+ $user_id = Dba::escape($GLOBALS['user']->id);
+
+ $sql = "DELETE FROM `user_vote` WHERE `object_id`='$object_id' AND `user`='$user_id'";
+ $db_results = Dba::write($sql);
+
+ /* Clean up anything that has no votes */
+ self::prune_tracks();
+
+ return true;
+
+ } // remove_vote
+
+ /**
+ * delete_votes
+ * This removes the votes for the specified object on the current playlist
+ */
+ public function delete_votes($row_id) {
+
+ $row_id = Dba::escape($row_id);
+
+ $sql = "DELETE FROM `user_vote` WHERE `object_id`='$row_id'";
+ $db_results = Dba::write($sql);
+
+ $sql = "DELETE FROM `tmp_playlist_data` WHERE `id`='$row_id'";
+ $db_results = Dba::write($sql);
+
+ return true;
+
+ } // delete_votes
+
+ /**
+ * delete_from_oid
+ * This takes an OID and type and removes the object from the democratic playlist
+ */
+ public function delete_from_oid($oid,$object_type) {
+
+ $row_id = $this->get_uid_from_object_id($oid,$object_type);
+ if ($row_id) {
+ debug_event('Democratic','Removing Votes for ' . $oid . ' of type ' . $object_type,'5');
+ $this->delete_votes($row_id);
+ }
+ else { debug_event('Democratic','Unable to find Votes for ' . $oid . ' of type ' . $object_type,'3'); }
- return true;
+ return true;
- } // delete_from_oid
+ } // delete_from_oid
- /**
- * delete
- * This deletes a democratic playlist
- */
- public static function delete($democratic_id) {
+ /**
+ * delete
+ * This deletes a democratic playlist
+ */
+ public static function delete($democratic_id) {
- $democratic_id = Dba::escape($democratic_id);
+ $democratic_id = Dba::escape($democratic_id);
- $sql = "DELETE FROM `democratic` WHERE `id`='$democratic_id'";
- $db_results = Dba::write($sql);
+ $sql = "DELETE FROM `democratic` WHERE `id`='$democratic_id'";
+ $db_results = Dba::write($sql);
- $sql = "DELETE FROM `tmp_playlist` WHERE `session`='$democratic_id'";
- $db_results = Dba::write($sql);
+ $sql = "DELETE FROM `tmp_playlist` WHERE `session`='$democratic_id'";
+ $db_results = Dba::write($sql);
- self::prune_tracks();
+ self::prune_tracks();
- return true;
+ return true;
- } // delete
+ } // delete
- /**
- * update
- * This updates an existing democratic playlist item. It takes a key'd array just like the create
- */
- public function update($data) {
+ /**
+ * update
+ * This updates an existing democratic playlist item. It takes a key'd array just like the create
+ */
+ public function update($data) {
- $name = Dba::escape($data['name']);
- $base = Dba::escape($data['democratic']);
- $cool = Dba::escape($data['cooldown']);
- $id = Dba::escape($this->id);
+ $name = Dba::escape($data['name']);
+ $base = Dba::escape($data['democratic']);
+ $cool = Dba::escape($data['cooldown']);
+ $id = Dba::escape($this->id);
- $sql = "UPDATE `democratic` SET `name`='$name', `base_playlist`='$base',`cooldown`='$cool' WHERE `id`='$id'";
- $db_results = Dba::write($sql);
+ $sql = "UPDATE `democratic` SET `name`='$name', `base_playlist`='$base',`cooldown`='$cool' WHERE `id`='$id'";
+ $db_results = Dba::write($sql);
- return true;
+ return true;
- } // update
+ } // update
- /**
- * create
- * This is the democratic play create function it inserts this into the democratic table
- */
- public static function create($data) {
+ /**
+ * create
+ * This is the democratic play create function it inserts this into the democratic table
+ */
+ public static function create($data) {
- // Clean up the input
- $name = Dba::escape($data['name']);
- $base = Dba::escape($data['democratic']);
- $cool = Dba::escape($data['cooldown']);
- $level = Dba::escape($data['level']);
- $default = Dba::escape($data['make_default']);
- $user = Dba::escape($GLOBALS['user']->id);
+ // Clean up the input
+ $name = Dba::escape($data['name']);
+ $base = Dba::escape($data['democratic']);
+ $cool = Dba::escape($data['cooldown']);
+ $level = Dba::escape($data['level']);
+ $default = Dba::escape($data['make_default']);
+ $user = Dba::escape($GLOBALS['user']->id);
- $sql = "INSERT INTO `democratic` (`name`,`base_playlist`,`cooldown`,`level`,`user`,`primary`) " .
- "VALUES ('$name','$base','$cool','$level','$user','$default')";
- $db_results = Dba::write($sql);
+ $sql = "INSERT INTO `democratic` (`name`,`base_playlist`,`cooldown`,`level`,`user`,`primary`) " .
+ "VALUES ('$name','$base','$cool','$level','$user','$default')";
+ $db_results = Dba::write($sql);
- if ($db_results) {
- $insert_id = Dba::insert_id();
- parent::create(array(
- 'session_id' => $insert_id,
- 'type' => 'vote',
- 'object_type' => 'song'
- ));
- }
+ if ($db_results) {
+ $insert_id = Dba::insert_id();
+ parent::create(array(
+ 'session_id' => $insert_id,
+ 'type' => 'vote',
+ 'object_type' => 'song'
+ ));
+ }
- return $db_results;
+ return $db_results;
- } // create
+ } // create
- /**
- * prune_tracks
- * This replaces the normal prune tracks and correctly removes the votes
- * as well
- */
- public static function prune_tracks() {
+ /**
+ * prune_tracks
+ * This replaces the normal prune tracks and correctly removes the votes
+ * as well
+ */
+ public static function prune_tracks() {
- // This deletes data without votes, if it's a voting democratic playlist
- $sql = "DELETE FROM `tmp_playlist_data` USING `tmp_playlist_data` " .
- "LEFT JOIN `user_vote` ON `tmp_playlist_data`.`id`=`user_vote`.`object_id` " .
- "LEFT JOIN `tmp_playlist` ON `tmp_playlist`.`id`=`tmp_playlist_data`.`tmp_playlist` " .
- "WHERE `user_vote`.`object_id` IS NULL AND `tmp_playlist`.`type` = 'vote'";
- $db_results = Dba::write($sql);
+ // This deletes data without votes, if it's a voting democratic playlist
+ $sql = "DELETE FROM `tmp_playlist_data` USING `tmp_playlist_data` " .
+ "LEFT JOIN `user_vote` ON `tmp_playlist_data`.`id`=`user_vote`.`object_id` " .
+ "LEFT JOIN `tmp_playlist` ON `tmp_playlist`.`id`=`tmp_playlist_data`.`tmp_playlist` " .
+ "WHERE `user_vote`.`object_id` IS NULL AND `tmp_playlist`.`type` = 'vote'";
+ $db_results = Dba::write($sql);
- return true;
+ return true;
- } // prune_tracks
+ } // prune_tracks
- /**
- * clear
- * This is really just a wrapper function, it clears the entire playlist
- * including all votes etc.
- */
- public function clear() {
+ /**
+ * clear
+ * This is really just a wrapper function, it clears the entire playlist
+ * including all votes etc.
+ */
+ public function clear() {
- $tmp_id = Dba::escape($this->tmp_playlist);
+ $tmp_id = Dba::escape($this->tmp_playlist);
- /* Clear all votes then prune */
- $sql = "DELETE FROM `user_vote` USING `user_vote` " .
- "LEFT JOIN `tmp_playlist_data` ON `user_vote`.`object_id` = `tmp_playlist_data`.`id` " .
- "WHERE `tmp_playlist_data`.`tmp_playlist`='$tmp_id'";
- $db_results = Dba::write($sql);
+ /* Clear all votes then prune */
+ $sql = "DELETE FROM `user_vote` USING `user_vote` " .
+ "LEFT JOIN `tmp_playlist_data` ON `user_vote`.`object_id` = `tmp_playlist_data`.`id` " .
+ "WHERE `tmp_playlist_data`.`tmp_playlist`='$tmp_id'";
+ $db_results = Dba::write($sql);
- // Prune!
- self::prune_tracks();
+ // Prune!
+ self::prune_tracks();
- // Clean the votes
- self::clear_votes();
+ // Clean the votes
+ self::clear_votes();
- return true;
+ return true;
- } // clear_playlist
+ } // clear_playlist
- /**
- * clean_votes
- * This removes in left over garbage in the votes table
- */
- public function clear_votes() {
+ /**
+ * clean_votes
+ * This removes in left over garbage in the votes table
+ */
+ public function clear_votes() {
- $sql = "DELETE FROM `user_vote` USING `user_vote` " .
- "LEFT JOIN `tmp_playlist_data` ON `user_vote`.`object_id`=`tmp_playlist_data`.`id` " .
- "WHERE `tmp_playlist_data`.`id` IS NULL";
- $db_results = Dba::write($sql);
+ $sql = "DELETE FROM `user_vote` USING `user_vote` " .
+ "LEFT JOIN `tmp_playlist_data` ON `user_vote`.`object_id`=`tmp_playlist_data`.`id` " .
+ "WHERE `tmp_playlist_data`.`id` IS NULL";
+ $db_results = Dba::write($sql);
- return true;
+ return true;
- } // clear_votes
+ } // clear_votes
- /**
- * get_vote
- * This returns the current count for a specific song
- */
- public function get_vote($id) {
+ /**
+ * get_vote
+ * This returns the current count for a specific song
+ */
+ public function get_vote($id) {
- if (parent::is_cached('democratic_vote', $id)) {
- return parent::get_from_cache('democratic_vote', $id);
- }
-
- $sql = 'SELECT COUNT(`user`) AS `count` FROM `user_vote` ' .
- "WHERE `object_id`='" . Dba::escape($id) . "'";
- $db_results = Dba::read($sql);
-
- $results = Dba::fetch_assoc($db_results);
- parent::add_to_cache('democratic_vote', $id, $results['count']);
- return $results['count'];
-
- } // get_vote
+ if (parent::is_cached('democratic_vote', $id)) {
+ return parent::get_from_cache('democratic_vote', $id);
+ }
+
+ $sql = 'SELECT COUNT(`user`) AS `count` FROM `user_vote` ' .
+ "WHERE `object_id`='" . Dba::escape($id) . "'";
+ $db_results = Dba::read($sql);
+
+ $results = Dba::fetch_assoc($db_results);
+ parent::add_to_cache('democratic_vote', $id, $results['count']);
+ return $results['count'];
+
+ } // get_vote
- /**
- * get_voters
- * This returns the users that voted for the specified object
- * This is an array of user ids
- */
- public function get_voters($object_id) {
+ /**
+ * get_voters
+ * This returns the users that voted for the specified object
+ * This is an array of user ids
+ */
+ public function get_voters($object_id) {
- return parent::get_from_cache('democratic_voters',$object_id);
+ return parent::get_from_cache('democratic_voters',$object_id);
- } // get_voters
+ } // get_voters
} // Democratic class