import org.eclipse.egit.github.core.CommitComment; //导入依赖的package包/类
@Test
public void testPullRequestCommentProducer() throws Exception {
    PullRequest pullRequest = pullRequestService.addPullRequest("testPullRequestCommentProducer");
    latestPullRequestId = pullRequest.getId();

    Endpoint commentProducerEndpoint = getMandatoryEndpoint("direct:validPullRequest");
    Exchange exchange = commentProducerEndpoint.createExchange();
    String commentText = "Pushed this comment at " + new Date();
    exchange.getIn().setBody(commentText);
    template.send(commentProducerEndpoint, exchange);

    Thread.sleep(1 * 1000);

    // Verify that the mock pull request service received this comment.
    List<CommitComment> commitComments = pullRequestService.getComments(null, (int) pullRequest.getId());
    assertEquals(1, commitComments.size());
    CommitComment commitComment = commitComments.get(0);
    assertEquals("Commit IDs did not match ", Long.toString(pullRequest.getId()), commitComment.getCommitId());
    assertEquals("Comment text did not match ", commentText, commitComment.getBodyText());
}
 

import org.eclipse.egit.github.core.CommitComment; //导入依赖的package包/类
public CommitComment addComment(Long pullRequestId, String bodyText) {
    CommitComment commitComment = new CommitComment();

    User author = createAuthor();
    commitComment.setUser(author);
    commitComment.setCommitId("" + pullRequestId);
    commitComment.setId(commentId.getAndIncrement());
    commitComment.setBody(bodyText);
    commitComment.setBodyText(bodyText);

    List<CommitComment> comments;
    if (allComments.containsKey(pullRequestId)) {
        comments = allComments.get(pullRequestId);
    } else {
        comments = new ArrayList<CommitComment>();
    }
    comments.add(commitComment);
    allComments.put(pullRequestId, comments);

    return commitComment;
}
 

import org.eclipse.egit.github.core.CommitComment; //导入依赖的package包/类
/**
 * Processes review comments of a Pull Request.
 */
private void processPullRequestReviewComments(Repository repository, PullRequest remotePullRequest,
        RepositoryPullRequestMapping localPullRequest, Map<String, Participant> participantIndex)
{
    updateCommentsCount(remotePullRequest, localPullRequest);

    PullRequestService pullRequestService = gitHubClientProvider.getPullRequestService(repository);
    RepositoryId repositoryId = RepositoryId.createFromUrl(repository.getRepositoryUrl());
    List<CommitComment> pullRequestReviewComments;
    try
    {
        pullRequestReviewComments = pullRequestService.getComments(repositoryId, remotePullRequest.getNumber());
    }
    catch (IOException e)
    {
        throw new RuntimeException(e);
    }

    remotePullRequest.setReviewComments(Math.max(remotePullRequest.getReviewComments(), pullRequestReviewComments.size()));

    for (CommitComment comment : pullRequestReviewComments)
    {
        addParticipant(participantIndex, comment.getUser(), Participant.ROLE_PARTICIPANT);
    }
}
 

import org.eclipse.egit.github.core.CommitComment; //导入依赖的package包/类
@Test
public void testNoParticipants() throws IOException
{
    when(issueService.getComments(any(IRepositoryIdProvider.class), anyInt())).thenReturn(Collections.<Comment>emptyList());
    when(gitHubPullRequestService.getComments(any(IRepositoryIdProvider.class), anyInt())).thenReturn(Collections.<CommitComment>emptyList());

    User user = mock(User.class);
    when(user.getLogin()).thenReturn("user");
    when(pullRequest.getUser()).thenReturn(user);
    testedClass.processPullRequest(repository, pullRequest);

    verify(pullRequestService).updatePullRequestParticipants(anyInt(), anyInt(), participantsIndexCaptor.capture());
    assertEquals(participantsIndexCaptor.getValue().size(), 1);
    Participant participant = participantsIndexCaptor.getValue().get("user");
    assertParticipant(participant, "user");
}
 

