project(serialplot)

set(PROGRAM_NAME ${CMAKE_PROJECT_NAME} CACHE STRING "Output program name")

set(PROGRAM_DISPLAY_NAME "SerialPlot" CACHE STRING "Display name (menus etc) of the program")

# Find includes in corresponding build directories

set(CMAKE_INCLUDE_CURRENT_DIR ON)

# Instruct CMake to run moc automatically when needed.

set(CMAKE_AUTOMOC ON)

# add local path for cmake modules

set(CMAKE_MODULE_PATH ${CMAKE_MODULE_PATH} "${CMAKE_SOURCE_DIR}/cmake/modules/")

# Find the QtWidgets library

find_package(Qt5Widgets)

# If set, cmake will download Qwt over SVN, build and use it as a static library.

set(BUILD_QWT true CACHE BOOL "Download and build Qwt automatically.")

# Find QWT or use static manually provided by user

set(QWT_USE_STATIC false CACHE BOOL "Use a static version of Qwt provided by user.")

set(QWT_STATIC_LIBRARY "" CACHE FILEPATH "Path to the static Qwt library, libqwt.a.")

set(QWT_STATIC_INCLUDE "" CACHE PATH "Path to the Qwt include directory when building Qwt static.")

if (BUILD_QWT)

  include(BuildQwt)

else (BUILD_QWT)

  if (QWT_USE_STATIC)

	set(QWT_LIBRARY ${QWT_STATIC_LIBRARY})

	set(QWT_INCLUDE_DIR ${QWT_STATIC_INCLUDE})

  else (QWT_USE_STATIC)

	find_package(Qwt 6.1 REQUIRED)

  endif (QWT_USE_STATIC)

endif (BUILD_QWT)

# includes

include_directories("./src" ${QWT_INCLUDE_DIR})

# wrap UI and resource files

qt5_wrap_ui(UI_FILES

  src/mainwindow.ui

  src/portcontrol.ui

  src/about_dialog.ui

  src/snapshotview.ui

  src/commandpanel.ui

  src/commandwidget.ui

  src/dataformatpanel.ui

  src/plotcontrolpanel.ui

  src/numberformatbox.ui

  src/endiannessbox.ui

  src/binarystreamreadersettings.ui

  src/asciireadersettings.ui

  src/framedreadersettings.ui

  )

if (WIN32)

  qt5_add_resources(RES_FILES misc/icons.qrc misc/winicons.qrc)

else (WIN32)

  qt5_add_resources(RES_FILES misc/icons.qrc)

endif (WIN32)

add_executable(${PROGRAM_NAME} WIN32

  src/main.cpp

  src/mainwindow.cpp

  src/portcontrol.cpp

  src/plot.cpp

  src/zoomer.cpp

  src/hidabletabwidget.cpp

  src/framebuffer.cpp

  src/scalepicker.cpp

  src/scalezoomer.cpp

  src/portlist.cpp

  src/snapshot.cpp

  src/snapshotview.cpp

  src/snapshotmanager.cpp

  src/plotsnapshotoverlay.cpp

  src/commandpanel.cpp

  src/commandwidget.cpp

  src/commandedit.cpp

  src/dataformatpanel.cpp

  src/plotcontrolpanel.cpp

  src/tooltipfilter.cpp

  src/sneakylineedit.cpp

  src/channelmanager.cpp

  src/framebufferseries.cpp

  src/numberformatbox.cpp

  src/endiannessbox.cpp

  src/abstractreader.cpp

  src/binarystreamreader.cpp

  src/binarystreamreadersettings.cpp

  src/asciireader.cpp

  src/asciireadersettings.cpp

  src/demoreader.cpp

  src/framedreader.cpp

  src/framedreadersettings.cpp

  src/plotmanager.cpp

  misc/windows_icon.rc

  ${UI_FILES}

  ${RES_FILES}

  )

# Use the Widgets module from Qt 5.

target_link_libraries(${PROGRAM_NAME} ${QWT_LIBRARY})

qt5_use_modules(${PROGRAM_NAME} Widgets SerialPort Svg)

if (BUILD_QWT)

  add_dependencies(${PROGRAM_NAME} QWT)

