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.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 import org.eclipse.jgit.treewalk.TreeWalk 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 ite = git.log.add(ObjectId.fromString(id)).call.iterator val rev = ite.next val old = ite.next val diffs = if(old != null){ // get diff between specified commit and its previous commit val reader = git.getRepository.newObjectReader val oldTreeIter = new CanonicalTreeParser oldTreeIter.reset(reader, git.getRepository.resolve(old.name + "^{tree}")) val newTreeIter = new CanonicalTreeParser newTreeIter.reset(reader, git.getRepository.resolve(id + "^{tree}")) import scala.collection.JavaConverters._ 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)) } } else { // initial commit val walk = new TreeWalk(git.getRepository) walk.addTree(rev.getTree) val buffer = new scala.collection.mutable.ListBuffer[DiffInfo]() while(walk.next){ buffer.append(DiffInfo(ChangeType.ADD, null, walk.getPathString, None, getContent(git, walk.getObjectId(0)))) } buffer.toList } html.commit(branch, CommitInfo(rev.getName, rev.getCommitterIdent.getWhen, rev.getCommitterIdent.getName, rev.getFullMessage), repositoryInfo, diffs) } /** * Get object content of the given id as String from the Git repository. * * @param git the Git object * @param id the object id * @return the object or None if object does not exist */ def getContent(git: Git, id: ObjectId): Option[String] = try { Some(new String(git.getRepository.getObjectDatabase.open(id).getBytes, "UTF-8")) } 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 ) } }