package com.estate.expert.admin.test;

import lombok.extern.slf4j.Slf4j;

import javax.websocket.*;
import java.io.IOException;
import java.net.URI;
import java.util.concurrent.Future;

/**
 * @ClassName WebsocketTest
 * @Description
 * @Author daisy
 * @Date 2024/1/2
 **/
@Slf4j
@ClientEndpoint
public class WebsocketTest {

    @OnOpen
    public void onOpen(Session session) {
        // 在建立连接时执行的逻辑
        log.info("onOpen");
        String subscriptionMessage = "{\"event\":\"subscribe\",\"topic\":\"PERP_NEAR_USDC@bbo\", \"id\":\"clientId555\"}";
        Future<Void> result = session.getAsyncRemote().sendText(subscriptionMessage);
        log.info("result: {}", result.isDone());

    }

    @OnMessage
    public void onMessage(String message) {
        // 处理接收到消息
        log.info("onMessage: {}", message);
    }

    public static void main(String[] args) throws Exception  {
        WebSocketContainer container = ContainerProvider.getWebSocketContainer();
        String accountId = "0xd1123119d6242281a07fff98e3d4fa0e0869d2eb6922ad7e13329ffa8cad902a";
        String uri = "wss://testnet-ws-evm.orderly.org/ws/stream/" + accountId; // 替换成实际的WebSocket服务器URL
        container.connectToServer(WebsocketTest.class, URI.create(uri));
        while (true) {
            Thread.sleep(60 * 60 * 1000);
        }
    }
}