🔀 merge
This commit is contained in:
@@ -9,8 +9,7 @@ import me.zhyd.oauth.model.AuthCallback;
|
|||||||
import me.zhyd.oauth.model.AuthToken;
|
import me.zhyd.oauth.model.AuthToken;
|
||||||
import me.zhyd.oauth.model.AuthUser;
|
import me.zhyd.oauth.model.AuthUser;
|
||||||
import me.zhyd.oauth.model.AuthUserGender;
|
import me.zhyd.oauth.model.AuthUserGender;
|
||||||
import me.zhyd.oauth.url.AuthPinterestUrlBuilder;
|
import me.zhyd.oauth.utils.UrlBuilder;
|
||||||
import me.zhyd.oauth.url.entity.AuthUserInfoEntity;
|
|
||||||
|
|
||||||
import java.util.Objects;
|
import java.util.Objects;
|
||||||
|
|
||||||
@@ -26,13 +25,12 @@ import static me.zhyd.oauth.config.AuthSource.PINTEREST;
|
|||||||
public class AuthPinterestRequest extends AuthDefaultRequest {
|
public class AuthPinterestRequest extends AuthDefaultRequest {
|
||||||
|
|
||||||
public AuthPinterestRequest(AuthConfig config) {
|
public AuthPinterestRequest(AuthConfig config) {
|
||||||
super(config, PINTEREST, new AuthPinterestUrlBuilder());
|
super(config, PINTEREST);
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
protected AuthToken getAccessToken(AuthCallback authCallback) {
|
protected AuthToken getAccessToken(AuthCallback authCallback) {
|
||||||
String accessTokenUrl = this.urlBuilder.getAccessTokenUrl(authCallback.getCode());
|
HttpResponse response = doPostAuthorizationCode(authCallback.getCode());
|
||||||
HttpResponse response = HttpRequest.post(accessTokenUrl).execute();
|
|
||||||
JSONObject accessTokenObject = JSONObject.parseObject(response.body());
|
JSONObject accessTokenObject = JSONObject.parseObject(response.body());
|
||||||
if (!response.isOk()) {
|
if (!response.isOk()) {
|
||||||
throw new AuthException("Unable to get token from Pinterest using code [" + authCallback.getCode() + "]: " + accessTokenObject);
|
throw new AuthException("Unable to get token from Pinterest using code [" + authCallback.getCode() + "]: " + accessTokenObject);
|
||||||
@@ -46,10 +44,10 @@ public class AuthPinterestRequest extends AuthDefaultRequest {
|
|||||||
|
|
||||||
@Override
|
@Override
|
||||||
protected AuthUser getUserInfo(AuthToken authToken) {
|
protected AuthUser getUserInfo(AuthToken authToken) {
|
||||||
String accessToken = authToken.getAccessToken();
|
String userinfoUrl = UrlBuilder.fromBaseUrl(userInfoUrl(authToken))
|
||||||
HttpResponse response = HttpRequest.get(this.urlBuilder.getUserInfoUrl(AuthUserInfoEntity.builder()
|
.queryParam("fields", "id,username,first_name,last_name,bio,image")
|
||||||
.accessToken(accessToken)
|
.build();
|
||||||
.build())).execute();
|
HttpResponse response = HttpRequest.post(userinfoUrl).execute();
|
||||||
JSONObject userObj = JSONObject.parseObject(response.body()).getJSONObject("data");
|
JSONObject userObj = JSONObject.parseObject(response.body()).getJSONObject("data");
|
||||||
|
|
||||||
return AuthUser.builder()
|
return AuthUser.builder()
|
||||||
|
|||||||
@@ -1,15 +1,12 @@
|
|||||||
package me.zhyd.oauth.request;
|
package me.zhyd.oauth.request;
|
||||||
|
|
||||||
|
import cn.hutool.http.HttpRequest;
|
||||||
import cn.hutool.http.HttpResponse;
|
import cn.hutool.http.HttpResponse;
|
||||||
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONArray;
|
||||||
import com.alibaba.fastjson.JSONObject;
|
import com.alibaba.fastjson.JSONObject;
|
||||||
import me.zhyd.oauth.config.AuthConfig;
|
import me.zhyd.oauth.config.AuthConfig;
|
||||||
import me.zhyd.oauth.exception.AuthException;
|
import me.zhyd.oauth.exception.AuthException;
|
||||||
import me.zhyd.oauth.model.AuthCallback;
|
import me.zhyd.oauth.model.*;
|
||||||
import me.zhyd.oauth.model.AuthResponse;
|
|
||||||
import me.zhyd.oauth.model.AuthToken;
|
|
||||||
import me.zhyd.oauth.model.AuthUser;
|
|
||||||
import me.zhyd.oauth.model.AuthUserGender;
|
|
||||||
import me.zhyd.oauth.utils.UrlBuilder;
|
import me.zhyd.oauth.utils.UrlBuilder;
|
||||||
|
|
||||||
import java.util.Objects;
|
import java.util.Objects;
|
||||||
@@ -32,14 +29,12 @@ public class AuthRenrenRequest extends AuthDefaultRequest {
|
|||||||
|
|
||||||
@Override
|
@Override
|
||||||
protected AuthToken getAccessToken(AuthCallback authCallback) {
|
protected AuthToken getAccessToken(AuthCallback authCallback) {
|
||||||
return getToken(this.urlBuilder.getAccessTokenUrl(authCallback.getCode()));
|
return this.getToken(accessTokenUrl(authCallback.getCode()));
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
protected AuthUser getUserInfo(AuthToken authToken) {
|
protected AuthUser getUserInfo(AuthToken authToken) {
|
||||||
|
|
||||||
HttpResponse response = doGetUserInfo(authToken);
|
HttpResponse response = doGetUserInfo(authToken);
|
||||||
|
|
||||||
JSONObject userObj = JSONObject.parseObject(response.body()).getJSONObject("response");
|
JSONObject userObj = JSONObject.parseObject(response.body()).getJSONObject("response");
|
||||||
|
|
||||||
return AuthUser.builder()
|
return AuthUser.builder()
|
||||||
@@ -57,7 +52,7 @@ public class AuthRenrenRequest extends AuthDefaultRequest {
|
|||||||
public AuthResponse refresh(AuthToken authToken) {
|
public AuthResponse refresh(AuthToken authToken) {
|
||||||
return AuthResponse.builder()
|
return AuthResponse.builder()
|
||||||
.code(SUCCESS.getCode())
|
.code(SUCCESS.getCode())
|
||||||
.data(getToken(this.urlBuilder.getRefreshUrl(authToken.getRefreshToken())))
|
.data(getToken(this.refreshTokenUrl(authToken.getRefreshToken())))
|
||||||
.build();
|
.build();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -9,8 +9,7 @@ import me.zhyd.oauth.model.AuthCallback;
|
|||||||
import me.zhyd.oauth.model.AuthToken;
|
import me.zhyd.oauth.model.AuthToken;
|
||||||
import me.zhyd.oauth.model.AuthUser;
|
import me.zhyd.oauth.model.AuthUser;
|
||||||
import me.zhyd.oauth.model.AuthUserGender;
|
import me.zhyd.oauth.model.AuthUserGender;
|
||||||
import me.zhyd.oauth.url.AuthStackOverflowUrlBuilder;
|
import me.zhyd.oauth.utils.UrlBuilder;
|
||||||
import me.zhyd.oauth.url.entity.AuthUserInfoEntity;
|
|
||||||
|
|
||||||
import static me.zhyd.oauth.config.AuthSource.STACK_OVERFLOW;
|
import static me.zhyd.oauth.config.AuthSource.STACK_OVERFLOW;
|
||||||
import static me.zhyd.oauth.utils.GlobalAuthUtil.parseQueryToMap;
|
import static me.zhyd.oauth.utils.GlobalAuthUtil.parseQueryToMap;
|
||||||
@@ -25,12 +24,12 @@ import static me.zhyd.oauth.utils.GlobalAuthUtil.parseQueryToMap;
|
|||||||
public class AuthStackOverflowRequest extends AuthDefaultRequest {
|
public class AuthStackOverflowRequest extends AuthDefaultRequest {
|
||||||
|
|
||||||
public AuthStackOverflowRequest(AuthConfig config) {
|
public AuthStackOverflowRequest(AuthConfig config) {
|
||||||
super(config, STACK_OVERFLOW, new AuthStackOverflowUrlBuilder());
|
super(config, STACK_OVERFLOW);
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
protected AuthToken getAccessToken(AuthCallback authCallback) {
|
protected AuthToken getAccessToken(AuthCallback authCallback) {
|
||||||
String accessTokenUrl = this.urlBuilder.getAccessTokenUrl(authCallback.getCode());
|
String accessTokenUrl = accessTokenUrl(authCallback.getCode());
|
||||||
HttpResponse response = HttpRequest.post(accessTokenUrl)
|
HttpResponse response = HttpRequest.post(accessTokenUrl)
|
||||||
.contentType("application/x-www-form-urlencoded")
|
.contentType("application/x-www-form-urlencoded")
|
||||||
.form(parseQueryToMap(accessTokenUrl))
|
.form(parseQueryToMap(accessTokenUrl))
|
||||||
@@ -48,10 +47,11 @@ public class AuthStackOverflowRequest extends AuthDefaultRequest {
|
|||||||
|
|
||||||
@Override
|
@Override
|
||||||
protected AuthUser getUserInfo(AuthToken authToken) {
|
protected AuthUser getUserInfo(AuthToken authToken) {
|
||||||
String accessToken = authToken.getAccessToken();
|
String userInfoUrl = UrlBuilder.fromBaseUrl(userInfoUrl(authToken))
|
||||||
HttpResponse response = HttpRequest.get(this.urlBuilder.getUserInfoUrl(AuthUserInfoEntity.builder()
|
.queryParam("site", "stackoverflow")
|
||||||
.accessToken(accessToken)
|
.queryParam("key", this.config.getStackOverflowKey())
|
||||||
.build())).execute();
|
.build();
|
||||||
|
HttpResponse response = HttpRequest.get(userInfoUrl).execute();
|
||||||
JSONObject userObj = JSONObject.parseObject(response.body()).getJSONArray("items").getJSONObject(0);
|
JSONObject userObj = JSONObject.parseObject(response.body()).getJSONArray("items").getJSONObject(0);
|
||||||
|
|
||||||
return AuthUser.builder()
|
return AuthUser.builder()
|
||||||
|
|||||||
@@ -1,48 +0,0 @@
|
|||||||
package me.zhyd.oauth.url;
|
|
||||||
|
|
||||||
import me.zhyd.oauth.exception.AuthException;
|
|
||||||
import me.zhyd.oauth.model.AuthResponseStatus;
|
|
||||||
import me.zhyd.oauth.url.entity.AuthUserInfoEntity;
|
|
||||||
|
|
||||||
import java.text.MessageFormat;
|
|
||||||
|
|
||||||
import static me.zhyd.oauth.config.AuthSource.PINTEREST;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Pinterest相关的URL构建类
|
|
||||||
*
|
|
||||||
* @author hongwei.peng (pengisgood(at)gmail(dot)com)
|
|
||||||
* @version 1.9.0
|
|
||||||
* @since 1.9.0
|
|
||||||
*/
|
|
||||||
public class AuthPinterestUrlBuilder extends AuthDefaultUrlBuilder {
|
|
||||||
|
|
||||||
private static final String PINTEREST_ACCESS_TOKEN_PATTERN = "{0}?client_id={1}&client_secret={2}&grant_type=authorization_code&code={3}";
|
|
||||||
private static final String PINTEREST_USER_INFO_PATTERN = "{0}?access_token={1}&fields=id,username,first_name,last_name,bio,image";
|
|
||||||
private static final String PINTEREST_AUTHORIZE_PATTERN = "{0}?client_id={1}&response_type=code&redirect_uri={2}&state={3}&scope=read_public";
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public String getAccessTokenUrl(String code) {
|
|
||||||
return MessageFormat.format(PINTEREST_ACCESS_TOKEN_PATTERN, PINTEREST.accessToken(), config.getClientId(), config.getClientSecret(), code);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public String getUserInfoUrl(AuthUserInfoEntity userInfoEntity) {
|
|
||||||
return MessageFormat.format(PINTEREST_USER_INFO_PATTERN, PINTEREST.userInfo(), userInfoEntity.getAccessToken());
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public String getAuthorizeUrl() {
|
|
||||||
return MessageFormat.format(PINTEREST_AUTHORIZE_PATTERN, PINTEREST.authorize(), config.getClientId(), config.getRedirectUri(), this.getRealState(config.getState()));
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public String getRefreshUrl(String refreshToken) {
|
|
||||||
throw new AuthException(AuthResponseStatus.UNSUPPORTED);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public String getRevokeUrl(String accessToken) {
|
|
||||||
throw new AuthException(AuthResponseStatus.UNSUPPORTED);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@@ -1,48 +0,0 @@
|
|||||||
package me.zhyd.oauth.url;
|
|
||||||
|
|
||||||
import me.zhyd.oauth.exception.AuthException;
|
|
||||||
import me.zhyd.oauth.model.AuthResponseStatus;
|
|
||||||
import me.zhyd.oauth.url.entity.AuthUserInfoEntity;
|
|
||||||
|
|
||||||
import java.text.MessageFormat;
|
|
||||||
|
|
||||||
import static me.zhyd.oauth.config.AuthSource.STACK_OVERFLOW;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Stack Overflow相关的URL构建类
|
|
||||||
*
|
|
||||||
* @author hongwei.peng (pengisgood(at)gmail(dot)com)
|
|
||||||
* @version 1.9.0
|
|
||||||
* @since 1.9.0
|
|
||||||
*/
|
|
||||||
public class AuthStackOverflowUrlBuilder extends AuthDefaultUrlBuilder {
|
|
||||||
|
|
||||||
private static final String SO_ACCESS_TOKEN_PATTERN = "{0}?client_id={1}&client_secret={2}&redirect_uri={3}&code={4}";
|
|
||||||
private static final String SO_USER_INFO_PATTERN = "{0}?access_token={1}&site=stackoverflow&key={2}";
|
|
||||||
private static final String SO_AUTHORIZE_PATTERN = "{0}?client_id={1}&response_type=code&redirect_uri={2}&state={3}";
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public String getAccessTokenUrl(String code) {
|
|
||||||
return MessageFormat.format(SO_ACCESS_TOKEN_PATTERN, STACK_OVERFLOW.accessToken(), config.getClientId(), config.getClientSecret(), config.getRedirectUri(), code);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public String getUserInfoUrl(AuthUserInfoEntity userInfoEntity) {
|
|
||||||
return MessageFormat.format(SO_USER_INFO_PATTERN, STACK_OVERFLOW.userInfo(), userInfoEntity.getAccessToken(), config.getStackOverflowKey());
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public String getAuthorizeUrl() {
|
|
||||||
return MessageFormat.format(SO_AUTHORIZE_PATTERN, STACK_OVERFLOW.authorize(), config.getClientId(), config.getRedirectUri(), this.getRealState(config.getState()));
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public String getRefreshUrl(String refreshToken) {
|
|
||||||
throw new AuthException(AuthResponseStatus.UNSUPPORTED);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public String getRevokeUrl(String accessToken) {
|
|
||||||
throw new AuthException(AuthResponseStatus.UNSUPPORTED);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@@ -3,7 +3,7 @@ package me.zhyd.oauth.utils;
|
|||||||
import cn.hutool.core.lang.Assert;
|
import cn.hutool.core.lang.Assert;
|
||||||
import cn.hutool.core.map.MapUtil;
|
import cn.hutool.core.map.MapUtil;
|
||||||
import cn.hutool.core.util.StrUtil;
|
import cn.hutool.core.util.StrUtil;
|
||||||
import lombok.Data;
|
import lombok.Setter;
|
||||||
|
|
||||||
import java.util.LinkedHashMap;
|
import java.util.LinkedHashMap;
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
@@ -16,11 +16,15 @@ import java.util.Map;
|
|||||||
* @author yangkai.shen (https://xkcoding.com)
|
* @author yangkai.shen (https://xkcoding.com)
|
||||||
* @date Created in 2019-07-18 15:47
|
* @date Created in 2019-07-18 15:47
|
||||||
*/
|
*/
|
||||||
@Data
|
@Setter
|
||||||
public class UrlBuilder {
|
public class UrlBuilder {
|
||||||
private String baseUrl;
|
|
||||||
|
|
||||||
private final Map<String, Object> params = new LinkedHashMap<>(4);
|
private final Map<String, Object> params = new LinkedHashMap<>(4);
|
||||||
|
private String baseUrl;
|
||||||
|
|
||||||
|
private UrlBuilder() {
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @param baseUrl 基础路径
|
* @param baseUrl 基础路径
|
||||||
|
|||||||
Reference in New Issue
Block a user