package com.example.sample; // https://mvnrepository.com/artifact/com.auth0/java-jwt import com.auth0.jwt.JWT; import com.auth0.jwt.algorithms.Algorithm; // https://mvnrepository.com/artifact/org.apache.httpcomponents/httpclient import org.apache.http.NameValuePair; import org.apache.http.client.methods.CloseableHttpResponse; import org.apache.http.client.methods.HttpGet; import org.apache.http.client.utils.URLEncodedUtils; import org.apache.http.impl.client.CloseableHttpClient; import org.apache.http.impl.client.HttpClients; import org.apache.http.message.BasicNameValuePair; import org.apache.http.util.EntityUtils; import com.fasterxml.jackson.databind.ObjectMapper; // JSON 파싱을 위해 추가 import java.io.IOException; import java.math.BigInteger; import java.nio.charset.StandardCharsets; import java.security.MessageDigest; import java.security.NoSuchAlgorithmException; import java.util.ArrayList; import java.util.List; import java.util.Map; import java.util.UUID; import java.util.stream.Collectors; public class TwapOrderQueryClient { public static void main(String[] args) throws NoSuchAlgorithmException, IOException { String accessKey = "발급받은 API KEY"; // 실제 발급받은 Access Key로 변경 String secretKey = "발급받은 SECRET KEY"; // 실제 발급받은 Secret Key로 변경 String apiUrl = "https://api.bithumb.com"; String twapQueryEndpoint = "/v1/twap"; // TWAP 주문내역 조회 엔드포인트 // --- 1. TWAP 주문내역 조회 파라미터 설정 (명세 반영) --- // 기본 파라미터 (map 대신 List 사용) List queryParams = new ArrayList<>(); queryParams.add(new BasicNameValuePair("market", "KRW-BTC")); // 마켓 ID queryParams.add(new BasicNameValuePair("state", "progress")); // TWAP 주문 상태 (progress, done, cancel) queryParams.add(new BasicNameValuePair("limit", "50")); queryParams.add(new BasicNameValuePair("order_by", "desc")); // queryParams.add(new BasicNameValuePair("next_key", "커서값")); // 페이지네이션 커서 // TWAP 주문 ID 목록 (uuids) List uuids = new ArrayList<>(); uuids.add("TWAP-A01B02C03D04E05F06"); uuids.add("TWAP-002-DONE"); // uuids 배열을 'uuids[]=' 형태로 쿼리 문자열에 추가 // Note: URLEncodedUtils.format은 Map이 아닌 List만 처리하므로, // uuids[]는 별도의 문자열로 구성해야 합니다. String uuidQuery = uuids.stream() .map(uuid -> "uuids[]=" + uuid) .collect(Collectors.joining("&")); // --- 2. JWT 토큰 생성 --- // 쿼리 문자열 인코딩 및 합치기 (서명에 사용) String baseQuery = URLEncodedUtils.format(queryParams, StandardCharsets.UTF_8); String finalQuery = baseQuery; if (!uuidQuery.isEmpty()) { finalQuery = finalQuery + "&" + uuidQuery; } // SHA-512 해시 생성 MessageDigest md = MessageDigest.getInstance("SHA-512"); md.update(finalQuery.getBytes(StandardCharsets.UTF_8)); String queryHash = String.format("%0128x", new BigInteger(1, md.digest())); // JWT 페이로드 및 토큰 생성 Algorithm algorithm = Algorithm.HMAC256(secretKey); String jwtToken = JWT.create() .withClaim("access_key", accessKey) .withClaim("nonce", UUID.randomUUID().toString()) .withClaim("timestamp", System.currentTimeMillis()) .withClaim("query_hash", queryHash) .withClaim("query_hash_alg", "SHA512") .sign(algorithm); String authenticationToken = "Bearer " + jwtToken; // --- 3. API 호출 (GET 메서드 및 TWAP 엔드포인트 사용) --- // 최종 쿼리 문자열을 URL에 추가 final HttpGet httpRequest = new HttpGet(apiUrl + twapQueryEndpoint + "?" + finalQuery); httpRequest.addHeader("Authorization", authenticationToken); try (CloseableHttpClient client = HttpClients.createDefault(); CloseableHttpResponse response = client.execute(httpRequest)) { // 응답 처리 int httpStatus = response.getStatusLine().getStatusCode(); String responseBody = EntityUtils.toString(response.getEntity(), StandardCharsets.UTF_8); System.out.println("--- TWAP 주문내역 조회 요청 결과 ---"); System.out.println("상태 코드: " + httpStatus); System.out.println("응답 본문: " + responseBody); if (httpStatus >= 200 && httpStatus < 300) { ObjectMapper mapper = new ObjectMapper(); Map responseMap = mapper.readValue(responseBody, Map.class); List dataList = (List) responseMap.get("data"); if (dataList != null) { System.out.println("조회된 TWAP 주문 건수: " + dataList.size()); } } } catch (Exception e) { throw new RuntimeException("API 요청 처리 중 예외 발생", e); } } }