radioprotocol.cpp

// Written by Adrian Musceac YO8RZZ , started December 2017.
//
// This program is free software; you can redistribute it and/or
// modify it under the terms of the GNU General Public License as
// published by the Free Software Foundation; either version 3 of the
// License, or (at your option) any later version.
//
// This program 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
// General Public License for more details.
//
// You should have received a copy of the GNU General Public License
// along with this program; if not, write to the Free Software
// Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.

#include "radioprotocol.h"

RadioProtocol::RadioProtocol(QObject *parent) :
    QObject(parent)
{
    _voip_channels = new QVector<Channel*>;
    _voip_users = new QVector<Station>;
    _buffer = new QByteArray;
}


QByteArray RadioProtocol::buildRepeaterInfo()
{
    QByteArray data;

    for(int i=0;i <_voip_channels->size();i++)
    {
        data.append(0xCF);
        data.append(0x77);
        data.append(0x07);
        data.append(0xAB);
        data.append(0x1); // TODO: msg type channel
        QRadioLink::Channel ch;
        ch.set_channel_id(_voip_channels->at(i)->id);
        ch.set_parent_id(_voip_channels->at(i)->parent_id);
        ch.set_name(_voip_channels->at(i)->name.toStdString().c_str());
        ch.set_description(_voip_channels->at(i)->description.toStdString().c_str());
        char bin[ch.ByteSize()];
        ch.SerializeToArray(bin,ch.ByteSize());
        data.append(bin, ch.ByteSize());
        data.append(0xAB);
        data.append(0x07);
        data.append(0x77);
        data.append(0xCF);
    }
    for(int i=0;i <_voip_users->size();i++)
    {
        data.append(0xCF);
        data.append(0x77);
        data.append(0x07);
        data.append(0xAB);
        data.append(0x2); // TODO: msg type user
        QRadioLink::User u;
        u.set_user_id(_voip_users->at(i).id);
        u.set_channel_id(_voip_users->at(i).channel_id);
        u.set_name(_voip_users->at(i).callsign.toStdString().c_str());
        char bin[u.ByteSize()];
        u.SerializeToArray(bin,u.ByteSize());
        data.append(bin, u.ByteSize());
        data.append(0xAB);
        data.append(0x07);
        data.append(0x77);
        data.append(0xCF);
    }
    return data;
}

void RadioProtocol::addChannel(Channel *chan)
{
    _voip_channels->push_back(chan);
}

void RadioProtocol::setStations(QVector<Station> list)
{
    delete _voip_users;
    _voip_users = new QVector<Station>(list);
}

void RadioProtocol::dataIn(QByteArray data)
{
    _buffer->append(data);
    QByteArray tail;
    tail.append(0xAB);
    tail.append(0x07);
    tail.append(0x77);
    tail.append(0xCF);
    QByteArray head;
    head.append(0xCF);
    head.append(0x77);
    head.append(0x07);
    head.append(0xAB);
    int t = _buffer->indexOf(tail);
    int h = _buffer->indexOf(head);
    if((t != -1) && (h != -1) && (t < h))
    {
        QByteArray payload = _buffer->left(t);
        QByteArray rest = _buffer->mid(t+4);
        processPayload(payload);
        _buffer->clear();
        dataIn(rest);
    }
    else if((t != -1) && (h == -1))
    {
        QByteArray payload = _buffer->left(t);
        processPayload(payload);
        QByteArray rest = _buffer->mid(t+4);
        _buffer->clear();
        _buffer->append(rest);
    }
    else if((t != -1) && (h != -1) && (t > h))
    {
        QByteArray rest = _buffer->mid(h+4);
        _buffer->clear();
        dataIn(rest);
    }
    else if((t == -1) && (h != -1))
    {
        QByteArray rest = _buffer->mid(h+4);
        _buffer->clear();
        _buffer->append(rest);
    }

}

void RadioProtocol::processPayload(QByteArray data)
{

    int msg_type = data.at(0);
    data = data.mid(1);
    switch(msg_type)
    {
    case 1:
    {
        QRadioLink::Channel ch;
        ch.ParseFromArray(data,data.size());
        Channel *chan = new Channel(ch.channel_id(),ch.parent_id(),QString::fromStdString(ch.name()),
                                    QString::fromStdString(ch.description()));
        //emit newChannel(chan);
        break;
    }
    case 2:
    {
        QRadioLink::User u;
        u.ParseFromArray(data,data.size());
        qDebug() << QString::fromStdString(u.name());
        break;
    }
    }
}