#include <QUrl>

// These includes are only required by ignoreSigpipe, which is unix-only
#ifndef __WINDOWS__
#include <signal.h>
#include <unistd.h>
#endif

// shout.h checks for WIN32 to see if we are on Windows.
#ifdef WIN64
#define WIN32
#endif
#include <shoutidjc/shout.h>
#ifdef WIN64
#undef WIN32
#endif

#include "broadcast/defs_broadcast.h"
#include "control/controlpushbutton.h"
#include "encoder/encoder.h"
#include "encoder/encoderbroadcastsettings.h"
#ifdef __OPUS__
#include "encoder/encoderopus.h"
#endif
#include "engine/sidechain/shoutconnection.h"
#include "mixer/playerinfo.h"
#include "moc_shoutconnection.cpp"
#include "preferences/usersettings.h"
#include "recording/defs_recording.h"
#include "track/track.h"
#include "util/logger.h"

namespace {

const int kConnectRetries = 30;
const int kMaxNetworkCache = 491520;  // 10 s mp3 @ 192 kbit/s
// Shoutcast default receive buffer 1048576 and autodumpsourcetime 30 s
// http://wiki.shoutcast.com/wiki/SHOUTcast_DNAS_Server_2
const int kMaxShoutFailures = 3;

const mixxx::Logger kLogger("ShoutConnection");

} // namespace

ShoutConnection::ShoutConnection(BroadcastProfilePtr profile,
        UserSettingsPointer pConfig)
        : m_pTextCodec(nullptr),
          m_pMetaData(),
          m_pShout(nullptr),
          m_pShoutMetaData(nullptr),
          m_iMetaDataLife(0),
          m_iShoutStatus(0),
          m_iShoutFailures(0),
          m_pConfig(pConfig),
          m_pProfile(profile),
          m_encoder(nullptr),
          m_pMasterSamplerate(new ControlProxy("[Master]", "samplerate", this)),
          m_pBroadcastEnabled(new ControlProxy(BROADCAST_PREF_KEY, "enabled", this)),
          m_custom_metadata(false),
          m_firstCall(false),
          m_format_is_mp3(false),
          m_format_is_ov(false),
          m_format_is_opus(false),
          m_format_is_aac(false),
          m_protocol_is_icecast1(false),
          m_protocol_is_icecast2(false),
          m_protocol_is_shoutcast(false),
          m_ogg_dynamic_update(false),
          m_threadWaiting(false),
          m_retryCount(0),
          m_reconnectFirstDelay(0.0),
          m_reconnectPeriod(5.0),
          m_noDelayFirstReconnect(true),
          m_limitReconnects(true),
          m_maximumRetries(10) {
    setStatus(BroadcastProfile::STATUS_UNCONNECTED);
    setState(NETWORKSTREAMWORKER_STATE_INIT);

    // shout_init() should've already been called by now
    if (!(m_pShout = shout_new())) {
        errorDialog(tr("Mixxx encountered a problem"),
                tr("Could not allocate shout_t"));
    }

    if (!(m_pShoutMetaData = shout_metadata_new())) {
        errorDialog(tr("Mixxx encountered a problem"),
                tr("Could not allocate shout_metadata_t"));
    }

    setFunctionCode(14);
    if (shout_set_nonblocking(m_pShout, 1) != SHOUTERR_SUCCESS) {
        errorDialog(tr("Error setting non-blocking mode:"),
                shout_get_error(m_pShout));
    }

#ifdef SHOUT_TLS
    // Libshout defaults to SHOUT_TLS_AUTO if build with SHOUT_TLS
    // Sometimes autodetection fails, resulting into no metadata send
    // https://bugs.launchpad.net/mixxx/+bug/1817395
    if (shout_set_tls(m_pShout, SHOUT_TLS_DISABLED) != SHOUTERR_SUCCESS) {
        errorDialog(tr("Error setting tls mode:"),
                shout_get_error(m_pShout));
    }
#endif
}

ShoutConnection::~ShoutConnection() {
    delete m_pMasterSamplerate;

    if (m_pShoutMetaData) {
        shout_metadata_free(m_pShoutMetaData);
    }

    if (m_pShout) {
        shout_close(m_pShout);
        shout_free(m_pShout);
    }

    // Wait maximum ~4 seconds. User will get annoyed but
    // if there is some network problems we let them settle
    wait(4000);

    // Signal user if thread doesn't die
    VERIFY_OR_DEBUG_ASSERT(!isRunning()) {
       qWarning() << "ShoutOutput::~ShoutOutput(): Thread didn't die.\
       Ignored but file a bug report if problems rise!";
    }
}

bool ShoutConnection::isConnected() {
    if (m_pShout) {
        m_iShoutStatus = shout_get_connected(m_pShout);
        if (m_iShoutStatus == SHOUTERR_CONNECTED) {
            return true;
        }
    }
    return false;
}

