Merge branch 'devel' of dev.sourcefabric.org:airtime into devel

This commit is contained in:
Martin Konecny 2012-09-18 15:27:35 -04:00
commit da11dc077e
6 changed files with 105 additions and 51 deletions

View File

@ -109,7 +109,7 @@ class UserController extends Zend_Controller_Action
# TODO : remove this. we only use default for now not to break the UI. # TODO : remove this. we only use default for now not to break the UI.
if (!$files_action) { # set default action if (!$files_action) { # set default action
$files_action = "reassign_to"; $files_action = "reassign_to";
$delId = 1; $new_owner = Application_Model_User::getFirstAdmin();
} }
# only delete when valid action is selected for the owned files # only delete when valid action is selected for the owned files
@ -132,8 +132,11 @@ class UserController extends Zend_Controller_Action
if ($files_action == "delete_cascade") { if ($files_action == "delete_cascade") {
$user->deleteAllFiles(); $user->deleteAllFiles();
} elseif ($files_action == "reassign_to") { } elseif ($files_action == "reassign_to") {
$new_owner = $this->_getParam("new_owner"); // TODO : fix code to actually use the line below and pick a
$user->reassignTo( $new_owner ); // real owner instead of defaulting to the first found admin
//$new_owner_id = $this->_getParam("new_owner");
//$new_owner = new Application_Model_User($new_owner_id);
$user->donateFilesTo( $new_owner );
} }
# Finally delete the user # Finally delete the user
$this->view->entries = $user->delete(); $this->view->entries = $user->delete();

View File