endif (BUILD_QWT)

# set compiler flags

set(CMAKE_CXX_FLAGS "${CMAKE_CXX_FLAGS} -Wall")

# Enable C++11 support, fail if not supported

include(CheckCXXCompilerFlag)

CHECK_CXX_COMPILER_FLAG("-std=c++11" COMPILER_SUPPORTS_CXX11)

CHECK_CXX_COMPILER_FLAG("-std=c++0x" COMPILER_SUPPORTS_CXX0X)

if(COMPILER_SUPPORTS_CXX11)

  set(CMAKE_CXX_FLAGS "${CMAKE_CXX_FLAGS} -std=c++11")

elseif(COMPILER_SUPPORTS_CXX0X)

  set(CMAKE_CXX_FLAGS "${CMAKE_CXX_FLAGS} -std=c++0x")

else()

  message(STATUS "The compiler ${CMAKE_CXX_COMPILER} has no C++11 support. Please use a different C++ compiler.")

endif()

# version number

set(MAJOR_VERSION 0 CACHE INT "Program major version number.")

set(MINOR_VERSION 7 CACHE INT "Program minor version number.")

set(PATCH_VERSION 1 CACHE INT "Program patch version number.")

set(VERSION_STRING "${MAJOR_VERSION}.${MINOR_VERSION}.${PATCH_VERSION}")

# get revision number from mercurial

find_program(MERCURIAL hg)

if (MERCURIAL)

  execute_process(COMMAND ${MERCURIAL} id -i

    WORKING_DIRECTORY ${CMAKE_CURRENT_SOURCE_DIR}

    RESULT_VARIABLE MERCURIAL_RESULT

    OUTPUT_VARIABLE VERSION_REVISION

    OUTPUT_STRIP_TRAILING_WHITESPACE)

  if(NOT MERCURIAL_RESULT EQUAL 0)

    set(VERSION_SCM_REVISION false)

  endif(NOT MERCURIAL_RESULT EQUAL 0)

endif (MERCURIAL)

if (NOT VERSION_REVISION)

  set(VERSION_REVISION "0")

endif (NOT VERSION_REVISION)

message("SCM revision: ${VERSION_REVISION}")

# configure version file

configure_file("${CMAKE_CURRENT_SOURCE_DIR}/src/version.h.in" "${CMAKE_CURRENT_BINARY_DIR}/version.h")

# add make run target

add_custom_target(run

    COMMAND ${PROGRAM_NAME}

    DEPENDS ${PROGRAM_NAME}

    WORKING_DIRECTORY ${CMAKE_PROJECT_DIR}

)

# installing

install(TARGETS ${PROGRAM_NAME} DESTINATION bin)

# for windows put libraries to install directory

if (WIN32)

  file(GLOB WINDOWS_INSTALL_LIBRARIES

    "${CMAKE_BINARY_DIR}/windows_install_libraries/*.*")

  install(FILES ${WINDOWS_INSTALL_LIBRARIES} DESTINATION bin)

endif (WIN32)

# install menu item and icon

configure_file("${CMAKE_CURRENT_SOURCE_DIR}/misc/program_name.desktop.in"

  "${CMAKE_BINARY_DIR}/${PROGRAM_NAME}.desktop")

configure_file("${CMAKE_CURRENT_SOURCE_DIR}/misc/program_name.png"

  "${CMAKE_BINARY_DIR}/${PROGRAM_NAME}.png" COPYONLY)

if (UNIX)

  # first copy files to share/serialplot/

  install(FILES

    ${CMAKE_BINARY_DIR}/${PROGRAM_NAME}.desktop

    DESTINATION share/applications/)

  install(FILES

    ${CMAKE_BINARY_DIR}/${PROGRAM_NAME}.png

	DESTINATION share/icons/hicolor/256x256/apps/)

endif (UNIX)

# uninstalling

configure_file(

  "${CMAKE_CURRENT_SOURCE_DIR}/cmake/cmake_uninstall.cmake.in"

  "${CMAKE_CURRENT_BINARY_DIR}/cmake_uninstall.cmake"

  @ONLY)