import org.eclipse.egit.github.core.CommitComment; //导入依赖的package包/类
@Override
public long getItemId(int position) {
    switch (getItemViewType(position)) {
    case TYPE_FILE_HEADER:
        String sha = ((CommitFile) getItem(position)).getSha();
        if (!TextUtils.isEmpty(sha))
            return sha.hashCode();
        else
            return super.getItemId(position);
    case TYPE_COMMENT:
    case TYPE_LINE_COMMENT:
        return ((CommitComment) getItem(position)).getId();
    default:
        return super.getItemId(position);
    }

}
 

import org.eclipse.egit.github.core.CommitComment; //导入依赖的package包/类
@Override
public boolean add(final CommitComment comment) {
    String path = comment.getPath();
    if (TextUtils.isEmpty(path))
        return super.add(comment);
    else {
        boolean added = false;
        for (FullCommitFile file : files)
            if (path.equals(file.getFile().getFilename())) {
                file.add(comment);
                added = true;
                break;
            }
        if (!added)
            added = super.add(comment);
        return added;
    }
}
 

import org.eclipse.egit.github.core.CommitComment; //导入依赖的package包/类
@Override
protected FullCommit run(Account account) throws Exception {
    RepositoryCommit commit = store.refreshCommit(repository, id);
    Commit rawCommit = commit.getCommit();
    if (rawCommit != null && rawCommit.getCommentCount() > 0) {
        List<CommitComment> comments = service.getComments(repository,
                commit.getSha());
        for (CommitComment comment : comments) {
            String formatted = HtmlUtils.format(comment.getBodyHtml())
                    .toString();
            comment.setBodyHtml(formatted);
            imageGetter.encode(comment, formatted);
        }
        return new FullCommit(commit, comments);
    } else
        return new FullCommit(commit);
}
 

import org.eclipse.egit.github.core.CommitComment; //导入依赖的package包/类
private void removeIssuesAlreadyReported(Multimap<String, Issue> fileViolations,
		Map<String, LinePositioner> linePositioners) throws MojoExecutionException {
	List<CommitComment> currentComments;
	try {
		currentComments = pullRequestService.getComments( repository, pullRequestId );
	} catch (IOException e) {
		throw new MojoExecutionException( "Unable to retrieve comments", e );
	}
	for (CommitComment comment : currentComments) {
		Iterator<Issue> issues = fileViolations.get(
				comment.getPath() ).iterator();
		while (issues.hasNext()) {
			Issue issue = (Issue) issues.next();
			Integer line = issue.line();
			if (line == null)
				line = 1;

			int position = linePositioners.get( comment.getPath() )
					.toPostion( line );
			if (position == comment.getPosition()
					&& issue.message().equals( comment.getBody() ))
				issues.remove();
		}
	}
}
 

import org.eclipse.egit.github.core.CommitComment; //导入依赖的package包/类
/**
 * Page comments on commit with given SHA-1
 *
 * @param repository
 * @param sha
 * @param start
 * @param size
 * @return page iterator over comments
 */
public PageIterator<CommitComment> pageComments(
		IRepositoryIdProvider repository, String sha, int start, int size) {
	String id = getId(repository);
	if (sha == null)
		throw new IllegalArgumentException("Sha cannot be null"); //$NON-NLS-1$
	if (sha.length() == 0)
		throw new IllegalArgumentException("Sha cannot be empty"); //$NON-NLS-1$

	StringBuilder uri = new StringBuilder(SEGMENT_REPOS);
	uri.append('/').append(id);
	uri.append(SEGMENT_COMMITS);
	uri.append('/').append(sha);
	uri.append(SEGMENT_COMMENTS);
	PagedRequest<CommitComment> request = createPagedRequest(start, size);
	request.setUri(uri);
	request.setType(new TypeToken<List<CommitComment>>() {
	}.getType());
	return createPageIterator(request);
}
 

