CC-2562 : Allow users to convert linked files into watched directories

This commit is contained in:
Naomi Aro 2011-07-25 12:41:13 +02:00
parent 79f8bb8af9
commit 0b5e3a54b4
1 changed files with 35 additions and 9 deletions

View File

@ -60,7 +60,7 @@ class MusicDir {
RabbitMq::PushSchedule(); RabbitMq::PushSchedule();
} }
/** /**
* Checks if p_dir1 is the ancestor of p_dir2. Returns * Checks if p_dir1 is the ancestor of p_dir2. Returns
* true if it is the ancestor, false otherwise. Note that * true if it is the ancestor, false otherwise. Note that
@ -77,7 +77,7 @@ class MusicDir {
if (strlen($p_dir1) > strlen($p_dir2)){ if (strlen($p_dir1) > strlen($p_dir2)){
return false; return false;
} }
return substr($p_dir2, 0, strlen($p_dir1)) == $p_dir1; return substr($p_dir2, 0, strlen($p_dir1)) == $p_dir1;
} }
@ -85,15 +85,15 @@ class MusicDir {
* Checks whether the path provided is a valid path. A valid path * Checks whether the path provided is a valid path. A valid path
* is defined as not being nested within an existing watched directory, * is defined as not being nested within an existing watched directory,
* or vice-versa. Throws a NestedDirectoryException if invalid. * or vice-versa. Throws a NestedDirectoryException if invalid.
* *
* @param string $p_path * @param string $p_path
* The path we want to validate * The path we want to validate
* @return void * @return void
*/ */
public static function isPathValid($p_path){ public static function isPathValid($p_path){
$dirs = self::getWatchedDirs(); $dirs = self::getWatchedDirs();
$dirs[] = self::getStorDir(); $dirs[] = self::getStorDir();
foreach ($dirs as $dirObj){ foreach ($dirs as $dirObj){
$dir = $dirObj->getDirectory(); $dir = $dirObj->getDirectory();
$diff = strlen($dir) - strlen($p_path); $diff = strlen($dir) - strlen($p_path);
@ -108,7 +108,7 @@ class MusicDir {
} else { /* diff < 0*/ } else { /* diff < 0*/
if (self::isAncestorDir($dir, $p_path)){ if (self::isAncestorDir($dir, $p_path)){
throw new NestedDirectoryException("'$p_path' is nested within existing watched directory: '$dir'"); throw new NestedDirectoryException("'$p_path' is nested within existing watched directory: '$dir'");
} }
} }
} }
} }
@ -121,10 +121,10 @@ class MusicDir {
$dir = new CcMusicDirs(); $dir = new CcMusicDirs();
$dir->setType($p_type); $dir->setType($p_type);
$p_path = realpath($p_path)."/"; $p_path = realpath($p_path)."/";
try { try {
/* isPathValid() checks if path is a substring or a superstring of an /* isPathValid() checks if path is a substring or a superstring of an
* existing dir and if not, throws NestedDirectoryException */ * existing dir and if not, throws NestedDirectoryException */
self::isPathValid($p_path); self::isPathValid($p_path);
$dir->setDirectory($p_path); $dir->setDirectory($p_path);
@ -143,7 +143,33 @@ class MusicDir {
public static function addWatchedDir($p_path) public static function addWatchedDir($p_path)
{ {
$res = self::addDir($p_path, "watched"); $res = self::addDir($p_path, "watched");
if($res['code'] == 0){ if ($res['code'] == 0){
//convert "linked" files (Airtime <= 1.8.2) to watched files.
$propel_link_dir = CcMusicDirsQuery::create()
->filterByType('link')
->findOne();
$link_files = CcFilesQuery::create()
->setFormatter(ModelCriteria::FORMAT_ON_DEMAND)
->filterByDbDirectory($propel_link_dir->getId())
->find();
foreach ($link_files as $link_file) {
$link_filepath = $link_file->getDbFilepath();
//convert "link" file into a watched file.
if ((strlen($propel_link_dir->getDirectory()) < $link_filepath) && (substr($link_filepath, 0, strlen($propel_link_dir->getDirectory())) === $propel_link_dir->getDirectory())) {
//get the filepath path not including the watched directory.
$sub_link_filepath = substr($link_filepath, strlen($propel_link_dir->getDirectory()));
$link_file->setDbDirectory($propel_link_dir->getId());
$link_file->setDbFilepath($sub_link_filepath);
$link_file->save();
}
}
$data = array(); $data = array();
$data["directory"] = $p_path; $data["directory"] = $p_path;
RabbitMq::SendMessageToMediaMonitor("new_watch", $data); RabbitMq::SendMessageToMediaMonitor("new_watch", $data);