JSSerialPort.hxx

Go to the documentation of this file.

 
#ifndef _UTILS_JSSERIALPORT_HXX_
#define _UTILS_JSSERIALPORT_HXX_
 
#ifdef __EMSCRIPTEN__
 
#include <emscripten.h>
#include <emscripten/val.h>
 
#include "utils/Hub.hxx"
#include "utils/JSHubPort.hxx"
 
class JSSerialPort
{
public:
    JSSerialPort(CanHubFlow *hflow, string device,
        std::function<void()> cb = []() {})
        : canHub_(hflow)
        , connectCallback_(std::move(cb))
    {
        string script = "Module.serial_device = '" + device + "';\n";
        emscripten_run_script(script.c_str());
        EM_ASM_(
            {
                var SerialPort = require('serialport');
                var portdev = Module.serial_device;
                console.log('Opening ' + portdev);
                var openerror = function(error) {
                    console.log(
                        'Failed to open serial port ' + portdev + ': ' + error);
                    console.log('Known serial ports:');
                    require('@serialport/bindings')
                        .list()
                        .then(function(ports) {
                            ports.forEach(function(port) {
                                console.log('port "' + port.path +
                                    '" pnp id: ' + port.pnpId +
                                    ' manufacturer: ' + port.manufacturer);
                            });
                        });
                };
                var c;
                try {
                    c = new SerialPort(
                        Module.serial_device, {baudRate : 115200});
                } catch(err) {
                    openerror(err);
                    return;
                }
                c.on("open", function(error) {
                    if (error) {
                        openerror(error);
                        return;
                    }
                    console.log('opened ' + c);
                    var client_port = new Module.JSHubPort(
                        $0, function(data) { c.write(data); });
                    c.on('close', function() {
                        console.log('serial port ' + portdev + ' closed.');
                        client_port.abandon();
                    });
                    c.on('error', function(err) {
                        console.log('error on serial port ' + portdev + ': ' + err);
                        c.close();
                        client_port.abandon();
                    });
                    c.on('data', function(data) { client_port.recv(data.toString()); });
                    _invoke_fnp($1);
                });
            },
            (unsigned long)canHub_, (unsigned long)&connectCallback_);
    }
 
    static void list_ports() {
        EM_ASM(
            {
                console.log('Known serial ports:');
                require('@serialport/bindings').list().then(function(ports)
                    {
                        ports.forEach(function(port)
                            {
                                console.log('port "' + port.path +
                                    '" pnp id: '  + port.pnpId + 
                                    ' manufacturer: ' + port.manufacturer);
                            });
                    });
            });
    }
 
private:
    CanHubFlow *canHub_;
    std::function<void()> connectCallback_;
};
 
#endif // __EMSCRIPTEN__
#endif // _UTILS_JSTCPCLIENT_HXX_