#include "dmxcontroller.h"

#include <unistd.h>
#include <sys/ioctl.h>

#include <QDebug>

DmxController::DmxController(QObject *parent) :
    QObject{parent},
    m_thread{*this},
    m_lastInfo{QDateTime::currentDateTime()},
    m_counter{},
    m_lightProject {
        .lightTypes {
            { .id=0, .name="Stairville MH-X50+" },
            { .id=1, .name="RGBW Strahler" },
            { .id=2, .name="RGB Strahler" },
            { .id=3, .name="Nebelmaschine" }
        },
        .lights {
            { .id=0,  .name="Lampe 1",       .lightTypeId=1, .address=32 },
            { .id=1,  .name="Lampe 2",       .lightTypeId=1, .address=0  },
            { .id=2,  .name="Lampe 3",       .lightTypeId=1, .address=7  },
            { .id=3,  .name="Lampe 4",       .lightTypeId=1, .address=14 },
            { .id=4,  .name="Moving Head 1", .lightTypeId=0, .address=40 },
            { .id=5,  .name="Moving Head 2", .lightTypeId=0, .address=43 },
            { .id=6,  .name="Moving Head 3", .lightTypeId=0, .address=46 },
            { .id=7,  .name="Moving Head 4", .lightTypeId=0, .address=49 },
            { .id=8,  .name="Test 1",        .lightTypeId=2, .address=70 },
            { .id=9,  .name="Test 2",        .lightTypeId=2, .address=72 },
            { .id=10, .name="Nebelmaschine", .lightTypeId=3, .address=80 }
        }
    }
{
    std::fill(std::begin(buf), std::end(buf), 0);

    buf[32] = 255;
    buf[33] = 255;
    buf[34] = 0;
    buf[35] = 0;
//    buf[36] = 255;
}

bool DmxController::start()
{
    m_serialPort.setPortName("/dev/ttyAMA0");
    if (!m_serialPort.setBaudRate(250000))
    {
        qCritical("setBaudRate() failed %s", qPrintable(m_serialPort.errorString()));
        return false;
    }
    if (!m_serialPort.setDataBits(QSerialPort::Data8))
    {
        qCritical("setDataBits() failed %s", qPrintable(m_serialPort.errorString()));
        return false;
    }
    if (!m_serialPort.setParity(QSerialPort::NoParity))
    {
        qCritical("setParity() failed %s", qPrintable(m_serialPort.errorString()));
        return false;
    }
    if (!m_serialPort.setStopBits(QSerialPort::TwoStop))
    {
        qCritical("setStopBits() failed %s", qPrintable(m_serialPort.errorString()));
        return false;
    }
    if (!m_serialPort.setFlowControl(QSerialPort::NoFlowControl))
    {
        qCritical("setFlowControl() failed %s", qPrintable(m_serialPort.errorString()));
        return false;
    }
    if (!m_serialPort.open(QIODevice::WriteOnly))
    {
        qCritical("open() failed %s", qPrintable(m_serialPort.errorString()));
        return false;
    }

    m_thread.start(QThread::TimeCriticalPriority);

    return true;
}

void DmxController::setChannel(int channel, int value)
{
    buf[channel] = value;
}

void DmxController::sendDmxBuffer()
{
    const auto now = QDateTime::currentDateTime();

    m_serialPort.setBreakEnabled(true);
    QThread::usleep(88);
    m_serialPort.setBreakEnabled(false);

//    const auto written = write(m_serialPort.handle(), buf, std::size(buf));
    const auto written = m_serialPort.write(buf, std::size(buf));
    m_serialPort.flush();
//    qDebug("%lli written", written);

    m_counter++;

    if (m_lastInfo.msecsTo(now) >= 1000)
    {
        qInfo("%i per second ä", m_counter);
        m_counter = 0;
        m_lastInfo = now;
    }
}