// Only called when applying settings while broadcasting is active
void ShoutConnection::applySettings() {
    // Do nothing if profile or Live Broadcasting is disabled
    if (!m_pBroadcastEnabled->toBool() || !m_pProfile->getEnabled()) {
        return;
    }

    // Setting the profile's enabled value to false tells the
    // connection's thread to exit, so no need to call
    // processDisconnect manually

    int dStatus = getStatus();
    if((dStatus == BroadcastProfile::STATUS_UNCONNECTED
            || dStatus == BroadcastProfile::STATUS_FAILURE)) {
        serverConnect();
    }
}

QByteArray ShoutConnection::encodeString(const QString& string) {
    if (m_pTextCodec) {
        return m_pTextCodec->fromUnicode(string);
    }
    return string.toLatin1();
}

void ShoutConnection::insertMetaData(const char *pName, const char *pValue) {
    int ret = shout_metadata_add(m_pShoutMetaData, pName, pValue);
    if (ret != SHOUTERR_SUCCESS) {
        kLogger.warning() << "shout_metadata_add" << pName << "fails with error code" << ret;
    }
}

void ShoutConnection::updateFromPreferences() {
    kLogger.debug() << m_pProfile->getProfileName()
                    << ": updating from preferences";

    int dStatus = getStatus();
    if (dStatus == BroadcastProfile::STATUS_CONNECTED ||
            dStatus == BroadcastProfile::STATUS_CONNECTING) {
        kLogger.warning()
                << m_pProfile->getProfileName()
                << "updateFromPreferences status:" << dStatus
                << ". Can't edit preferences when playing";
        return;
    }

    setState(NETWORKSTREAMWORKER_STATE_BUSY);

    // Delete m_encoder if it has been initialized (with maybe) different bitrate.
    // delete m_encoder calls write() check if it will be exit early
    DEBUG_ASSERT(m_iShoutStatus != SHOUTERR_CONNECTED);
    m_encoder.reset();

    m_format_is_mp3 = false;
    m_format_is_ov = false;
    m_format_is_aac = false;
    m_protocol_is_icecast1 = false;
    m_protocol_is_icecast2 = false;
    m_protocol_is_shoutcast = false;
    m_ogg_dynamic_update = false;

    // Convert a bunch of QStrings to QByteArrays so we can get regular C char*
    // strings to pass to libshout.

    QString codec = m_pProfile->getMetadataCharset();
    if (!codec.isEmpty()) {
        QByteArray baCodec = codec.toLatin1();
        m_pTextCodec = QTextCodec::codecForName(baCodec);
        if (!m_pTextCodec) {
            kLogger.warning()
                    << "Couldn't find broadcast metadata codec for codec:" << codec
                    << " defaulting to ISO-8859-1.";
        } else {
            // Indicates our metadata is in the provided charset.
            insertMetaData("charset",  baCodec.constData());
        }
    }

    QString serverType = m_pProfile->getServertype();

    QString host = m_pProfile->getHost();
    int start = host.indexOf(QLatin1String("//"));
    if (start == -1) {
        // the host part requires preceding //.
        // Without them, the path is treated relative and goes to the
        // path() section.
        host.prepend(QLatin1String("//"));
    }
    QUrl serverUrl = host;

    int port = m_pProfile->getPort();
    serverUrl.setPort(port);

    QString mountPoint = m_pProfile->getMountpoint();
    if (!mountPoint.isEmpty()) {
        if (!mountPoint.startsWith('/')) {
            mountPoint.prepend('/');
        }
        serverUrl.setPath(mountPoint);
    }

    QString login = m_pProfile->getLogin();
    if (!login.isEmpty()) {
        serverUrl.setUserName(login);
    }

    kLogger.debug() << "Using server URL:" << serverUrl;

    QByteArray baPassword = m_pProfile->getPassword().toLatin1();
    QByteArray baFormat = m_pProfile->getFormat().toLatin1();
    int iBitrate = m_pProfile->getBitrate();

    // Encode metadata like stream name, website, desc, genre, title/author with
    // the chosen TextCodec.
    QByteArray baStreamName = encodeString(m_pProfile->getStreamName());
    QByteArray baStreamWebsite = encodeString(m_pProfile->getStreamWebsite());
    QByteArray baStreamDesc = encodeString(m_pProfile->getStreamDesc());
    QByteArray baStreamGenre = encodeString(m_pProfile->getStreamGenre());
    QByteArray baStreamIRC = encodeString(m_pProfile->getStreamIRC());
    QByteArray baStreamAIM = encodeString(m_pProfile->getStreamAIM());
    QByteArray baStreamICQ = encodeString(m_pProfile->getStreamICQ());

    // Whether the stream is public.
    bool streamPublic = m_pProfile->getStreamPublic();

    // Dynamic Ogg metadata update
    m_ogg_dynamic_update = m_pProfile->getOggDynamicUpdate();

    m_custom_metadata = m_pProfile->getEnableMetadata();
    m_customTitle = m_pProfile->getCustomTitle();
    m_customArtist = m_pProfile->getCustomArtist();

    m_metadataFormat = m_pProfile->getMetadataFormat();

    bool enableReconnect = m_pProfile->getEnableReconnect();
    if (enableReconnect) {
        m_reconnectFirstDelay = m_pProfile->getReconnectFirstDelay();
        m_reconnectPeriod = m_pProfile->getReconnectPeriod();
        m_noDelayFirstReconnect = m_pProfile->getNoDelayFirstReconnect();
        m_limitReconnects = m_pProfile->getLimitReconnects();
        m_maximumRetries = m_pProfile->getMaximumRetries();
    } else {
        m_limitReconnects = true;
        m_maximumRetries = 0;
    }

    int format;
    int protocol;

    if (shout_set_host(m_pShout, serverUrl.host().toLatin1().constData())
            != SHOUTERR_SUCCESS) {
        errorDialog(tr("Error setting hostname!"), shout_get_error(m_pShout));
        return;
    }

    if (shout_set_port(m_pShout,
            static_cast<unsigned short>(serverUrl.port(BROADCAST_DEFAULT_PORT)))
            != SHOUTERR_SUCCESS) {
        errorDialog(tr("Error setting port!"), shout_get_error(m_pShout));
        return;
    }

    if (shout_set_password(m_pShout, baPassword.constData())
            != SHOUTERR_SUCCESS) {
        errorDialog(tr("Error setting password!"), shout_get_error(m_pShout));
        return;
    }

    if (shout_set_mount(m_pShout, serverUrl.path().toLatin1().constData())
            != SHOUTERR_SUCCESS) {
        errorDialog(tr("Error setting mount!"), shout_get_error(m_pShout));
        return;
    }

    if (shout_set_user(m_pShout, serverUrl.userName().toLatin1().constData())
            != SHOUTERR_SUCCESS) {
        errorDialog(tr("Error setting username!"), shout_get_error(m_pShout));
        return;
    }

    if (shout_set_name(m_pShout, baStreamName.constData()) != SHOUTERR_SUCCESS) {
        errorDialog(tr("Error setting stream name!"), shout_get_error(m_pShout));
        return;
    }

    if (shout_set_description(m_pShout, baStreamDesc.constData()) != SHOUTERR_SUCCESS) {
        errorDialog(tr("Error setting stream description!"), shout_get_error(m_pShout));
        return;
    }

    if (shout_set_genre(m_pShout, baStreamGenre.constData()) != SHOUTERR_SUCCESS) {
        errorDialog(tr("Error setting stream genre!"), shout_get_error(m_pShout));
        return;
    }

    if (shout_set_url(m_pShout, baStreamWebsite.constData()) != SHOUTERR_SUCCESS) {
        errorDialog(tr("Error setting stream url!"), shout_get_error(m_pShout));
        return;
    }

#ifdef SHOUT_META_IRC
    if (shout_set_meta(m_pShout, SHOUT_META_IRC, baStreamIRC.constData()) != SHOUTERR_SUCCESS) {
        errorDialog(tr("Error setting stream IRC!"), shout_get_error(m_pShout));
        return;
    }
#endif

#ifdef SHOUT_META_AIM
    if (shout_set_meta(m_pShout, SHOUT_META_AIM, baStreamAIM.constData()) != SHOUTERR_SUCCESS) {
        errorDialog(tr("Error setting stream AIM!"), shout_get_error(m_pShout));
        return;
    }
#endif

#ifdef SHOUT_META_ICQ
    if (shout_set_meta(m_pShout, SHOUT_META_ICQ, baStreamICQ.constData()) != SHOUTERR_SUCCESS) {
        errorDialog(tr("Error setting stream ICQ!"), shout_get_error(m_pShout));
        return;
    }
#endif

    if (shout_set_public(m_pShout, streamPublic ? 1 : 0) != SHOUTERR_SUCCESS) {
        errorDialog(tr("Error setting stream public!"), shout_get_error(m_pShout));
        return;
    }

    m_format_is_mp3 = !qstrcmp(baFormat.constData(), ENCODING_MP3);
    m_format_is_ov = !qstrcmp(baFormat.constData(), ENCODING_OGG);
    m_format_is_opus = !qstrcmp(baFormat.constData(), ENCODING_OPUS);
    m_format_is_aac =
            (!qstrcmp(baFormat.constData(), ENCODING_AAC) ||
                    !qstrcmp(baFormat.constData(), ENCODING_HEAAC) ||
                    !qstrcmp(baFormat.constData(), ENCODING_HEAACV2));
    if (m_format_is_mp3) {
        format = SHOUT_FORMAT_MP3;
    } else if (m_format_is_ov || m_format_is_opus) {
        format = SHOUT_FORMAT_OGG;
#ifdef SHOUT_FORMAT_AAC
    } else if (m_format_is_aac) {
        format = SHOUT_FORMAT_AAC;
#endif
    } else {
        errorDialog(tr("Unknown stream encoding format!"),
                tr("Use a libshout version with %1 enabled")
                        .arg(baFormat.constData()));
        return;
    }

    if (shout_set_format(m_pShout, format) != SHOUTERR_SUCCESS) {
        errorDialog(tr("Error setting stream encoding format!"), shout_get_error(m_pShout));
        return;
    }

    if (iBitrate < 0) {
        qWarning() << "Error: unknown bit rate:" << iBitrate;
    }

    auto masterSamplerate = mixxx::audio::SampleRate::fromDouble(m_pMasterSamplerate->get());
    VERIFY_OR_DEBUG_ASSERT(masterSamplerate.isValid()) {
        qWarning() << "Invalid sample rate!" << masterSamplerate;
        return;
    }

    if (m_format_is_ov && masterSamplerate == 96000) {
        errorDialog(tr("Broadcasting at 96 kHz with Ogg Vorbis is not currently "
                       "supported. Please try a different sample rate or switch "
                       "to a different encoding."),
                    tr("See https://bugs.launchpad.net/mixxx/+bug/686212 for more "
                       "information."));
        return;
    }

#ifdef __OPUS__
    if (m_format_is_opus && masterSamplerate != EncoderOpus::getMasterSamplerate()) {
        errorDialog(
            EncoderOpus::getInvalidSamplerateMessage(),
            tr("Unsupported sample rate")
        );
        return;
    }
#endif

    if (shout_set_audio_info(
            m_pShout, SHOUT_AI_BITRATE,
            QByteArray::number(iBitrate).constData()) != SHOUTERR_SUCCESS) {
        errorDialog(tr("Error setting bitrate"), shout_get_error(m_pShout));
        return;
    }

    m_protocol_is_icecast2 = serverType == BROADCAST_SERVER_ICECAST2;
    m_protocol_is_shoutcast = serverType == BROADCAST_SERVER_SHOUTCAST;
    m_protocol_is_icecast1 = serverType == BROADCAST_SERVER_ICECAST1;

    if (m_protocol_is_icecast2) {
        protocol = SHOUT_PROTOCOL_HTTP;
    } else if (m_protocol_is_shoutcast) {
        protocol = SHOUT_PROTOCOL_ICY;
    } else if (m_protocol_is_icecast1) {
        protocol = SHOUT_PROTOCOL_XAUDIOCAST;
    } else {
        errorDialog(tr("Error: unknown server protocol!"), shout_get_error(m_pShout));
        return;
    }

    if (m_protocol_is_shoutcast && !m_format_is_mp3) {
        errorDialog(tr("Error: libshout only supports Shoutcast with MP3 format!"),
                    shout_get_error(m_pShout));
        return;
    }

    if (shout_set_protocol(m_pShout, protocol) != SHOUTERR_SUCCESS) {
        errorDialog(tr("Error setting protocol!"), shout_get_error(m_pShout));
        return;
    }

    // Initialize m_encoder
    EncoderSettingsPointer pBroadcastSettings =
            std::make_shared<EncoderBroadcastSettings>(m_pProfile);
    m_encoder = EncoderFactory::getFactory().createEncoder(
                    pBroadcastSettings, this);

    QString userErrorMsg;
    int ret = -1;
    if (m_encoder) {
        ret = m_encoder->initEncoder(static_cast<int>(masterSamplerate), &userErrorMsg);
    }

    // TODO(XXX): Use mixxx::audio::SampleRate instead of int in initEncoder
    if (ret < 0) {
        // delete m_encoder calls write() make sure it will be exit early
        DEBUG_ASSERT(m_iShoutStatus != SHOUTERR_CONNECTED);
        m_encoder.reset();

        setState(NETWORKSTREAMWORKER_STATE_ERROR);

        m_lastErrorStr = pBroadcastSettings->getFormat() + QChar(' ') +
                QObject::tr(" encoder failure") + QChar('\n');
        if (userErrorMsg.isEmpty()) {
            m_lastErrorStr.append(QObject::tr(
                    "Failed to apply the selected settings."));
        } else {
            m_lastErrorStr.append(userErrorMsg);
        }
        return;
    }
    setState(NETWORKSTREAMWORKER_STATE_READY);
}

