Method handleNetworkEvent

core/network/WebSocket.cpp:520–670

}

void WebSocket::handleNetworkEvent(yasio::io_event* event)
{
    int channelIndex = event->cindex();
    auto channel     = _service->channel_at(event->cindex());
    switch (event->kind())
    {
    case YEK_ON_PACKET:
        if (_state == State::CONNECTING)
        {
            auto&& pkt = event->packet_view();
            this->do_handshake(pkt.data(), pkt.size());
            if (_handshakeFinished)
            {
                ErrorCode error = ErrorCode::OK;
                if (_responseCode == 101)
                {
                    auto it = _responseHeaders.find("sec-websocket-accept");
                    if (it != _responseHeaders.end())
                    {
                        auto& secAccept = it->second;
                        if (_verifySecKey != secAccept)
                            error = ErrorCode::VERIFY_SEC_ACCEPT_FAILURE;
                    }
                    else
                        error = ErrorCode::NO_SEC_ACCEPT;
                }
                else
                    error = ErrorCode::UPGRADE_FAILURE;

                if (error == ErrorCode::OK)
                {
                    _state             = State::OPEN;
                    auto& timerForRead = channel->get_user_timer();
                    timerForRead.cancel();
                    _transport = event->transport();
                    _eventQueue.emplace_back(new WsOpenEvent());

                    // WebSocketProtocol::sendPing(*this);

                    // starts websocket heartbeat timer
                    //_heartbeatTimer->expires_from_now(std::chrono::seconds(30));
                    //_heartbeatTimer->async_wait([this](io_service& service) {
                    //    WebSocketProtocol::sendFrame(*this, "WSWS", 4, ws::detail::opcode::ping);
                    //    return false;
                    //});
                }
                else
                {
                    if (!_responseData.empty())
                        AXLOGE("WebSocket: handshake fail, detail: {}", _responseData);

                    //_state = State::CLOSING;
                    _service->close(channelIndex);
                    _eventQueue.emplace_back(new ErrorEvent(error));
                }
            }
        }
        else if (_state == State::OPEN)