#

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

#

#-------------------------------------------------

#

# Project created by QtCreator 2015-03-04T08:20:06

#

#-------------------------------------------------

QT       += core gui serialport

greaterThan(QT_MAJOR_VERSION, 4): QT += widgets

TARGET = serialplot

TEMPLATE = app

CONFIG += qwt

SOURCES += \

    src/main.cpp\

    src/mainwindow.cpp \

    src/portcontrol.cpp \

    src/plot.cpp \

    src/zoomer.cpp \

    src/hidabletabwidget.cpp \

    src/framebuffer.cpp \

    src/scalepicker.cpp \

    src/scalezoomer.cpp \

    src/portlist.cpp \

    src/snapshotview.cpp \

    src/snapshotmanager.cpp \

    src/snapshot.cpp \

    src/plotsnapshotoverlay.cpp \

    src/commandpanel.cpp \

    src/commandwidget.cpp \

    src/commandedit.cpp \

    src/dataformatpanel.cpp \

    src/tooltipfilter.cpp \

    src/sneakylineedit.cpp \

    src/channelmanager.cpp \

    src/framebufferseries.cpp \

    src/plotcontrolpanel.cpp \

    src/numberformatbox.cpp \

    src/endiannessbox.cpp \

    src/framedreadersettings.cpp \

    src/abstractreader.cpp \

    src/binarystreamreader.cpp \

    src/binarystreamreadersettings.cpp \

    src/asciireadersettings.cpp \

    src/asciireader.cpp \

    src/demoreader.cpp \

    src/framedreader.cpp \

HEADERS += \

    src/mainwindow.h \

    src/utils.h \

    src/portcontrol.h \

    src/floatswap.h \

    src/plot.h \

    src/zoomer.h \

    src/hidabletabwidget.h \

    src/framebuffer.h \

    src/scalepicker.h \

    src/scalezoomer.h \

    src/portlist.h \

    src/snapshotview.h \

    src/snapshotmanager.h \

    src/snapshot.h \

    src/plotsnapshotoverlay.h \

    src/commandpanel.h \

    src/commandwidget.h \

    src/commandedit.h \

    src/dataformatpanel.h \

    src/tooltipfilter.h \

    src/sneakylineedit.h \

    src/channelmanager.h \

    src/framebufferseries.h \

    src/plotcontrolpanel.h \

    src/numberformatbox.h \

    src/endiannessbox.h \

    src/framedreadersettings.h \

    src/abstractreader.h \

    src/binarystreamreader.h \

    src/binarystreamreadersettings.h \

    src/asciireadersettings.h \

    src/asciireader.h \

    src/demoreader.h \

    src/framedreader.h \

FORMS += \

    src/mainwindow.ui \

    src/about_dialog.ui \

    src/portcontrol.ui \

    src/snapshotview.ui \

    src/commandpanel.ui \

    src/commandwidget.ui \

    src/dataformatpanel.ui \

    src/plotcontrolpanel.ui \

    src/numberformatbox.ui \

    src/endiannessbox.ui \

    src/framedreadersettings.ui \

    src/binarystreamreadersettings.ui \

    src/asciireadersettings.ui

INCLUDEPATH += qmake/ src/

CONFIG += c++11

RESOURCES += misc/icons.qrc

win32 {

    RESOURCES += misc/winicons.qrc

}

    }

}

// TODO: this could be a part of AbstractReader

void AsciiReader::enable(bool enabled)

{

    if (enabled)

    {

        discardFirstLine = true;

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

                         this, &AsciiReader::onDataReady);

    }

    else

    {

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

    }

}

void AsciiReader::pause(bool enabled)

{

    paused = enabled;

}

void AsciiReader::onDataReady()

