File Source for LMediaManagerCore.php

<?php
/**
* Class file.
*
* @license http://opensource.org/licenses/mozilla1.1.php Mozilla Public License
* @copyright 2005, diemeisterei GmbH. All rights reserved.
* @author $Author: schmunk $
* @version $Revision: 601 $ $Date: 2007-02-24 23:49:30 +0100 (Sa, 24 Feb 2007) $
* @package Phundament.Packages
* @subpackage LMediaManager
*/
/**
* Provides database access and administration functions
*
* @package System.Util
* @subpackage Cores
*/
Prado :: setPathOfAlias("LMediaManager", dirname(__FILE__));
Prado :: using("LMediaManager.db.propel.*");
Prado :: using("LMediaManager.db.propel.l_media_manager.*");
class LMediaManagerCore extends TControl
{
/**
* @return media files directory, defined in application.xml
*/
function getMediaDir()
{
$param= $this->Application->getParameters();
$return= $param->itemAt("MediaDir");
if (!$this->User->isInRole('root'))
$return .= "/web/" . $this->User->Name;
return $return;
}
/**
* scans media directory and updates database
*/
public function updateDatabase($directory= '', $deleteMissing= false, $rightsPanel= null)
{
// TODO
if ($directory == '' && $this->User->isInRole('root'))
$directory= $this->MediaDir . "/web/root";
elseif ($directory == '') $directory= $this->MediaDir;
if ($cache= $this->Application->Cache)
{
$cache->delete("LMediaManager:sets");
}
$files= $this->scanDirectory($directory);
$this->updateMediaFiles($directory, $files, $deleteMissing, $rightsPanel);
}
/**
* returns records from database
*
* Either a Criteria object or a Integer id.
* @param Criteria|integer
*/
public function queryRecords($c= null)
{
static $results;
#Prado :: trace("QueryRecords() ...", "Lithron.LMediaManager");
// caching
if ($c instanceof Criteria)
{
$_id = md5(serialize($c));
}
else
$_id = $c;
if (isset($results[$_id])) return $results[$_id];
// querying
if (is_numeric($c))
{
Prado :: trace("Querying database by id($_id)", "Lithron.LMediaManager");
$results[$_id]= $result= LMediaManagerFilesPeer :: retrieveByPK($c, $this->Application->getModule("database")->getConnection("l_media_manager", "propel"));
return $result;
}
elseif (is_string($c))
{
$string= $c . "%";
$c= new Criteria;
$c->add(LMediaManagerFilesPeer :: DIRECTORY, $string, Criteria :: LIKE);
}
if (!$c instanceof Criteria)
{
$c= new Criteria;
}
Prado :: trace("Querying database by criteria ($_id)", "Lithron.LMediaManager");
$results[$_id]= $result= LMediaManagerFilesPeer :: doSelect($c, $this->Application->getModule("database")->getConnection("l_media_manager", "propel"));
#Prado :: trace("Queried.", "Lithron.LMediaManager");
return $result;
}
/**
* scans media directory
*/
private function scanDirectory($dir, $files= array ())
{
if (!is_dir($dir))
{
Prado :: log("Invalid media files directory", 4, "Lithron.LMediaManager");
return;
}
$_scan= scandir($dir);
foreach ($_scan AS $item)
{
$location= $dir . "/" . $item;
if (substr($item, 0, 1) == ".")
continue;
if (is_dir($location))
{
$files= $this->scanDirectory($location, $files);
}
if (is_file($location))
{
// may need rework due to performance :( TODO
$_data['name']= $item;
$_data['directory']= $dir;
$_data['md5']= md5_file($location);
$_data['size']= filesize($location);
#var_dump($_data);
$files[]= $_data;
}
}
#var_dump($files);
$this->Application->getModule("user_message")->add($dir . " scanned", 1);
return $files;
}
/**
* compares files and updates database
*/
private function updateMediaFiles($directory, $files, $deleteMissing= false, $permissions= LPermissions :: DEFAULTS)
{
$completeRS= $this->queryRecords();
$subsetRS= $this->queryRecords($directory);
$filesProcessed= array ();
$conn= $this->Application->getModule("database")->getConnection("l_media_manager", "propel");
$magick= new LImage;
$this->Application->getModule("user_message")->add("Found " . count($completeRS) . " files in database", 1);
$this->Application->getModule("user_message")->add("Found " . count($files) . " files in filesystem", 1);
if (is_array($files))
// walk throgh files from filesystem
foreach ($files AS $file)
{
$_found= false;
// compare with database
if (is_array($completeRS))
{
#Prado :: trace("Comparing " . $file['name'] . " with files from database.", "Lithron.LMediaManager");
#var_dump($completeRS);
foreach ($completeRS AS $key => $record)
{
// compare md5
if ($record->getMd5() == $file['md5'])
{
unset ($completeRS[$key]);
Prado :: trace("Found " . $file['name'] . " in database.", "Lithron.LMediaManager");
$_found= true;
break;
}
}
}
foreach ($filesProcessed AS $key => $record)
{
# if ($record['directory'].$record['name'] == $file['directory'].$file['name'])
# continue;
if ($record['md5'] == $file['md5'])
{
Prado :: log("Duplicate media file '{$file['name']}' - FILE WAS NOT ADDED", 8, "Lithron.LMediaManager");
continue 2;
}
}
$filesProcessed[]= $file;
// set columns
if ($_found == false)
{
$this->Application->getModule("user_message")->add("New " . $file['name'] . " scanned", 1);
Prado :: trace("New media file '{$file['name']}'", "Lithron.LMediaManager");
// create new file if md5 not found
$new= new LMediaManagerFiles;
$_data= $magick->doIdentify($file['directory'] . "/" . $file['name']);
if (is_array($_data))
foreach ($_data AS $key => $d)
{
$file[$key]= $d;
// TODO ?
@ $new->setType($file['type']);
$new->setSize($file['size']);
@ $new->setSizeShort($file['size_short']);
@ $new->setWidth($file['width']);
@ $new->setHeight($file['height']);
@ $new->setColorspace($file['colorspace']);
@ $new->setTransparent($file['transparent']);
@ $new->setResolutionX($file['resolution_x']);
@ $new->setResolutionY($file['resolution_y']);
@ $new->setColors($file['colors']);
@ $new->setImageDepth($file['image_depth']);
}
$new->setDescription($file['name']);
}
else
{
Prado :: trace("Existing media file '{$file['name']}' found", "Lithron.LMediaManager");
// open existing file and update info
$c= new Criteria;
$c->add(LMediaManagerFilesPeer :: MD5, $file['md5']);
LRightsManager :: restrictCriteria($c, "LMediaManagerFilesPeer");
$result= LMediaManagerFilesPeer :: doSelect($c, $conn);
if (isset ($result[0]))
$new= $result[0];
else
{
// do not apply changes when file is from another user
$um = $this->Application->getModule("user_message");
if ($um !== null) $um->add("File {$file['name']} not added to database, same file exists with md5 ({$file['md5']})!", 1);
Prado :: trace("No changes applied to existing media file '{$file['name']}'", "Lithron.LMediaManager");
continue;
}
}
LRightsManager :: setRights($new, $permissions);
$new->setFileName($file['name']);
$new->setMd5($file['md5']);
$new->setDirectory($file['directory']);
$new->setStatus(true);
$new->save();
}
if (is_array($completeRS))
// set missing files in db to status false
foreach ($completeRS AS $file)
{
// compare complete with subset
$missingId= false;
foreach ($subsetRS AS $sub)
{
if ($sub->getId() == $file->getId())
{
$missingId= $sub->getId();
break;
}
}
Prado :: trace("Non-existing file in database '{$file->getFileName()}'", "Lithron.LMediaManager");
$c= new Criteria;
$c->add(LMediaManagerFilesPeer :: ID, $missingId);
$result= LMediaManagerFilesPeer :: doSelect($c, $conn);
foreach ($result AS $record)
{
if ($deleteMissing)
{
Prado :: trace("Deleting media file ", "Lithron.LMediaManager");
$record->delete();
}
else
{
$record->setStatus(false);
$record->save();
}
}
}
}
}
?>

Source for file LMediaManagerCore.php