Copyright © 2018 Hasan Yavuz Özderya

void DataRecorder::feedIn(const SamplePack& data)

    Q_ASSERT(file.isOpen());    // recorder should be disconnected before stopping recording

    Q_ASSERT(!data.hasX());     // NYI

    // check if number of channels has changed during recording and warn

    unsigned numChannels = data.numChannels();

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

                   << " to " << numChannels <<

    lastNumChannels = numChannels;

    // write data

    unsigned numSamples = data.numSamples();

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

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

            fileStream << data.data(ci)[i];

            if (ci != numChannels-1) fileStream << _sep;

  Copyright © 2018 Hasan Yavuz Özderya

#include "sink.h"

/**

 * Implemented as a `Sink` that writes incoming data to a file. Before

 * connecting a `Source` recording must be started with the `startRecording`

 * method. Also before calling `stopRecording`, recorder should be disconnected

 * from source.

 */

class DataRecorder : public QObject, public Sink

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

     * calling this function recorder should be connected to a `Source`.

protected:

    virtual void feedIn(const SamplePack& data);

# test for recroder

add_executable(TestRecorder EXCLUDE_FROM_ALL

  test_recorder.cpp

  ../src/samplepack.cpp

  ../src/sink.cpp

  ../src/source.cpp

  ../src/datarecorder.cpp

)

qt5_use_modules(TestRecorder Widgets Test)

add_test(NAME test_recorder COMMAND TestRecorder)

add_dependencies(check

  Test

  TestReaders

  TestRecorder

  )

/*

  Copyright © 2018 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/>.

*/

#define CATCH_CONFIG_MAIN  // This tells Catch to provide a main() - only do this in one cpp file

#include "catch.hpp"

#include <QDir>

#include "datarecorder.h"

#include "test_helpers.h"

#define TEST_FILE_NAME   "sp_test_recording.csv"

TEST_CASE("test recording single channel", "[recorder]")

{

    DataRecorder rec;

    TestSource source(1, false);

    // temporary file, remove if exists

    auto fileName = QDir::tempPath() + QString("/" TEST_FILE_NAME);

    if (QFile::exists(fileName)) QFile::remove(fileName);

    // connect source → sink

    source.connectSink(&rec);

    // prepare data

    QStringList channelNames({"Channel 1"});

    SamplePack samples(5, 1);

    for (int i = 0; i < 5; i++)

    {

        samples.data(0)[i] = i+1;

    }

    // test

    rec.startRecording(fileName, ",", channelNames);

    source._feed(samples);

    rec.stopRecording();

    // read file contents back

    QFile recordFile(fileName);

    REQUIRE(recordFile.open(QIODevice::ReadOnly | QIODevice::Text));

    // NOTE: mind the extra parantheses, otherwise 'catch' macros fail to compile

    REQUIRE((recordFile.readLine() == "Channel 1\n"));

    for (int i = 0; i < 5; i++)

        REQUIRE((recordFile.readLine() == QString("%1\n").arg(i+1)));

    // cleanup

    if (QFile::exists(fileName)) QFile::remove(fileName);

}