0
implementation group: 'com.github.scribejava', name: 'scribejava-apis', version: '8.3.1'

0
OAuth20Service service = new ServiceBuilder("{API_KEY}").apiSecret("{SECRET_KEY}").callback("{CALLBACK_URL}").build(this);

0
abstract public class AuthModule extends DefaultApi20
1
{
2
    // 구현 예정
3
}

0
abstract public class AuthModule extends DefaultApi20
1
{
2
    protected OAuth20Service service;
3
    
4
    @Getter
5
    protected String unique;
6

7
    protected AuthModule(ServiceBuilderOAuth20 serviceBuilder, String unique)
8
    {
9
        service = serviceBuilder.build(this);
10
        
11
        this.unique = unique;
12
    }
13
}

0
public String getAuthorizationUrl(String state)
1
{
2
    return service.getAuthorizationUrl(state);
3
}

0
public OAuth2AccessToken getAccessToken(String code) throws IOException, ExecutionException, InterruptedException
1
{
2
    return service.getAccessToken(code);
3
}

0
public OAuth2AccessToken getRefreshAccessToken(String refresh) throws IOException
1
{
2
    HashMap<String, String> params = new HashMap<>();
3
    params.put("client_id", service.getApiKey());
4
    params.put("client_secret", service.getApiSecret());
5
    params.put("refresh_token", refresh);
6
    
7
    StringBuilder builder = new StringBuilder();
8
    
9
    for (Map.Entry<String, String> param : params.entrySet())
10
    {
11
        builder.append("&").append(URLEncoder.encode(param.getKey(), StandardCharsets.UTF_8)).append("=").append(URLEncoder.encode(param.getValue(), StandardCharsets.UTF_8));
12
    }
13
    
14
    byte[] paramBytes = builder.toString().getBytes(StandardCharsets.UTF_8);
15
    
16
    URL url = new URL(getRefreshTokenEndpoint());
17
    
18
    HttpURLConnection connection = (HttpURLConnection) url.openConnection();
19
    connection.setRequestMethod("POST");
20
    connection.setDoOutput(true);
21
    connection.getOutputStream().write(paramBytes);
22
    
23
    BufferedReader reader = new BufferedReader(new InputStreamReader(connection.getInputStream(), StandardCharsets.UTF_8));
24
    
25
    StringBuilder responseBuilder = new StringBuilder();
26
    String temp;
27
    
28
    while ((temp = reader.readLine()) != null)
29
    {
30
        responseBuilder.append(temp);
31
    }
32
    
33
    reader.close();
34
    
35
    ObjectMapper mapper = new ObjectMapper();
36
    
37
    JsonNode node = mapper.readTree(responseBuilder.toString());
38
    
39
    String access_token = node.get("access_token").textValue();
40
    String token_type = node.get("token_type").textValue();
41
    int expires_in = node.get("expires_in").intValue();
42
    
43
    return new OAuth2AccessToken(access_token, token_type, expires_in, null, null, responseBuilder.toString());
44
}
45

46
@Override
47
public String getRefreshTokenEndpoint()
48
{
49
    return Util.builder(getAccessTokenEndpoint(), "?grant_type=refresh_token");
50
}

0
public Response getUserInfo(String access) throws IOException, ExecutionException, InterruptedException
1
{
2
    OAuthRequest oAuthRequest = new OAuthRequest(Verb.GET, getUserInfoEndPoint());
3
    service.signRequest(access, oAuthRequest);
4
    
5
    return service.execute(oAuthRequest);
6
}
7

8
abstract protected String getUserInfoEndPoint();
9
    
10
abstract public UserInfoBean getUserInfoBean(String body) throws JsonProcessingException;

0
abstract public boolean deleteInfo(String access) throws IOException, ExecutionException, InterruptedException;

0
abstract public String getUpdateAuthorizationUrl(String state);

0
protected static ApiKeyBean getApiKeyBean(String platform)
1
{
2
    ApiKeyBean apiKeyBean;
3
    apiKeyBean = new ApiKeyBean();
4
    
5
    // API 키 획득 시도
6
    try
7
    {
8
        HashMap<String, String> map = Util.getProperties(platform);
9
        
10
        apiKeyBean.setApi(map.get("api"));
11
        apiKeyBean.setSecret(map.get("secret"));
12
        apiKeyBean.setCallback(map.get("callback"));
13
    }
14
    
15
    // 예외
16
    catch (Exception e)
17
    {
18
        e.printStackTrace();
19
    }
20
    
21
    return apiKeyBean;
22
}