bool ShoutConnection::serverConnect() {
    if (!m_pProfile->getEnabled()) {
        return false;
    }

    start(QThread::HighPriority);
    setState(NETWORKSTREAMWORKER_STATE_CONNECTING);
    return true;
}

bool ShoutConnection::processConnect() {
    kLogger.debug() << "processConnect";

    // Make sure that we call updateFromPreferences always
    updateFromPreferences();

    if (!m_encoder) {
        // updateFromPreferences failed
        setStatus(BroadcastProfile::STATUS_FAILURE);
        kLogger.warning() << "ShoutOutput::processConnect() returning false";
        return false;
    }

    setStatus(BroadcastProfile::STATUS_CONNECTING);
    m_iShoutFailures = 0;
    m_lastErrorStr.clear();
    // set to a high number to automatically update the metadata
    // on the first change
    m_iMetaDataLife = 31337;
    // clear metadata, to make sure the first track is not skipped
    // because it was sent via an previous connection (see metaDataHasChanged)
    if(m_pMetaData) {
        m_pMetaData.reset();
    }
    // If static metadata is available, we only need to send metadata one time
    m_firstCall = false;

    while (m_iShoutFailures < kMaxShoutFailures) {
        shout_close(m_pShout);
        m_iShoutStatus = shout_open(m_pShout);
        if (m_iShoutStatus == SHOUTERR_SUCCESS) {
            m_iShoutStatus = SHOUTERR_CONNECTED;
            setState(NETWORKSTREAMWORKER_STATE_CONNECTED);
        }

        if ((m_iShoutStatus == SHOUTERR_BUSY) ||
            (m_iShoutStatus == SHOUTERR_CONNECTED) ||
            (m_iShoutStatus == SHOUTERR_SUCCESS))
        {
            break;
        }

        // SHOUTERR_INSANE self is corrupt or incorrect
        // SHOUTERR_UNSUPPORTED The protocol/format combination is unsupported
        // SHOUTERR_NOLOGIN The server refused login
        // SHOUTERR_MALLOC There wasn't enough memory to complete the operation
        if (m_iShoutStatus == SHOUTERR_INSANE ||
            m_iShoutStatus == SHOUTERR_UNSUPPORTED ||
            m_iShoutStatus == SHOUTERR_NOLOGIN ||
            m_iShoutStatus == SHOUTERR_MALLOC) {
            m_lastErrorStr = shout_get_error(m_pShout);
            qWarning() << "Streaming server made fatal error. Can't continue connecting:"
                       << m_lastErrorStr;
            break;
        }

        m_iShoutFailures++;
        m_lastErrorStr = shout_get_error(m_pShout);
        kLogger.warning()
                << m_iShoutFailures << "/" << kMaxShoutFailures
                << "Streaming server failed connect. Failures:"
                << m_lastErrorStr;
    }

    // If we don't have any fatal errors let's try to connect
    if ((m_iShoutStatus == SHOUTERR_BUSY ||
             m_iShoutStatus == SHOUTERR_CONNECTED ||
             m_iShoutStatus == SHOUTERR_SUCCESS) &&
             m_iShoutFailures < kMaxShoutFailures) {
        m_iShoutFailures = 0;
        int timeout = 0;
        while (m_iShoutStatus == SHOUTERR_BUSY &&
                timeout < kConnectRetries &&
                m_pProfile->getEnabled()) {
        	setState(NETWORKSTREAMWORKER_STATE_WAITING);
            kLogger.debug() << "Connection pending. Waiting...";
            m_iShoutStatus = shout_get_connected(m_pShout);

            if (m_iShoutStatus != SHOUTERR_BUSY &&
                    m_iShoutStatus != SHOUTERR_SUCCESS &&
                    m_iShoutStatus != SHOUTERR_CONNECTED) {
                qWarning() << "Streaming server made error:" << m_iShoutStatus;
            }

            // If socket is busy then we wait half second
            if (m_iShoutStatus == SHOUTERR_BUSY) {
                m_enabledMutex.lock();
                m_waitEnabled.wait(&m_enabledMutex, 500);
                m_enabledMutex.unlock();
            }

            ++ timeout;
        }
        if (m_iShoutStatus == SHOUTERR_CONNECTED) {
        	setState(NETWORKSTREAMWORKER_STATE_READY);
            kLogger.debug() << "***********Connected to streaming server...";

            m_retryCount = 0;

            if(m_pOutputFifo->readAvailable()) {
            	m_pOutputFifo->flushReadData(m_pOutputFifo->readAvailable());
            }
            m_threadWaiting = true;

            setStatus(BroadcastProfile::STATUS_CONNECTED);
            emit broadcastConnected();

            kLogger.debug() << "processConnect() returning true";
            return true;
        } else if (m_iShoutStatus == SHOUTERR_SOCKET) {
            m_lastErrorStr = "Socket error";
            kLogger.warning()
                    << "processConnect() socket error."
                    << "Is socket already in use?";
        } else if (m_pProfile->getEnabled()) {
            m_lastErrorStr = shout_get_error(m_pShout);
            kLogger.warning()
                    << "processConnect() error:"
                    << m_iShoutStatus << m_lastErrorStr;
        }
    }

    // no connection, clean up
    shout_close(m_pShout);
    // delete m_encoder calls write() check if it will be exit early
    DEBUG_ASSERT(m_iShoutStatus != SHOUTERR_CONNECTED);
    m_encoder.reset();
    if (m_pProfile->getEnabled()) {
        setStatus(BroadcastProfile::STATUS_FAILURE);
    } else {
        setStatus(BroadcastProfile::STATUS_UNCONNECTED);
    }
    kLogger.debug() << "processConnect() returning false";
    return false;
}

