omx-sync.js

// node-omxplayer-sync
// Ben Moren
// https://github.com/bmoren/node-omxplayer-sync/
// http://benmoren.com
// GNU General Public License v3.0

var fs = require('fs');
var server = require('http').createServer();
var socket = require('socket.io-client')('http://192.168.0.99:3000');
// var io = require('socket.io')(server);
var io = require('socket.io')(server, {'pingInterval': 10000, 'pingTimeout': 15000});
var dbus = require('dbus-native');
var exec = require('child_process').exec;
var file = process.argv.slice(2)[0]; //get a path to the video argument
var options = '-o hdmi -b --loop --no-osd '
var currentPosition, totalDuration;
var bus; //main DBUS
var gate = true;
var omx;

server.listen(3000, function() { console.log( 'Listening on port 3000') });

// PARSE TERMINAL INPUT.
if(file == undefined){
  console.log("no video file specified");
  return
}

//kill previous player if the script needs to restart
var killall = exec('killall omxplayer.bin', (error, stdout, stderr) => {
  if (error) {
    console.error(`exec error: ${error}`);
    return;
  }
  console.log(`stdout: ${stdout}`);
  console.log(`stderr: ${stderr}`);
});

console.log('current video path: ' + file);

//start omx player
omx = exec('omxplayer '+options+file, (error, stdout, stderr) => {
  if (error) {
    console.error(`omxplayer exec error: ${error}`);
    return;
  }
  console.log(`exec omxplayer stdout: ${stdout}`);
  console.log(`exec omxplayer stderr: ${stderr}`);
});

omx.on('exit', function(code){
  console.log('EXIT CODE: '+ code +' @ ' + Date() );
  // relaunch omxplayer
  process.exit(0);

});

//SOCKET.IO HANDLING
io.on('connection', function(socket){
  console.log("Listener connected: " + socket.id + ' @ ' + Date());

  socket.on('disconnect', function(){
    console.log("Listener disconnected: " + socket.id );
  });

});

socket.on('connect', function(){
  console.log("Connected to the broadcaster as: " + socket.id + ' @ ' + Date() );

});

socket.on('loopFlag', function(loopFlag){
  console.log('loop flag recieved  @ ' + Date());
  seek( s2micro(1) );
  setTimeout(function(){
    gate = true;
  },1000)
})

//DBUS HANDLING
setTimeout(function(){ //wait for dbus to become available.

  bus = dbus.sessionBus({
          busAddress: fs.readFileSync('/tmp/omxplayerdbus.pi', 'ascii').trim()
  });

  setTimeout(function(){
    bus.invoke({
            path: "/org/mpris/MediaPlayer2",
            interface: "org.freedesktop.DBus.Properties",
            member: "Duration",
            destination: "org.mpris.MediaPlayer2.omxplayer",
    }, function(err, duration) {
            totalDuration = duration; //set to a global
            console.log("Duration: " + totalDuration);
    });

    //send out loop flag
    setInterval(function(){
      bus.invoke({
              path: "/org/mpris/MediaPlayer2",
              interface: "org.freedesktop.DBus.Properties",
              member: "Position",
              destination: "org.mpris.MediaPlayer2.omxplayer",
      }, function(err, position) {
              currentPosition = position; //set to a global
              // console.log("CP: " + currentPosition);
      });


      if(currentPosition >= totalDuration - s2micro(1) && gate == true){ //are we in the end range of the file?
        gate = false;
        console.log( "*File Ended @ " + Date() );
        io.emit('loopFlag', { loopFlag : 'loop' }); //add one of these above outside the interval loop to reset when the server boots?
      }

    },250);

  }, 1000)
}, 1000);

function seek(pos){
  bus.invoke({
          path: "/org/mpris/MediaPlayer2",
          interface: "org.mpris.MediaPlayer2.Player",
          member: "SetPosition",
          destination: "org.mpris.MediaPlayer2.omxplayer",
          signature: "ox",
          body: [ '/not/used', pos ]
  }, function(err) {
    if(err != null){
          console.log("ERROR: "+err);
        }
  });

}

function s2micro(seconds){
  return seconds * 1000000;
}