{

    while(_device->canReadLine())

    {

        QByteArray line = _device->readLine();

        // discard only once when we just started reading

        if (discardFirstLine)

        {

            discardFirstLine = 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

        // empty lines in the input when the port is just opened.

        if (line.isEmpty())

        {

            continue;

        }

        auto separatedValues = line.split(',');

        unsigned numReadChannels; // effective number of channels to read

        unsigned numComingChannels = separatedValues.length();

        if (autoNumOfChannels)

        {

            // did number of channels changed?

            if (numComingChannels != _numOfChannels)

            {

                _numOfChannels = numComingChannels;

                emit numOfChannelsChanged(numComingChannels);

            }

            numReadChannels = numComingChannels;

        }

        else if (numComingChannels >= _numOfChannels)

        {

            numReadChannels = _numOfChannels;

        }

        else // there is missing channel data

        {

            numReadChannels = separatedValues.length();

            qWarning() << "Incoming data is missing data for some channels!";

        }

        // parse read line

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

        {

            bool ok;

            double channelSample = separatedValues[ci].toDouble(&ok);

            if (ok)

            {

                _channelMan->addChannelData(ci, &channelSample, 1);

                sampleCount++;

            }

            else

            {

                qWarning() << "Data parsing error for channel: " << ci;

            }

        }

        emit dataAdded();

    }

}

/*

  Copyright © 2016 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 ASCIIREADER_H

#define ASCIIREADER_H

#include "abstractreader.h"

#include "asciireadersettings.h"

class AsciiReader : public AbstractReader

{

    Q_OBJECT

public:

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

    QWidget* settingsWidget();

    unsigned numOfChannels();

    void enable(bool enabled = true);

public slots:

    void pause(bool);

private:

    AsciiReaderSettings _settingsWidget;

    unsigned _numOfChannels;

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

    unsigned autoNumOfChannels;

    bool paused;

    // We may have (usually true) started reading in the middle of a

    // line, so its a better idea to just discard first line.

    bool discardFirstLine;

private slots:

    void onDataReady();

};

#endif // ASCIIREADER_H

/*

  Copyright © 2016 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 "utils.h"

#include "asciireadersettings.h"

#include "ui_asciireadersettings.h"

AsciiReaderSettings::AsciiReaderSettings(QWidget *parent) :

    QWidget(parent),

    ui(new Ui::AsciiReaderSettings)

{

    ui->setupUi(this);

    // Note: if directly connected we get a runtime warning on incompatible signal arguments

    connect(ui->spNumOfChannels, SELECT<int>::OVERLOAD_OF(&QSpinBox::valueChanged),

            [this](int value)

            {

                emit numOfChannelsChanged(value);

            });

}

AsciiReaderSettings::~AsciiReaderSettings()

{

    delete ui;

}

unsigned AsciiReaderSettings::numOfChannels()

{

    return ui->spNumOfChannels->value();

}

/*

  Copyright © 2016 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 ASCIIREADERSETTINGS_H

#define ASCIIREADERSETTINGS_H

#include <QWidget>

namespace Ui {

class AsciiReaderSettings;

}

class AsciiReaderSettings : public QWidget

{

    Q_OBJECT

public:

    explicit AsciiReaderSettings(QWidget *parent = 0);

    ~AsciiReaderSettings();

    unsigned numOfChannels();

signals:

    void numOfChannelsChanged(unsigned);

private:

    Ui::AsciiReaderSettings *ui;

};

#endif // ASCIIREADERSETTINGS_H

#include "binarystreamreader.h"

#include "floatswap.h"

BinaryStreamReader::BinaryStreamReader(QIODevice* device, ChannelManager* channelMan, QObject *parent) :

    AbstractReader(device, channelMan, parent)

{

    paused = false;

    skipByteRequested = false;

    skipSampleRequested = false;

    sampleCount = 0;

    _numOfChannels = _settingsWidget.numOfChannels();

    connect(&_settingsWidget, &BinaryStreamReaderSettings::numOfChannelsChanged,

            this, &BinaryStreamReader::numOfChannelsChanged);

    connect(&_settingsWidget, &BinaryStreamReaderSettings::numOfChannelsChanged,

            this, &BinaryStreamReader::onNumOfChannelsChanged);

    // initial number format selection

    onNumberFormatChanged(_settingsWidget.numberFormat());

    connect(&_settingsWidget, &BinaryStreamReaderSettings::numberFormatChanged,

            this, &BinaryStreamReader::onNumberFormatChanged);

    // enable skip byte and sample buttons

    connect(&_settingsWidget, &BinaryStreamReaderSettings::skipByteRequested,

            [this]()

            {

                skipByteRequested = true;

            });

    connect(&_settingsWidget, &BinaryStreamReaderSettings::skipSampleRequested,

            [this]()

            {

                skipSampleRequested = true;

            });

}

QWidget* BinaryStreamReader::settingsWidget()

{

    return &_settingsWidget;

}

unsigned BinaryStreamReader::numOfChannels()

{

    return _numOfChannels;

}

void BinaryStreamReader::enable(bool enabled)

{

    if (enabled)

    {

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

                         this, &BinaryStreamReader::onDataReady);

    }

    else

    {

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

    }

}

void BinaryStreamReader::pause(bool enabled)

{

    paused = enabled;

}

void BinaryStreamReader::onNumberFormatChanged(NumberFormat numberFormat)

{

    switch(numberFormat)

    {

        case NumberFormat_uint8:

            sampleSize = 1;

            readSample = &BinaryStreamReader::readSampleAs<quint8>;

            break;

        case NumberFormat_int8:

            sampleSize = 1;

            readSample = &BinaryStreamReader::readSampleAs<qint8>;

            break;

        case NumberFormat_uint16:

            sampleSize = 2;

            readSample = &BinaryStreamReader::readSampleAs<quint16>;

            break;

        case NumberFormat_int16:

            sampleSize = 2;

            readSample = &BinaryStreamReader::readSampleAs<qint16>;

            break;

        case NumberFormat_uint32:

            sampleSize = 4;

            readSample = &BinaryStreamReader::readSampleAs<quint32>;

            break;

        case NumberFormat_int32:

            sampleSize = 4;

            readSample = &BinaryStreamReader::readSampleAs<qint32>;

            break;

        case NumberFormat_float:

            sampleSize = 4;

            readSample = &BinaryStreamReader::readSampleAs<float>;

            break;

    }

}

void BinaryStreamReader::onNumOfChannelsChanged(unsigned value)

{

    _numOfChannels = value;

}

void BinaryStreamReader::onDataReady()

{

    // a package is a set of channel data like {CHAN0_SAMPLE, CHAN1_SAMPLE...}

    int packageSize = sampleSize * _numOfChannels;

    int bytesAvailable = _device->bytesAvailable();

    // skip 1 byte if requested

    if (bytesAvailable > 0 && skipByteRequested)

    {

        _device->read(1);

        skipByteRequested = false;

        bytesAvailable--;

    }

    // skip 1 sample (channel) if requested

    if (bytesAvailable >= (int) sampleSize && skipSampleRequested)

    {

        _device->read(sampleSize);

        skipSampleRequested = false;

        bytesAvailable--;

    }

    if (bytesAvailable < packageSize) return;

    int numOfPackagesToRead =

        (bytesAvailable - (bytesAvailable % packageSize)) / packageSize;

    if (paused)

    {

        // read and discard data

        _device->read(numOfPackagesToRead*packageSize);

        return;

    }

    double* channelSamples = new double[numOfPackagesToRead*_numOfChannels];

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

    {

        for (unsigned int ci = 0; ci < _numOfChannels; ci++)

        {

            // channelSamples[ci].replace(i, (this->*readSample)());

            channelSamples[ci*numOfPackagesToRead+i] = (this->*readSample)();

        }

    }

    for (unsigned int ci = 0; ci < _numOfChannels; ci++)

    {

        addChannelData(ci,

                       channelSamples + ci*numOfPackagesToRead,

                       numOfPackagesToRead);

    }

    emit dataAdded();

    delete channelSamples;

}

template<typename T> double BinaryStreamReader::readSampleAs()

{

    T data;

    _device->read((char*) &data, sizeof(data));

    if (_settingsWidget.endianness() == LittleEndian)

    {

        data = qFromLittleEndian(data);

    }

    else

    {

        data = qFromBigEndian(data);

    }

    return double(data);

}

void BinaryStreamReader::addChannelData(unsigned int channel,

                                        double* data, unsigned size)

{

    _channelMan->addChannelData(channel, data, size);

    sampleCount += size;

}