import org.eclipse.egit.github.core.CommitComment; //导入依赖的package包/类
/**
 * Add comment to given commit
 *
 * @param repository
 * @param sha
 * @param comment
 * @return created comment
 * @throws IOException
 */
public CommitComment addComment(IRepositoryIdProvider repository,
		String sha, CommitComment comment) throws IOException {
	String id = getId(repository);
	if (sha == null)
		throw new IllegalArgumentException("Sha cannot be null"); //$NON-NLS-1$
	if (sha.length() == 0)
		throw new IllegalArgumentException("Sha cannot be empty"); //$NON-NLS-1$

	StringBuilder uri = new StringBuilder(SEGMENT_REPOS);
	uri.append('/').append(id);
	uri.append(SEGMENT_COMMITS);
	uri.append('/').append(sha);
	uri.append(SEGMENT_COMMENTS);
	return client.post(uri.toString(), comment, CommitComment.class);
}
 

import org.eclipse.egit.github.core.CommitComment; //导入依赖的package包/类
@Test
public void pullRequestCommentTest() throws Exception {
    PullRequest pr1 = pullRequestService.addPullRequest("First add");
    PullRequest pr2 = pullRequestService.addPullRequest("Second");
    CommitComment commitComment1 = pullRequestService.addComment(pr1.getId(), "First comment");
    CommitComment commitComment2 = pullRequestService.addComment(pr2.getId(), "Second comment");
    mockResultEndpoint.expectedBodiesReceivedInAnyOrder(commitComment1, commitComment2);

    Thread.sleep(1 * 1000);         // TODO do I need this?

    mockResultEndpoint.assertIsSatisfied();
}
 

import org.eclipse.egit.github.core.CommitComment; //导入依赖的package包/类
public List<CommitComment> getComments(IRepositoryIdProvider repository, int pullRequestId) {
    Long id = new Long(pullRequestId);
    if (allComments.containsKey(id)) {
        List<CommitComment> comments = allComments.get(id);
        return comments;
    } else {
        return emptyComments;
    }
}
 

import org.eclipse.egit.github.core.CommitComment; //导入依赖的package包/类
/**
 * {@inheritDoc}
 */
@Override
public void process(Repository repository, Event event, boolean isSoftSync, String[] synchronizationTags, GitHubEventContext context)
{
    PullRequestReviewCommentPayload payload = getPayload(event);
    CommitComment commitComment = payload.getComment();
    PullRequest pullRequest = getPullRequestByComment(repository, commitComment);
    if (pullRequest == null)
    {
        return;
    }

    context.savePullRequest(pullRequest);
}
 

import org.eclipse.egit.github.core.CommitComment; //导入依赖的package包/类
/**
 * Add file to adapter
 *
 * @param file
 */
public void addItem(final FullCommitFile file) {
    addItem(TYPE_FILE_HEADER, file.getFile());
    List<CharSequence> lines = diffStyler.get(file.getFile().getFilename());
    int number = 0;
    for (CharSequence line : lines) {
        addItem(TYPE_FILE_LINE, line);
        for (CommitComment comment : file.get(number))
            addItem(TYPE_LINE_COMMENT, comment);
        number++;
    }
}
 

import org.eclipse.egit.github.core.CommitComment; //导入依赖的package包/类
/**
 * Create task to create a comment
 *
 * @param activity
 * @param repository
 * @param commit
 * @param comment
 */
protected CreateCommentTask(final Activity activity,
        final IRepositoryIdProvider repository, final String commit,
        final CommitComment comment) {
    super(activity);

    this.repository = repository;
    this.commit = commit;
    this.comment = comment;
}
 

import org.eclipse.egit.github.core.CommitComment; //导入依赖的package包/类
@Override
public CommitComment run(final Account account) throws Exception {
    CommitComment created = service.addComment(repository, commit, comment);
    String formatted = HtmlUtils.format(created.getBodyHtml()).toString();
    created.setBodyHtml(formatted);
    return created;

}
 

