/*

  Copyright © 2017 Hasan Yavuz Özderya

  This file is part of serialplot.

  serialplot 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.

  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/>.

*/

#include "abstractreader.h"

AbstractReader::AbstractReader(QIODevice* device, ChannelManager* channelMan,

                               DataRecorder* recorder, QObject* parent) :

    QObject(parent)

{

    _device = device;

    _channelMan = channelMan;

    _recorder = recorder;

    recording = false;

    // initialize sps counter

    sampleCount = 0;

    samplesPerSecond = 0;

    QObject::connect(&spsTimer, &QTimer::timeout,

                     this, &AbstractReader::spsTimerTimeout);

    // TODO: start sps timer when reader is enabled

    spsTimer.start(SPS_UPDATE_TIMEOUT * 1000);

}

void AbstractReader::spsTimerTimeout()

{

    unsigned currentSps = samplesPerSecond;

    samplesPerSecond = (sampleCount/numOfChannels())/SPS_UPDATE_TIMEOUT;

    if (currentSps != samplesPerSecond)

    {

        emit samplesPerSecondChanged(samplesPerSecond);

    }

    sampleCount = 0;

}

void AbstractReader::addData(double* samples, unsigned length)

{

    _channelMan->addData(samples, length);

    if (recording)

    {

        _recorder->addData(samples, length, numOfChannels());

    }

    sampleCount += length;

}

/*

  Copyright © 2017 Hasan Yavuz Özderya

  This file is part of serialplot.

  serialplot 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.

  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/>.

*/

#include "datarecorder.h"

#include <QtDebug>

DataRecorder::DataRecorder(QObject *parent) :

    QObject(parent),

    fileStream(&file)

{

    lastNumChannels = 0;

}

bool DataRecorder::startRecording(QString fileName, QStringList channelNames)

{

    Q_ASSERT(!file.isOpen());

    // open file

    file.setFileName(fileName);

    if (!file.open(QIODevice::WriteOnly))

    {

        qCritical() << "Opening file " << fileName

                    << " for recording failed with error: " << file.error();

        return false;

    }

    // write header line

    if (!channelNames.isEmpty())

    {

        fileStream << channelNames.join(",");

        fileStream << "\n";

        lastNumChannels = channelNames.length();

    }

    return true;

}

void DataRecorder::addData(double* data, unsigned length, unsigned numOfChannels)

{

    Q_ASSERT(length > 0);

    Q_ASSERT(length % numOfChannels == 0);

    if (lastNumChannels != 0 && numOfChannels != lastNumChannels)

    {

        qWarning() << "Number of channels changed from " << lastNumChannels

                   << " to " << numOfChannels <<

            " during recording, CSV file is corrupted but no data will be lost.";

    }

    lastNumChannels = numOfChannels;

    unsigned numOfSamples = length / numOfChannels; // per channel

    for (unsigned int i = 0; i < numOfSamples; i++)

    {

        for (unsigned ci = 0; ci < numOfChannels; ci++)

        {

            fileStream << data[ci * numOfSamples + i];

            if (ci != numOfChannels-1) fileStream << ",";

        }

        fileStream << '\n';

    }

}

void DataRecorder::stopRecording()

{

    Q_ASSERT(file.isOpen());

    file.close();

    lastNumChannels = 0;

}

/*

  Copyright © 2017 Hasan Yavuz Özderya

  This file is part of serialplot.

  serialplot 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.

  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 DATARECORDER_H

#define DATARECORDER_H

#include <QObject>

#include <QFile>

#include <QTextStream>

class DataRecorder : public QObject

{

    Q_OBJECT

public:

    explicit DataRecorder(QObject *parent = 0);

    /**

     * @brief Starts recording data to a file in CSV format.

     *

     * File is opened and header line (names of channels) is written.

     *

     * @param fileName name of the recording file

     * @param channelNames names of the channels for header line, if empty no header line is written

     * @return false if file operation fails (read only etc.)

     */

    bool startRecording(QString fileName, QStringList channelNames);

    /**

     * @brief Adds data to a channel.

     *

     * Multiple rows of data can be added at a time. Each channels

     * data should be ordered consecutively in the `data` array:

     *

     * [CH0_SMP0, CH0_SMP1 ... CH0_SMPN, CH1_SMP0, CH1_SMP1, ... , CHN_SMPN]

     *

     * If `numOfChannels` changes during recording, no data will be

     * lost (ie. it will be written to the file) but this will produce

     * an invalid CSV file. An error message will be written to the

     * console.

     *

     * @param data samples array

     * @param length number of samples in `data`, must be multiple of `numOfChannels`

     * @param numOfChannels how many channels samples this data carries

     */

    void addData(double* data, unsigned length, unsigned numOfChannels);

    /// Stops recording, closes file.

    void stopRecording();

