camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From acosent...@apache.org
Subject [2/3] camel git commit: CAMEL-10159: github endpoint to support creating issues
Date Thu, 21 Jul 2016 09:32:10 GMT
CAMEL-10159: github endpoint to support creating issues


Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/d619bb70
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/d619bb70
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/d619bb70

Branch: refs/heads/master
Commit: d619bb70178968ad7a9a6a67e49d9efab4ddbb19
Parents: 1153beb
Author: Andrea Cosentino <ancosen@gmail.com>
Authored: Thu Jul 21 11:06:20 2016 +0200
Committer: Andrea Cosentino <ancosen@gmail.com>
Committed: Thu Jul 21 11:31:04 2016 +0200

----------------------------------------------------------------------
 .../camel/component/github/GitHubEndpoint.java  |  3 +
 .../camel/component/github/GitHubType.java      |  2 +-
 .../github/producer/CreateIssueProducer.java    | 63 ++++++++++++++++
 .../producer/CreateIssueProducerTest.java       | 79 ++++++++++++++++++++
 .../github/services/MockIssueService.java       | 19 +++++
 5 files changed, 165 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/camel/blob/d619bb70/components/camel-github/src/main/java/org/apache/camel/component/github/GitHubEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-github/src/main/java/org/apache/camel/component/github/GitHubEndpoint.java
b/components/camel-github/src/main/java/org/apache/camel/component/github/GitHubEndpoint.java
index a76fee4..2dd757a 100644
--- a/components/camel-github/src/main/java/org/apache/camel/component/github/GitHubEndpoint.java
+++ b/components/camel-github/src/main/java/org/apache/camel/component/github/GitHubEndpoint.java
@@ -24,6 +24,7 @@ import org.apache.camel.component.github.consumer.PullRequestCommentConsumer;
 import org.apache.camel.component.github.consumer.PullRequestConsumer;
 import org.apache.camel.component.github.consumer.TagConsumer;
 import org.apache.camel.component.github.producer.ClosePullRequestProducer;
+import org.apache.camel.component.github.producer.CreateIssueProducer;
 import org.apache.camel.component.github.producer.GetCommitFileProducer;
 import org.apache.camel.component.github.producer.PullRequestCommentProducer;
 import org.apache.camel.component.github.producer.PullRequestFilesProducer;
@@ -97,6 +98,8 @@ public class GitHubEndpoint extends DefaultEndpoint {
             return new PullRequestFilesProducer(this);
         } else if (type == GitHubType.GETCOMMITFILE) {
             return new GetCommitFileProducer(this);
+        } else if (type == GitHubType.CREATEISSUE) {
+            return new CreateIssueProducer(this);
         }
         throw new IllegalArgumentException("Cannot create producer with type " + type);
     }

http://git-wip-us.apache.org/repos/asf/camel/blob/d619bb70/components/camel-github/src/main/java/org/apache/camel/component/github/GitHubType.java
----------------------------------------------------------------------
diff --git a/components/camel-github/src/main/java/org/apache/camel/component/github/GitHubType.java
b/components/camel-github/src/main/java/org/apache/camel/component/github/GitHubType.java
index cc831d0..14269f7 100644
--- a/components/camel-github/src/main/java/org/apache/camel/component/github/GitHubType.java
+++ b/components/camel-github/src/main/java/org/apache/camel/component/github/GitHubType.java
@@ -19,6 +19,6 @@ package org.apache.camel.component.github;
 public enum GitHubType {
 
     CLOSEPULLREQUEST, PULLREQUESTCOMMENT, COMMIT, PULLREQUEST, TAG, PULLREQUESTSTATE,
-    PULLREQUESTFILES, GETCOMMITFILE
+    PULLREQUESTFILES, GETCOMMITFILE, CREATEISSUE
 
 }

