package app import util.Directory._ import util.Implicits._ import util.{JGitUtil, FileTypeUtil} 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.treewalk._ import org.eclipse.jgit.revwalk.RevCommit import org.eclipse.jgit.diff.DiffEntry.ChangeType import org.eclipse.jgit.revwalk.RevWalk case class RepositoryInfo(owner: String, name: String, url: String, branchList: List[String], tags: List[String]) case class FileInfo(id: ObjectId, isDirectory: Boolean, name: String, time: Date, message: String, committer: String) case class CommitInfo(id: String, time: Date, committer: String, message: String){ def this(rev: org.eclipse.jgit.revwalk.RevCommit) = this(rev.getName, rev.getCommitterIdent.getWhen, rev.getCommitterIdent.getName, rev.getFullMessage) } case class DiffInfo(changeType: ChangeType, oldPath: String, newPath: String, oldContent: Option[String], newContent: Option[String]) case class ContentInfo(viewType: String, content: Option[String]) /** * The repository viewer. */ class RepositoryViewerServlet extends ServletBase { /** * Displays user information. */ get("/:owner") { val owner = params("owner") html.user(owner, getRepositories(owner).map(JGitUtil.getRepositoryInfo(owner, _, servletContext))) } /** * Displays 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) } /** * Displays the file list of the repository root and the specified branch. */ get("/:owner/:repository/tree/:id") { val owner = params("owner") val repository = params("repository") fileList(owner, repository, params("id")) } /** * Displays the file list of the specified path and branch. */ get("/:owner/:repository/tree/:id/*") { val owner = params("owner") val repository = params("repository") fileList(owner, repository, params("id"), multiParams("splat").head) } /** * Displays 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 (logs, hasNext) = JGitUtil.getCommitLog( Git.open(getRepositoryDir(owner, repository)).getRepository, branchName, page) html.commits(branchName, JGitUtil.getRepositoryInfo(owner, repository, servletContext), logs.splitWith{ (commit1, commit2) => view.helpers.date(commit1.time) == view.helpers.date(commit2.time) }, page, hasNext) } /** * Displays the file content of the specified branch or commit. */ get("/:owner/:repository/blob/:id/*"){ val owner = params("owner") val repository = params("repository") val id = params("id") // branch name or commit id val raw = params.get("raw").getOrElse("false").toBoolean val path = multiParams("splat").head.replaceFirst("^tree/.+?/", "") val repositoryInfo = JGitUtil.getRepositoryInfo(owner, repository, servletContext) val git = Git.open(getRepositoryDir(owner, repository)) val commitId = git.getRepository.resolve(id) val revWalk = new RevWalk(git.getRepository) val revCommit = revWalk.parseCommit(commitId) revWalk.dispose @scala.annotation.tailrec def getPathObjectId(path: String, walk: TreeWalk): ObjectId = walk.next match { case true if(walk.getPathString == path) => walk.getObjectId(0) case true => getPathObjectId(path, walk) } val treeWalk = new TreeWalk(git.getRepository) treeWalk.addTree(revCommit.getTree) treeWalk.setRecursive(true) val objectId = getPathObjectId(path, treeWalk) treeWalk.release if(raw){ // Download contentType = "application/octet-stream" JGitUtil.getContent(git, objectId, false) } else { // Viewer val large = FileTypeUtil.isLarge(git.getRepository.getObjectDatabase.open(objectId).getSize) val viewer = if(FileTypeUtil.isImage(path)) "image" else if(large) "large" else "text" val content = ContentInfo(viewer, if(viewer == "text") JGitUtil.getContent(git, objectId, false).map(new String(_, "UTF-8")) else None) html.blob(id, repositoryInfo, path.split("/").toList, content, new CommitInfo(revCommit)) } } /** * Displays details of the specified commit. */ get("/:owner/:repository/commit/:id"){ val owner = params("owner") val repository = params("repository") val id = params("id") val repositoryInfo = JGitUtil.getRepositoryInfo(owner, repository, servletContext) val git = Git.open(getRepositoryDir(owner, repository)) @scala.annotation.tailrec def getCommitLog(i: java.util.Iterator[RevCommit], logs: List[RevCommit]): List[RevCommit] = i.hasNext match { case true if(logs.size < 2) => getCommitLog(i, logs :+ i.next) case _ => logs } val revWalk = new RevWalk(git.getRepository) revWalk.markStart(revWalk.parseCommit(git.getRepository.resolve(id))) val commits = getCommitLog(revWalk.iterator, Nil) revWalk.release val rev = commits(0) val old = commits(1) 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, JGitUtil.getContent(git, diff.getOldId.toObjectId, false).map(new String(_, "UTF-8")), JGitUtil.getContent(git, diff.getNewId.toObjectId, false).map(new String(_, "UTF-8"))) } } 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, JGitUtil.getContent(git, walk.getObjectId(0), false).map(new String(_, "UTF-8")))) } walk.release buffer.toList } html.commit(id, CommitInfo(rev.getName, rev.getCommitterIdent.getWhen, rev.getCommitterIdent.getName, rev.getFullMessage), repositoryInfo, diffs) } /** * Provides HTML of the file list. * * @param owner the repository owner * @param repository the repository name * @param rev the branch name or commit id(optional) * @param path the directory path (optional) * @return HTML of the file list */ private def fileList(owner: String, repository: String, revstr: String = "", path: String = ".") = { val revision = if(revstr.isEmpty){ Git.open(getRepositoryDir(owner, repository)).getRepository.getBranch } else { revstr } val git = Git.open(getRepositoryDir(owner, repository)) // get latest commit val revWalk = new RevWalk(git.getRepository) val objectId = git.getRepository.resolve(revision) val revCommit = revWalk.parseCommit(objectId) revWalk.dispose val files = JGitUtil.getFileList(owner, repository, revision, path) // process README.md val readme = files.find(_.name == "README.md").map { file => import org.pegdown._ val git = Git.open(getRepositoryDir(owner, repository)) new PegDownProcessor().markdownToHtml(new String(git.getRepository.open(file.id).getBytes, "UTF-8")) } html.files( // current branch revision, // repository JGitUtil.getRepositoryInfo(owner, repository, servletContext), // current path if(path == ".") Nil else path.split("/").toList, // latest commit CommitInfo(revCommit.getName, revCommit.getCommitterIdent.getWhen, revCommit.getCommitterIdent.getName, revCommit.getShortMessage), // file list files, // readme readme ) } }