JSTcpHub.hxx

Go to the documentation of this file.

 
#ifndef _UTILS_JSTCPHUB_HXX_
#define _UTILS_JSTCPHUB_HXX_
 
#ifdef __EMSCRIPTEN__
 
#include <emscripten.h>
#include <emscripten/val.h>
 
#include "utils/Hub.hxx"
#include "utils/JSHubPort.hxx"
 
class JSTcpHub
{
public:
    JSTcpHub(CanHubFlow *hflow, int port)
        : canHub_(hflow)
    {
        EM_ASM_(
            {
                var net = require('net');
                var server = net.createServer(function(c)
                    {
                        console.log('client connected');
                        c.setEncoding('utf-8');
                        c.setTimeout(0);
                        c.setKeepAlive(true);
                        var client_port =
                            new Module.JSHubPort($1, function(data)
                                {
                                    c.write(data);
                                });
                        c.on('close', function()
                            {
                                console.log('client disconnected');
                                client_port.abandon();
                            });
                        c.on('error', function()
                            {
                                console.log('client error -- disconnected');
                                client_port.abandon();
                            });
                        c.on('data', function(data)
                            {
                                client_port.recv(data);
                            });
                    });
                server.listen($0, function()
                    {
                        console.log('listening on port ' + $0);
                    });
            },
            port, (unsigned long)canHub_);
    }
 
private:
    CanHubFlow *canHub_;
};
 
#endif // __EMSCRIPTEN__
#endif // _UTILS_JSTCPHUB_HXX_