0
@Getter
1
@Setter
2
public class ApiKeyBean
3
{
4
    // API 키
5
    private String api;
6
    
7
    // API SECRET 키
8
    private String secret;
9
    
10
    // 콜백 URL
11
    private String callback;
12
}

0
api={API_KEY}
1
secret={SECRET_KEY}
2
callback={CALLBACK_URL}

0
package oauth.account.module;
1

2
import com.fasterxml.jackson.core.JsonProcessingException;
3
import com.fasterxml.jackson.databind.JsonNode;
4
import com.fasterxml.jackson.databind.ObjectMapper;
5
import com.github.scribejava.core.builder.ServiceBuilderOAuth20;
6
import com.github.scribejava.core.builder.api.DefaultApi20;
7
import com.github.scribejava.core.model.OAuth2AccessToken;
8
import com.github.scribejava.core.model.OAuthRequest;
9
import com.github.scribejava.core.model.Response;
10
import com.github.scribejava.core.model.Verb;
11
import com.github.scribejava.core.oauth.AccessTokenRequestParams;
12
import com.github.scribejava.core.oauth.OAuth20Service;
13
import global.module.Util;
14
import lombok.Getter;
15
import oauth.account.bean.ApiKeyBean;
16
import oauth.account.bean.UserInfoBean;
17

18
import java.io.BufferedReader;
19
import java.io.IOException;
20
import java.io.InputStreamReader;
21
import java.net.HttpURLConnection;
22
import java.net.URL;
23
import java.net.URLEncoder;
24
import java.nio.charset.StandardCharsets;
25
import java.util.HashMap;
26
import java.util.Map;
27
import java.util.concurrent.ExecutionException;
28

29
/**
30
 * 인증 모듈 추상 클래스
31
 *
32
 * @author RWB
33
 * @since 2021.09.29 Wed 23:30:47
34
 */
