app.js

const NodeMediaServer = require('./streaming/node_media_server');

const config = {
	rtmp: {
		port: 1935,
		chunk_size: 6,
		gop_cache: true,
		ping: 60,
		ping_timeout: 30
	},
	http: {
		port: 8000,
		webroot: './public',
		mediaroot: './streaming/media',
		allow_origin: '*'
	},
	trans: {
		ffmpeg: '.\\streaming\\ffmpeg\\ffmpeg.exe',
		tasks: [
			{
				app: 'live',
				ac: 'aac',
				mp4: true,
				mp4Flags: '[movflags=faststart]',
			}
		]
	}
};


let nms = new NodeMediaServer(config);
nms.run();

nms.on('preConnect', (id, args) => {
	console.log('[NodeEvent on preConnect]', `id=${id} args=${JSON.stringify(args)}`);
	// let session = nms.getSession(id);
	// session.reject();
});

nms.on('postConnect', (id, args) => {
	console.log('[NodeEvent on postConnect]', `id=${id} args=${JSON.stringify(args)}`);
});

nms.on('doneConnect', (id, args) => {
	console.log('[NodeEvent on doneConnect]', `id=${id} args=${JSON.stringify(args)}`);
});

nms.on('prePublish', (id, StreamPath, args) => {
	console.log('[NodeEvent on prePublish]', `id=${id} StreamPath=${StreamPath} args=${JSON.stringify(args)}`);
	// let session = nms.getSession(id);
	// session.reject();
});

nms.on('postPublish', (id, StreamPath, args) => {
	console.log('[NodeEvent on postPublish]', `id=${id} StreamPath=${StreamPath} args=${JSON.stringify(args)}`);
});

nms.on('donePublish', (id, StreamPath, args) => {
	console.log('[NodeEvent on donePublish]', `id=${id} StreamPath=${StreamPath} args=${JSON.stringify(args)}`);
});

nms.on('prePlay', (id, StreamPath, args) => {
	console.log('[NodeEvent on prePlay]', `id=${id} StreamPath=${StreamPath} args=${JSON.stringify(args)}`);
	// let session = nms.getSession(id);
	// session.reject();
});

nms.on('postPlay', (id, StreamPath, args) => {
	console.log('[NodeEvent on postPlay]', `id=${id} StreamPath=${StreamPath} args=${JSON.stringify(args)}`);
});

nms.on('donePlay', (id, StreamPath, args) => {
	console.log('[NodeEvent on donePlay]', `id=${id} StreamPath=${StreamPath} args=${JSON.stringify(args)}`);
});
userInformationApi = require('./userInformationApi');