mumsi/MumbleCommunicator.cpp

#include <cstring>
#include <functional>

#include "MumbleCommunicator.hpp"

void mumble::MumbleCommunicator::receiveAudioFrameCallback(uint8_t *audio_data, uint32_t audio_data_size) {
    int dataPointer = 1;
    opus_int16 pcmData[1024];

    if (audio_data[0] == 0x80) {
        int64_t sessionId;
        int64_t sequenceNumber;
        int64_t opusDataLength;
        bool lastPacket;

        dataPointer += mumble_parse_variant(&sessionId, &audio_data[dataPointer]);
        dataPointer += mumble_parse_variant(&sequenceNumber, &audio_data[dataPointer]);
        dataPointer += mumble_parse_variant(&opusDataLength, &audio_data[dataPointer]);

        lastPacket = (opusDataLength & 0x2000) != 0;
        opusDataLength = opusDataLength & 0x1fff;


        unsigned int iAudioBufferSize;
        unsigned int iFrameSize = mumble::SAMPLE_RATE / 100;
        iAudioBufferSize = iFrameSize;
        iAudioBufferSize *= 12;
        int decodedSamples = opus_decode(opusDecoder,
                                         reinterpret_cast<const unsigned char *>(&audio_data[dataPointer]),
                                         opusDataLength,
                                         pcmData,
                                         iAudioBufferSize,
                                         0);

        fileHandle.write(pcmData, decodedSamples);

        logger.debug("Received %d bytes of Opus data (seq %ld), decoded to %d bytes. Push it to outputQueue.",
                     opusDataLength, sequenceNumber, decodedSamples);

        samplesBuffer.pushSamples(pcmData, decodedSamples);

    } else {
        logger.warn("Received %d bytes of non-recognisable audio data.", audio_data_size);
    }
}

static void mumble_audio_callback(uint8_t *audio_data, uint32_t audio_data_size, void *userData) {
    mumble::MumbleCommunicator *mumbleCommunicator = static_cast<mumble::MumbleCommunicator *>(userData);
    mumbleCommunicator->receiveAudioFrameCallback(audio_data, audio_data_size);
}

static void mumble_serversync_callback(char *welcome_text,
                                       int32_t session,
                                       int32_t max_bandwidth,
                                       int64_t permissions,
                                       void *usterData) {
    printf("%s\n", welcome_text);
}

static int verify_cert(uint8_t *, uint32_t) {
    // Accept every cert
    return 1;
}

mumble::MumbleCommunicator::MumbleCommunicator(
        ISamplesBuffer &samplesBuffer,
        std::string user,
        std::string password,
        std::string host,
        int port) : samplesBuffer(samplesBuffer),
                    outgoingAudioSequenceNumber(1),
                    logger(log4cpp::Category::getInstance("MumbleCommunicator")) {

    quit = false;

    opusDecoder = opus_decoder_create(SAMPLE_RATE, 1, nullptr); //todo grab error

    opusEncoder = opus_encoder_create(SAMPLE_RATE, 1, OPUS_APPLICATION_VOIP, nullptr);
    opus_encoder_ctl(opusEncoder, OPUS_SET_VBR(0));

    fileHandle = SndfileHandle("capture_mumble.wav", SFM_WRITE, SF_FORMAT_WAV | SF_FORMAT_PCM_16, 1, SAMPLE_RATE);

    struct mumble_config config;
    std::memset(&config, 0, sizeof(config));

    config.user_data = this;

    config.size = sizeof(config);
    config.host = const_cast<char *>(host.c_str());
    if (port > 0) {
        config.port = const_cast<char *>(std::to_string(port).c_str());
    }
    config.server_password = const_cast<char *>(password.c_str());
    config.username = const_cast<char *>(user.c_str());
    config.user_cert_filename = nullptr;
    config.user_privkey_filename = nullptr;

    config.ssl_verification_callback = verify_cert;
    config.audio_callback = mumble_audio_callback;
    config.serversync_callback = mumble_serversync_callback;

    mumble = mumble_connect(nullptr, &config);

    if (mumble == nullptr) {
        throw mumble::Exception("couldn't establish mumble connection");
    }
}

mumble::MumbleCommunicator::~MumbleCommunicator() {
    mumble_close(mumble);
}

void mumble::MumbleCommunicator::loop() {

    senderThread.reset(new std::thread(&MumbleCommunicator::senderThreadFunction, this));

    while (!quit) {
        int status = mumble_tick(mumble);
        logger.debug("tick");
        if (status < 0) {
            throw mumble::Exception("mumble_tick status " + status);
        }

        //todo Other processing here?
    }
}


void mumble::MumbleCommunicator::senderThreadFunction() {
    while (!quit) {
        opus_int16 pcmData[1024];
        unsigned char outputBuffer[1024];

        int pcmLength = samplesBuffer.pullSamples(pcmData, 960, true);

        logger.debug("Pop %d samples from inputQueue.", pcmLength);

        int encodedSamples = opus_encode(opusEncoder, pcmData, pcmLength, outputBuffer, sizeof(outputBuffer));

        if (encodedSamples < 1) {
            logger.warn("opus_encode returned %d: %s", encodedSamples, opus_strerror(encodedSamples));
        } else {
//            logger.debug("Sending %d bytes of Opus audio data (seq %d).", encodedSamples,
//                         outgoingAudioSequenceNumber);
//
//            //todo to powinno dać się bezpiecznie wykonać w osobnym wątku
//            mumble_send_audio_data(mumble, outgoingAudioSequenceNumber, outputBuffer, encodedSamples);
//
//            outgoingAudioSequenceNumber += 1;
        }
    }
}