#include "LedDeviceFadeCandy.h" static const signed MAX_NUM_LEDS = 10000; // OPC can handle 21845 leds - in theory, fadecandy device should handle 10000 leds static const unsigned OPC_SET_PIXELS = 0; // OPC command codes static const unsigned OPC_SYS_EX = 255; // OPC command codes static const unsigned OPC_HEADER_SIZE = 4; // OPC header size LedDeviceFadeCandy::LedDeviceFadeCandy(const Json::Value &deviceConfig) : LedDevice() { _deviceReady = init(deviceConfig); } LedDeviceFadeCandy::~LedDeviceFadeCandy() { _client.close(); } LedDevice* LedDeviceFadeCandy::construct(const Json::Value &deviceConfig) { return new LedDeviceFadeCandy(deviceConfig); } bool LedDeviceFadeCandy::init(const Json::Value &deviceConfig) { _client.close(); if (_ledCount > MAX_NUM_LEDS) { Error(_log, "fadecandy/opc: Invalid attempt to write led values. Not more than %d leds are allowed.", MAX_NUM_LEDS); return false; } _host = deviceConfig.get("output", "127.0.0.1").asString(); _port = deviceConfig.get("port", 7890).asInt(); _channel = deviceConfig.get("channel", 0).asInt(); _gamma = deviceConfig.get("gamma", 1.0).asDouble(); _noDither = ! deviceConfig.get("dither", false).asBool(); _noInterp = ! deviceConfig.get("interpolation", false).asBool(); _manualLED = deviceConfig.get("manualLed", false).asBool(); _ledOnOff = deviceConfig.get("ledOn", false).asBool(); _setFcConfig = deviceConfig.get("setFcConfig", false).asBool(); _whitePoint_r = 1.0; _whitePoint_g = 1.0; _whitePoint_b = 1.0; const Json::Value whitePointConfig = deviceConfig["whitePoint"]; if ( whitePointConfig.isArray() && whitePointConfig.size() == 3 ) { _whitePoint_r = whitePointConfig[0].asDouble(); _whitePoint_g = whitePointConfig[1].asDouble(); _whitePoint_b = whitePointConfig[2].asDouble(); } _opc_data.resize( _ledRGBCount + OPC_HEADER_SIZE ); _opc_data[0] = _channel; _opc_data[1] = OPC_SET_PIXELS; _opc_data[2] = _ledRGBCount >> 8; _opc_data[3] = _ledRGBCount & 0xff; return true; } bool LedDeviceFadeCandy::isConnected() { return _client.state() == QAbstractSocket::ConnectedState; } bool LedDeviceFadeCandy::tryConnect() { if ( _client.state() == QAbstractSocket::UnconnectedState ) { _client.connectToHost( _host.c_str(), _port); if ( _client.waitForConnected(1000) ) { Info(_log,"fadecandy/opc: connected to %s:%i on channel %i", _host.c_str(), _port, _channel); if (_setFcConfig) { sendFadeCandyConfiguration(); } } } return isConnected(); } int LedDeviceFadeCandy::write( const std::vector & ledValues ) { uint idx = OPC_HEADER_SIZE; for (const ColorRgb& color : ledValues) { _opc_data[idx ] = unsigned( color.red ); _opc_data[idx+1] = unsigned( color.green ); _opc_data[idx+2] = unsigned( color.blue ); idx += 3; } return ( transferData()<0 ? -1 : 0 ); } int LedDeviceFadeCandy::transferData() { if ( isConnected() || tryConnect() ) return _client.write( _opc_data, _opc_data.size() ); return -2; } int LedDeviceFadeCandy::sendSysEx(uint8_t systemId, uint8_t commandId, QByteArray msg) { if ( isConnected() ) { QByteArray sysExData; ssize_t data_size = msg.size() + 4; sysExData.resize( 4 + OPC_HEADER_SIZE ); sysExData[0] = 0; sysExData[1] = OPC_SYS_EX; sysExData[2] = data_size >>8; sysExData[3] = data_size &0xff; sysExData[4] = systemId >>8; sysExData[5] = systemId &0xff; sysExData[6] = commandId >>8; sysExData[7] = commandId &0xff; sysExData += msg; return _client.write( sysExData, sysExData.size() ); } return -1; } void LedDeviceFadeCandy::sendFadeCandyConfiguration() { Debug(_log, "send configuration to fadecandy"); QString data = "{\"gamma\": "+QString::number(_gamma,'g',4)+", \"whitepoint\": ["+QString::number(_whitePoint_r,'g',4)+", "+QString::number(_whitePoint_g,'g',4)+", "+QString::number(_whitePoint_b,'g',4)+"]}"; sendSysEx(1, 1, data.toLocal8Bit() ); char firmware_data = ((uint8_t)_noDither | ((uint8_t)_noInterp << 1) | ((uint8_t)_manualLED << 2) | ((uint8_t)_ledOnOff << 3) ); sendSysEx(1, 2, QByteArray(1,firmware_data) ); }