bool ShoutConnection::processDisconnect() {
    kLogger.debug() << "processDisconnect()";
    bool disconnected = false;
    if (isConnected()) {
    	m_threadWaiting = false;

        // We are connected but broadcast is disabled. Disconnect.
        shout_close(m_pShout);
        m_iShoutStatus = SHOUTERR_UNCONNECTED;

        emit broadcastDisconnected();
        disconnected = true;
    }
    // delete m_encoder calls write() check if it will be exit early
    DEBUG_ASSERT(m_iShoutStatus != SHOUTERR_CONNECTED);
    m_encoder.reset();
    return disconnected;
}

void ShoutConnection::write(const unsigned char* header, const unsigned char* body,
                            int headerLen, int bodyLen) {
    setFunctionCode(7);
	if (!m_pShout || m_iShoutStatus != SHOUTERR_CONNECTED) {
        // This happens when the decoder calls flush() and the connection is
        // already down
        return;
    }

    // Send header if there is one
    if (headerLen > 0) {
        if(!writeSingle(header, headerLen)) {
            return;
        }
    }

    if(!writeSingle(body, bodyLen)) {
        return;
    }

    ssize_t queuelen = shout_queuelen(m_pShout);
    if (queuelen > 0) {
        kLogger.debug() << "shout_queuelen" << queuelen;
        if (queuelen > kMaxNetworkCache) {
            m_lastErrorStr = tr("Network cache overflow");
            tryReconnect();
        }
    }
}
// These are not used for streaming, but the interface requires them
int ShoutConnection::tell() {
    if (!m_pShout) {
        return -1;
    }
    return -1;
}
// These are not used for streaming, but the interface requires them
void ShoutConnection::seek(int pos) {
    Q_UNUSED(pos)
    return;
}
// These are not used for streaming, but the interface requires them
int ShoutConnection::filelen() {
    return 0;
}

