const motion = require('hls-motion-detect');
 
let detectServer = new motion.DetectServer({
    ffmpegPath: 'ffmpeg', 
    ffprobePath: 'ffprobe', 
    recordingsPath: './recorded'
})
.listen(1336)
.on('source-added', (source) => {
    console.log(`New Source added [${source.systemName}] URL [${source.sourceURL}]`);
    
    source
    .on('start', (filepath) => {
        console.log(`Source [${source.systemName}] started`);
    })
    .on('stop', () => {
        console.log(`Source [${source.systemName}] stopped`);
    })
    .on('record-start', (filepath) => {
        console.log(`Source [${source.systemName}] started recording: ${filepath}`);
    })
    .on('record-stop', (filepath) => {
        console.log(`Source [${source.systemName}] stopped recording`);
    });
})
.on('source-removed', (systemName) => {
    console.log(`Source removed [${systemName}]`);
});

let apiServer = new motion.ApiServer(detectServer)
.listen(1337)
.on('listen', (port) => {
    console.log(`REST API server running at port ${port}`);
}).
on('debug', (msg) => {
    console.log(msg);
}).
on('error', (msg) => {
    console.error(msg);
});

{
    "systemName": "test",
    "name": "test",
    "sourceURL": "http://myLiveServer/live/myStream/index.m3u8"
}

{
    "systemName": "test"
}

{
    "systemName": "test",
    "interval": 3, // in seconds, if not specified default is one second.
    "x": 100, // not supported yet, defaults to 0.
    "y": 100, // not supported yet, defaults to 0.
    "width": 100, // not supported yet, defaults to 0.
    "height": 100, // not supported yet, defaults to 0.
    "threshold": 30, // (between 1 and 50) defaults to 35, use higher value to increase sensitivity and lower value to decrease sensitivity.
    "maxIdleTime": 60 // time to wait since last segment detected to raise idle event (Used by RabbitMQ to remove the source).
}

{
    "systemName": "test"
}

let webServer = new motion.WebServer(detectServer)
.listen({
    port: 3888,
    path: './lib/plugins/web-server/web', // you can change that static path to your own web folder
})
.on('listen', (port) => {
    console.log(`Web server running at port ${port}`);
});

let rabbitServer = new motion.RabbitServer(detectServer)
.on('listen', () => {
    console.log('Rabbit-MQ server running');
}).
on('error', (msg) => {
    console.error(msg);
})
.listen({
//	auth: 'guest:guest',
    host: 'localhost',
//	port: 5672,
    queue: 'stream-queue'
});

let kaltura = new Kaltura(detectServer, {
    partnerId: 123, // replace with your Kaltura account id
    secret: 'your secret here'
})
.on('error', (msg) => {
    console.error(msg);
})
.on('entry-created', (entry) => {
    console.log(`New entry [${entry.id}] uploaded`);
});