public class Main {
    private final ListenerContainer listenerContainer = new ListenerContainer();
    private final PropertiesEntity properties = new PropertiesEntity("127.0.0.1:5500", "token");

    public Main() {
        // new 一个对象以触发监听器的注册
        new TestListener(listenerContainer, properties);
    }

    private void run() {
        try {
            // 新建一个 WebSocket 连接
            new MyWebSocketClient(properties.getAddress(), properties.getToken(), listenerContainer).connect();
        } catch (URISyntaxException e) {
            log.error(e.getLocalizedMessage());
        }
    }

    public static void main(String[] args) {
        new Main().run();
    }
}

public class TestListener {
    private final PropertiesEntity properties;

    public TestListener(ListenerContainer listenerContainer, PropertiesEntity properties) {
        this.properties = properties;
        // 通过在构造器内对 listenerContainer 添加一个事件实现注册
        listenerContainer.addOnEventListener(event -> {
            // 判断事件的类型是否为 message-created(新消息创建, 即接收到消息)
            if (event.getType().equals(MessageEvents.MESSAGE_CREATED)) {
                this.onMessage(event);
            }
        });
    }

    public void onMessage(EventEntity event) {
        if ("test".equals(event.getMessage().getContent())) {
            ChannelEntity channel = event.getChannel();
            // 通过对应 API 类的方法发送消息
            MessageApi messageApi = new MessageApi(event.getPlatform(), event.getSelfId(), properties);
            messageApi.createMessage((channel.getType().equals(ChannelEntity.DIRECT) ? "private:" : "") + channel.getId(),
                    "test done!");
        }
    }
}