35
abstract public class AuthModule extends DefaultApi20
36
{
37
    protected OAuth20Service service;
38
    
39
    @Getter
40
    protected String unique;
41
    
42
    /**
43
     * 생성자 메서드
44
     *
45
     * @param serviceBuilder: [ServiceBuilderOAuth20] API 서비스 빌더
46
     * @param unique: [String] 유니크 키
47
     */
48
    protected AuthModule(ServiceBuilderOAuth20 serviceBuilder, String unique)
49
    {
50
        service = serviceBuilder.build(this);
51
        
52
        this.unique = unique;
53
    }
54
    
55
    abstract protected String getUserInfoEndPoint();
56
    
57
    abstract public UserInfoBean getUserInfoBean(String body) throws JsonProcessingException;
58
    
59
    abstract public boolean deleteInfo(String access) throws IOException, ExecutionException, InterruptedException;
60
    
61
    abstract public String getUpdateAuthorizationUrl(String state);
62
    
63
    /**
64
     * 인증 URL 반환 메서드
65
     *
66
     * @param state: [String] 고유 상태값
67
     *
68
     * @return [String] 인증 URL
69
     */
70
    public String getAuthorizationUrl(String state)
71
    {
72
        return service.getAuthorizationUrl(state);
73
    }
74
    
75
    /**
76
     * 접근 토큰 반환 메서드
77
     *
78
     * @param code: [String] 인증 코드
79
     *
80
     * @return [OAuth2AccessToken] 접근 토큰
81
     *
82
     * @throws IOException 데이터 입출력 예외
83
     * @throws ExecutionException 실행 예외
84
     * @throws InterruptedException 인터럽트 예외
85
     */
86
    public OAuth2AccessToken getAccessToken(String code) throws IOException, ExecutionException, InterruptedException
87
    {
88
        return service.getAccessToken(code);
89
    }
90
    
91
    /**
92
     * 접근 토큰 반환 메서드
93
     *
94
     * @param params: [AccessTokenRequestParams] AccessTokenRequestParams 객체
95
     *
96
     * @return [OAuth2AccessToken] 접근 토큰
97
     *
98
     * @throws IOException 데이터 입출력 예외
99
     * @throws ExecutionException 실행 예외
100
     * @throws InterruptedException 인터럽트 예외
101
     */
102
    public OAuth2AccessToken getAccessToken(AccessTokenRequestParams params) throws IOException, ExecutionException, InterruptedException
103
    {
104
        return service.getAccessToken(params);
105
    }
106
    
107
    /**
108
     * 접근 토큰 갱신 및 반환 메서드
109
     *
110
     * @param refresh: [String] 리프레쉬 토큰
111
     *
112
     * @return [OAuth2AccessToken] 접근 토큰
113
     *
114
     * @throws IOException 데이터 입출력 예외
115
     */
116
    public OAuth2AccessToken getRefreshAccessToken(String refresh) throws IOException
117
    {
118
        HashMap<String, String> params = new HashMap<>();
119
        params.put("client_id", service.getApiKey());
120
        params.put("client_secret", service.getApiSecret());
121
        params.put("refresh_token", refresh);
122
        
123
        StringBuilder builder = new StringBuilder();
124
        
125
        for (Map.Entry<String, String> param : params.entrySet())
126
        {
127
            builder.append("&").append(URLEncoder.encode(param.getKey(), StandardCharsets.UTF_8)).append("=").append(URLEncoder.encode(param.getValue(), StandardCharsets.UTF_8));
128
        }
129
        
130
        byte[] paramBytes = builder.toString().getBytes(StandardCharsets.UTF_8);
131
        
132
        URL url = new URL(getRefreshTokenEndpoint());
133
        
134
        HttpURLConnection connection = (HttpURLConnection) url.openConnection();
135
        connection.setRequestMethod("POST");
136
        connection.setDoOutput(true);
137
        connection.getOutputStream().write(paramBytes);
138
        
139
        BufferedReader reader = new BufferedReader(new InputStreamReader(connection.getInputStream(), StandardCharsets.UTF_8));
140
        
141
        StringBuilder responseBuilder = new StringBuilder();
142
        String temp;
143
        
144
        while ((temp = reader.readLine()) != null)
145
        {
146
            responseBuilder.append(temp);
147
        }
148
        
149
        reader.close();
150
        
151
        ObjectMapper mapper = new ObjectMapper();
152
        
153
        JsonNode node = mapper.readTree(responseBuilder.toString());
154
        
155
        String access_token = node.get("access_token").textValue();
156
        String token_type = node.get("token_type").textValue();
157
        int expires_in = node.get("expires_in").intValue();
158
        
159
        return new OAuth2AccessToken(access_token, token_type, expires_in, refresh, null, responseBuilder.toString());
160
    }
161
    
162
    /**
163
     * 사용자 정보 응답 반환 메서드
164
     *
165
     * @param access: [String] 접근 토큰
166
     *
167
     * @return [Response] 사용자 정보 응답
168
     *
169
     * @throws IOException 데이터 입출력 예외
170
     * @throws ExecutionException 실행 예외
171
     * @throws InterruptedException 인터럽트 예외
172
     */
173
    public Response getUserInfo(String access) throws IOException, ExecutionException, InterruptedException
174
    {
175
        OAuthRequest oAuthRequest = new OAuthRequest(Verb.GET, getUserInfoEndPoint());
176
        service.signRequest(access, oAuthRequest);
177
        
178
        return service.execute(oAuthRequest);
179
    }
180
    
181
    /**
182
     * 접근 토큰 재발급 요청 URL 반환 메서드
183
     *
184
     * @return [String] 접근 토큰 재발급 요청 URL
185
     */
186
    @Override
187
    public String getRefreshTokenEndpoint()
188
    {
189
        return Util.builder(getAccessTokenEndpoint(), "?grant_type=refresh_token");
190
    }
191
    
192
    /**
193
     * API 키 객체 반환 메서드
194
     *
195
     * @param platform: [String] 플랫폼
196
     *
197
     * @return [ApiKeyBean] API 키 객체
198
     */
199
    protected static ApiKeyBean getApiKeyBean(String platform)
200
    {
201
        ApiKeyBean apiKeyBean;
202
        apiKeyBean = new ApiKeyBean();
203
        
204
        // API 키 획득 시도
205
        try
206
        {
207
            HashMap<String, String> map = Util.getProperties(platform);
208
            
209
            apiKeyBean.setApi(map.get("api"));
210
            apiKeyBean.setSecret(map.get("secret"));
211
            apiKeyBean.setCallback(map.get("callback"));
212
        }
213
        
214
        // 예외
215
        catch (Exception e)
216
        {
217
            e.printStackTrace();
218
        }
219
        
220
        return apiKeyBean;
221
    }
222
}