SerialAPI.h

/****************************************************************/
// By Bill Hsu
// Shanghai University
// My Blog:        http://BillHsu.me
// jUART Project:  http://github.com/billhsu/jUART
// Created on:     2013-01-09
/****************************************************************/

#ifndef H_SerialAPI
#define H_SerialAPI
#include <boost/bind.hpp> 
#include <boost/asio.hpp>
#include <boost/asio/serial_port.hpp>
#include <boost/thread.hpp> 
#include <deque>
#include <boost/lexical_cast.hpp> 
#include <boost/date_time/posix_time/posix_time_types.hpp>
#include "JSAPIAuto.h"
#include "BrowserHost.h"


class SerialAPI: public FB::JSAPIAuto
{
public:
    SerialAPI(const FB::BrowserHostPtr& host);
    ~SerialAPI(void);

    // Open serial device. e.g. "COM1" in Windows or "/dev/ttyS0" in Linux
    bool open(std::string _device);

    ///////////////////////////////////////////////////////////////////////////////
    /// @fn Serial::set_option()
    ///
    /// @brief  Set serial port opinions
    ///         parity:     0->none, 1->odd, 2->even
    ///         csize:      5 6 7 8
    ///         flow:       0->none, 1->software, 2->hardware
    ///         stop:       0->one,  1->onepointfive, 2->two
    ///////////////////////////////////////////////////////////////////////////////
    bool set_option(unsigned int baud, unsigned int parity = 0,
        unsigned int csize = 8, unsigned int flow = 0, unsigned int stop = 0);

    // Send a byte to serial port
    void send(const char msg)
    {
        io.post(boost::bind(&SerialAPI::do_send, this, msg)); 
    }
    bool sendtest()
    {
        io.post(boost::bind(&SerialAPI::do_send, this, 'a'));
        return true;
    }
    bool is_open()
    {
        return serial.is_open();
    }

    void close()
    {
        io.post(boost::bind(&SerialAPI::do_close, this, boost::system::error_code()));
        m_thread.join();
        io.reset();
    }

    void recv_callback(const FB::JSObjectPtr& callback);
    void err_callback(const FB::JSObjectPtr& callback);



private:
    boost::asio::io_service io;
    boost::asio::serial_port serial;

    std::string device;
    static const int max_buffer_length = 512;

    char recv_msg[max_buffer_length];
    std::deque<char> send_msg;

    FB::BrowserHostPtr m_host;
    FB::JSObjectPtr m_recv_callback;
    FB::JSObjectPtr m_err_callback;

    boost::thread m_thread;

    void recv_start(void);
    void recv_complete(const boost::system::error_code& error, size_t bytes_transferred);

    void do_send(const char msg);
    void send_start(void);
    void send_complete(const boost::system::error_code& error);

    void do_close(const boost::system::error_code& error);
};

#endif //H_SerialAPI