import org.eclipse.egit.github.core.CommitComment; //导入依赖的package包/类
/**
 * Add comment to file
 *
 * @param comment
 * @return this file
 */
public FullCommitFile add(final CommitComment comment) {
    int line = comment.getPosition();
    if (line >= 0) {
        List<CommitComment> lineComments = comments.get(line);
        if (lineComments == null) {
            lineComments = new ArrayList<CommitComment>(4);
            comments.put(line, lineComments);
        }
        lineComments.add(comment);
    }
    return this;
}
 

import org.eclipse.egit.github.core.CommitComment; //导入依赖的package包/类
private void recordGit(Multimap<String, Issue> fileViolations, Map<String, LinePositioner> linePositioners,
		Map<String, String> filesSha) throws IOException {
	Iterator<RepositoryCommit> commits = pullRequestService.getCommits( repository, pullRequestId ).iterator();
	if (!commits.hasNext())
		return;

	Collection<Entry<String, Issue>> entries = fileViolations.entries();
	for (Entry<String, Issue> entry : entries) {
		String path = entry.getKey();

		CommitComment comment = new CommitComment();
		comment.setBody( entry.getValue().message() );
		comment.setCommitId( filesSha.get( path ) );
		comment.setPath( path );

		Integer line = entry.getValue().line();
		if (line == null)
			continue;

		comment.setLine( line );
		comment.setPosition( linePositioners.get( path ).toPostion( line ) );

		getLog().debug( "Path: " + path );
		getLog().debug( "Line: " + line );
		getLog().debug( "Position: " + comment.getPosition() );

		try {
			pullRequestService
					.createComment( repository, pullRequestId, comment );
		} catch (Exception e) {
			getLog().error( "Unable to comment on: " + path );
			getLog().debug( e );
		}
	}
}
 

import org.eclipse.egit.github.core.CommitComment; //导入依赖的package包/类
private void reportSuccesses(int successCounter) throws IOException {
 System.out.println(successCounter +" things went well");
 GitHubClient client = new GitHubClient();
 String botUserName = System.getProperty("testUserName");
 String botPassword = System.getProperty("testUserPass");
 client.setCredentials(botUserName, botPassword);
 
 String sha = System.getenv("TRAVIS_COMMIT");
 System.out.println("making a comment on commit "+sha);
 
 RepositoryService repoService = new RepositoryService(client);
 Repository repo = repoService.getRepository("DeveloperLiberationFront", "Pdf-Reviewer");
 CommitService service = new CommitService(client);
 CommitComment comment = new CommitComment();
 
    String message = "step | pass?\n" +
            "--- | --- \n" +
            "canary site online |  :fire: \n" +
            "authenticated with GitHub | :fire: \n" +
            "no carry over reviews |  ::fire: \n" +
            "created request |  :fire: \n" +
            "Uploaded pdf |  :fire: \n" +
            "Found issues in GitHub |  :fire: \n";
    
    for(int i = 0; i< successCounter; i++) {
        message = message.replaceFirst(":fire:", ":white_check_mark:");
    }

 comment.setBody(message);
    service.addComment(repo, sha, comment);
}
 

import org.eclipse.egit.github.core.CommitComment; //导入依赖的package包/类
/**
 * Page pull request commit comments
 *
 * @param repository
 * @param id
 * @param start
 * @param size
 * @return iterator over pages of commit comments
 */
public PageIterator<CommitComment> pageComments(
		IRepositoryIdProvider repository, int id, int start, int size) {
	String repoId = getId(repository);
	StringBuilder uri = new StringBuilder(SEGMENT_REPOS);
	uri.append('/').append(repoId);
	uri.append(SEGMENT_PULLS);
	uri.append('/').append(id);
	uri.append(SEGMENT_COMMENTS);
	PagedRequest<CommitComment> request = createPagedRequest(start, size);
	request.setUri(uri);
	request.setType(new TypeToken<List<CommitComment>>() {
	}.getType());
	return createPageIterator(request);
}