Author: dblevins
Date: Thu Aug 11 00:14:40 2011
New Revision: 1156408
URL: http://svn.apache.org/viewvc?rev=1156408&view=rev
Log:
Reformatted
Modified:
openejb/trunk/sandbox/tools/src/main/java/org/apache/openejb/tools/twitter/AuthorizationUrlGenerator.java
openejb/trunk/sandbox/tools/src/main/java/org/apache/openejb/tools/twitter/OpenEJBMessageFilterUtil.java
openejb/trunk/sandbox/tools/src/main/java/org/apache/openejb/tools/twitter/Retweet.java
openejb/trunk/sandbox/tools/src/main/java/org/apache/openejb/tools/twitter/TwitterAccount.java
openejb/trunk/sandbox/tools/src/main/java/org/apache/openejb/tools/twitter/UserStatusRetriever.java
openejb/trunk/sandbox/tools/src/main/java/org/apache/openejb/tools/twitter/vo/ValidStatuses.java
openejb/trunk/sandbox/tools/src/main/java/org/apache/openejb/tools/twitter/vo/ValidStatusesOfUser.java
Modified:
openejb/trunk/sandbox/tools/src/main/java/org/apache/openejb/tools/twitter/AuthorizationUrlGenerator.java
URL:
http://svn.apache.org/viewvc/openejb/trunk/sandbox/tools/src/main/java/org/apache/openejb/tools/twitter/AuthorizationUrlGenerator.java?rev=1156408&r1=1156407&r2=1156408&view=diff
==============================================================================
---
openejb/trunk/sandbox/tools/src/main/java/org/apache/openejb/tools/twitter/AuthorizationUrlGenerator.java
(original)
+++
openejb/trunk/sandbox/tools/src/main/java/org/apache/openejb/tools/twitter/AuthorizationUrlGenerator.java
Thu Aug 11 00:14:40 2011
@@ -46,8 +46,7 @@ public class AuthorizationUrlGenerator {
consumer = new DefaultOAuthConsumer(
retweetToolProperties.getProperty("retweetApp.consumer.key"),
- retweetToolProperties
- .getProperty("retweetApp.consumerSecret.key"));
+
retweetToolProperties.getProperty("retweetApp.consumerSecret.key"));
provider = new DefaultOAuthProvider(
"http://twitter.com/oauth/request_token";,
Modified:
openejb/trunk/sandbox/tools/src/main/java/org/apache/openejb/tools/twitter/OpenEJBMessageFilterUtil.java
URL:
http://svn.apache.org/viewvc/openejb/trunk/sandbox/tools/src/main/java/org/apache/openejb/tools/twitter/OpenEJBMessageFilterUtil.java?rev=1156408&r1=1156407&r2=1156408&view=diff
==============================================================================
---
openejb/trunk/sandbox/tools/src/main/java/org/apache/openejb/tools/twitter/OpenEJBMessageFilterUtil.java
(original)
+++
openejb/trunk/sandbox/tools/src/main/java/org/apache/openejb/tools/twitter/OpenEJBMessageFilterUtil.java
Thu Aug 11 00:14:40 2011
@@ -23,7 +23,6 @@ import org.apache.openejb.tools.twitter.
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
-import java.util.Arrays;
import java.util.Calendar;
import java.util.Date;
import java.util.List;
@@ -37,15 +36,13 @@ public class OpenEJBMessageFilterUtil im
private static Logger logger =
Logger.getLogger(OpenEJBMessageFilterUtil.class);
/**
- *
* @param keyValuePairs
* @return RetweetableStatusesVO contains tweetIDs (i.e StatusIDs ) for
OpenEJB account and TomEE account
*/
@SuppressWarnings("rawtypes")
- public static ValidStatusesOfUser getNonRetweetedValidStatusIDs(
- List<Map> keyValuePairs) {
+ public static ValidStatusesOfUser getNonRetweetedValidStatusIDs(List<Map>
keyValuePairs) {
- ValidStatusesOfUser retweetableStatusesVO = new ValidStatusesOfUser();
+ ValidStatusesOfUser retweetableStatusesVO = new ValidStatusesOfUser();
List<String> tweetIDsForOpenEJBTwitterAccount = new
ArrayList<String>();
List<String> tweetIDsForTomEETwitterAcount = new ArrayList<String>();
@@ -53,19 +50,18 @@ public class OpenEJBMessageFilterUtil im
Map keyValue = (Map) keyValuePair;
if (keyValue.containsKey("text")) {
addValidTweetsForOpenEJBAccount(tweetIDsForOpenEJBTwitterAccount, keyValue);
-
addValidTweetsForApacheTomEEAccount(tweetIDsForTomEETwitterAcount,keyValue);
+
addValidTweetsForApacheTomEEAccount(tweetIDsForTomEETwitterAcount, keyValue);
}
}
retweetableStatusesVO.setTweetIDsForOpenEJBTwitterAccount(tweetIDsForOpenEJBTwitterAccount);
retweetableStatusesVO.setTweetIDsForTomEETwitterAcount(tweetIDsForTomEETwitterAcount);
-
+
return retweetableStatusesVO;
}
- static void addValidTweetsForApacheTomEEAccount(
- List<String> tweetIDsForTomEETwitterAcount, Map
keyValue) {
-
+ static void addValidTweetsForApacheTomEEAccount(List<String>
tweetIDsForTomEETwitterAcount, Map keyValue) {
+
String tweet = (String) keyValue.get("text");
if (!isOlderThanAnHour(keyValue) & isTomEETweet(tweet) &
!isRetweeted(keyValue)) {
@@ -73,33 +69,31 @@ public class OpenEJBMessageFilterUtil im
} else {
logWhyTweetWasRejectedForTomEEAccount(keyValue, tweet);
}
-
-
- }
- private static void logWhyTweetWasRejectedForTomEEAccount(Map keyValue,
- String tweet) {
+
+ }
+
+ private static void logWhyTweetWasRejectedForTomEEAccount(Map keyValue,
String tweet) {
logger.debug("Is TomEE Tweet?:" + isTomEETweet(tweet));
logger.debug("Was it retweeted before:" + isRetweeted(keyValue));
logger.info("Tweet Not Considered:" + keyValue.get("text"));
- }
+ }
- /**
+ /**
* Considers as a TomEE tweet, if it contains any of the hashtags
configured
* Allowed hashtags are configured in RetweetTool.properties
* NOTE: The hashtags in the property file should be pipe separated
*/
- static boolean isTomEETweet(String tweet) {
+ static boolean isTomEETweet(String tweet) {
- String hashTagsSupported = (String)
RetweetAppUtil.getTwitterAppProperties().get("tomee.supported.hashtags");
- Pattern pattern =
Pattern.compile(".*(#|@)("+hashTagsSupported+").*",Pattern.CASE_INSENSITIVE);
- Matcher matcher = pattern.matcher(tweet);
- return matcher.matches();
- }
-
- @SuppressWarnings("rawtypes")
- static void addValidTweetsForOpenEJBAccount(List<String> openEJBStatusIDs,
- Map keyValue) {
+ String hashTagsSupported = (String)
RetweetAppUtil.getTwitterAppProperties().get("tomee.supported.hashtags");
+ Pattern pattern = Pattern.compile(".*(#|@)(" + hashTagsSupported +
").*", Pattern.CASE_INSENSITIVE);
+ Matcher matcher = pattern.matcher(tweet);
+ return matcher.matches();
+ }
+
+ @SuppressWarnings("rawtypes")
+ static void addValidTweetsForOpenEJBAccount(List<String> openEJBStatusIDs,
Map keyValue) {
String tweet = (String) keyValue.get("text");
if (!isOlderThanAnHour(keyValue) & isOpenEJBTweet(tweet) &
!isRetweeted(keyValue)) {
addAcceptedTweetIDs(openEJBStatusIDs, keyValue, tweet);
@@ -110,8 +104,7 @@ public class OpenEJBMessageFilterUtil im
@SuppressWarnings("rawtypes")
- static void addAcceptedTweetIDs(List<String> openEJBStatusIDs,
- Map keyValue, String tweet) {
+ static void addAcceptedTweetIDs(List<String> openEJBStatusIDs, Map
keyValue, String tweet) {
logger.info("Adding Tweet:" + tweet);
Number tweetId = (Number) keyValue.get("id");
openEJBStatusIDs.add(tweetId.toString());
@@ -144,8 +137,8 @@ public class OpenEJBMessageFilterUtil im
@SuppressWarnings("rawtypes")
private static boolean isRetweeted(Map keyValue) {
-
- Integer retweetCount;
+
+ Integer retweetCount;
try {
retweetCount = getRetweetCount(keyValue, null);
} catch (NumberFormatException ignoredException) {
@@ -180,26 +173,4 @@ public class OpenEJBMessageFilterUtil im
Matcher matcher = pattern.matcher(tweet);
return matcher.matches();
}
-
-
- static boolean isOpenEJBMentioned(String word) {
- if ((word.startsWith("#") || word.startsWith("@")) &&
word.trim().length() >= 8) {
- if (word.trim().substring(1, 8).equalsIgnoreCase("openejb")) {
- return true;
- }
- }
-
- return false;
- }
-
- static boolean isTomEEMentioned(String word) {
- if ((word.startsWith("#") || word.startsWith("@")) &&
word.trim().length() >= 6) {
- if (word.trim().substring(1, 6).equals("TomEE")) {
- return true;
- }
- }
-
- return false;
- }
-
}
Modified:
openejb/trunk/sandbox/tools/src/main/java/org/apache/openejb/tools/twitter/Retweet.java
URL:
http://svn.apache.org/viewvc/openejb/trunk/sandbox/tools/src/main/java/org/apache/openejb/tools/twitter/Retweet.java?rev=1156408&r1=1156407&r2=1156408&view=diff
==============================================================================
---
openejb/trunk/sandbox/tools/src/main/java/org/apache/openejb/tools/twitter/Retweet.java
(original)
+++
openejb/trunk/sandbox/tools/src/main/java/org/apache/openejb/tools/twitter/Retweet.java
Thu Aug 11 00:14:40 2011
@@ -16,17 +16,11 @@
*/
package org.apache.openejb.tools.twitter;
-import java.io.IOException;
-import java.util.Collection;
-import java.util.Properties;
-import java.util.Set;
-
import oauth.signpost.OAuthConsumer;
import oauth.signpost.commonshttp.CommonsHttpOAuthConsumer;
import oauth.signpost.exception.OAuthCommunicationException;
import oauth.signpost.exception.OAuthExpectationFailedException;
import oauth.signpost.exception.OAuthMessageSignerException;
-
import org.apache.http.HttpResponse;
import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.HttpClient;
@@ -35,6 +29,11 @@ import org.apache.http.impl.client.Defau
import org.apache.log4j.Logger;
import org.apache.openejb.tools.twitter.util.RetweetAppUtil;
+import java.io.IOException;
+import java.util.Collection;
+import java.util.Properties;
+import java.util.Set;
+
/**
* We should monitor this feed http://twitter.com/#!/OpenEJB/contributors
* and retweet anything that mentions OpenEJB
@@ -67,18 +66,18 @@ public class Retweet {
Set<String> validOpenEJBTweetIDs =
UserStatusRetriever.getAllContributorsStatuses().getValidTweetIDsForOpenEJBAccount();
Set<String> validTomEETweetIDs =
UserStatusRetriever.getAllContributorsStatuses().getValidTweetIDsForTomEEAccount();
- retweetIfNotEmpty(validOpenEJBTweetIDs,TwitterAccount.OPENEJB);
- retweetIfNotEmpty(validTomEETweetIDs,TwitterAccount.TOMEE);
+ retweetIfNotEmpty(validOpenEJBTweetIDs, TwitterAccount.OPENEJB);
+ retweetIfNotEmpty(validTomEETweetIDs, TwitterAccount.TOMEE);
}
- private static void retweetIfNotEmpty(Collection<String>
tweetIDs,TwitterAccount twitterAccount) {
+ private static void retweetIfNotEmpty(Collection<String> tweetIDs,
TwitterAccount twitterAccount) {
if (!tweetIDs.isEmpty()) {
- logger.info("About to retweet "+tweetIDs+" at
"+twitterAccount.toString() +" twitter account");
- retweetThisCollectionOfStatuses(tweetIDs,twitterAccount);
+ logger.info("About to retweet " + tweetIDs + " at " +
twitterAccount.toString() + " twitter account");
+ retweetThisCollectionOfStatuses(tweetIDs, twitterAccount);
} else {
- logger.info("No message to retweet at
"+twitterAccount.toString()+" twitter account");
+ logger.info("No message to retweet at " +
twitterAccount.toString() + " twitter account");
}
}
@@ -86,7 +85,7 @@ public class Retweet {
for (String statusIDToRetweet : nonRetweetedOpenEJBStatusIDs) {
try {
- retweet(statusIDToRetweet,twitterAccount);
+ retweet(statusIDToRetweet, twitterAccount);
pauseBeforeTheNextRetweet();
} catch (OAuthMessageSignerException e) {
e.printStackTrace();
@@ -110,9 +109,9 @@ public class Retweet {
retweetToolProperties.getProperty("retweetApp.openejb.authorizedUser.consumer.tokenSecret"));
}
-
- public static void initConsumerForTomEEAccount(){
- consumer = new CommonsHttpOAuthConsumer(
+
+ public static void initConsumerForTomEEAccount() {
+ consumer = new CommonsHttpOAuthConsumer(
retweetToolProperties.getProperty("retweetApp.consumer.key"),
retweetToolProperties
.getProperty("retweetApp.consumerSecret.key"));
@@ -120,20 +119,20 @@ public class Retweet {
consumer.setTokenWithSecret(retweetToolProperties.getProperty("retweetApp.tomee.authorizedUser.consumer.token"),
retweetToolProperties.getProperty("retweetApp.tomee.authorizedUser.consumer.tokenSecret"));
-
+
}
public static HttpResponse retweet(String statusIDToRetweet,
TwitterAccount twitterAccount) throws OAuthMessageSignerException,
OAuthExpectationFailedException, OAuthCommunicationException {
HttpPost httpPost = new HttpPost(RetweetAppConstants.RETWEET_URL +
statusIDToRetweet + ".json");
-
+
initBasedOnAccountToRetweetAt(twitterAccount);
consumer.sign(httpPost);
HttpResponse response = null;
try {
response = getHttpClient().execute(httpPost);
logger.debug(response.getStatusLine());
-
- logger.info("Retweeted " + statusIDToRetweet +" at
"+twitterAccount.toString()+" twitter account" );
+
+ logger.info("Retweeted " + statusIDToRetweet + " at " +
twitterAccount.toString() + " twitter account");
} catch (ClientProtocolException e) {
e.printStackTrace();
} catch (IOException e) {
@@ -143,17 +142,14 @@ public class Retweet {
return response;
}
- private static void initBasedOnAccountToRetweetAt(
- TwitterAccount twitterAccount) {
- if(twitterAccount.equals(TwitterAccount.OPENEJB))
- {
- initConsumerForOpenEJBAccount();
+ private static void initBasedOnAccountToRetweetAt(
+ TwitterAccount twitterAccount) {
+ if (twitterAccount.equals(TwitterAccount.OPENEJB)) {
+ initConsumerForOpenEJBAccount();
+ } else if (twitterAccount.equals(TwitterAccount.TOMEE)) {
+ initConsumerForTomEEAccount();
}
- else if(twitterAccount.equals(TwitterAccount.TOMEE))
- {
- initConsumerForTomEEAccount();
- }
- }
+ }
public static HttpClient getHttpClient() {
return new DefaultHttpClient();
Modified:
openejb/trunk/sandbox/tools/src/main/java/org/apache/openejb/tools/twitter/TwitterAccount.java
URL:
http://svn.apache.org/viewvc/openejb/trunk/sandbox/tools/src/main/java/org/apache/openejb/tools/twitter/TwitterAccount.java?rev=1156408&r1=1156407&r2=1156408&view=diff
==============================================================================
---
openejb/trunk/sandbox/tools/src/main/java/org/apache/openejb/tools/twitter/TwitterAccount.java
(original)
+++
openejb/trunk/sandbox/tools/src/main/java/org/apache/openejb/tools/twitter/TwitterAccount.java
Thu Aug 11 00:14:40 2011
@@ -17,5 +17,5 @@
package org.apache.openejb.tools.twitter;
public enum TwitterAccount {
- OPENEJB,TOMEE
+ OPENEJB, TOMEE
}
Modified:
openejb/trunk/sandbox/tools/src/main/java/org/apache/openejb/tools/twitter/UserStatusRetriever.java
URL:
http://svn.apache.org/viewvc/openejb/trunk/sandbox/tools/src/main/java/org/apache/openejb/tools/twitter/UserStatusRetriever.java?rev=1156408&r1=1156407&r2=1156408&view=diff
==============================================================================
---
openejb/trunk/sandbox/tools/src/main/java/org/apache/openejb/tools/twitter/UserStatusRetriever.java
(original)
+++
openejb/trunk/sandbox/tools/src/main/java/org/apache/openejb/tools/twitter/UserStatusRetriever.java
Thu Aug 11 00:14:40 2011
@@ -16,6 +16,12 @@
*/
package org.apache.openejb.tools.twitter;
+import org.apache.http.HttpResponse;
+import org.apache.http.client.ClientProtocolException;
+import org.apache.http.client.methods.HttpGet;
+import org.apache.openejb.tools.twitter.vo.ValidStatuses;
+import org.apache.openejb.tools.twitter.vo.ValidStatusesOfUser;
+
import java.io.IOException;
import java.io.StringReader;
import java.util.HashSet;
@@ -23,12 +29,6 @@ import java.util.List;
import java.util.Map;
import java.util.Set;
-import org.apache.http.HttpResponse;
-import org.apache.http.client.ClientProtocolException;
-import org.apache.http.client.methods.HttpGet;
-import org.apache.openejb.tools.twitter.vo.ValidStatuses;
-import org.apache.openejb.tools.twitter.vo.ValidStatusesOfUser;
-
public class UserStatusRetriever {
public static HttpGet getHttpRequestToRetrieveUserStatuses(String
screenName) {
@@ -53,7 +53,6 @@ public class UserStatusRetriever {
/**
* Retrieves non-retweeted, less-than-an-hour-old statuses from a
specified contributor
- *
*/
@SuppressWarnings("rawtypes")
public static ValidStatusesOfUser getAcceptedStatusesOfContributor(String
screenName) {
@@ -61,7 +60,7 @@ public class UserStatusRetriever {
String responseBody =
JsonResponseParser.getResponseBody(userStatusResponse);
StringReader dataToParse = new StringReader(responseBody);
List<Map> listFromJson =
JsonResponseParser.getListFromJson(dataToParse);
-
+
ValidStatusesOfUser validStatusesOfUser =
OpenEJBMessageFilterUtil.getNonRetweetedValidStatusIDs(listFromJson);
return validStatusesOfUser;
}
@@ -74,11 +73,11 @@ public class UserStatusRetriever {
openEJBStatuses.addAll(getAcceptedStatusesOfContributor(screenName).getTweetIDsForOpenEJBTwitterAccount());
tomEEStatuses.addAll(getAcceptedStatusesOfContributor(screenName).getTweetIDsForTomEETwitterAcount());
}
-
+
ValidStatuses validStatuses = new ValidStatuses();
validStatuses.setValidTweetIDsForOpenEJBAccount(openEJBStatuses);
validStatuses.setValidTweetIDsForTomEEAccount(tomEEStatuses);
-
+
return validStatuses;
}
Modified:
openejb/trunk/sandbox/tools/src/main/java/org/apache/openejb/tools/twitter/vo/ValidStatuses.java
URL:
http://svn.apache.org/viewvc/openejb/trunk/sandbox/tools/src/main/java/org/apache/openejb/tools/twitter/vo/ValidStatuses.java?rev=1156408&r1=1156407&r2=1156408&view=diff
==============================================================================
---
openejb/trunk/sandbox/tools/src/main/java/org/apache/openejb/tools/twitter/vo/ValidStatuses.java
(original)
+++
openejb/trunk/sandbox/tools/src/main/java/org/apache/openejb/tools/twitter/vo/ValidStatuses.java
Thu Aug 11 00:14:40 2011
@@ -20,26 +20,27 @@ import java.util.HashSet;
import java.util.Set;
/**
- * One instance holding valid statuses from all contributors
+ * One instance holding valid statuses from all contributors
*/
public class ValidStatuses {
- Set<String> validTweetIDsForOpenEJBAccount = new HashSet<String>();
- Set<String> validTweetIDsForTomEEAccount = new HashSet<String>();
-
- public Set<String> getValidTweetIDsForOpenEJBAccount() {
- return validTweetIDsForOpenEJBAccount;
- }
- public void setValidTweetIDsForOpenEJBAccount(
- Set<String> validTweetIDsForOpenEJBAccount) {
- this.validTweetIDsForOpenEJBAccount =
validTweetIDsForOpenEJBAccount;
- }
- public Set<String> getValidTweetIDsForTomEEAccount() {
- return validTweetIDsForTomEEAccount;
- }
- public void setValidTweetIDsForTomEEAccount(
- Set<String> validTweetIDsForTomEEAccount) {
- this.validTweetIDsForTomEEAccount =
validTweetIDsForTomEEAccount;
- }
-
+ Set<String> validTweetIDsForOpenEJBAccount = new HashSet<String>();
+ Set<String> validTweetIDsForTomEEAccount = new HashSet<String>();
+
+ public Set<String> getValidTweetIDsForOpenEJBAccount() {
+ return validTweetIDsForOpenEJBAccount;
+ }
+
+ public void setValidTweetIDsForOpenEJBAccount(Set<String>
validTweetIDsForOpenEJBAccount) {
+ this.validTweetIDsForOpenEJBAccount = validTweetIDsForOpenEJBAccount;
+ }
+
+ public Set<String> getValidTweetIDsForTomEEAccount() {
+ return validTweetIDsForTomEEAccount;
+ }
+
+ public void setValidTweetIDsForTomEEAccount(Set<String>
validTweetIDsForTomEEAccount) {
+ this.validTweetIDsForTomEEAccount = validTweetIDsForTomEEAccount;
+ }
+
}
Modified:
openejb/trunk/sandbox/tools/src/main/java/org/apache/openejb/tools/twitter/vo/ValidStatusesOfUser.java
URL:
http://svn.apache.org/viewvc/openejb/trunk/sandbox/tools/src/main/java/org/apache/openejb/tools/twitter/vo/ValidStatusesOfUser.java?rev=1156408&r1=1156407&r2=1156408&view=diff
==============================================================================
---
openejb/trunk/sandbox/tools/src/main/java/org/apache/openejb/tools/twitter/vo/ValidStatusesOfUser.java
(original)
+++
openejb/trunk/sandbox/tools/src/main/java/org/apache/openejb/tools/twitter/vo/ValidStatusesOfUser.java
Thu Aug 11 00:14:40 2011
@@ -21,27 +21,27 @@ import java.util.List;
/**
* One instance for each contributor. Holds the valid tweet-ids of that
particular contributor
- *
*/
public class ValidStatusesOfUser {
-
+
List<String> tweetIDsForOpenEJBTwitterAccount = new ArrayList<String>();
List<String> tweetIDsForTomEETwitterAcount = new ArrayList<String>();
-
- public List<String> getTweetIDsForOpenEJBTwitterAccount() {
- return tweetIDsForOpenEJBTwitterAccount;
- }
- public void setTweetIDsForOpenEJBTwitterAccount(
- List<String> tweetIDsForOpenEJBTwitterAccount) {
- this.tweetIDsForOpenEJBTwitterAccount =
tweetIDsForOpenEJBTwitterAccount;
- }
- public List<String> getTweetIDsForTomEETwitterAcount() {
- return tweetIDsForTomEETwitterAcount;
- }
- public void setTweetIDsForTomEETwitterAcount(
- List<String> tweetIDsForTomEETwitterAcount) {
- this.tweetIDsForTomEETwitterAcount =
tweetIDsForTomEETwitterAcount;
- }
+
+ public List<String> getTweetIDsForOpenEJBTwitterAccount() {
+ return tweetIDsForOpenEJBTwitterAccount;
+ }
+
+ public void setTweetIDsForOpenEJBTwitterAccount(List<String>
tweetIDsForOpenEJBTwitterAccount) {
+ this.tweetIDsForOpenEJBTwitterAccount =
tweetIDsForOpenEJBTwitterAccount;
+ }
+
+ public List<String> getTweetIDsForTomEETwitterAcount() {
+ return tweetIDsForTomEETwitterAcount;
+ }
+
+ public void setTweetIDsForTomEETwitterAcount(List<String>
tweetIDsForTomEETwitterAcount) {
+ this.tweetIDsForTomEETwitterAcount = tweetIDsForTomEETwitterAcount;
+ }
}
