#include "abstractreader.h"

AbstractReader::AbstractReader(QIODevice* device, QObject* parent) :

    QObject(parent)

{

    _device = device;

}

void AbstractReader::pause(bool enabled)

{

    paused = enabled;

}

unsigned AbstractReader::numChannels() const

{

    // TODO: an alternative is to never set _numChannels to '0'

    // do not allow '0'

    return _numChannels == 0 ? 1 : _numChannels;

}

void AbstractReader::enable(bool enabled)

{

    if (enabled)

    {

        QObject::connect(_device, &QIODevice::readyRead,

                         this, &AbstractReader::onDataReady);

    }

    else

    {

        QObject::disconnect(_device, 0, this, 0);

        disconnectSinks();

    }

}

#include <QObject>

#include <QIODevice>

#include <QWidget>

#include <QTimer>

#include "source.h"

/**

 * All reader classes must inherit this class.

 */

class AbstractReader : public QObject, public Source

{

    Q_OBJECT

public:

    explicit AbstractReader(QIODevice* device, QObject* parent = 0);

    /**

     * Returns a widget to be shown in data format panel when reader

     * is selected.

     */

    virtual QWidget* settingsWidget() = 0;

    /// Reader should only read when enabled. Default state should be

    /// 'disabled'.

    /// None of the current readers support X channel at the moment

    bool hasX() const final { return false; };

    unsigned numChannels() const;

signals:

    // TODO: should we keep this?

    void numOfChannelsChanged(unsigned);

public slots:

    /**

     * Pauses the reading.

     *

     * Reader should actually continue reading to keep the

     * synchronization but shouldn't commit data.

     */

    void pause(bool enabled);

protected:

    QIODevice* _device;

    bool paused;

    unsigned _numChannels;

protected slots:

    /// all derived readers has to override this function

    virtual void onDataReady() = 0;

};

#endif // ABSTRACTREADER_H

            [this](unsigned value)

            {

                _numChannels = value;

                updateNumChannels(); // TODO: setting numchannels = 0, should remove all buffers

                                     // do we want this?

                autoNumOfChannels = (_numChannels == NUMOFCHANNELS_AUTO);

                if (!autoNumOfChannels)

                {

                    emit numOfChannelsChanged(value);

                }

            });

    connect(&_settingsWidget, &AsciiReaderSettings::delimiterChanged,

            [this](QChar d)

            {

                delimiter = d;

            });

}

QWidget* AsciiReader::settingsWidget()

{

    return &_settingsWidget;

}

void AsciiReader::onDataReady()

{

    while(_device->canReadLine())

    {

        QString line = QString(_device->readLine());

        // discard only once when we just started reading

        if (firstReadAfterEnable)

        {

            firstReadAfterEnable = false;

            continue;

        }

        // discard data if paused

        if (paused)

        {

            continue;

        }

        // parse data

        line = line.trimmed();

        // Note: When data coming from pseudo terminal is buffered by

        // system CR is converted to LF for some reason. This causes

  serialplot 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 serialplot.  If not, see <http://www.gnu.org/licenses/>.

*/

#ifndef ASCIIREADER_H

#define ASCIIREADER_H

#include <QSettings>

#include "abstractreader.h"

#include "asciireadersettings.h"

class AsciiReader : public AbstractReader

{

    Q_OBJECT

public:

    explicit AsciiReader(QIODevice* device, QObject *parent = 0);

    QWidget* settingsWidget();

    /// Stores settings into a `QSettings`

    void saveSettings(QSettings* settings);

    /// Loads settings from a `QSettings`.

    void loadSettings(QSettings* settings);

private:

    AsciiReaderSettings _settingsWidget;

    /// number of channels will be determined from incoming data

    unsigned autoNumOfChannels;

    QChar delimiter; ///< selected column delimiter

private slots:

    void onDataReady() override;

};

#endif // ASCIIREADER_H