feat(newPrice): 新增OKX交易所相关功能模块

Administrator

14 hours ago 635199d881d45a8c92abea57e89b69634ab4b366

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
package com.xcong.excoin.modules.newPrice.utils;
 
 
import com.xcong.excoin.common.exception.FebsException;
import com.xcong.excoin.modules.newPrice.enums.HttpMethod;
import okhttp3.MediaType;
import okhttp3.Request;
import okhttp3.RequestBody;
 
public final class RequestBuilder {
    private static final MediaType JSON_TYPE = MediaType.parse("application/json; charset=utf-8");
 
    private RequestBuilder() {
    }
 
    public static Request.Builder buildPublicRequest(String fullUrl, HttpMethod httpMethod, boolean issimulated) {
        try {
            final Request.Builder result;
            switch (httpMethod) {
                case POST:
                    OkHttpUtils builder = OkHttpUtils.builder();
                    if(issimulated){
                        builder.addHeader("x-simulated-trading","1");
                    }
                    result = builder
                            .url(fullUrl)
                            .post(true)
                            .sync();
                    break;
                case GET:
                    OkHttpUtils builder1 = OkHttpUtils.builder();
                    if(issimulated){
                        builder1.addHeader("x-simulated-trading","1");
                    }
                    result = builder1
                            .url(fullUrl)
                            .addHeader("Content-Type", "application/x-www-form-urlencoded")
                            .get()
                            .sync();
                    break;
                case PUT:
                    OkHttpUtils builder2 = OkHttpUtils.builder();
                    if(issimulated){
                        builder2.addHeader("x-simulated-trading","1");
                    }
                    result = builder2
                            .url(fullUrl)
                            .addHeader("Content-Type", "application/x-www-form-urlencoded")
                            .post(false)
                            .sync();
                    break;
                case DELETE:
                    OkHttpUtils builder3 = OkHttpUtils.builder();
                    if(issimulated){
                        builder3.addHeader("x-simulated-trading","1");
                    }
                    result = builder3
                            .url(fullUrl)
                            .post(false)
                            .sync();
                    break;
                default:
                    throw new FebsException("Invalid HTTP method: " + httpMethod);
            }
            return result;
        } catch (IllegalArgumentException e) {
            throw new FebsException("Invalid URL: " + e.getMessage());
        }
    }
 
    public static Request buildApiKeyRequest(String fullUrl,String body,String passphrase,String sign,String timeStamp, HttpMethod httpMethod, String apiKey,boolean issimulate) {
        try {
            final Request request;
            switch (httpMethod) {
                case POST:
                    Request.Builder builder = new Request.Builder();
                    if(issimulate){
                        builder.addHeader("x-simulated-trading","1");
                    }
                    request = builder
                            .url(fullUrl)
                            .post(RequestBody.create(JSON_TYPE, body))
                            .addHeader("OK-ACCESS-KEY", apiKey)
                            .addHeader("OK-ACCESS-SIGN", sign)
                            .addHeader("OK-ACCESS-TIMESTAMP", timeStamp)
                            .addHeader("OK-ACCESS-PASSPHRASE", passphrase)
                            .build();
                    break;
                case GET:
                    Request.Builder builder1 = new Request.Builder();
                    if(issimulate){
                        builder1.addHeader("x-simulated-trading","1");
                    }
                    request = builder1
                            .url(fullUrl)
                            .get()
                            .addHeader("Content-Type", "application/x-www-form-urlencoded")
                            .addHeader("OK-ACCESS-KEY", apiKey)
                            .addHeader("OK-ACCESS-KEY", apiKey)
                            .addHeader("OK-ACCESS-SIGN", sign)
                            .addHeader("OK-ACCESS-TIMESTAMP", timeStamp)
                            .addHeader("OK-ACCESS-PASSPHRASE", passphrase)
                            .build();
                    break;
                case PUT:
                    Request.Builder builder2 = new Request.Builder();
                    if(issimulate){
                        builder2.addHeader("x-simulated-trading","1");
                    }
                    request = builder2
                            .url(fullUrl)
                            .put(RequestBody.create(JSON_TYPE, ""))
                            .addHeader("Content-Type", "application/x-www-form-urlencoded")
                            .addHeader("OK-ACCESS-KEY", apiKey)
                            .addHeader("OK-ACCESS-KEY", apiKey)
                            .addHeader("OK-ACCESS-SIGN", sign)
                            .addHeader("OK-ACCESS-TIMESTAMP", timeStamp)
                            .addHeader("OK-ACCESS-PASSPHRASE", passphrase)
                            .build();
                    break;
                case DELETE:
                    Request.Builder builder3 = new Request.Builder();
                    if(issimulate){
                        builder3.addHeader("x-simulated-trading","1");
                    }
                    request = builder3
                            .url(fullUrl)
                            .delete()
                            .addHeader("Content-Type", "application/x-www-form-urlencoded")
                            .addHeader("OK-ACCESS-KEY", apiKey)
                            .addHeader("OK-ACCESS-KEY", apiKey)
                            .addHeader("OK-ACCESS-SIGN", sign)
                            .addHeader("OK-ACCESS-TIMESTAMP", timeStamp)
                            .addHeader("OK-ACCESS-PASSPHRASE", passphrase)
                            .build();
                    break;
                default:
                    throw new FebsException("Invalid HTTP method: " + httpMethod);
            }
            return request;
        } catch (IllegalArgumentException e) {
            throw new FebsException("Invalid URL: " + e.getMessage());
        }
    }
 
    public static Request buildWebsocketRequest(String fullUrl) {
        return new Request.Builder().url(fullUrl).build();
    }
 
}