LineReader.h

Go to the documentation of this file.

#ifndef LINE_READER_H
#define LINE_READER_H

#include <iostream>
#include <vector>
#include <boost/asio.hpp>

class LineReader {
public:
    // CTOR
    LineReader(boost::asio::io_service& io_service): m_InputStream(io_service, ::dup(STDIN_FILENO)), m_InputBuffer(4096), m_InputReader(&m_InputBuffer) {
        // Read single lines of input from STDIN
        do_read();
    }
    
    void SetOnInputLineCallback(std::function<void(const std::vector<unsigned char>)> a_OnInputLineCallback) {
        m_OnInputLineCallback = a_OnInputLineCallback;
    }
    
private:
    // Helpers
    void do_read() {
        boost::asio::async_read_until(m_InputStream, m_InputBuffer, '\n',[this](boost::system::error_code a_ErrorCode, size_t) {
            if (!a_ErrorCode) {
                // Obtain one line from the input buffer, parse the provided hex dump, and create a StreamFrame from it
                char l_InputLineBuffer[1000];
                m_InputReader.getline(l_InputLineBuffer,1000);
                std::istringstream l_InputStream(l_InputLineBuffer);
                l_InputStream >> std::hex;
                std::vector<unsigned char> l_Buffer;
                l_Buffer.reserve(65536);
                l_Buffer.insert(l_Buffer.end(),std::istream_iterator<unsigned int>(l_InputStream), {});
                if (m_OnInputLineCallback) {
                    m_OnInputLineCallback(std::move(l_Buffer));
                } // if
                
                // Read the next line
                do_read();
            } else {
                // Some error occured
                m_InputStream.close();
            } // else
        });
    }

    // Members
    std::function<void(const std::vector<unsigned char>)> m_OnInputLineCallback;
    boost::asio::posix::stream_descriptor m_InputStream;
    boost::asio::streambuf m_InputBuffer;
    std::istream m_InputReader;
};

#endif // LINE_READER_H