http://git-wip-us.apache.org/repos/asf/camel/blob/d619bb70/components/camel-github/src/main/java/org/apache/camel/component/github/producer/CreateIssueProducer.java
----------------------------------------------------------------------
diff --git a/components/camel-github/src/main/java/org/apache/camel/component/github/producer/CreateIssueProducer.java
b/components/camel-github/src/main/java/org/apache/camel/component/github/producer/CreateIssueProducer.java
new file mode 100644
index 0000000..337fe54
--- /dev/null
+++ b/components/camel-github/src/main/java/org/apache/camel/component/github/producer/CreateIssueProducer.java
@@ -0,0 +1,63 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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 org.apache.camel.component.github.producer;
+
+import org.apache.camel.Exchange;
+import org.apache.camel.component.github.GitHubEndpoint;
+import org.apache.camel.spi.Registry;
+import org.apache.camel.util.ObjectHelper;
+import org.eclipse.egit.github.core.Issue;
+import org.eclipse.egit.github.core.service.IssueService;
+
+/**
+ * Producer endpoint that closes a pull request.  The endpoint requires the "GitHubPullRequest"
header,
+ * identifying the pull request number (integer).
+ */
+public class CreateIssueProducer extends AbstractGitHubProducer {
+    
+    private IssueService issueService;
+
+    public CreateIssueProducer(GitHubEndpoint endpoint) throws Exception {
+        super(endpoint);
+        
+        Registry registry = endpoint.getCamelContext().getRegistry();
+        Object service = registry.lookupByName("githubIssuesService");
+        if (service != null) {
+        	issueService = (IssueService) service;
+        } else {
+        	issueService = new IssueService();
+        }
+        initService(issueService);
+    }
+
+    public void process(Exchange exchange) throws Exception {
+    	Issue issue = new Issue();
+        String issueTitle = exchange.getIn().getHeader("GitHubIssueTitle", String.class);
+        if (ObjectHelper.isEmpty(issueTitle)) {
+            throw new IllegalArgumentException("Issue Title must be specified to create an
issue");
+        }
+        issue.setTitle(issueTitle);
+        issue.setBody(exchange.getIn().getBody(String.class));
+        
+        Issue finalIssue = issueService.createIssue(getRepository(), issue);
+        
+        // copy the header of in message to the out message
+        exchange.getOut().copyFrom(exchange.getIn());
+        exchange.getOut().setBody(finalIssue);
+    }
+
+}

http://git-wip-us.apache.org/repos/asf/camel/blob/d619bb70/components/camel-github/src/test/java/org/apache/camel/component/github/producer/CreateIssueProducerTest.java
----------------------------------------------------------------------
diff --git a/components/camel-github/src/test/java/org/apache/camel/component/github/producer/CreateIssueProducerTest.java
b/components/camel-github/src/test/java/org/apache/camel/component/github/producer/CreateIssueProducerTest.java
new file mode 100644
index 0000000..14508a0
--- /dev/null
+++ b/components/camel-github/src/test/java/org/apache/camel/component/github/producer/CreateIssueProducerTest.java
@@ -0,0 +1,79 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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 org.apache.camel.component.github.producer;
+
+import java.util.Map;
+
+import org.apache.camel.Endpoint;
+import org.apache.camel.Exchange;
+import org.apache.camel.Message;
+import org.apache.camel.Processor;
+import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.component.github.GitHubComponent;
+import org.apache.camel.component.github.GitHubComponentTestBase;
+import org.eclipse.egit.github.core.Issue;
+import org.eclipse.egit.github.core.Repository;
+import org.junit.Test;
+
+public class CreateIssueProducerTest extends GitHubComponentTestBase {
+
+    @Override
+    protected RouteBuilder createRouteBuilder() throws Exception {
+        return new RouteBuilder() {
+
+            @Override
+            public void configure() throws Exception {
+                context.addComponent("github", new GitHubComponent());
+                from("direct:createIssue")
+                        .process(new MockPullRequestStateProducerProcessor())
+                        .to("github://createissue?state=success&username=someguy&password=apassword&repoOwner=anotherguy&repoName=somerepo");
+            } // end of configure
+
+
+        };
+    }
+
+    @Test
+    public void testCreateIssue() throws Exception {
+    	Repository repository = new Repository();
+
+        Endpoint issueProducerEndpoint = getMandatoryEndpoint("direct:createIssue");
+        Exchange exchange = issueProducerEndpoint.createExchange();
+        String issueBody = "There's an error";
+        exchange.getIn().setBody(issueBody);
+        template.send(issueProducerEndpoint, exchange);
+
+        Thread.sleep(1 * 1000);
+
+        // Verify that the mock pull request service received this comment.
+        Issue issue = issueService.getIssue(repository, 1);
+        assertEquals("Error", issue.getTitle());
+        assertEquals("There's an error", issue.getBody());
+    }
+
+
+    public class MockPullRequestStateProducerProcessor implements Processor {
+        @Override
+        public void process(Exchange exchange) throws Exception {
+            Message in = exchange.getIn();
+            Map<String, Object> headers = in.getHeaders();
+            headers.put("GitHubIssueTitle", "Error");
+        }
+    }
+
+
+}

http://git-wip-us.apache.org/repos/asf/camel/blob/d619bb70/components/camel-github/src/test/java/org/apache/camel/component/github/services/MockIssueService.java
----------------------------------------------------------------------
diff --git a/components/camel-github/src/test/java/org/apache/camel/component/github/services/MockIssueService.java
b/components/camel-github/src/test/java/org/apache/camel/component/github/services/MockIssueService.java
index dd7b376..a3565ba 100644
--- a/components/camel-github/src/test/java/org/apache/camel/component/github/services/MockIssueService.java
+++ b/components/camel-github/src/test/java/org/apache/camel/component/github/services/MockIssueService.java
@@ -22,6 +22,7 @@ import java.util.List;
 
 import org.eclipse.egit.github.core.Comment;
 import org.eclipse.egit.github.core.IRepositoryIdProvider;
+import org.eclipse.egit.github.core.Issue;
 import org.eclipse.egit.github.core.service.IssueService;
 
 public class MockIssueService extends IssueService {
@@ -44,4 +45,22 @@ public class MockIssueService extends IssueService {
         Comment addedComment = mockPullRequestService.addComment((long) issueNumber, commentText);
         return addedComment;
     }
+    
+    @Override
+    public Issue createIssue(IRepositoryIdProvider repository, Issue issue) {
+        Issue finalIssue = new Issue();
+        issue.setBody("There's an error");
+        issue.setTitle("Error");
+        issue.setId(1L);
+        return finalIssue;
+    }
+    
+    @Override
+    public Issue getIssue(IRepositoryIdProvider repository, String issueNumber) {
+    	Issue issue = new Issue();
+        issue.setBody("There's an error");
+        issue.setTitle("Error");
+        issue.setId(1L);
+        return issue;
+    }
 }


Mime
View raw message