input.h

Go to the documentation of this file.

/*****************************************
 * This file is documented for Doxygen.
 * If you modify this file please update
 * the comments so that Doxygen will still
 * be able to work.
 ****************************************/
#ifndef INPUT_H
#define INPUT_H

#include <json.h>
#include <threadbaseclass.h>
#include <inputinterface.h>
#include <associatorinterface.h>
#include <gpickparser.h>
#include <jsonparser.h>
#include <ccparser.h>
#include <simplepickparser.h>
#include <queue.h>

#include <thread>
#include <mutex>
#include <future>
#include <string>
#include <sstream>
#include <iostream>
#include <fstream>
#include <vector>
#include <memory>

namespace glass3 {

namespace input {

#define GPICK_TYPE "gpick"
#define JSON_TYPE "json"
#define CC_TYPE "dat"
#define SIMPLE_TYPE "txt"


class Input : public glass3::util::iInput,
    public glass3::util::ThreadBaseClass {
 public:
    Input();

    explicit Input(std::shared_ptr<const json::Object> config);

    ~Input();

    bool setup(std::shared_ptr<const json::Object> config) override;

    void clear() override;

    std::shared_ptr<json::Object> getInputData() override;

    int getInputDataCount() override;

    void setInputDataMaxSize(int size);

    int getInputDataMaxSize();

 protected:
    glass3::util::WorkState work() override;

    virtual std::shared_ptr<json::Object> parse(std::string inputType,
                                                std::string inputMessage);

    virtual std::string fetchRawData(std::string* pOutType) = 0;

 private:
    std::atomic<int> m_QueueMaxSize;

    std::atomic<int> m_iReportInterval;

    int m_iParseCounter;

    std::time_t tLastWorkReport;

    glass3::util::Queue* m_DataQueue;

    glass3::parse::GPickParser * m_GPickParser;

    glass3::parse::JSONParser * m_JSONParser;

    glass3::parse::CCParser * m_CCParser;

    glass3::parse::SimplePickParser * m_SimplePickParser;
};
}  // namespace input
}  // namespace glass3
#endif  // INPUT_H