This repository has been archived on 2026-05-31. You can view files and clone it, but cannot push or open issues or pull requests.
powersync-core/libnymea-core/hardware/radio433/radio433transmitter.cpp
2025-11-17 16:42:41 +01:00

115 lines
2.7 KiB
C++

// SPDX-License-Identifier: LGPL-3.0-or-later
/* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * *
*
* Copyright (C) 2013 - 2024, nymea GmbH
* Copyright (C) 2024 - 2025, chargebyte austria GmbH
*
* This file is part of nymea.
*
* nymea is free software: you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public License
* as published by the Free Software Foundation, either version 3
* of the License, or (at your option) any later version.
*
* nymea is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public License
* along with nymea. If not, see <https://www.gnu.org/licenses/>.
*
* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * */
#include "radio433transmitter.h"
namespace nymeaserver {
Radio433Trasmitter::Radio433Trasmitter(QObject *parent, int gpio) :
QThread(parent),m_gpioPin(gpio)
{
}
Radio433Trasmitter::~Radio433Trasmitter()
{
quit();
wait();
deleteLater();
}
bool Radio433Trasmitter::startTransmitter()
{
return setUpGpio();
}
bool Radio433Trasmitter::available()
{
return m_available;
}
void Radio433Trasmitter::run()
{
QList<int> rawData;
m_queueMutex.lock();
while(!m_rawDataQueue.isEmpty()){
rawData = m_rawDataQueue.dequeue();
m_queueMutex.unlock();
m_gpio->setValue(Gpio::ValueLow);
int flag=1;
foreach (int delay, rawData) {
// 1 = High, 0 = Low
int value = flag %2;
m_gpio->setValue((Gpio::Value)value);
flag++;
usleep(delay);
}
m_gpio->setValue(Gpio::ValueLow);
}
m_queueMutex.unlock();
}
void Radio433Trasmitter::allowSending(bool sending)
{
m_allowSendingMutex.lock();
m_allowSending = sending;
m_allowSendingMutex.unlock();
}
bool Radio433Trasmitter::setUpGpio()
{
m_gpio = new Gpio(m_gpioPin, this);
if(!m_gpio->exportGpio() || !m_gpio->setDirection(Gpio::DirectionOutput) || !m_gpio->setValue(Gpio::ValueLow)){
m_available = false;
return false;
}
m_available = true;
return true;
}
void Radio433Trasmitter::sendData(int delay, QList<int> rawData, int repetitions)
{
QList<int> timings;
for (int i = 0; i < repetitions; i++) {
foreach (int data, rawData) {
timings.append(delay*data);
}
}
m_queueMutex.lock();
m_rawDataQueue.enqueue(timings);
m_queueMutex.unlock();
if(!isRunning()){
start();
}
}
}