-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
11 changed files
with
711 additions
and
9 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
|
|
@@ -6,6 +6,7 @@ target/ | |
| .project | ||
| .settings | ||
| .springBeans | ||
| .vscode | ||
| bin/ | ||
| logs/ | ||
| *.log* | ||
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
262 changes: 262 additions & 0 deletions
262
src/main/java/edu/tamu/app/service/manager/GitHubService.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,262 @@ | ||
| package edu.tamu.app.service.manager; | ||
|
|
||
| import java.io.IOException; | ||
| import java.util.ArrayList; | ||
| import java.util.HashMap; | ||
| import java.util.List; | ||
| import java.util.Map; | ||
| import java.util.Optional; | ||
| import java.util.concurrent.atomic.AtomicInteger; | ||
|
|
||
| import org.apache.log4j.Logger; | ||
| import org.kohsuke.github.GHBlob; | ||
| import org.kohsuke.github.GHIssue; | ||
| import org.kohsuke.github.GHLabel; | ||
| import org.kohsuke.github.GHOrganization; | ||
| import org.kohsuke.github.GHProject; | ||
| import org.kohsuke.github.GHProjectCard; | ||
| import org.kohsuke.github.GHProjectColumn; | ||
| import org.kohsuke.github.GHRepository; | ||
| import org.kohsuke.github.GHUser; | ||
| import org.kohsuke.github.GitHub; | ||
| import org.kohsuke.github.GitHubBuilder; | ||
|
|
||
| import edu.tamu.app.cache.model.Card; | ||
| import edu.tamu.app.cache.model.Member; | ||
| import edu.tamu.app.cache.model.RemoteProject; | ||
| import edu.tamu.app.cache.model.Sprint; | ||
| import edu.tamu.app.model.ManagementService; | ||
| import edu.tamu.app.model.request.FeatureRequest; | ||
|
|
||
| public class GitHubService extends MappingRemoteProjectManagerBean { | ||
|
|
||
| private static final Logger logger = Logger.getLogger(GitHubService.class); | ||
|
|
||
| static final String ORGANIZATION = "TAMULib"; | ||
| static final String REQUEST_LABEL = "request"; | ||
| static final String ISSUE_LABEL = "issue"; | ||
| static final String FEATURE_LABEL = "feature"; | ||
| static final String DEFECT_LABEL = "bug"; | ||
|
|
||
| private final ManagementService managementService; | ||
|
|
||
| private final GitHubBuilder ghBuilder; | ||
|
|
||
| private final GitHub github; | ||
|
|
||
| private final Map<String, Member> members; | ||
|
|
||
| private GHLabel label; | ||
|
|
||
| public GitHubService(final ManagementService managementService) throws IOException { | ||
| this.managementService = managementService; | ||
| ghBuilder = new GitHubBuilder(); | ||
| github = getGitHubInstance(); | ||
| members = new HashMap<String, Member>(); | ||
| } | ||
|
|
||
| @Override | ||
| public List<RemoteProject> getRemoteProjects() throws Exception { | ||
| logger.info("Fetching remote projects"); | ||
| final List<RemoteProject> remoteProjects = new ArrayList<RemoteProject>(); | ||
| final GHOrganization org = github.getOrganization(ORGANIZATION); | ||
| for (GHRepository repo : org.getRepositories().values()) { | ||
| final List<GHLabel> labels = repo.listLabels().asList(); | ||
| remoteProjects.add(buildRemoteProject(repo, labels)); | ||
| } | ||
| return remoteProjects; | ||
| } | ||
|
|
||
| @Override | ||
| public RemoteProject getRemoteProjectByScopeId(final String scopeId) throws Exception { | ||
| logger.info("Fetching remote project by scope id " + scopeId); | ||
| GHRepository repo = github.getRepositoryById(scopeId); | ||
| List<GHLabel> labels = repo.listLabels().asList(); | ||
| return buildRemoteProject(repo, labels); | ||
| } | ||
|
|
||
| @Override | ||
| public List<Sprint> getActiveSprintsByProjectId(final String projectScopeId) throws Exception { | ||
| logger.info("Fetching active sprints for project with scope id " + projectScopeId); | ||
| List<Sprint> activeSprints = new ArrayList<Sprint>(); | ||
| GHRepository repo = github.getRepositoryById(projectScopeId); | ||
| List<GHProject> projects = repo.listProjects().asList(); | ||
| for (GHProject project : projects) { | ||
| String sprintId = String.valueOf(project.getId()); | ||
| String name = project.getName(); | ||
| String projectName = repo.getName(); | ||
| List<Card> cards = getCards(project); | ||
| activeSprints.add(new Sprint(sprintId, name, projectName, cards)); | ||
| } | ||
| return activeSprints; | ||
| } | ||
|
|
||
| @Override | ||
| public Object push(final FeatureRequest request) throws Exception { | ||
| logger.info("Submitting feature request " + request.getTitle() + " to project with scope id " + request.getScopeId()); | ||
| String repoId = String.valueOf(request.getProjectId()); | ||
| String title = request.getTitle(); | ||
| String body = request.getDescription(); | ||
| GHRepository repo = github.getRepositoryById(repoId); | ||
| return repo.createIssue(title).body(body).create(); | ||
| } | ||
|
|
||
| protected GitHub getGitHubInstance() throws IOException { | ||
| GitHub githubInstance; | ||
| final Optional<String> endpoint = managementService.getSettingValue("url"); | ||
| final Optional<String> token = managementService.getSettingValue("token"); | ||
| if (!endpoint.isPresent()) { | ||
| throw new RuntimeException("GitHub service enpoint was not defined"); | ||
| } | ||
| if (token.isPresent()) { | ||
| githubInstance = ghBuilder | ||
| .withEndpoint(endpoint.get()) | ||
| .withOAuthToken(token.get()) | ||
| .build(); | ||
| } else { | ||
| githubInstance = ghBuilder | ||
| .withEndpoint(endpoint.get()) | ||
| .withPassword(getSettingValue("username"), getSettingValue("password")) | ||
| .build(); | ||
| } | ||
| return githubInstance; | ||
| } | ||
|
|
||
| private String getSettingValue(final String key) { | ||
| final Optional<String> setting = managementService.getSettingValue(key); | ||
| if (setting.isPresent()) { | ||
| return setting.get(); | ||
| } | ||
|
|
||
| throw new RuntimeException("No setting " + key + " found in settings for service " + managementService.getName()); | ||
| } | ||
|
|
||
| private RemoteProject buildRemoteProject(GHRepository repo, List<GHLabel> labels) throws IOException { | ||
| List<GHProject> projects = repo.listProjects().asList(); | ||
| final String scopeId = String.valueOf(repo.getId()); | ||
| final String name = repo.getName(); | ||
| int requestCount = 0; | ||
| int issueCount = 0; | ||
| int featureCount = 0; | ||
| int defectCount = 0; | ||
|
|
||
| for (GHProject project : projects) { | ||
| requestCount += getPrimaryWorkItemCount(REQUEST_LABEL, project, labels); | ||
| issueCount += getPrimaryWorkItemCount(ISSUE_LABEL, project, labels); | ||
| featureCount += getPrimaryWorkItemCount(FEATURE_LABEL, project, labels); | ||
| defectCount += getPrimaryWorkItemCount(DEFECT_LABEL, project, labels); | ||
| } | ||
|
|
||
| return new RemoteProject(scopeId, name, requestCount, issueCount, featureCount, defectCount); | ||
| } | ||
|
|
||
| private int getPrimaryWorkItemCount(final String type, final GHProject project, final List<GHLabel> labels) | ||
| throws IOException { | ||
| label = getLabelByName(labels, type); | ||
| return project.listColumns() | ||
| .asList() | ||
| .stream() | ||
| .map(this::countCardsOnColumn) | ||
| .reduce(0L, (a, b) -> a + b) | ||
| .intValue(); | ||
| } | ||
|
|
||
| private GHLabel getLabelByName(final List<GHLabel> labels, final String name) { | ||
| return labels.stream() | ||
| .filter(label -> label.getName().equals(name)) | ||
| .findFirst() | ||
| .get(); | ||
| } | ||
|
|
||
| private long countCardsOnColumn(GHProjectColumn column) { | ||
| try { | ||
| return column.listCards() | ||
| .asList() | ||
| .stream() | ||
| .filter(this::cardContainsLabel) | ||
| .count(); | ||
| } catch (IOException e) { | ||
| throw new RuntimeException(e); | ||
| } | ||
| } | ||
|
|
||
| private boolean cardContainsLabel(GHProjectCard card) { | ||
| try { | ||
| return card.getContent().getLabels().contains(label); | ||
| } catch (IOException e) { | ||
| throw new RuntimeException(e); | ||
| } | ||
| } | ||
|
|
||
| private List<Card> getCards(GHProject project) throws IOException { | ||
| List<Card> cards = new ArrayList<Card>(); | ||
| for (GHProjectColumn column : project.listColumns().asList()) { | ||
| List<GHProjectCard> projectCards = column.listCards().asList(); | ||
| AtomicInteger cardNumber = new AtomicInteger(); | ||
| for (GHProjectCard card : projectCards) { | ||
| GHIssue content = card.getContent(); | ||
|
|
||
| String id = String.valueOf(card.getId()); | ||
| String name = content.getTitle(); | ||
| String number = String.valueOf(cardNumber.getAndIncrement()); | ||
| String type = getCardType(content); | ||
| String description = content.getBody(); | ||
| String status = card.getColumn().getName(); | ||
| // TODO: Figure out how we want to handle sizes | ||
| String estimate = null; | ||
| List<Member> assignees = new ArrayList<Member>(); | ||
| for (GHUser user : content.getAssignees()) { | ||
| assignees.add(getMember(user)); | ||
| } | ||
| cards.add(new Card(id, number, mapCardType(type), name, description, mapStatus(status), mapEstimate(estimate), assignees)); | ||
| } | ||
| } | ||
| return cards; | ||
| } | ||
|
|
||
| private String getCardType(GHIssue content) throws IOException { | ||
| List<GHLabel> labels = (List<GHLabel>) content.getLabels(); | ||
| GHLabel label = labels.stream() | ||
| .filter(label1 -> label1.getName().equals(DEFECT_LABEL)) | ||
| .findFirst() | ||
| .orElseGet(() -> labels.stream() | ||
| .filter(label2 -> label2.getName().equals(FEATURE_LABEL)) | ||
| .findFirst() | ||
| .orElseGet(() -> labels.stream() | ||
| .filter(label3 -> label3.getName().equals(ISSUE_LABEL)) | ||
| .findFirst() | ||
| .orElseGet(() -> labels.stream() | ||
| .filter(label4 -> label4.getName().equals(REQUEST_LABEL)) | ||
| .findFirst() | ||
| .orElse(null) | ||
| ) | ||
| ) | ||
| ); | ||
| return label == null ? null : label.getName(); | ||
| } | ||
|
|
||
| Member getMember(GHUser user) throws IOException { | ||
| Member member; | ||
| String memberId = String.valueOf(user.getId()); | ||
| Optional<Member> cachedMember = getCachedMember(memberId); | ||
| if (cachedMember.isPresent()) { | ||
| member = cachedMember.get(); | ||
| } else { | ||
| String name = user.getName(); | ||
| String avatarPath = user.getAvatarUrl(); | ||
| member = new Member(memberId, name, avatarPath); | ||
|
|
||
| cacheMember(memberId, member); | ||
| } | ||
| return member; | ||
| } | ||
|
|
||
| private Optional<Member> getCachedMember(final String id) { | ||
| return Optional.ofNullable(members.get(id)); | ||
| } | ||
|
|
||
| private void cacheMember(String id, Member member) { | ||
| members.put(id, member); | ||
| } | ||
|
|
||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.