From a1ea877042b93949ef244b96e8affd65cc3f89c1 Mon Sep 17 00:00:00 2001 From: James Moger <james.moger@gitblit.com> Date: Wed, 01 Jun 2011 20:19:51 -0400 Subject: [PATCH] Readme markdown on summary page per-repository. --- src/com/gitblit/utils/JGitUtils.java | 654 +++++++++++++++++++++++++++++++++++++++++++++++++---------- 1 files changed, 539 insertions(+), 115 deletions(-) diff --git a/src/com/gitblit/utils/JGitUtils.java b/src/com/gitblit/utils/JGitUtils.java index 31b5677..5f72c9a 100644 --- a/src/com/gitblit/utils/JGitUtils.java +++ b/src/com/gitblit/utils/JGitUtils.java @@ -1,22 +1,49 @@ +/* + * Copyright 2011 gitblit.com. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ package com.gitblit.utils; import java.io.ByteArrayOutputStream; import java.io.File; import java.io.IOException; import java.io.InputStream; -import java.io.RandomAccessFile; -import java.text.DateFormat; -import java.text.SimpleDateFormat; +import java.io.OutputStream; +import java.nio.charset.Charset; +import java.text.ParseException; import java.util.ArrayList; +import java.util.Collection; import java.util.Collections; import java.util.Date; import java.util.HashMap; import java.util.List; import java.util.Map; +import java.util.Map.Entry; import java.util.Set; +import java.util.concurrent.atomic.AtomicInteger; +import java.util.zip.ZipEntry; +import java.util.zip.ZipOutputStream; import org.eclipse.jgit.api.Git; +import org.eclipse.jgit.diff.DiffEntry; +import org.eclipse.jgit.diff.DiffEntry.ChangeType; +import org.eclipse.jgit.diff.DiffFormatter; +import org.eclipse.jgit.diff.RawTextComparator; import org.eclipse.jgit.errors.ConfigInvalidException; +import org.eclipse.jgit.errors.IncorrectObjectTypeException; +import org.eclipse.jgit.errors.MissingObjectException; +import org.eclipse.jgit.errors.StopWalkException; import org.eclipse.jgit.lib.AnyObjectId; import org.eclipse.jgit.lib.Constants; import org.eclipse.jgit.lib.FileMode; @@ -29,44 +56,73 @@ import org.eclipse.jgit.revwalk.RevBlob; import org.eclipse.jgit.revwalk.RevCommit; import org.eclipse.jgit.revwalk.RevObject; +import org.eclipse.jgit.revwalk.RevSort; import org.eclipse.jgit.revwalk.RevTree; import org.eclipse.jgit.revwalk.RevWalk; +import org.eclipse.jgit.revwalk.filter.RevFilter; import org.eclipse.jgit.treewalk.TreeWalk; +import org.eclipse.jgit.treewalk.filter.AndTreeFilter; +import org.eclipse.jgit.treewalk.filter.OrTreeFilter; import org.eclipse.jgit.treewalk.filter.PathFilter; import org.eclipse.jgit.treewalk.filter.PathFilterGroup; +import org.eclipse.jgit.treewalk.filter.PathSuffixFilter; +import org.eclipse.jgit.treewalk.filter.TreeFilter; +import org.eclipse.jgit.util.io.DisabledOutputStream; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import com.gitblit.wicket.models.Metric; -import com.gitblit.wicket.models.PathModel; -import com.gitblit.wicket.models.RefModel; +import com.gitblit.models.PathModel; +import com.gitblit.models.PathModel.PathChangeModel; +import com.gitblit.models.RefModel; +import com.gitblit.models.TicketModel; +import com.gitblit.models.TicketModel.Comment; public class JGitUtils { - /** Prefix for notes refs */ - public static final String R_NOTES = "refs/notes/"; + static final Logger LOGGER = LoggerFactory.getLogger(JGitUtils.class); - /** Standard notes ref */ - public static final String R_NOTES_COMMITS = R_NOTES + "commits"; + public static Repository createRepository(File repositoriesFolder, String name, boolean bare) { + Git git = Git.init().setDirectory(new File(repositoriesFolder, name)).setBare(bare).call(); + return git.getRepository(); + } - private final static Logger LOGGER = LoggerFactory.getLogger(JGitUtils.class); - - public static List<String> getRepositoryList(File repositoriesFolder, boolean exportAll, boolean readNested) { + public static List<String> getRepositoryList(File repositoriesFolder, boolean exportAll, + boolean readNested) { List<String> list = new ArrayList<String>(); - list.addAll(getNestedRepositories(repositoriesFolder, repositoriesFolder, exportAll, readNested)); + list.addAll(getNestedRepositories(repositoriesFolder, repositoriesFolder, exportAll, + readNested)); Collections.sort(list); return list; } - public static List<String> getNestedRepositories(File repositoriesFolder, File folder, boolean exportAll, boolean readNested) { - String basefile = repositoriesFolder.getAbsolutePath(); + public static List<String> getNestedRepositories(File repositoriesFolder, File folder, + boolean exportAll, boolean readNested) { List<String> list = new ArrayList<String>(); + if (folder == null || !folder.exists()) { + return list; + } + String basefile = repositoriesFolder.getAbsolutePath(); for (File file : folder.listFiles()) { if (file.isDirectory() && !file.getName().equalsIgnoreCase(Constants.DOT_GIT)) { // if this is a git repository add it to the list + // + // first look for standard folder/.git structure File gitFolder = new File(file, Constants.DOT_GIT); boolean isGitRepository = gitFolder.exists() && gitFolder.isDirectory(); - boolean exportRepository = isGitRepository && (exportAll || new File(gitFolder, "git-daemon-export-ok").exists()); + + // then look for folder.git/HEAD or folder/HEAD and + // folder/config + if (!isGitRepository) { + if ((file.getName().endsWith(Constants.DOT_GIT_EXT) && new File(file, + Constants.HEAD).exists()) + || (new File(file, "config").exists() && new File(file, Constants.HEAD) + .exists())) { + gitFolder = file; + isGitRepository = true; + } + } + boolean exportRepository = isGitRepository + && (exportAll || new File(gitFolder, "git-daemon-export-ok").exists()); if (exportRepository) { // determine repository name relative to repositories folder @@ -80,28 +136,83 @@ // look for nested repositories if (readNested) { - list.addAll(getNestedRepositories(repositoriesFolder, file, exportAll, readNested)); + list.addAll(getNestedRepositories(repositoriesFolder, file, exportAll, + readNested)); } } } return list; } + public static RevCommit getFirstCommit(Repository r, String branch) { + if (!hasCommits(r)) { + return null; + } + if (StringUtils.isEmpty(branch)) { + branch = Constants.HEAD; + } + try { + RevWalk walk = new RevWalk(r); + walk.sort(RevSort.REVERSE); + RevCommit head = walk.parseCommit(r.resolve(branch)); + walk.markStart(head); + RevCommit commit = walk.next(); + walk.dispose(); + return commit; + } catch (Throwable t) { + LOGGER.error("Failed to determine first commit", t); + } + return null; + } + + public static Date getFirstChange(Repository r, String branch) { + RevCommit commit = getFirstCommit(r, branch); + if (commit == null) { + if (r == null || !r.getDirectory().exists()) { + return new Date(0); + } + // fresh repository + return new Date(r.getDirectory().lastModified()); + } + return getCommitDate(commit); + } + + public static boolean hasCommits(Repository r) { + if (r != null && r.getDirectory().exists()) { + return new File(r.getDirectory(), Constants.R_HEADS).list().length > 0; + } + return false; + } + public static Date getLastChange(Repository r) { + if (!hasCommits(r)) { + // null repository + if (r == null) { + return new Date(0); + } + // fresh repository + return new Date(r.getDirectory().lastModified()); + } RevCommit commit = getCommit(r, Constants.HEAD); return getCommitDate(commit); } - public static RevCommit getCommit(Repository r, String commitId) { + public static RevCommit getCommit(Repository r, String objectId) { RevCommit commit = null; + if (!hasCommits(r)) { + return null; + } try { - ObjectId objectId = r.resolve(commitId); + if (objectId == null || objectId.trim().length() == 0) { + objectId = Constants.HEAD; + } + ObjectId object = r.resolve(objectId); RevWalk walk = new RevWalk(r); - RevCommit rev = walk.parseCommit(objectId); + RevCommit rev = walk.parseCommit(object); commit = rev; walk.dispose(); } catch (Throwable t) { - LOGGER.error("Failed to determine last change", t); + LOGGER.error("Failed to get commit " + objectId, t); } return commit; } @@ -109,13 +220,13 @@ public static Map<ObjectId, List<String>> getAllRefs(Repository r) { Map<ObjectId, List<String>> refs = new HashMap<ObjectId, List<String>>(); Map<AnyObjectId, Set<Ref>> allRefs = r.getAllRefsByPeeledObjectId(); - for (AnyObjectId id : allRefs.keySet()) { + for (Entry<AnyObjectId, Set<Ref>> setRefs : allRefs.entrySet()) { List<String> list = new ArrayList<String>(); - for (Ref setRef : allRefs.get(id)) { + for (Ref setRef : setRefs.getValue()) { String name = setRef.getName(); list.add(name); } - refs.put(id.toObjectId(), list); + refs.put(setRefs.getKey().toObjectId(), list); } return refs; } @@ -123,15 +234,15 @@ public static Map<ObjectId, List<String>> getRefs(Repository r, String baseRef) { Map<ObjectId, List<String>> refs = new HashMap<ObjectId, List<String>>(); Map<AnyObjectId, Set<Ref>> allRefs = r.getAllRefsByPeeledObjectId(); - for (AnyObjectId id : allRefs.keySet()) { + for (Entry<AnyObjectId, Set<Ref>> setRefs : allRefs.entrySet()) { List<String> list = new ArrayList<String>(); - for (Ref setRef : allRefs.get(id)) { + for (Ref setRef : setRefs.getValue()) { String name = setRef.getName(); if (name.startsWith(baseRef)) { list.add(name); } } - refs.put(id.toObjectId(), list); + refs.put(setRefs.getKey().toObjectId(), list); } return refs; } @@ -191,21 +302,26 @@ } public static String getRawContentAsString(Repository r, RevBlob blob) { - return new String(getRawContent(r, blob)); + byte[] content = getRawContent(r, blob); + return new String(content, Charset.forName(Constants.CHARACTER_ENCODING)); } public static String getRawContentAsString(Repository r, RevCommit commit, String blobPath) { RevObject obj = getRevObject(r, commit.getTree(), blobPath); - return new String(getRawContent(r, (RevBlob) obj)); + byte[] content = getRawContent(r, (RevBlob) obj); + return new String(content, Charset.forName(Constants.CHARACTER_ENCODING)); } - public static List<PathModel> getFilesInPath(Repository r, String basePath, String commitId) { - RevCommit commit = getCommit(r, commitId); + public static List<PathModel> getFilesInPath(Repository r, String basePath, String objectId) { + RevCommit commit = getCommit(r, objectId); return getFilesInPath(r, basePath, commit); } public static List<PathModel> getFilesInPath(Repository r, String basePath, RevCommit commit) { List<PathModel> list = new ArrayList<PathModel>(); + if (commit == null) { + return list; + } final TreeWalk walk = new TreeWalk(r); try { walk.addTree(commit.getTree()); @@ -241,29 +357,120 @@ return list; } - public static List<PathModel> getCommitChangedPaths(Repository r, String commitId) { + public static List<PathChangeModel> getFilesInCommit(Repository r, String commitId) { RevCommit commit = getCommit(r, commitId); - return getCommitChangedPaths(r, commit); + return getFilesInCommit(r, commit); } - public static List<PathModel> getCommitChangedPaths(Repository r, RevCommit commit) { + public static List<PathChangeModel> getFilesInCommit(Repository r, RevCommit commit) { + List<PathChangeModel> list = new ArrayList<PathChangeModel>(); + if (commit == null) { + LOGGER.warn("getFilesInCommit for NULL commit"); + return list; + } + try { + final RevWalk rw = new RevWalk(r); + + RevTree commitTree = commit.getTree(); + + final TreeWalk walk = new TreeWalk(r); + walk.reset(); + walk.setRecursive(true); + if (commit.getParentCount() == 0) { + walk.addTree(commitTree); + while (walk.next()) { + list.add(new PathChangeModel(walk.getPathString(), walk.getPathString(), 0, + walk.getRawMode(0), commit.getId().getName(), ChangeType.ADD)); + } + } else { + RevCommit parent = rw.parseCommit(commit.getParent(0).getId()); + RevTree parentTree = parent.getTree(); + walk.addTree(parentTree); + walk.addTree(commitTree); + walk.setFilter(TreeFilter.ANY_DIFF); + + RawTextComparator cmp = RawTextComparator.DEFAULT; + DiffFormatter df = new DiffFormatter(DisabledOutputStream.INSTANCE); + df.setRepository(r); + df.setDiffComparator(cmp); + df.setDetectRenames(true); + List<DiffEntry> diffs = df.scan(parentTree, commitTree); + for (DiffEntry diff : diffs) { + if (diff.getChangeType().equals(ChangeType.DELETE)) { + list.add(new PathChangeModel(diff.getOldPath(), diff.getOldPath(), 0, diff + .getNewMode().getBits(), commit.getId().getName(), diff + .getChangeType())); + } else { + list.add(new PathChangeModel(diff.getNewPath(), diff.getNewPath(), 0, diff + .getNewMode().getBits(), commit.getId().getName(), diff + .getChangeType())); + } + } + } + } catch (Throwable t) { + LOGGER.error("failed to determine files in commit!", t); + } + return list; + } + + public static List<PathModel> getDocuments(Repository r, List<String> extensions) { List<PathModel> list = new ArrayList<PathModel>(); + RevCommit commit = getCommit(r, Constants.HEAD); final TreeWalk walk = new TreeWalk(r); - walk.setRecursive(false); try { walk.addTree(commit.getTree()); - while (walk.next()) { - list.add(getPathModel(walk, null, commit)); + if (extensions != null && extensions.size() > 0) { + Collection<TreeFilter> suffixFilters = new ArrayList<TreeFilter>(); + for (String extension : extensions) { + if (extension.charAt(0) == '.') { + suffixFilters.add(PathSuffixFilter.create(extension)); + } else { + // escape the . since this is a regexp filter + suffixFilters.add(PathSuffixFilter.create("\\." + extension)); + } + } + TreeFilter filter = OrTreeFilter.create(suffixFilters); + walk.setFilter(filter); + walk.setRecursive(true); + while (walk.next()) { + list.add(getPathModel(walk, null, commit)); + } + } else { + while (walk.next()) { + list.add(getPathModel(walk, null, commit)); + } } - } catch (IOException e) { LOGGER.error("Failed to get files for commit " + commit.getName(), e); } finally { - if (walk != null) { - walk.release(); - } + walk.release(); } + Collections.sort(list); return list; + } + + public static Map<ChangeType, AtomicInteger> getChangedPathsStats(List<PathChangeModel> paths) { + Map<ChangeType, AtomicInteger> stats = new HashMap<ChangeType, AtomicInteger>(); + for (PathChangeModel path : paths) { + if (!stats.containsKey(path.changeType)) { + stats.put(path.changeType, new AtomicInteger(0)); + } + stats.get(path.changeType).incrementAndGet(); + } + return stats; + } + + public static enum DiffOutputType { + PLAIN, GITWEB, GITBLIT; + + public static DiffOutputType forName(String name) { + for (DiffOutputType type : values()) { + if (type.name().equalsIgnoreCase(name)) { + return type; + } + } + return null; + } } private static PathModel getPathModel(TreeWalk walk, String basePath, RevCommit commit) { @@ -280,12 +487,14 @@ } try { if (!walk.isSubtree()) { - size = walk.getObjectReader().getObjectSize(walk.getObjectId(0), Constants.OBJ_BLOB); + size = walk.getObjectReader() + .getObjectSize(walk.getObjectId(0), Constants.OBJ_BLOB); } } catch (Throwable t) { - LOGGER.error("Failed to retrieve blobl size", t); + LOGGER.error("Failed to retrieve blob size", t); } - return new PathModel(name, walk.getPathString(), size, walk.getFileMode(0).getBits(), commit.getName()); + return new PathModel(name, walk.getPathString(), size, walk.getFileMode(0).getBits(), + commit.getName()); } public static String getPermissionsFromMode(int mode) { @@ -308,21 +517,138 @@ return "" + mode; } - public static boolean isTreeFromMode(int mode) { - return FileMode.TREE.equals(mode); + public static List<RevCommit> getRevLog(Repository r, int maxCount) { + return getRevLog(r, Constants.HEAD, 0, maxCount); } - public static List<RevCommit> getRevLog(Repository r, int maxCount) { + public static List<RevCommit> getRevLog(Repository r, String objectId, int offset, int maxCount) { + return getRevLog(r, objectId, null, offset, maxCount); + } + + public static List<RevCommit> getRevLog(Repository r, String objectId, String path, int offset, + int maxCount) { List<RevCommit> list = new ArrayList<RevCommit>(); + if (!hasCommits(r)) { + return list; + } try { - Git git = new Git(r); - Iterable<RevCommit> revlog = git.log().call(); - for (RevCommit rev : revlog) { - list.add(rev); - if (maxCount > 0 && list.size() == maxCount) { - break; + if (objectId == null || objectId.trim().length() == 0) { + objectId = Constants.HEAD; + } + RevWalk walk = new RevWalk(r); + ObjectId object = r.resolve(objectId); + walk.markStart(walk.parseCommit(object)); + if (!StringUtils.isEmpty(path)) { + TreeFilter filter = AndTreeFilter.create( + PathFilterGroup.createFromStrings(Collections.singleton(path)), + TreeFilter.ANY_DIFF); + walk.setTreeFilter(filter); + } + Iterable<RevCommit> revlog = walk; + if (offset > 0) { + int count = 0; + for (RevCommit rev : revlog) { + count++; + if (count > offset) { + list.add(rev); + if (maxCount > 0 && list.size() == maxCount) { + break; + } + } + } + } else { + for (RevCommit rev : revlog) { + list.add(rev); + if (maxCount > 0 && list.size() == maxCount) { + break; + } } } + walk.dispose(); + } catch (Throwable t) { + LOGGER.error("Failed to determine last change", t); + } + return list; + } + + public static enum SearchType { + AUTHOR, COMMITTER, COMMIT; + + public static SearchType forName(String name) { + for (SearchType type : values()) { + if (type.name().equalsIgnoreCase(name)) { + return type; + } + } + return null; + } + + public String toString() { + return name().toLowerCase(); + } + } + + public static List<RevCommit> searchRevlogs(Repository r, String objectId, String value, + final SearchType type, int offset, int maxCount) { + final String lcValue = value.toLowerCase(); + List<RevCommit> list = new ArrayList<RevCommit>(); + if (!hasCommits(r)) { + return list; + } + try { + if (objectId == null || objectId.trim().length() == 0) { + objectId = Constants.HEAD; + } + RevWalk walk = new RevWalk(r); + walk.setRevFilter(new RevFilter() { + + @Override + public RevFilter clone() { + return this; + } + + @Override + public boolean include(RevWalk walker, RevCommit commit) throws StopWalkException, + MissingObjectException, IncorrectObjectTypeException, IOException { + switch (type) { + case AUTHOR: + return (commit.getAuthorIdent().getName().toLowerCase().indexOf(lcValue) > -1) + || (commit.getAuthorIdent().getEmailAddress().toLowerCase() + .indexOf(lcValue) > -1); + case COMMITTER: + return (commit.getCommitterIdent().getName().toLowerCase().indexOf(lcValue) > -1) + || (commit.getCommitterIdent().getEmailAddress().toLowerCase() + .indexOf(lcValue) > -1); + case COMMIT: + return commit.getFullMessage().toLowerCase().indexOf(lcValue) > -1; + } + return false; + } + + }); + ObjectId object = r.resolve(objectId); + walk.markStart(walk.parseCommit(object)); + Iterable<RevCommit> revlog = walk; + if (offset > 0) { + int count = 0; + for (RevCommit rev : revlog) { + count++; + if (count > offset) { + list.add(rev); + if (maxCount > 0 && list.size() == maxCount) { + break; + } + } + } + } else { + for (RevCommit rev : revlog) { + list.add(rev); + if (maxCount > 0 && list.size() == maxCount) { + break; + } + } + } + walk.dispose(); } catch (Throwable t) { LOGGER.error("Failed to determine last change", t); } @@ -333,23 +659,27 @@ return getRefs(r, Constants.R_TAGS, maxCount); } - public static List<RefModel> getHeads(Repository r, int maxCount) { + public static List<RefModel> getLocalBranches(Repository r, int maxCount) { return getRefs(r, Constants.R_HEADS, maxCount); + } + + public static List<RefModel> getRemoteBranches(Repository r, int maxCount) { + return getRefs(r, Constants.R_REMOTES, maxCount); } public static List<RefModel> getRefs(Repository r, String refs, int maxCount) { List<RefModel> list = new ArrayList<RefModel>(); try { Map<String, Ref> map = r.getRefDatabase().getRefs(refs); - for (String name : map.keySet()) { - Ref ref = map.get(name); + for (Entry<String, Ref> entry : map.entrySet()) { + Ref ref = entry.getValue(); RevCommit commit = getCommit(r, ref.getObjectId().getName()); - list.add(new RefModel(name, ref, commit)); + list.add(new RefModel(entry.getKey(), ref, commit)); } Collections.sort(list); Collections.reverse(list); if (maxCount > 0 && list.size() > maxCount) { - list = list.subList(0, maxCount); + list = new ArrayList<RefModel>(list.subList(0, maxCount)); } } catch (IOException e) { LOGGER.error("Failed to retrieve " + refs, e); @@ -358,10 +688,11 @@ } public static Ref getRef(Repository r, String id) { + // FIXME try { Map<String, Ref> map = r.getRefDatabase().getRefs(id); - for (String name : map.keySet()) { - return map.get(name); + for (Entry<String, Ref> entry : map.entrySet()) { + return entry.getValue(); } } catch (IOException e) { LOGGER.error("Failed to retrieve ref " + id, e); @@ -370,7 +701,7 @@ } public static Date getCommitDate(RevCommit commit) { - return new Date(commit.getCommitTime() * 1000l); + return new Date(commit.getCommitTime() * 1000L); } public static String getDisplayName(PersonIdent person) { @@ -378,43 +709,11 @@ r.append(person.getName()); r.append(" <"); r.append(person.getEmailAddress()); - r.append(">"); + r.append('>'); return r.toString(); } - public static String getRepositoryDescription(Repository r) { - File dir = r.getDirectory(); - if (dir.exists()) { - File description = new File(dir, "description"); - if (description.exists() && description.length() > 0) { - RandomAccessFile raf = null; - try { - raf = new RandomAccessFile(description, "r"); - byte[] buffer = new byte[(int) description.length()]; - raf.readFully(buffer); - return new String(buffer); - } catch (Throwable t) { - } finally { - try { - raf.close(); - } catch (Throwable t) { - } - } - } - } - return ""; - } - - public static String getRepositoryOwner(Repository r) { - StoredConfig c = readConfig(r); - if (c == null) { - return ""; - } - String o = c.getString("gitweb", null, "owner"); - return o == null ? "" : o; - } - - private static StoredConfig readConfig(Repository r) { + public static StoredConfig readConfig(Repository r) { StoredConfig c = r.getConfig(); if (c != null) { try { @@ -429,28 +728,153 @@ return null; } - public static List<Metric> getDateMetrics(Repository r) { - final Map<String, Metric> map = new HashMap<String, Metric>(); + public static boolean zip(Repository r, String basePath, String objectId, OutputStream os) + throws Exception { + RevCommit commit = getCommit(r, objectId); + if (commit == null) { + return false; + } + final RevWalk rw = new RevWalk(r); + final TreeWalk walk = new TreeWalk(r); try { - DateFormat df = new SimpleDateFormat("yyyy-MM"); - Git git = new Git(r); - Iterable<RevCommit> revlog = git.log().call(); - for (RevCommit rev : revlog) { - Date d = getCommitDate(rev); - String p = df.format(d); - if (!map.containsKey(p)) - map.put(p, new Metric(p)); - map.get(p).count++; + walk.addTree(commit.getTree()); + ZipOutputStream zos = new ZipOutputStream(os); + zos.setComment("Generated by Git:Blit"); + if (basePath != null && basePath.length() > 0) { + PathFilter f = PathFilter.create(basePath); + walk.setFilter(f); + } + walk.setRecursive(true); + while (walk.next()) { + ZipEntry entry = new ZipEntry(walk.getPathString()); + entry.setSize(walk.getObjectReader().getObjectSize(walk.getObjectId(0), + Constants.OBJ_BLOB)); + entry.setComment(commit.getName()); + zos.putNextEntry(entry); + + ObjectId entid = walk.getObjectId(0); + FileMode entmode = walk.getFileMode(0); + RevBlob blob = (RevBlob) rw.lookupAny(entid, entmode.getObjectType()); + rw.parseBody(blob); + + ObjectLoader ldr = r.open(blob.getId(), Constants.OBJ_BLOB); + byte[] tmp = new byte[4096]; + InputStream in = ldr.openStream(); + int n; + while ((n = in.read(tmp)) > 0) { + zos.write(tmp, 0, n); + } + in.close(); + } + zos.finish(); + return true; + } catch (IOException e) { + LOGGER.error("Failed to zip files from commit " + commit.getName(), e); + } finally { + walk.release(); + rw.dispose(); + } + return false; + } + + public static RefModel getTicketsBranch(Repository r) { + RefModel ticgitBranch = null; + try { + // search for ticgit branch in local heads + for (RefModel ref : getLocalBranches(r, -1)) { + if (ref.displayName.endsWith("ticgit")) { + ticgitBranch = ref; + break; + } + } + + // search for ticgit branch in remote heads + if (ticgitBranch == null) { + for (RefModel ref : getRemoteBranches(r, -1)) { + if (ref.displayName.endsWith("ticgit")) { + ticgitBranch = ref; + break; + } + } } } catch (Throwable t) { - LOGGER.error("Failed to mine log history for metrics", t); + LOGGER.error("Failed to find ticgit branch!", t); } - List<String> keys = new ArrayList<String>(map.keySet()); - Collections.sort(keys); - List<Metric> metrics = new ArrayList<Metric>(); - for (String key:keys) { - metrics.add(map.get(key)); - } - return metrics; + return ticgitBranch; + } + + public static List<TicketModel> getTickets(Repository r) { + RefModel ticgitBranch = getTicketsBranch(r); + List<PathModel> paths = getFilesInPath(r, null, ticgitBranch.commit); + List<TicketModel> tickets = new ArrayList<TicketModel>(); + for (PathModel ticketFolder : paths) { + if (ticketFolder.isTree()) { + try { + TicketModel t = new TicketModel(ticketFolder.name); + readTicketContents(r, ticgitBranch, t); + tickets.add(t); + } catch (Throwable t) { + LOGGER.error("Failed to get a ticket!", t); + } + } + } + Collections.sort(tickets); + Collections.reverse(tickets); + return tickets; + } + + public static TicketModel getTicket(Repository r, String ticketFolder) { + RefModel ticketsBranch = getTicketsBranch(r); + if (ticketsBranch != null) { + try { + TicketModel ticket = new TicketModel(ticketFolder); + readTicketContents(r, ticketsBranch, ticket); + return ticket; + } catch (Throwable t) { + LOGGER.error("Failed to get ticket " + ticketFolder, t); + } + } + return null; + } + + private static void readTicketContents(Repository r, RefModel ticketsBranch, TicketModel ticket) { + List<PathModel> ticketFiles = getFilesInPath(r, ticket.name, ticketsBranch.commit); + for (PathModel file : ticketFiles) { + String content = getRawContentAsString(r, ticketsBranch.commit, file.path).trim(); + if (file.name.equals("TICKET_ID")) { + ticket.id = content; + } else if (file.name.equals("TITLE")) { + ticket.title = content; + } else { + String[] chunks = file.name.split("_"); + if (chunks[0].equals("ASSIGNED")) { + ticket.handler = content; + } else if (chunks[0].equals("COMMENT")) { + try { + Comment c = new Comment(file.name, content); + ticket.comments.add(c); + } catch (ParseException e) { + e.printStackTrace(); + } + } else if (chunks[0].equals("TAG")) { + if (content.startsWith("TAG_")) { + ticket.tags.add(content.substring(4)); + } else { + ticket.tags.add(content); + } + } else if (chunks[0].equals("STATE")) { + ticket.state = content; + } + } + } + Collections.sort(ticket.comments); + } + + public static String getTicketContent(Repository r, String filePath) { + RefModel ticketsBranch = getTicketsBranch(r); + if (ticketsBranch != null) { + return getRawContentAsString(r, ticketsBranch.commit, filePath); + } + return ""; } } -- Gitblit v1.9.1