package org.jim.server.command.handler;

import java.util.Objects;
import org.jim.core.ImChannelContext;
import org.jim.core.ImPacket;
import org.jim.core.exception.ImException;
import org.jim.core.http.HttpRequest;
import org.jim.core.packets.Command;
import org.jim.core.ws.WsSessionContext;
import org.jim.server.JimServerAPI;
import org.jim.server.command.AbstractCmdHandler;
import org.jim.server.processor.handshake.HandshakeCmdProcessor;

public class HandshakeReqHandler extends AbstractCmdHandler {
    public HandshakeReqHandler() {
    }

    public ImPacket handler(ImPacket packet, ImChannelContext channelContext) throws ImException {
        HandshakeCmdProcessor handshakeProcessor = (HandshakeCmdProcessor)this.getMultiProcessor(channelContext, HandshakeCmdProcessor.class);
        if (Objects.isNull(handshakeProcessor)) {
            JimServerAPI.remove(channelContext, "没有对应的握手协议处理器HandshakeCmdProcessor...");
            return null;
        } else {
            ImPacket handShakePacket = handshakeProcessor.handshake(packet, channelContext);
            if (handShakePacket == null) {
                JimServerAPI.remove(channelContext, "业务层不同意握手");
                return null;
            } else {
                JimServerAPI.send(channelContext, handShakePacket);
                WsSessionContext wsSessionContext = (WsSessionContext)channelContext.getSessionContext();
                HttpRequest request = wsSessionContext.getHandshakeRequestPacket();
                handshakeProcessor.onAfterHandshake(request, channelContext);
                return null;
            }
        }
    }

    public Command command() {
        return Command.COMMAND_HANDSHAKE_REQ;
    }
}