rhaco.org

PHP library & setup framework

jaja rev. 263

branches/pond/library/CustomViews.php

DBの設計変更

<?php
Rhaco::import("generic.Views");
Rhaco::import("tag.feed.FeedParser");
Rhaco::import("util.DocUtil");
Rhaco::import("io.FileUtil");
Rhaco::import("model.CommitLog");
Rhaco::import("model.Repository");
Rhaco::import("arbo.network.SvnLogger");

class CustomViews extends Views{
	/**
	 * top
	 *
	 * @return unknown
	 */
	function index(){
		return $this->read(new Repository(),new C(Q::order(Repository::columnSortOrder())));
	}
	
	/**
	 * コミットログのRSSを出力する
	 *
	 */
	function rss(){
		$rss = new Rss20(Rhaco::constant(VAR_TITLE),Rhaco::constant(VAR_DESCRIPTION),Rhaco::url());
		$result = $this->dbUtil->select(new CommitLog(),new C(Q::fact(),Q::pager(20),Q::orderDesc(CommitLog::columnRev())));
		
		foreach($result as $obj){
			$rss->setItem($obj->toItem());
		}
		Logger::disableDisplay();
		$rss->output();
	}

/**
	 * rhaco docの表示
	 *
	 * @param unknown_type $path
	 * @return unknown
	 */
	function api($path=""){
		$flow = new Flow();

if(Cache::isExpiry("rhaco_api_paths")){
			$len = strlen(Rhaco::rhacopath());
			
			foreach(FileUtil::find("/\.php$/",Rhaco::rhacopath(),true) as $file){
				$dir = substr($file->getDirectory(),$len);
				$name = substr($file->getFullname(),$len);
				
				$paths[$dir] = str_replace(array("/"),array("."),$dir)."*";
				$paths[$name] = str_replace(array("/",".php"),array(".",""),$name);
			}
			Cache::set("rhaco_api_paths",$paths);
		}
		$fpath = FileUtil::path(Rhaco::rhacopath(),$path);
		if(Cache::isExpiry("rhaco_api_doc_".$fpath)){
			Cache::set("rhaco_api_doc_".$fpath,DocUtil::parse($fpath));
		}
		$flow->setVariable("docs",Cache::get("rhaco_api_doc_".$fpath));
		$flow->setVariable("paths",Cache::get("rhaco_api_paths"));
		$flow->setVariable("path",$path);

return $flow->parser();
	}
	
	/**
	 * ソースを表示する
	 *
	 * @param unknown_type $name
	 * @param unknown_type $rev
	 * @param unknown_type $url
	 * @return unknown
	 */
	function source($name,$rev,$url){
		$log = $this->dbUtil->get(new CommitLog(),new C(
													Q::eq(Repository::columnName(),$name),
													Q::eq(CommitLog::columnRepositoryId(),Repository::columnId()),
													Q::eq(CommitLog::columnRev(),$rev),
													Q::fact()
									));
		if($log !== null){
			$repository = $log->getFactRepositoryId();
			$source = $this->dbUtil->get(new Source(),new C(
												Q::eq(Source::columnLogId(),$log->getId()),
												Q::eq(Source::columnPath(),$url)
									));
			if($source === null){
				$svn = new SvnLogger($repository->getType(),$repository->getUrl(),$repository->getCmd());
				$src = $svn->cat($url,$rev);

if($src !== null){
					$source = new Source();
					$source->setLogId($log->getId());
					$source->setPath($url);
					$source->setValue($src);

$source = $this->dbUtil->get($source,new C(
										Q::eq(Source::columnLogId(),$source->getLogId()),
										Q::eq(Source::columnPath(),$source->getPath()),
										Q::goc(),
										Q::lock()
									));
					$this->dbUtil->commit();									
				}
			}
			if($source !== null){
				$parser = $this->parser();
				$parser->setVariable("source",$source);
				$parser->setVariable("log",$log);
				$parser->setVariable("repository",$repository);
				return $parser;
			}
			Header::redirect(Rhaco::url("svn/".$repository->getName()."?q=".$url));
		}
		Header::redirect(Rhaco::url());
	}
	
	/**
	 * リポジトリのログを表示する
	 *
	 * @param unknown_type $name
	 * @param unknown_type $rev
	 * @return unknown
	 */
	function svn($name,$rev=null){
		$repository = $this->dbUtil->get(new Repository(),new C(Q::eq(Repository::columnName(),$name)));

if($repository !== null){
			$criteria = new Criteria();
			$criteria->q(Q::eq(CommitLog::columnRepositoryId(),$repository->getId()));
			if(!empty($rev)) $criteria->q(Q::lte(CommitLog::columnRev(),$rev));

$svn = new SvnLogger($repository->getType(),$repository->getUrl(),$repository->getCmd());
			$lastObj = $this->dbUtil->get(new CommitLog(),new C(
														Q::orderDesc(CommitLog::columnRev()),
														Q::eq(CommitLog::columnRepositoryId(),$repository->getId())
											));

if($lastObj == null || $lastObj->getCommited() < (DateUtil::addHour(time(),-1 * (Rhaco::constant(VAR_SVN_EXPIRY_TIME))))){
				$from = ($lastObj == null) ? 1 : $lastObj->getRev();
				$limit = 5;				
				$last = $svn->last();
				if($last - $from > $limit) $last = $from + $limit;

$count = $this->dbUtil->count(new CommitLog(),new C(
														Q::gt(CommitLog::columnRev(),$from),
														Q::lte(CommitLog::columnRev(),$last),
														Q::eq(CommitLog::columnRepositoryId(),$repository->getId())
											));
				if($count != ($last - $from)){
					$maps = array();
					$result = $this->dbUtil->select(new CommitLog(),new C(
														Q::gte(CommitLog::columnRev(),$from),
														Q::lte(CommitLog::columnRev(),$last),
														Q::eq(CommitLog::columnRepositoryId(),$repository->getId())
											));
					foreach($result as $obj){
						$maps[$obj->getRev()] = $obj;
					}
					foreach($svn->revision($from,$last) as $model){
						if(!isset($maps[$model->id])){
							$obj = CommitLog::copy($this->dbUtil,$repository->getId(),$model);
							$maps[$obj->getRev()] = $obj;
						}
					}
				}
			}
			$parser = $this->read(new CommitLog(),$criteria);
			$parser->setVariable("repository",$repository);
			$parser->setVariable("description",$repository->getDescription());
			return $parser;
		}
		Header::redirect(Rhaco::url());
	}
}
?>