package app
import util.Directory._
import util.Implicits._
import org.scalatra._
import java.io.File
import java.util.Date
import org.eclipse.jgit.api.Git
import org.eclipse.jgit.lib._
import org.eclipse.jgit.revwalk._
import org.apache.commons.io.FileUtils
import org.eclipse.jgit.revwalk.RevWalk
import org.eclipse.jgit.treewalk.CanonicalTreeParser
import org.eclipse.jgit.diff.DiffEntry.ChangeType
import org.eclipse.jgit.errors.MissingObjectException
case class RepositoryInfo(owner: String, name: String, url: String, branchList: List[String], tags: List[String])
case class FileInfo(isDirectory: Boolean, name: String, time: Date, message: String, committer: String)
case class CommitInfo(id: String, time: Date, committer: String, message: String)
case class DiffInfo(changeType: ChangeType, oldPath: String, newPath: String, oldContent: Option[String], newContent: Option[String])
/**
* The repository viewer.
*/
class RepositoryViewerServlet extends ServletBase {
/**
* Shows user information.
*/
get("/:owner") {
val owner = params("owner")
html.user(owner, getRepositories(owner).map(getRepositoryInfo(owner, _)))
}
/**
* Shows the file list of the repository root and the default branch.
*/
get("/:owner/:repository") {
val owner = params("owner")
val repository = params("repository")
fileList(owner, repository)
}
/**
* Shows the file list of the repository root and the specified branch.
*/
get("/:owner/:repository/tree/:branch") {
val owner = params("owner")
val repository = params("repository")
fileList(owner, repository, params("branch"))
}
/**
* Shows the file list of the specified path and branch.
*/
get("/:owner/:repository/tree/:branch/*") {
val owner = params("owner")
val repository = params("repository")
fileList(owner, repository, params("branch"), multiParams("splat").head)
}
/**
* Shows the commit list of the specified branch.
*/
get("/:owner/:repository/commits/:branch"){
val owner = params("owner")
val repository = params("repository")
val branchName = params("branch")
val page = params.getOrElse("page", "1").toInt
val dir = getBranchDir(owner, repository, branchName)
// TODO Do recursive without var.
val i = Git.open(dir).log.call.iterator
val listBuffer = scala.collection.mutable.ListBuffer[CommitInfo]()
var count = 0
while(i.hasNext && listBuffer.size < 30){
count = count + 1
val ref = i.next
if((page - 1) * 30 < count){
listBuffer.append(CommitInfo(ref.getName, ref.getCommitterIdent.getWhen, ref.getCommitterIdent.getName, ref.getShortMessage))
}
}
html.commits(branchName, getRepositoryInfo(owner, repository),
listBuffer.toSeq.splitWith{ (commit1, commit2) =>
view.helpers.date(commit1.time) == view.helpers.date(commit2.time)
}, page, i.hasNext)
}
/**
* Shows the file content of the specified branch.
*/
get("/:owner/:repository/blob/:branch/*"){
val owner = params("owner")
val repository = params("repository")
val branchName = params("branch")
val path = multiParams("splat").head.replaceFirst("^tree/.+?/", "")
val dir = getBranchDir(owner, repository, branchName)
val content = FileUtils.readFileToString(new File(dir, path), "UTF-8")
val git = Git.open(dir)
val latestRev = git.log.addPath(path).call.iterator.next
html.blob(branchName, getRepositoryInfo(owner, repository), path.split("/").toList, content,
CommitInfo(latestRev.getName, latestRev.getCommitterIdent.getWhen, latestRev.getCommitterIdent.getName, latestRev.getShortMessage))
}
/**
* Shows details of the specified commit.
*/
get("/:owner/:repository/commit/:id"){
val owner = params("owner")
val repository = params("repository")
val id = params("id")
val repositoryInfo = getRepositoryInfo(owner, repository)
// get branch by commit id
val branch = repositoryInfo.branchList.find { branch =>
val git = Git.open(getBranchDir(owner, repository, branch))
git.log.add(ObjectId.fromString(id)).call.iterator.hasNext
}.get
val dir = getBranchDir(owner, repository, branch)
val git = Git.open(dir)
val rev = git.log.add(ObjectId.fromString(id)).call.iterator.next
// get diff
val reader = git.getRepository.newObjectReader
val oldTreeIter = new CanonicalTreeParser
oldTreeIter.reset(reader, git.getRepository.resolve(id + "^{tree}"))
// TODO specify previous commit
val newTreeIter = new CanonicalTreeParser
newTreeIter.reset(reader, git.getRepository.resolve("HEAD^{tree}"))
import scala.collection.JavaConverters._
val diffs = git.diff.setNewTree(newTreeIter).setOldTree(oldTreeIter).call.asScala.map { diff =>
DiffInfo(diff.getChangeType, diff.getOldPath, diff.getNewPath,
getContent(git, diff.getOldId.toObjectId),
getContent(git, diff.getNewId.toObjectId))
}
html.commit(branch,
CommitInfo(rev.getName, rev.getCommitterIdent.getWhen, rev.getCommitterIdent.getName, rev.getFullMessage),
repositoryInfo, diffs)
}
def getContent(git: Git, id: ObjectId): Option[String] = try {
Some(new String(git.getRepository.getObjectDatabase.open(id).getBytes()))
} catch {
case e: MissingObjectException => None
}
/**
* Returns the repository information. It contains branch names and tag names.
*
* @param owner the repository owner
* @param repository the repository name
*/
def getRepositoryInfo(owner: String, repository: String): RepositoryInfo = {
val git = Git.open(getRepositoryDir(owner, repository))
RepositoryInfo(
owner, repository, "http://localhost:8080%s/git/%s/%s.git".format(servletContext.getContextPath, owner, repository),
// branches
git.branchList.call.toArray.map { ref =>
ref.asInstanceOf[Ref].getName.replaceFirst("^refs/heads/", "")
}.toList,
// tags
git.tagList.call.toArray.map { ref =>
ref.asInstanceOf[Ref].getName
}.toList
)
}
/**
* Provides HTML of the file list.
*
* @param owner the repository owner
* @param repository the repository name
* @param branch the branch name (optional)
* @param path the directory path (optional)
* @return HTML of the file list
*/
def fileList(owner: String, repository: String, branch: String = "", path: String = ".") = {
val branchName = if(branch.isEmpty){
Git.open(getRepositoryDir(owner, repository)).getRepository.getBranch
} else {
branch
}
val dir = getBranchDir(owner, repository, branchName)
val git = Git.open(dir)
val latestRev = {if(path == ".") git.log else git.log.addPath(path)}.call.iterator.next
html.files(
// current branch
branchName,
// repository
getRepositoryInfo(owner, repository),
// current path
if(path == ".") Nil else path.split("/").toList,
// latest commit
CommitInfo(latestRev.getName, latestRev.getCommitterIdent.getWhen, latestRev.getCommitterIdent.getName, latestRev.getShortMessage),
// file list
new File(dir, path).listFiles()
.filterNot{ file => file.getName == ".git" }
.sortWith { (file1, file2) =>
if(file1.isDirectory && !file2.isDirectory){
true
} else if(!file1.isDirectory && file2.isDirectory){
false
} else {
file1.getName.compareTo(file2.getName) < 0
}
}
.map { file =>
val rev = Git.open(dir).log.addPath(if(path == ".") file.getName else path + "/" + file.getName).call.iterator.next
if(rev == null){
None
} else {
Some(FileInfo(file.isDirectory, file.getName, latestRev.getCommitterIdent.getWhen, rev.getShortMessage, rev.getCommitterIdent.getName))
}
}
.flatten.toList
)
}
}