@ -729,6 +729,7 @@ SQL;
$unionTable = "({$plTable} UNION {$blTable} UNION {$fileTable} UNION {$streamTable}) AS RESULTS"; $unionTable = "({$plTable} UNION {$blTable} UNION {$fileTable} UNION {$streamTable}) AS RESULTS";
//choose which table we need to select data from. //choose which table we need to select data from.
// TODO : use constants instead of numbers -- RG
switch ($type) { switch ($type) {
case 0: case 0:
$fromTable = $unionTable; $fromTable = $unionTable;
@ -1056,12 +1057,14 @@ SQL;
{ {
$con = Propel::getConnection(); $con = Propel::getConnection();
$sql = "SELECT id, filepath as fp" $sql = <<<SQL
." FROM CC_FILES" SELECT id,
." WHERE directory = :dir_id" filepath AS fp
." AND file_exists = 'TRUE'" FROM cc_files
." AND replay_gain is NULL" WHERE directory = :dir_id
." LIMIT :lim"; AND file_exists = 'TRUE'
AND replay_gain IS NULL LIMIT :lim
SQL;
$stmt = $con->prepare($sql); $stmt = $con->prepare($sql);
$stmt->bindParam(':dir_id', $dir_id); $stmt->bindParam(':dir_id', $dir_id);
@ -1170,6 +1173,8 @@ SQL;
return $this->_file->getDbFileExists(); return $this->_file->getDbFileExists();
} }
// note: never call this method from controllers because it does a sleep
public function uploadToSoundCloud() public function uploadToSoundCloud()
{ {
global $CC_CONFIG; global $CC_CONFIG;
@ -1196,6 +1201,7 @@ SQL;
} catch (Services_Soundcloud_Invalid_Http_Response_Code_Exception $e) { } catch (Services_Soundcloud_Invalid_Http_Response_Code_Exception $e) {
$code = $e->getHttpCode(); $code = $e->getHttpCode();
$msg = $e->getHttpBody(); $msg = $e->getHttpBody();
// TODO : Do not parse JSON by hand
$temp = explode('"error":',$msg); $temp = explode('"error":',$msg);
$msg = trim($temp[1], '"}'); $msg = trim($temp[1], '"}');
$this->setSoundCloudErrorCode($code); $this->setSoundCloudErrorCode($code);

View File

@ -215,7 +215,7 @@ class Application_Model_User
return $user->getCcFilessRelatedByDbOwnerId(); return $user->getCcFilessRelatedByDbOwnerId();
} }
public function donateFilesTo($user) public function donateFilesTo($user) // $user is object not user id
{ {
$my_files = $this->getOwnedFiles(); $my_files = $this->getOwnedFiles();
foreach ($my_files as $file) { foreach ($my_files as $file) {
@ -242,18 +242,27 @@ class Application_Model_User
{ {
return CcSubjsQuery::create()->filterByDbType($type)->find(); return CcSubjsQuery::create()->filterByDbType($type)->find();
} }
public static function getFirstAdminId()
{ public static function getFirstAdmin() {
$admins = Application_Model_User::getUsersOfType('A'); $admins = Application_Model_User::getUsersOfType('A');
if (count($admins) > 0) { // found admin => pick first one if (count($admins) > 0) { // found admin => pick first one
return $admins[0];
return $admins[0]->getDbId();
} else { } else {
Logging::warn("Warning. no admins found in database"); Logging::warn("Warning. no admins found in database");
return null; return null;
} }
} }
public static function getFirstAdminId()
{
$admin = self::getFirstAdmin();
if ($admin) {
return $admin->getDbId();
} else {
return null;
}
}
public static function getUsers(array $type, $search=null) public static function getUsers(array $type, $search=null)
{ {
$con = Propel::getConnection(); $con = Propel::getConnection();

View File

@ -64,7 +64,7 @@ var AIRTIME = (function(AIRTIME) {
helper : function() { helper : function() {
var $el = $(this), selected = mod var $el = $(this), selected = mod
.getChosenAudioFilesLength(), container, message, li = $("#side_playlist ul li:first"), width = li .getChosenAudioFilesLength(), container, message, li = $("#side_playlist ul[id='spl_sortable'] li:first"), width = li
.width(), height = li.height(); .width(), height = li.height();
// dragging an element that has an unselected // dragging an element that has an unselected

View File

@ -255,6 +255,8 @@ function eventRender(event, element, view) {
} }
//add scheduled show content empty icon //add scheduled show content empty icon
addIcon = checkEmptyShowStatus(event);
if (!addIcon) {
if (view.name === 'agendaDay' || view.name === 'agendaWeek') { if (view.name === 'agendaDay' || view.name === 'agendaWeek') {
if (event.show_empty === 1 && event.record === 0 && event.rebroadcast === 0) { if (event.show_empty === 1 && event.record === 0 && event.rebroadcast === 0) {
if (event.soundcloud_id === -1) { if (event.soundcloud_id === -1) {
@ -280,6 +282,7 @@ function eventRender(event, element, view) {
} }
} }
} }
}
//rebroadcast icon //rebroadcast icon
if((view.name === 'agendaDay' || view.name === 'agendaWeek') && event.rebroadcast === 1) { if((view.name === 'agendaDay' || view.name === 'agendaWeek') && event.rebroadcast === 1) {
@ -416,6 +419,7 @@ function getCurrentShow(){
function addQtipToSCIcons(ele){ function addQtipToSCIcons(ele){
var id = $(ele).attr("id"); var id = $(ele).attr("id");
if($(ele).hasClass("progress")){ if($(ele).hasClass("progress")){
$(ele).qtip({ $(ele).qtip({
content: { content: {
@ -508,6 +512,36 @@ function addQtipToSCIcons(ele){
} }
} }
/* This functions does two things:
* 1. Checks if each event(i.e. a show) is over and removes the show empty icon if it is
* 2. Else, if an event is passed in, it checks if the event(i.e. a show) is over
* This gets checked when we are deciding if the show-empty icon should be added
* at the beginning of an event render callback.
*/
function checkEmptyShowStatus(e) {
var currDate = new Date();
var endTime;
if (e === undefined) {
var events = $('#schedule_calendar').fullCalendar('clientEvents');
$.each(events, function(i, event){
endTime = event.end;
$emptyIcon = $("span[id="+event.id+"][class='small-icon show-empty']");
if (currDate.getTime() > endTime.getTime() && $emptyIcon.length === 1) {
$emptyIcon.remove();
}
});
} else {
endTime = e.end;
var showOver = false;
if (currDate.getTime() > endTime.getTime()) {
showOver = true;
}
return showOver;
}
}
//Alert the error and reload the page //Alert the error and reload the page
//this function is used to resolve concurrency issue //this function is used to resolve concurrency issue
function alertShowErrorAndReload(){ function alertShowErrorAndReload(){
@ -518,6 +552,7 @@ function alertShowErrorAndReload(){
$(document).ready(function(){ $(document).ready(function(){
setInterval( "checkSCUploadStatus()", 5000 ); setInterval( "checkSCUploadStatus()", 5000 );
setInterval( "getCurrentShow()", 5000 ); setInterval( "getCurrentShow()", 5000 );
setInterval( "checkEmptyShowStatus()", 5000 );
}); });
var view_name; var view_name;

View File

@ -66,6 +66,7 @@ class Organizer(ReportHandler,Loggable):
# See hack in mmp.magic_move # See hack in mmp.magic_move
def new_dir_watch(d): def new_dir_watch(d):
# TODO : rewrite as return lambda : dispatcher.send(...
def cb(): def cb():
dispatcher.send(signal="add_subwatch", sender=self, dispatcher.send(signal="add_subwatch", sender=self,
directory=d) directory=d)