bool ShoutConnection::writeSingle(const unsigned char* data, size_t len) {
    setFunctionCode(8);
    int ret = shout_send_raw(m_pShout, data, len);
    if (ret == SHOUTERR_BUSY) {
        // in case of busy, frames are queued
        // try to flush queue after a short sleep
        kLogger.warning() << "writeSingle() SHOUTERR_BUSY, trying again";
        usleep(10000); // wait 10 ms until "busy" is over. TODO() tweak for an optimum.
        // if this fails, the queue is transmitted after the next regular shout_send_raw()
        (void)shout_send_raw(m_pShout, nullptr, 0);
    } else if (ret < SHOUTERR_SUCCESS) {
        m_lastErrorStr = shout_get_error(m_pShout);
        kLogger.warning()
                << "writeSingle() error:"
                << ret << m_lastErrorStr;
        if (++m_iShoutFailures > kMaxShoutFailures) {
            tryReconnect();
        }
        return false;
    } else {
        m_iShoutFailures = 0;
    }
    return true;
}

void ShoutConnection::process(const CSAMPLE* pBuffer, const int iBufferSize) {
    setFunctionCode(4);
    if (!m_pProfile->getEnabled()) {
        return;
    }

    setState(NETWORKSTREAMWORKER_STATE_BUSY);

    // If we aren't connected, bail.
    if (m_iShoutStatus != SHOUTERR_CONNECTED) {
        return;
    }

    // Save a copy of the smart pointer in a local variable
    // to prevent race conditions when resetting the member
    // pointer while disconnecting in the worker thread!
    const EncoderPointer pEncoder = m_encoder;

    // If we are connected, encode the samples.
    if (iBufferSize > 0 && pEncoder) {
        setFunctionCode(6);
        pEncoder->encodeBuffer(pBuffer, iBufferSize);
        // the encoded frames are received by the write() callback.
    }

    // Check if track metadata has changed and if so, update.
    if (metaDataHasChanged()) {
        updateMetaData();
    }
    setState(NETWORKSTREAMWORKER_STATE_READY);
}

