package com.xcong.excoin.modules.okxNewPrice.okxWs;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.xcong.excoin.modules.okxNewPrice.okxWs.enums.ExchangeInfoEnum;
import com.xcong.excoin.modules.okxNewPrice.utils.SignUtils;
import com.xcong.excoin.modules.okxNewPrice.utils.WsParamBuild;
import lombok.extern.slf4j.Slf4j;
import org.java_websocket.client.WebSocketClient;

/**
 * @author Administrator
 */
@Slf4j
public class LoginWs {
    public static void websocketLogin(WebSocketClient webSocketClient) {

        log.info("开始执行LoginWs......");
        try {

            JSONArray argsArray = new JSONArray();
            JSONObject loginArgs = new JSONObject();
            // 获取登录凭证信息（需要从配置或Redis中获取）
            String apiKey = ExchangeInfoEnum.OKX_UAT.getApiKey();
            String passphrase = ExchangeInfoEnum.OKX_UAT.getPassphrase();
            String timestamp = String.valueOf(System.currentTimeMillis() /1000);
            String sign = SignUtils.signWebsocket(timestamp, ExchangeInfoEnum.OKX_UAT.getSecretKey());

            loginArgs.put("apiKey", apiKey);
            loginArgs.put("passphrase", passphrase);
            loginArgs.put("timestamp", timestamp);
            loginArgs.put("sign", sign);
            argsArray.add(loginArgs);

            String option = "login";
            JSONObject login = WsParamBuild.buildJsonObject(null,option, argsArray);
            webSocketClient.send(login.toJSONString());
            log.info("发送登录:{}",option);
        } catch (Exception e) {
            log.error("WebSocket登录请求构建失败", e);
        }
    }
}