Method performHandshakeForSSHAuth

src/Client/Connection.cpp:526–563

#if USE_SSH
void Connection::performHandshakeForSSHAuth()
{
    String challenge;
    {
        writeVarUInt(Protocol::Client::SSHChallengeRequest, *out);
        out->next();
        UInt64 packet_type = 0;
        if (in->eof())
            throw Poco::Net::NetException("Connection reset by peer");

        readVarUInt(packet_type, *in);
        if (packet_type == Protocol::Server::SSHChallenge)
        {
            readStringBinary(challenge, *in);
        }
        else if (packet_type == Protocol::Server::Exception)
            receiveException()->rethrow();
        else
            throwUnexpectedPacket(packet_type, "SSHChallenge or Exception");
    }

    writeVarUInt(Protocol::Client::SSHChallengeResponse, *out);

    auto pack_string_for_ssh_sign = [&](String challenge_)
    {
        String message;
        message.append(std::to_string(DBMS_TCP_PROTOCOL_VERSION));
        message.append(default_database);
        message.append(user);
        message.append(challenge_);
        return message;
    };

    String to_sign = pack_string_for_ssh_sign(challenge);
    String signature = ssh_private_key.signString(to_sign);
    writeStringBinary(signature, *out);
    out->next();
}
#endif