private:

    unsigned lastNumChannels;   ///< used for error message only

    QFile file;

    QTextStream fileStream;

};

#endif // DATARECORDER_H

/*

  Copyright © 2017 Hasan Yavuz Özderya

  This file is part of serialplot.

  serialplot 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.

  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/>.

*/

#include "recordpanel.h"

#include "ui_recordpanel.h"

#include <QIcon>

#include <QFile>

#include <QFileInfo>

#include <QMessageBox>

#include <QFileDialog>

#include <QRegularExpression>

#include <QtDebug>

RecordPanel::RecordPanel(DataRecorder* recorder, QWidget *parent) :

    QWidget(parent),

    ui(new Ui::RecordPanel),

    recordToolBar(tr("Record Toolbar")),

    recordAction(QIcon::fromTheme("media-record"), tr("Record"), this)

{

    overwriteSelected = false;

    _recorder = recorder;

    ui->setupUi(this);

    recordToolBar.setObjectName("tbRecord");

    recordAction.setCheckable(true);

    recordToolBar.addAction(&recordAction);

    ui->pbRecord->setDefaultAction(&recordAction);

    connect(ui->pbBrowse, &QPushButton::clicked,

            this, &RecordPanel::selectFile);

    connect(&recordAction, &QAction::triggered,

            this, &RecordPanel::onRecord);

    connect(ui->cbRecordPaused, SIGNAL(toggled(bool)),

            this, SIGNAL(recordPausedChanged(bool)));

}

RecordPanel::~RecordPanel()

{

    delete ui;

}

QToolBar* RecordPanel::toolbar()

{

    return &recordToolBar;

}

bool RecordPanel::isRecording()

{

    return recordAction.isChecked();

}

bool RecordPanel::recordPaused()

{

    return ui->cbRecordPaused->isChecked();

}

bool RecordPanel::selectFile()

{

    QString fileName = QFileDialog::getSaveFileName(

        parentWidget(), tr("Select recording file"));

    if (fileName.isEmpty())

    {

        return false;

    }

    else

    {

        selectedFile = fileName;

        ui->lbFileName->setText(selectedFile);

        overwriteSelected = QFile::exists(fileName);

        return true;

    }

}

void RecordPanel::onRecord(bool start)

{

    if (!start)

    {

        stopRecording();

        return;

    }

    // check file name

    bool canceled = false;

    if (selectedFile.isEmpty() && !selectFile())

    {

        canceled = true;

    }

    if (!overwriteSelected && QFile::exists(selectedFile))

    {

        if (ui->cbAutoIncrement->isChecked())

        {

            // TODO: should we increment even if user selected to replace?

            canceled = !incrementFileName();

        }

        else

        {

            canceled = !confirmOverwrite(selectedFile);

        }

    }

    overwriteSelected = false;

    if (canceled)

    {

        recordAction.setChecked(false);

    }

    else

    {

        startRecording();

    }

}

bool RecordPanel::incrementFileName(void)

{

    QFileInfo fileInfo(selectedFile);

    QString base = fileInfo.completeBaseName();

    QRegularExpression regex("(.*?)(\\d+)(?!.*\\d)(.*)");

    auto match = regex.match(base);

    if (match.hasMatch())

    {

        bool ok;

        int fileNum = match.captured(2).toInt(&ok);

        base = match.captured(1) + QString::number(fileNum + 1) + match.captured(3);

    }

    else

    {

        base += "_1";

    }

    QString suffix = fileInfo.suffix();;

    if (!suffix.isEmpty())

    {

        suffix = "." + suffix;

    }

    QString autoFileName = fileInfo.path() + "/" + base + suffix;

    // check if auto generated file name exists, ask user another name

    if (QFile::exists(autoFileName))

    {

        if (!confirmOverwrite(autoFileName))

        {

            return false;

        }

    }

    else

    {

        selectedFile = autoFileName;

    }

    ui->lbFileName->setText(selectedFile);

    return true;

}

bool RecordPanel::confirmOverwrite(QString fileName)

