Add Clapper deamon subprocess

Daemon is responsible for starting and later watching over spawned "broadwayd" and "remote" app needed for remote playback control. We cannot use systemd n Flatpak, so we make do with running optional background subprocesses.
This commit is contained in:
Rafostar
2020-12-16 19:54:30 +01:00
parent 254d1aa9db
commit 84762de76a
6 changed files with 104 additions and 30 deletions

66
clapper_src/daemon.js Normal file
View File

@@ -0,0 +1,66 @@
const { Gio, GLib, GObject } = imports.gi;
const Debug = imports.clapper_src.debug;
let { debug } = Debug;
var Daemon = GObject.registerClass(
class ClapperDaemon extends Gio.SubprocessLauncher
{
_init()
{
/* FIXME: show output when debugging is on */
const flags = Gio.SubprocessFlags.STDOUT_SILENCE
| Gio.SubprocessFlags.STDERR_SILENCE;
super._init({ flags });
this.errMsg = 'exited with error or was forced to close';
this.loop = GLib.MainLoop.new(null, false);
this.broadwayd = this.spawnv(['gtk4-broadwayd', '--port=8086']);
this.broadwayd.wait_async(null, this._onBroadwaydClosed.bind(this));
this.setenv('GDK_BACKEND', 'broadway', true);
const remoteApp = this.spawnv(['com.github.rafostar.Clapper.Remote']);
remoteApp.wait_async(null, this._onRemoteClosed.bind(this));
this.loop.run();
}
_checkProcResult(proc, result)
{
let hadError = false;
try {
hadError = proc.wait_finish(result);
}
catch(err) {
debug(err);
}
return hadError;
}
_onBroadwaydClosed(proc, result)
{
const hadError = this._checkProcResult(proc, result);
if(hadError)
debug(`broadwayd ${this.errMsg}`);
this.broadwayd = null;
this.loop.quit();
}
_onRemoteClosed(proc, result)
{
const hadError = this._checkProcResult(proc, result);
if(hadError)
debug(`remote app ${this.errMsg}`);
if(this.broadwayd)
this.broadwayd.force_exit();
}
});

View File

@@ -0,0 +1,6 @@
const { Daemon } = imports.clapper_src.daemon;
function main()
{
new Daemon();
}

View File

@@ -296,13 +296,14 @@ class ClapperPlayerBase extends GstPlayer.Player
if(!this.webapp)
this.webapp = new WebApp();
this.webapp.startRemoteApp();
this.webapp.startDaemonApp();
}
else
this.webapp.stopRemoteApp();
this.webapp.stopDaemonApp();
}
else if(this.webserver) {
/* remote app will close too when connection is lost */
/* remote app will close when connection is lost
* which will cause the daemon to close too */
this.webserver.stopListening();
}
break;

View File

@@ -14,35 +14,33 @@ class ClapperWebApp extends Gio.SubprocessLauncher
super._init({ flags });
this.remoteApp = null;
this.isRemoteClosing = false;
this.setenv('GDK_BACKEND', 'broadway', true);
this.daemonApp = null;
this.isDaemonClosing = false;
}
startRemoteApp()
startDaemonApp()
{
if(this.remoteApp)
if(this.daemonApp)
return;
this.remoteApp = this.spawnv([Misc.appId + '.Remote']);
this.remoteApp.wait_async(null, this._onRemoteClosed.bind(this));
this.daemonApp = this.spawnv([Misc.appId + '.Daemon']);
this.daemonApp.wait_async(null, this._onDaemonClosed.bind(this));
debug('remote app started');
debug('daemon app started');
}
stopRemoteApp()
stopDaemonApp()
{
if(!this.remoteApp || this.isRemoteClosing)
if(!this.daemonApp || this.isDaemonClosing)
return;
this.isRemoteClosing = true;
this.remoteApp.force_exit();
this.isDaemonClosing = true;
this.daemonApp.force_exit();
debug('send stop signal to remote app');
debug('send stop signal to daemon app');
}
_onRemoteClosed(proc, result)
_onDaemonClosed(proc, result)
{
let hadError;
@@ -53,12 +51,12 @@ class ClapperWebApp extends Gio.SubprocessLauncher
debug(err);
}
this.remoteApp = null;
this.isRemoteClosing = false;
this.daemonApp = null;
this.isDaemonClosing = false;
if(hadError)
debug('remote app exited with error');
debug('daemon app exited with error or was forced to close');
debug('remote app closed');
debug('daemon app closed');
}
});