package com.xcong.excoin.modules.okxApi.wsHandler;

import com.alibaba.fastjson.JSONObject;
import org.java_websocket.client.WebSocketClient;

/**
 * OKX WebSocket 频道处理器接口。
 *
 * <p>每个 OKX 频道对应一个实现类。新增频道只需实现此接口，
 * 然后通过 {@code OkxKlineWebSocketClient.addChannelHandler()} 注册即可。
 *
 * <h3>实现类</h3>
 * <ul>
 *   <li>{@code OkxCandlestickChannelHandler} — K 线数据</li>
 *   <li>{@code OkxPositionsChannelHandler} — 持仓更新</li>
 *   <li>{@code OkxAccountChannelHandler} — 账户信息</li>
 *   <li>{@code OkxOrderInfoChannelHandler} — 订单信息（止盈止损、PnL跟踪）</li>
 * </ul>
 *
 * <h3>路由机制</h3>
 * {@code handleMessage()} 返回 {@code true} 表示消息已被该 handler 处理，
 * 路由循环会停止遍历。返回 {@code false} 表示不匹配（channel 名不相等）。
 *
 * @author Administrator
 */
public interface OkxChannelHandler {

    /** 频道名称，如 {@code "candle1m"} */
    String getChannelName();

    /** 发送订阅请求 */
    void subscribe(WebSocketClient ws);

    /** 发送取消订阅请求 */
    void unsubscribe(WebSocketClient ws);

    /**
     * 处理频道推送消息。
     *
     * @param response WebSocket 推送的完整 JSON
     * @return true 表示已处理（循环停止），false 表示频道不匹配（继续遍历下一个 handler）
     */
    boolean handleMessage(JSONObject response);
}