{

    // prepare message box

    QMessageBox mb(parentWidget());

    mb.setWindowTitle(tr("File Already Exists"));

    mb.setIcon(QMessageBox::Warning);

    mb.setText(tr("File (%1) already exists. How to continue?").arg(fileName));

    auto bCancel    = mb.addButton(QMessageBox::Cancel);

    auto bOverwrite = mb.addButton(tr("Overwrite"), QMessageBox::DestructiveRole);

    mb.addButton(tr("Select Another File"), QMessageBox::YesRole);

    mb.setEscapeButton(bCancel);

    // show message box

    mb.exec();

    if (mb.clickedButton() == bCancel)

    {

        return false;

    }

    else if (mb.clickedButton() == bOverwrite)

    {

        selectedFile = fileName;

        return true;

    }

    else                    // select button

    {

        return selectFile();

    }

}

void RecordPanel::startRecording(void)

{

    qDebug() << "start recording";

    // TEST CODE

    QStringList cn;

    // cn << "chan0" << "chan1" << "chan2";

    _recorder->startRecording(selectedFile, cn);

    // add test data

    // double data[3] = {15., 15., 15.};

    // _recorder.addData(data, 3, 3);

    emit recordStarted();

}

void RecordPanel::stopRecording(void)

{

    emit recordStopped();

    _recorder->stopRecording();

}

<?xml version="1.0" encoding="UTF-8"?>

<ui version="4.0">

 <class>RecordPanel</class>

 <widget class="QWidget" name="RecordPanel">

  <property name="geometry">

   <rect>

    <x>0</x>

    <y>0</y>

    <width>532</width>

    <height>152</height>

   </rect>

  </property>

  <property name="windowTitle">

   <string>Form</string>

  </property>

  <layout class="QHBoxLayout" name="horizontalLayout_2">

   <item>

    <layout class="QVBoxLayout" name="verticalLayout">

     <item>

      <layout class="QHBoxLayout" name="horizontalLayout">

       <item>

        <widget class="QPushButton" name="pbBrowse">

         <property name="toolTip">

          <string>Select record file</string>

         </property>

         <property name="text">

          <string>Browse</string>

         </property>

        </widget>

       </item>

       <item>

        <widget class="QLabel" name="lbFileName">

         <property name="sizePolicy">

          <sizepolicy hsizetype="MinimumExpanding" vsizetype="Preferred">

           <horstretch>0</horstretch>

           <verstretch>0</verstretch>

          </sizepolicy>

         </property>

         <property name="text">

          <string>Select file...</string>

         </property>

        </widget>

       </item>

      </layout>

     </item>

     <item>

      <widget class="QCheckBox" name="cbRecordPaused">

       <property name="toolTip">

        <string>Continue recording to file even when plotting is paused</string>

       </property>

       <property name="text">

        <string>Record while paused</string>

       </property>

       <property name="checked">

        <bool>true</bool>

       </property>

      </widget>

     </item>

     <item>

      <widget class="QCheckBox" name="cbAutoIncrement">

       <property name="toolTip">

        <string>Increments file name automatically everytime a new recording starts</string>

       </property>

       <property name="text">

        <string>Auto increment file name</string>

       </property>

       <property name="checked">

        <bool>true</bool>

       </property>

      </widget>

     </item>

     <item>

      <widget class="QCheckBox" name="cpStopOnClose">

       <property name="text">

        <string>Stop recording when port closed</string>

       </property>

       <property name="checked">

        <bool>true</bool>

       </property>

      </widget>

     </item>

     <item>

      <spacer name="verticalSpacer">

       <property name="orientation">

        <enum>Qt::Vertical</enum>

       </property>

       <property name="sizeHint" stdset="0">

        <size>

         <width>20</width>

         <height>40</height>

        </size>

       </property>

      </spacer>

     </item>

    </layout>

   </item>

   <item>

    <layout class="QVBoxLayout" name="verticalLayout_2">

     <item>

      <widget class="QToolButton" name="pbRecord">

       <property name="minimumSize">

        <size>

         <width>85</width>

         <height>50</height>

        </size>

       </property>

       <property name="toolTip">

        <string>Start/Stop Recording</string>

       </property>

       <property name="text">

        <string>Record</string>

       </property>

      </widget>

     </item>

     <item>

      <spacer name="verticalSpacer_2">

       <property name="orientation">

        <enum>Qt::Vertical</enum>

       </property>

       <property name="sizeHint" stdset="0">

        <size>

         <width>20</width>

         <height>40</height>

        </size>

       </property>

      </spacer>

     </item>

    </layout>

   </item>

  </layout>

 </widget>

 <resources/>

 <connections/>

</ui>