lburgazzoli commented on a change in pull request #138: Add tests to the
twitter itest project
URL: https://github.com/apache/camel-quarkus/pull/138#discussion_r314405007
##########
File path:
integration-tests/twitter/src/main/java/org/apache/camel/quarkus/component/twitter/CamelRoute.java
##########
@@ -16,25 +16,118 @@
*/
package org.apache.camel.quarkus.component.twitter;
-import io.quarkus.runtime.annotations.RegisterForReflection;
+import java.util.Arrays;
+import java.util.HashSet;
+import java.util.Set;
+
+import org.apache.camel.Exchange;
import org.apache.camel.builder.RouteBuilder;
-import org.eclipse.microprofile.config.inject.ConfigProperty;
+import org.apache.camel.component.twitter.TwitterConstants;
-@RegisterForReflection
public class CamelRoute extends RouteBuilder {
- @ConfigProperty(name = "twitter.user.name")
- String twitterUserName;
+ private static final Set<String> TWITTER_SEARCH_HEADERS = new HashSet<>(
+ Arrays.asList(TwitterConstants.TWITTER_COUNT,
TwitterConstants.TWITTER_KEYWORDS,
+ TwitterConstants.TWITTER_MAXID,
TwitterConstants.TWITTER_NUMBER_OF_PAGES,
+ TwitterConstants.TWITTER_SEARCH_LANGUAGE,
TwitterConstants.TWITTER_SINCEID));
+
+ private final StringBuilder ownTweets = new StringBuilder();
+ private final StringBuilder directMessages = new StringBuilder();
@Override
public void configure() {
- from("twitter-timeline:user?user=ApacheCamel&count=1")
- .to("log:timeline?showAll=true");
+ rest()
+ .get("/timeline")
+ /* Expose the polled messages */
+ .route()
+ .id("get-timeline")
+ .setBody(() -> {
+ synchronized (ownTweets) {
+ return ownTweets.toString();
+ }
+ })
+ .endRest()
+ .post("/timeline")
+ .route()
+ .id("post-timeline")
+ .to("twitter-timeline://user")
+ .setHeader(Exchange.HTTP_RESPONSE_CODE, simple("201"))
+ .endRest()
+
+ .get("/search")
+ .route()
+ .id("get-search")
+ // The servlet component does not pass the query params as
camel message headers for some reason
+ .process(e -> {
+ final String query = e.getIn().getHeader("CamelHttpQuery",
String.class);
+ for (String kv : query.split("&")) {
+ final String[] keyVal = kv.split("=");
+ if (TWITTER_SEARCH_HEADERS.contains(keyVal[0])) {
+ // Consider URL decoding if you copy this to
production code
+ e.getOut().setHeader(keyVal[0], keyVal[1]);
+ }
+ }
+ })
+
.to("twitter-search://_keywords_passed_via_CamelTwitterKeywords_header_")
+ .to("log:search?showAll=true")
+ .endRest()
+
+ .post("/directmessage")
+ .route()
+ .id("post-directmessage")
+
.to("twitter-directmessage://{{camel.component.twitter-directmessage.user}}")
Review comment:
`camel.component.twitter-directmessage` is a syntax used to automatically
bind properties to a component so I would use a property like `twitter.user` to
avoid confusion
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