bool ShoutConnection::metaDataHasChanged() {
    TrackPointer pTrack;

    // TODO(rryan): This is latency and buffer size dependent. Should be based
    // on time.
    if (m_iMetaDataLife < 16) {
        m_iMetaDataLife++;
        return false;
    }

    m_iMetaDataLife = 0;

    pTrack = PlayerInfo::instance().getCurrentPlayingTrack();
    if (!pTrack) {
        return false;
    }

    if (m_pMetaData) {
        if (!pTrack->getId().isValid() || !m_pMetaData->getId().isValid()) {
            if ((pTrack->getArtist() == m_pMetaData->getArtist()) &&
                (pTrack->getTitle() == m_pMetaData->getArtist())) {
                return false;
            }
        } else if (pTrack->getId() == m_pMetaData->getId()) {
            return false;
        }
    }
    m_pMetaData = pTrack;
    return true;
}

void ShoutConnection::updateMetaData() {
    setFunctionCode(5);
    if (!m_pShout) {
        kLogger.debug() << "updateMetaData failed, invalid m_pShout";
        return;
    }
    if (!m_pShoutMetaData) {
        kLogger.debug() << "updateMetaData failed, invalid m_pShoutMetaData";
        return;
    }

    /**
     * If track has changed and static metadata is disabled
     * Send new metadata to broadcast!
     * This works only for MP3 streams properly as stated in comments, see shout.h
     * WARNING: Changing OGG metadata dynamically by using shout_set_metadata
     * will cause stream interruptions to listeners
     *
     * Also note: Do not try to include Vorbis comments in OGG packages and send them to stream.
     * This was done in EncoderVorbis previously and caused interruptions on track change as well
     * which sounds awful to listeners.
     * To conclude: Only write OGG metadata one time, i.e., if static metadata is used.
     */


    // If we use either MP3 streaming or OGG streaming with dynamic update of
    // metadata being enabled, we want dynamic metadata changes
    if (!m_custom_metadata && (m_format_is_mp3 || m_ogg_dynamic_update)) {
        if (m_pMetaData != nullptr) {

            QString artist = m_pMetaData->getArtist();
            QString title = m_pMetaData->getTitle();

            // shoutcast uses only "song" as field for "artist - title".
            // icecast2 supports separate fields for "artist" and "title",
            // which will get displayed accordingly if the streamingformat and
            // player supports it. ("song" is treated as an alias for "title")
            //
            // Note (EinWesen):
            // Currently that seems to be OGG only, although it is no problem
            // setting both fields for MP3, tested players do not show anything different.
            // Also I do not know about icecast1. To be safe, i stick to the
            // old way for those use cases.
            if (!m_format_is_mp3 && m_protocol_is_icecast2) {
            	setFunctionCode(9);
            	insertMetaData("artist", encodeString(artist).constData());
            	insertMetaData("title", encodeString(title).constData());
            } else {
                // we are going to take the metadata format and replace all
                // the references to $title and $artist by doing a single
                // pass over the string
                int replaceIndex = 0;

                // Make a copy so we don't overwrite the references only
                // once per streaming session.
                QString metadataFinal = m_metadataFormat;
                do {
                    // find the next occurrence
                    replaceIndex = metadataFinal.indexOf(
                                      QRegExp("\\$artist|\\$title"),
                                      replaceIndex);

                    if (replaceIndex != -1) {
                        if (metadataFinal.indexOf(
                                          QRegExp("\\$artist"), replaceIndex)
                                          == replaceIndex) {
                            metadataFinal.replace(replaceIndex, 7, artist);
                            // skip to the end of the replacement
                            replaceIndex += artist.length();
                        } else {
                            metadataFinal.replace(replaceIndex, 6, title);
                            replaceIndex += title.length();
                        }
                    }
                } while (replaceIndex != -1);

                QByteArray baSong = encodeString(metadataFinal);
                setFunctionCode(10);
                insertMetaData("song",  baSong.constData());
            }
            setFunctionCode(11);
            int ret = shout_set_metadata(m_pShout, m_pShoutMetaData);
            if (ret != SHOUTERR_SUCCESS) {
                kLogger.warning() << "shout_set_metadata fails with error code" << ret;
            }
        }
    } else {
        // Otherwise we might use static metadata
        // If we use static metadata, we only need to call the following line once
        if (m_custom_metadata && !m_firstCall) {

            // see comment above...
            if (!m_format_is_mp3 && m_protocol_is_icecast2) {
            	setFunctionCode(12);
                insertMetaData("artist", encodeString(m_customArtist).constData());
                insertMetaData("title", encodeString(m_customTitle).constData());
            } else {
                QByteArray baCustomSong = encodeString(m_customArtist.isEmpty() ? m_customTitle : m_customArtist + " - " + m_customTitle);
                insertMetaData("song", baCustomSong.constData());
            }

            setFunctionCode(13);
            shout_set_metadata(m_pShout, m_pShoutMetaData);
            m_firstCall = true;
        }
    }
}

