iSharkFly-Docs
/
java-tutorials
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

small cleanup

This commit is contained in:
eugenp 2015-03-12 01:33:24 +02:00
parent 29fb3263c9
commit 7724bd2428
2 changed files with 48 additions and 43 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
spring-security-oauth/src/main/java/org/baeldung/persistence/model/User.java
View File

@ -42,7 +42,7 @@ public class User {
return username; return username;
} }
public void setUsername(String username) { public void setUsername(final String username) {
this.username = username; this.username = username;
} }
@ -50,7 +50,7 @@ public class User {
return accessToken; return accessToken;
} }
public void setAccessToken(String accessToken) { public void setAccessToken(final String accessToken) {
this.accessToken = accessToken; this.accessToken = accessToken;
} }
@ -58,7 +58,7 @@ public class User {
return refreshToken; return refreshToken;
} }
public void setRefreshToken(String refreshToken) { public void setRefreshToken(final String refreshToken) {
this.refreshToken = refreshToken; this.refreshToken = refreshToken;
} }
@ -66,7 +66,7 @@ public class User {
return tokenExpiration; return tokenExpiration;
} }
public void setTokenExpiration(Date tokenExpiration) { public void setTokenExpiration(final Date tokenExpiration) {
this.tokenExpiration = tokenExpiration; this.tokenExpiration = tokenExpiration;
} }
@ -74,10 +74,12 @@ public class User {
return needCaptcha; return needCaptcha;
} }
public void setNeedCaptcha(boolean needCaptcha) { public void setNeedCaptcha(final boolean needCaptcha) {
this.needCaptcha = needCaptcha; this.needCaptcha = needCaptcha;
} }
//
@Override @Override
public int hashCode() { public int hashCode() {
final int prime = 31; final int prime = 31;
@ -108,4 +110,5 @@ public class User {
public String toString() { public String toString() {
return "User [username=" + username + "]"; return "User [username=" + username + "]";
} }
} }

78
spring-security-oauth/src/main/java/org/baeldung/web/schedule/ScheduledTasks.java
View File

@ -11,7 +11,6 @@ import org.baeldung.reddit.util.RedditApiConstants;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled; import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.security.authentication.UsernamePasswordAuthenticationToken; import org.springframework.security.authentication.UsernamePasswordAuthenticationToken;
import org.springframework.security.core.authority.SimpleGrantedAuthority; import org.springframework.security.core.authority.SimpleGrantedAuthority;
@ -24,7 +23,6 @@ import org.springframework.util.MultiValueMap;
import com.fasterxml.jackson.databind.JsonNode; import com.fasterxml.jackson.databind.JsonNode;
@EnableScheduling
public class ScheduledTasks { public class ScheduledTasks {
private OAuth2RestTemplate redditRestTemplate; private OAuth2RestTemplate redditRestTemplate;
@ -42,48 +40,52 @@ public class ScheduledTasks {
} }
} }
private void submitPost(Post post) { private void submitPost(final Post post) {
try { try {
final User user = post.getUser(); submitPostInternal(post);
final DefaultOAuth2AccessToken token = new DefaultOAuth2AccessToken(user.getAccessToken());
token.setRefreshToken(new DefaultOAuth2RefreshToken((user.getRefreshToken())));
token.setExpiration(user.getTokenExpiration());
redditRestTemplate.getOAuth2ClientContext().setAccessToken(token);
//
final UsernamePasswordAuthenticationToken userAuthToken = new UsernamePasswordAuthenticationToken(user.getUsername(), token.getValue(), Arrays.asList(new SimpleGrantedAuthority("ROLE_USER")));
SecurityContextHolder.getContext().setAuthentication(userAuthToken);
//
final MultiValueMap<String, String> param = new LinkedMultiValueMap<String, String>();
param.add(RedditApiConstants.TITLE, post.getTitle());
param.add(RedditApiConstants.SR, post.getSubreddit());
param.add(RedditApiConstants.URL, post.getUrl());
param.add(RedditApiConstants.API_TYPE, "json");
param.add(RedditApiConstants.KIND, "link");
param.add(RedditApiConstants.RESUBMIT, "true");
param.add(RedditApiConstants.THEN, "comments");
if (post.isSendReplies()) {
param.add(RedditApiConstants.SENDREPLIES, "true");
}
logger.info("Submit link with these parameters: " + param.entrySet());
final JsonNode node = redditRestTemplate.postForObject("https://oauth.reddit.com/api/submit", param, JsonNode.class);
final JsonNode errorNode = node.get("json").get("errors").get(0);
if (errorNode == null) {
post.setSent(true);
post.setSubmissionResponse("Successfully sent");
postReopsitory.save(post);
logger.info("Successfully sent " + post.toString());
} else {
post.setSubmissionResponse(errorNode.toString());
postReopsitory.save(post);
logger.info("Error occurred: " + errorNode.toString() + "while submitting post " + post.toString());
}
} catch (final Exception e) { } catch (final Exception e) {
logger.error("Error occurred while submitting post " + post.toString(), e); logger.error("Error occurred while submitting post " + post.toString(), e);
} }
} }
public void setRedditRestTemplate(OAuth2RestTemplate redditRestTemplate) { private void submitPostInternal(final Post post) {
final User user = post.getUser();
final DefaultOAuth2AccessToken token = new DefaultOAuth2AccessToken(user.getAccessToken());
token.setRefreshToken(new DefaultOAuth2RefreshToken((user.getRefreshToken())));
token.setExpiration(user.getTokenExpiration());
redditRestTemplate.getOAuth2ClientContext().setAccessToken(token);
//
final UsernamePasswordAuthenticationToken userAuthToken = new UsernamePasswordAuthenticationToken(user.getUsername(), token.getValue(), Arrays.asList(new SimpleGrantedAuthority("ROLE_USER")));
SecurityContextHolder.getContext().setAuthentication(userAuthToken);
//
final MultiValueMap<String, String> param = new LinkedMultiValueMap<String, String>();
param.add(RedditApiConstants.TITLE, post.getTitle());
param.add(RedditApiConstants.SR, post.getSubreddit());
param.add(RedditApiConstants.URL, post.getUrl());
param.add(RedditApiConstants.API_TYPE, "json");
param.add(RedditApiConstants.KIND, "link");
param.add(RedditApiConstants.RESUBMIT, "true");
param.add(RedditApiConstants.THEN, "comments");
if (post.isSendReplies()) {
param.add(RedditApiConstants.SENDREPLIES, "true");
}
logger.info("Submit link with these parameters: " + param.entrySet());
final JsonNode node = redditRestTemplate.postForObject("https://oauth.reddit.com/api/submit", param, JsonNode.class);
final JsonNode errorNode = node.get("json").get("errors").get(0);
if (errorNode == null) {
post.setSent(true);
post.setSubmissionResponse("Successfully sent");
postReopsitory.save(post);
logger.info("Successfully sent " + post.toString());
} else {
post.setSubmissionResponse(errorNode.toString());
postReopsitory.save(post);
logger.info("Error occurred: " + errorNode.toString() + "while submitting post " + post.toString());
}
}
public void setRedditRestTemplate(final OAuth2RestTemplate redditRestTemplate) {
this.redditRestTemplate = redditRestTemplate; this.redditRestTemplate = redditRestTemplate;
} }
} }