package com.example.mina.client.base;


import com.example.mina.client.entity.AbstractClientMessage;
import com.example.mina.client.entity.Command;
import com.example.mina.server.base.AbstractHardwareDataBuffer;
import com.example.mina.server.util.LogUtils;
import lombok.Data;
import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IdleStatus;
import org.apache.mina.core.session.IoSession;

import java.io.UnsupportedEncodingException;
import java.nio.charset.StandardCharsets;

@Data
public abstract class AbstractVirtualBoxClientHandler extends IoHandlerAdapter {

    protected AbstractClientMessage clientMessage;

    protected AbstractHardwareDataBuffer hardwareDataBuffer;

    public AbstractVirtualBoxClientHandler(AbstractClientMessage clientMessage,
                                           AbstractHardwareDataBuffer abstractHardwareDataBuffer) {
        this.clientMessage = clientMessage;
        this.hardwareDataBuffer = abstractHardwareDataBuffer;
    }

    @Override
    public void exceptionCaught(IoSession session, Throwable throwable) {
        System.out.println("客户端exceptionCaught被调用！");
        throwable.printStackTrace();
    }

    @Override
    public void messageReceived(IoSession session, Object message) {
        //handleCommandResponse(clientMessage.getCommands().get(1).getBytes(), (byte[]) message, ((byte[]) message).length);
        System.out.println("客户端messageReceived被调用！");
        System.out.println("client端接收信息：" + new String((byte[])message, StandardCharsets.UTF_8));
        LogUtils.println("client端接收信息hex：",(byte[])message);
    }

    @Override
    public void messageSent(IoSession session, Object message) {
        System.out.println("客户端messageSent被调用！");
        System.out.println("client端发送信息：" + new String((byte[])message, StandardCharsets.UTF_8));
        LogUtils.println("client端发送信息hex：",(byte[])message);
    }

    @Override
    public void inputClosed(IoSession session) {
        System.out.println("客户端inputClosed被调用！");
        System.out.println("client端：" + session.getId() + " 关闭输入");
    }

    @Override
    public void sessionClosed(IoSession session) {
        System.out.println("客户端sessionClosed被调用！");
        System.out.println("client端与：" + session.getRemoteAddress().toString() + " 关闭连接");
        System.exit(0);
    }

    @Override
    public void sessionCreated(IoSession session) {
        System.out.println("客户端sessionCreated被调用！");
        System.out.println("client端与：" + session.getRemoteAddress().toString() + " 建立连接");
    }

    @Override
    public void sessionIdle(IoSession session, IdleStatus status) {
        System.out.println("客户端sessionIdle被调用！");
        System.out.println("client端闲置连接：会话 " + session.getId() + " 被触发 " + session.getIdleCount(status) + " 次");
    }

    @Override
    public void sessionOpened(IoSession session) {
        //        for (int i = 0; i < clientMessage.getCommands().size(); i++) {
//            handleOneCommand(i, session);
//        }
//        handleOneCommand(1, session);
        System.out.println("客户端sessionOpened被调用！");
        System.out.println("client端打开连接");
    }

    protected void handleOneCommand(int i, IoSession session) {

        Command command = clientMessage.getCommands().get(i);

        session.write(command.getBytes());
    }

    protected abstract boolean handleCommandResponse(byte[] cmd, byte[] response, int responseLen);

}