void ShoutConnection::errorDialog(const QString& text, const QString& detailedError) {
    qWarning() << "Streaming error: " << detailedError;
    ErrorDialogProperties* props = ErrorDialogHandler::instance()->newDialogProperties();
    props->setType(DLG_WARNING);
    props->setTitle(tr("Connection error"));
    props->setText(tr("One of the Live Broadcasting connections raised this error:<br>"
            "<b>Error with connection '%1':</b><br>")
            .arg(profile()->getProfileName()) + text);
    props->setDetails(detailedError);
    props->setKey(detailedError);   // To prevent multiple windows for the same error
    props->setDefaultButton(QMessageBox::Close);
    props->setModal(false);
    ErrorDialogHandler::instance()->requestErrorDialog(props);
    setState(NETWORKSTREAMWORKER_STATE_ERROR);
}

void ShoutConnection::infoDialog(const QString& text, const QString& detailedInfo) {
    ErrorDialogProperties* props = ErrorDialogHandler::instance()->newDialogProperties();
    props->setType(DLG_INFO);
    props->setTitle(tr("Connection message"));
    props->setText(tr("<b>Message from Live Broadcasting connection '%1':</b><br>")
            .arg(profile()->getProfileName()) + text);
    props->setDetails(detailedInfo);
    props->setKey(text + detailedInfo);
    props->setDefaultButton(QMessageBox::Close);
    props->setModal(false);
    ErrorDialogHandler::instance()->requestErrorDialog(props);
}

bool ShoutConnection::waitForRetry() {
    if (m_limitReconnects &&
            m_retryCount >= m_maximumRetries) {
        return false;
    }
    ++m_retryCount;

    kLogger.debug() << "waitForRetry()" << m_retryCount << "/" << m_maximumRetries;

    double delay;
    if (m_retryCount == 1) {
        delay = m_reconnectFirstDelay;
    } else {
        delay = m_reconnectPeriod;
    }

    if (delay > 0) {
        m_enabledMutex.lock();
        m_waitEnabled.wait(&m_enabledMutex, static_cast<unsigned long>(delay * 1000));
        m_enabledMutex.unlock();
        if (!m_pProfile->getEnabled()) {
            return false;
        }
    }
    return true;
}

