OpenROV / openrov-cockpit

src/plugins/mjpeg-video/index.js

(function() 
{
    const fs        = require('fs');

'const' is available in ES6 (use 'esversion: 6') or Mozilla JS extensions (use moz).

    const respawn   = require('respawn');

'const' is available in ES6 (use 'esversion: 6') or Mozilla JS extensions (use moz).

    const util      = require('util');

'const' is available in ES6 (use 'esversion: 6') or Mozilla JS extensions (use moz).

    const io        = require('socket.io-client');

'const' is available in ES6 (use 'esversion: 6') or Mozilla JS extensions (use moz).

    const assert    = require('assert');

'const' is available in ES6 (use 'esversion: 6') or Mozilla JS extensions (use moz).

    const Listener  = require( 'Listener' );

'const' is available in ES6 (use 'esversion: 6') or Mozilla JS extensions (use moz).

    var logger;
    var defaults = 
    {
        port: 8300,
        wspath: '/mjpeg'
    };

    class MjpgStreamer

'class' is available in ES6 (use 'esversion: 6') or Mozilla JS extensions (use moz).

    {
        constructor( name, deps )
        {
            logger = deps.logger;
            
            logger.info( "Loaded Cockpit Plugin: MjpgStreamer" );

            this.globalBus  = deps.globalEventLoop;
            this.cockpitBus = deps.cockpit;

            this.settings   = {};
            this.camera     = null;

            this.supervisorLaunchOptions = 
            [
                "nice",
                "-1",
                "node",
                require.resolve( 'mjpeg-video-server' ),
                "-p",
                defaults.port,
                "-c",
                "/etc/openrov/STAR_openrov_net.chained.crt",
                "-k",
                "/etc/openrov/star_openrov_net.key",
            ];

            // Handle mock options
            if( process.env.USE_MOCK === 'true' ) 
            {
                if( process.env.MOCK_VIDEO_TYPE === "MJPEG" )
                {
                    logger.info( "Using MJPEG video format in Mock Mode.");

                    this.supervisorLaunchOptions.push( '-m' );
                    this.supervisorLaunchOptions.push( 'true' );

                    if( process.env.MOCK_VIDEO_HARDWARE === 'false' )
                    {
                        logger.info( "Using actual MJPEG video source.");

                        this.supervisorLaunchOptions.push( '-h' );
                        this.supervisorLaunchOptions.push( 'true' );
                    }
                    else
                    {
                        logger.info( "Using mocked MJPEG video source.");
                    }
                }
                else
                {
                    this.disabled = true;
                    return;
                }
            }

            this.supervisor = io.connect( 'http://localhost:' + defaults.port,
            {
                path: defaults.wspath,
                reconnection: true,
                reconnectionAttempts: Infinity,
                reconnectionDelay: 1000
            });

            this.svMonitor = respawn( this.supervisorLaunchOptions, 
            {
                name: 'mjpeg-video-server',
                env: 
                {
                    'COCKPIT_PATH': process.env[ "COCKPIT_PATH" ],

['COCKPIT_PATH'] could be written in dot notation.

                    'DEBUG': 'app*'
                },
                maxRestarts: -1,
                sleep: 1000
            });

            this.svMonitor.on( "stdout", (data) =>

'arrow function syntax (=>)' is only available in ES6 (use 'esversion: 6').

            {
                logger.debug( data.toString() );
            });

            this.svMonitor.on( "stderr", (data) =>

'arrow function syntax (=>)' is only available in ES6 (use 'esversion: 6').

            {
                logger.debug( data.toString() );
            });      

            // Set up listeners
            this.listeners = 
            {
                settings: new Listener( this.globalBus, 'settings-change.mjpegVideo', true, (settings) =>

'arrow function syntax (=>)' is only available in ES6 (use 'esversion: 6').

                {
                    try
                    {
                        // Check for settings changes
                        assert.notDeepEqual( settings.mjpegVideo, this.settings );

                        // Update settings
                        this.settings = settings.mjpegVideo;

                        logger.info( `Updating MJPEG streamer settings to: \n${this.settings}` );

'template literal syntax' is only available in ES6 (use 'esversion: 6').

                        // Send update to supervisor so it restarts the stream
                        this.supervisor.emit( "updateSettings", this.settings );
                    }
                    catch( err )
                    {
                        // Do nothing
                    }
                }),

                scanForCameras: new Listener( this.cockpitBus, "plugin.mjpegVideo.scanForCameras", false, () =>

'arrow function syntax (=>)' is only available in ES6 (use 'esversion: 6').

                {
                    logger.info( "Scanning" );
                    this.supervisor.emit( "scan" );
                }),

                svConnect: new Listener( this.supervisor, 'connect', false, () =>

'arrow function syntax (=>)' is only available in ES6 (use 'esversion: 6').

                {
                    logger.info( 'Successfully connected to mjpg-streamer supervisor' );

                    // Start listening for settings changes (gets the latest settings)
                    this.listeners.settings.enable();
                }),

                svDisconnect: new Listener( this.supervisor, 'disconnect', false, function()
                {
                    logger.info( 'Disconnected from mjpg-streamer supervisor' );
                }),

                svError: new Listener( this.supervisor, 'error', false, function(err)
                {
                    logger.error(err, 'Mjpg-streamer supervisor connection error' );
                }),

                svReconnect: new Listener( this.supervisor, 'reconnect', false, function()
                {
                    logger.info('Reconnecting to mjpg-streamer supervisor...');
                }),

                svStreamRegistration: new Listener( this.supervisor, 'stream.registration', false, ( serial, info ) =>

'arrow function syntax (=>)' is only available in ES6 (use 'esversion: 6').

                {
                    logger.info('Stream Registration: ' + JSON.stringify(info) );

                    this.globalBus.emit( 'CameraRegistration', 
                    {
                        location:           "forward",               // TODO: Lookup location based on serial ID
                        videoMimeType: 		"video/x-motion-jpeg",
                        resolution:         info.resolution,
                        framerate:          info.framerate, 
                        wspath:             "",
                        relativeServiceUrl: `:${info.port}`,

'template literal syntax' is only available in ES6 (use 'esversion: 6').

                        sourcePort:         info.port,
                        sourceAddress:      "",
                        connectionType:     info.connectionType
                    });
                })
            }

There should be a semicolon.

        }

        start()
        {
            if( this.disabled )
            {
                return;
            }

            // Enable listeners
            this.listeners.svConnect.enable();
            this.listeners.svDisconnect.enable();
            this.listeners.svError.enable();
            this.listeners.svReconnect.enable();
            this.listeners.svStreamRegistration.enable();

            this.listeners.scanForCameras.enable();

            // Start the supervisor process
            this.svMonitor.start();
        }

        stop()
        {
            if( this.disabled )
            {
                return;
            }
            
            // Stop the supervisor process
            this.svMonitor.stop();

            // Disable all listeners
            for( var listener in this.listeners ) 
            {
                if( this.listeners.hasOwnProperty( listener ) ) 
                {
                    listener.disable();
                }
            }
        }

        getSettingSchema()
        {
            return [
            {
                'title':    'MJPEG Video',
                'type':     'object',
                'id':       'mjpegVideo',
                'category' : 'video',

                'properties': {
                    'framerate': 
                    {
                        'type': 'string',
                        'enum': 
                        [
                            '30',
                            '15',
                            '10'
                        ],
                        'title': 'Framerate (FPS)',
                        'default': '30'
                    },
                    'resolution': 
                    {
                        'type': 'string',
                        'enum': 
                        [
                            '1920x1080',
                            '1280x720',
                            '800x600',
                            '640x480',
                            '352x288',
                            '320x240',
                            '176x144',
                            '160x120'
                        ],
                        'title': 'Resolution',
                        'default': '800x600'
                    }                    
                },

                'required': 
                [
                    'framerate',    // Framerate setting for camera
                    'resolution'    // Resolution setting for camera
                ]
            }];
        }
    }

    module.exports = function( name, deps ) 
    {
        if( process.env.PRODUCTID == "trident" )
        {
            deps.logger.debug( "MjpgStreamer Not supported on trident" );
            return {};
        }

        return new MjpgStreamer( name, deps );
    };
}());