void ShoutConnection::tryReconnect() {
    QString originalErrorStr = m_lastErrorStr;
    setStatus(BroadcastProfile::STATUS_FAILURE);

    processDisconnect();
    while (waitForRetry()) {
        if (processConnect()) {
            break;
        }
    }

    if (getStatus() == BroadcastProfile::STATUS_FAILURE) {
        QString errorText;
        if (m_retryCount > 0) {
            errorText = tr("Lost connection to streaming server and %1 attempts to reconnect have failed.")
                    .arg(m_retryCount);
        } else {
            errorText = tr("Lost connection to streaming server.");
        }
        errorDialog(errorText,
                    originalErrorStr + "\n" +
                    m_lastErrorStr + "\n" +
                    tr("Please check your connection to the Internet."));
    }
}

void ShoutConnection::outputAvailable() {
    m_readSema.release();
}

void ShoutConnection::setOutputFifo(QSharedPointer<FIFO<CSAMPLE>> pOutputFifo) {
    m_pOutputFifo = pOutputFifo;
}

QSharedPointer<FIFO<CSAMPLE>> ShoutConnection::getOutputFifo() {
    return m_pOutputFifo;
}

bool ShoutConnection::threadWaiting() {
    return atomicLoadRelaxed(m_threadWaiting);
}

void ShoutConnection::run() {
    QThread::currentThread()->setObjectName(
            QString("ShoutOutput '%1'").arg(m_pProfile->getProfileName()));
    kLogger.debug() << "run: Starting thread";

#ifndef __WINDOWS__
    ignoreSigpipe();
#endif

    VERIFY_OR_DEBUG_ASSERT(m_pOutputFifo) {
        kLogger.warning() << "run: Broadcast FIFO handle is not available. Aborting";
        return;
    }

    if (!processConnect()) {
        errorDialog(tr("Can't connect to streaming server"),
                m_lastErrorStr + "\n\n" +
                        tr("Please check your connection to the Internet and "
                           "verify that your username and password are "
                           "correct."));
        return;
    }

    setStatus(BroadcastProfile::STATUS_CONNECTED);

    while(true) {
        // Stop the thread if broadcasting is turned off
        if (!m_pProfile->getEnabled()
                || !m_pBroadcastEnabled->toBool()
                || getStatus() == BroadcastProfile::STATUS_FAILURE
                || getStatus() == BroadcastProfile::STATUS_UNCONNECTED) {
            m_threadWaiting = false;
            kLogger.debug() << "run: Connection disabled or failed. Disconnecting";
            if(processDisconnect()) {
                setStatus(BroadcastProfile::STATUS_UNCONNECTED);
            }
            setFunctionCode(2);
            break;
        }

        setFunctionCode(1);
        incRunCount();
        if(!m_readSema.tryAcquire(1, 1000)) {
            continue;
        }

        int readAvailable = m_pOutputFifo->readAvailable();
        if (readAvailable) {
            setFunctionCode(3);
            CSAMPLE* dataPtr1;
            ring_buffer_size_t size1;
            CSAMPLE* dataPtr2;
            ring_buffer_size_t size2;

            // We use size1 and size2, so we can ignore the return value
            (void)m_pOutputFifo->aquireReadRegions(readAvailable, &dataPtr1, &size1,
                    &dataPtr2, &size2);

            // Push frames to the encoder.
            process(dataPtr1, size1);
            if (size2 > 0) {
                process(dataPtr2, size2);
            }

            m_pOutputFifo->releaseReadRegions(readAvailable);
        }
    }

    kLogger.debug() << "run: Thread stopped";
}

#ifndef __WINDOWS__
void ShoutConnection::ignoreSigpipe() {
    // If the remote connection is closed, shout_send_raw() can cause a
    // SIGPIPE. If it is unhandled then Mixxx will quit immediately.
#ifdef Q_OS_MAC
    // The per-thread approach using pthread_sigmask below does not seem to work
    // on macOS.
    struct sigaction sa;
    memset(&sa, 0, sizeof(sa));
    sa.sa_handler = SIG_IGN;
    if (sigaction(SIGPIPE, &sa, NULL) != 0) {
        kLogger.warning() << "ignoreSigpipe() failed";
    }
#else
    // http://www.microhowto.info/howto/ignore_sigpipe_without_affecting_other_threads_in_a_process.html
    sigset_t sigpipe_mask;
    sigemptyset(&sigpipe_mask);
    sigaddset(&sigpipe_mask, SIGPIPE);
    sigset_t saved_mask;
    if (pthread_sigmask(SIG_BLOCK, &sigpipe_mask, &saved_mask) != 0) {
        kLogger.warning() << "ignoreSigpipe() failed";
    }
#endif
}
#endif