From dd86164a0294d8dc927174fc03062469dc544d23 Mon Sep 17 00:00:00 2001
From: Simon Vieille <simon@deblan.fr>
Date: Wed, 14 Feb 2018 11:57:16 +0100
Subject: [PATCH] Wrapper to start/restart/stop the server easily

---
 README.md                      |  11 +-
 server/server                  | 226 +++++----------------------------
 server/src/resource/server.php | 199 +++++++++++++++++++++++++++++
 3 files changed, 243 insertions(+), 193 deletions(-)
 create mode 100644 server/src/resource/server.php

diff --git a/README.md b/README.md
index b34953d..6f7c8c0 100644
--- a/README.md
+++ b/README.md
@@ -37,7 +37,7 @@ $ cd remote-i3wm-ws/
 $ cd client && composer install && cd ..
 $ cd server && composer install && cd ..
 $ php -S 0.0.0.0:15000 -t client/&
-$ php server/server&
+$ php server/src/resource/server.php
 ```
 
 The server can be run with verbosity:
@@ -46,3 +46,12 @@ The server can be run with verbosity:
 * `--vv` to show handlers messages
 
 Open `http://your.local.ip:15000` and enjoy!
+
+If you want to start/stop/restart the websocket easily:
+
+```
+$ export REMOTE_I3WM_WS_OPTIONS="-v"
+$ server/server start
+$ server/server stop
+$ server/server restart
+```
diff --git a/server/server b/server/server
index 67e2b67..2b757df 100755
--- a/server/server
+++ b/server/server
@@ -1,200 +1,42 @@
-#!/usr/bin/env php
-<?php
+#!/bin/sh
 
-require __DIR__.'/vendor/autoload.php';
+ACTION=start
+PID_PATH=/tmp/remote_i3wm_ws.pid
 
-use Ratchet\Server\IoServer;
-use Ratchet\Http\HttpServer;
-use Ratchet\WebSocket\WsServer;
-use Ratchet\ConnectionInterface;
+ri3wmws_stop() {
+    if [ -f "$PID_PATH" ]; then
+        PID=$(cat "$PID_PATH")
 
-$options = getopt(
-    'v',
-    ['verbose', 'vv']
-);
+        if [ -n "$PID" -a $(egrep "^[0-9]+$" "$PID_PATH") ]; then
+            kill -9 "$PID"
+            rm "$PID_PATH"
+            printf "Server stopped\n"
+        else
+            printf "Server not started\n"
+        fi
+    else
+        printf "Server not started\n"
+    fi
+}
 
-$serverOutput = new Output(isset($options['v']) || isset($options['verbose']));
-$messageOutput = new Output(isset($options['vv']));
-$server = new Server($serverOutput);
-$shell = new Shell();
+ri3wmws_start() {
+    php src/resource/server.php "$REMOTE_I3WM_WS_OPTIONS" &
+    PID=$!
 
-$server->addMessageHandler('pointer', function (ConnectionInterface $from, array $data) use ($shell, $messageOutput) {
-    $x = $data['x'] ?? null;
-    $y = $data['y'] ?? null;
-    $click = $data['click'] ?? null;
+    printf $PID > "$PID_PATH"
+    chmod 600 "$PID_PATH"
+    printf "Server is running\n"
+}
 
-    if ($x !== null && $y !== null) {
-        $mouseLocations = $shell->exec('xdotool getmouselocation');
-        preg_match('/x:(\d+) y:(\d+) /', $mouseLocations, $matches);
-        $mouseX = (int) ($matches[1] + $x * 2.5);
-        $mouseY = (int) ($matches[2] + $y * 2.5);
+ri3wmws_restart() {
+    ri3wmws_stop
+    ri3wmws_start
+}
 
-        $shell->exec('xdotool mousemove %s %s', $mouseX, $mouseY);
-        $messageOutput->writeln('Pointer moved');
-    } elseif ($click !== null) {
-        if ($click === 'left') {
-            $shell->exec('xdotool click 1');
-            $messageOutput->writeln('Left click');
-        } elseif ($click === 'middle') {
-            $shell->exec('xdotool click 2');
-            $messageOutput->writeln('Middle click');
-        } elseif ($click === 'right') {
-            $shell->exec('xdotool click 3');
-            $messageOutput->writeln('Right click');
-        }
-    }
-});
+cd "$(dirname "$0")"
 
-$server->addMessageHandler('scroll', function (ConnectionInterface $from, array $data) use ($shell, $messageOutput) {
-    $value = $data['value'] ?? null;
-
-    if ($value === 'down') {
-        $shell->exec('xdotool click 5 && xdotool click 5');
-        $messageOutput->writeln('Scrolling down');
-    } elseif ($value === 'up') {
-        $shell->exec('xdotool click 4 && xdotool click 4');
-        $messageOutput->writeln('Scrolling up');
-    }
-});
-
-$server->addMessageHandler('workspace', function (ConnectionInterface $from, array $data) use ($shell, $messageOutput) {
-    $value = $data['value'] ?? null;
-
-    if (!empty($value)) {
-        $shell->exec("i3-msg 'workspace \"%s\"'", $value);
-        $messageOutput->writeln('Workspace changed');
-    }
-});
-
-$server->addMessageHandler('volume', function (ConnectionInterface $from, array $data) use ($shell, $messageOutput) {
-    $value = $data['value'] ?? null;
-
-    if ($value === null) {
-        return;
-    }
-
-    if ($value === 'up') {
-        $shell->exec('amixer set Master 2%%+');
-        $from->send(json_encode(['type' => 'response', 'value' => 'Volume up']));
-        $messageOutput->writeln('Volume up');
-    } elseif ($value === 'down') {
-        $shell->exec('amixer set Master 2%%-');
-        $from->send(json_encode(['type' => 'response', 'value' => 'Volume down']));
-        $messageOutput->writeln('Volume down');
-    } else {
-        $shell->exec('amixer set Master %d%%', (int) $value);
-        $from->send(json_encode(['type' => 'response', 'value' => sprintf('Volume set to %d%%', $value)]));
-        $messageOutput->writeln(sprintf('Volume set to %d%%', $value));
-    }
-});
-
-$server->addMessageHandler('media', function (ConnectionInterface $from, array $data) use ($shell, $messageOutput) {
-    $value = $data['value'] ?? null;
-
-    if ($value === 'playpause') {
-        $cmd = 'play-pause';
-    } elseif ($value === 'next') {
-        $cmd = 'next';
-    } elseif ($value === 'prev') {
-        $cmd = 'previous';
-    }
-
-    if (!empty($cmd)) {
-        $shell->exec('playerctl -p spotify %s', $cmd);
-
-        usleep(500000);
-        $status = trim($shell->exec('playerctl -p spotify status'));
-
-        if ($status === 'Playing') {
-            $song = $shell->exec('playerctl -p spotify metadata xesam:title');
-            $from->send(json_encode(['type' => 'response', 'value' => 'Playing: '.$song]));
-            $messageOutput->writeln('Spotify playing');
-        } else {
-            $from->send(json_encode(['type' => 'response', 'value' => 'Paused']));
-            $messageOutput->writeln('Spotify paused');
-        }
-    }
-});
-
-$server->addMessageHandler('keys', function (ConnectionInterface $from, array $data) use ($shell, $messageOutput) {
-    $value = $data['value'] ?? null;
-
-    if (!empty($value)) {
-        $keys = explode(',', $value);
-
-        foreach ($keys as $k => $v) {
-            if ($v === 'win') {
-                $keys[$k] = 'super';
-            } elseif ($v === 'ctrl') {
-                $keys[$k] = 'Control_L';
-            } elseif ($v === 'alt') {
-                $keys[$k] = 'Alt_L';
-            }
-        }
-
-        $value = implode('+', $keys);
-
-        $shell->exec('xdotool key %s', escapeshellarg($value));
-        $messageOutput->writeln('Key pressed');
-    }
-});
-
-$server->addMessageHandler('key', function (ConnectionInterface $from, array $data) use ($shell, $messageOutput) {
-    $value = $data['value'] ?? null;
-    $map = [
-        'up' => 'Up',
-        'down' => 'Down',
-        'left' => 'Left',
-        'right' => 'Right',
-        'tab' => 'Tab',
-        'backspace' => 'BackSpace',
-        'enter' => 'Return',
-        'space' => 'space',
-        'escape' => 'Escape',
-    ];
-
-    if (!empty($value) && isset($map[$value])) {
-        $shell->exec('xdotool key %s', $map[$value]);
-        $messageOutput->writeln('Key pressed');
-    }
-});
-
-$server->addMessageHandler('text', function (ConnectionInterface $from, array $data) use ($shell, $messageOutput) {
-    $value = $data['value'] ?? null;
-
-    if (trim($value) !== '') {
-        $shell->exec('xdotool type %s', escapeshellarg($value));
-        $messageOutput->writeln('Text wrote');
-    }
-});
-
-$server->addMessageHandler('screenshot', function (ConnectionInterface $from, array $data) use ($shell, $messageOutput) {
-    $tmpFilename = sprintf('%s/remote_i3wm_ws_screenshot.jpg', sys_get_temp_dir());
-    $shell->exec('import -window root -quality 10 -display :0 %1$s && chmod 600 %1$s', $tmpFilename);
-
-    if (file_exists($tmpFilename)) {
-        $base64 = base64_encode(file_get_contents($tmpFilename));
-
-        $from->send(json_encode([
-            'type' => 'screenshot',
-            'value' => $base64,
-        ]));
-
-        unlink($tmpFilename);
-    }
-});
-
-$server->addMessageHandler('messages', function (ConnectionInterface $from, array $data) use ($server) {
-    $value = $data['value'] ?? [];
-
-    foreach ($value as $msg) {
-        $server->onMessage($from, json_encode($msg));
-    }
-});
-
-$webSocker = IoServer::factory(
-    new HttpServer(new WsServer($server)),
-    14598
-);
-
-$webSocker->run();
+case "$1" in
+    start) ri3wmws_start;;
+    restart) ri3wmws_restart;;
+    stop) ri3wmws_stop;;
+esac;
diff --git a/server/src/resource/server.php b/server/src/resource/server.php
new file mode 100644
index 0000000..9e458b2
--- /dev/null
+++ b/server/src/resource/server.php
@@ -0,0 +1,199 @@
+<?php
+
+require __DIR__.'/../../vendor/autoload.php';
+
+use Ratchet\Server\IoServer;
+use Ratchet\Http\HttpServer;
+use Ratchet\WebSocket\WsServer;
+use Ratchet\ConnectionInterface;
+
+$options = getopt(
+    'v',
+    ['verbose', 'vv']
+);
+
+$serverOutput = new Output(isset($options['v']) || isset($options['verbose']));
+$messageOutput = new Output(isset($options['vv']));
+$server = new Server($serverOutput);
+$shell = new Shell();
+
+$server->addMessageHandler('pointer', function (ConnectionInterface $from, array $data) use ($shell, $messageOutput) {
+    $x = $data['x'] ?? null;
+    $y = $data['y'] ?? null;
+    $click = $data['click'] ?? null;
+
+    if ($x !== null && $y !== null) {
+        $mouseLocations = $shell->exec('xdotool getmouselocation');
+        preg_match('/x:(\d+) y:(\d+) /', $mouseLocations, $matches);
+        $mouseX = (int) ($matches[1] + $x * 2.5);
+        $mouseY = (int) ($matches[2] + $y * 2.5);
+
+        $shell->exec('xdotool mousemove %s %s', $mouseX, $mouseY);
+        $messageOutput->writeln('Pointer moved');
+    } elseif ($click !== null) {
+        if ($click === 'left') {
+            $shell->exec('xdotool click 1');
+            $messageOutput->writeln('Left click');
+        } elseif ($click === 'middle') {
+            $shell->exec('xdotool click 2');
+            $messageOutput->writeln('Middle click');
+        } elseif ($click === 'right') {
+            $shell->exec('xdotool click 3');
+            $messageOutput->writeln('Right click');
+        }
+    }
+});
+
+$server->addMessageHandler('scroll', function (ConnectionInterface $from, array $data) use ($shell, $messageOutput) {
+    $value = $data['value'] ?? null;
+
+    if ($value === 'down') {
+        $shell->exec('xdotool click 5 && xdotool click 5');
+        $messageOutput->writeln('Scrolling down');
+    } elseif ($value === 'up') {
+        $shell->exec('xdotool click 4 && xdotool click 4');
+        $messageOutput->writeln('Scrolling up');
+    }
+});
+
+$server->addMessageHandler('workspace', function (ConnectionInterface $from, array $data) use ($shell, $messageOutput) {
+    $value = $data['value'] ?? null;
+
+    if (!empty($value)) {
+        $shell->exec("i3-msg 'workspace \"%s\"'", $value);
+        $messageOutput->writeln('Workspace changed');
+    }
+});
+
+$server->addMessageHandler('volume', function (ConnectionInterface $from, array $data) use ($shell, $messageOutput) {
+    $value = $data['value'] ?? null;
+
+    if ($value === null) {
+        return;
+    }
+
+    if ($value === 'up') {
+        $shell->exec('amixer set Master 2%%+');
+        $from->send(json_encode(['type' => 'response', 'value' => 'Volume up']));
+        $messageOutput->writeln('Volume up');
+    } elseif ($value === 'down') {
+        $shell->exec('amixer set Master 2%%-');
+        $from->send(json_encode(['type' => 'response', 'value' => 'Volume down']));
+        $messageOutput->writeln('Volume down');
+    } else {
+        $shell->exec('amixer set Master %d%%', (int) $value);
+        $from->send(json_encode(['type' => 'response', 'value' => sprintf('Volume set to %d%%', $value)]));
+        $messageOutput->writeln(sprintf('Volume set to %d%%', $value));
+    }
+});
+
+$server->addMessageHandler('media', function (ConnectionInterface $from, array $data) use ($shell, $messageOutput) {
+    $value = $data['value'] ?? null;
+
+    if ($value === 'playpause') {
+        $cmd = 'play-pause';
+    } elseif ($value === 'next') {
+        $cmd = 'next';
+    } elseif ($value === 'prev') {
+        $cmd = 'previous';
+    }
+
+    if (!empty($cmd)) {
+        $shell->exec('playerctl -p spotify %s', $cmd);
+
+        usleep(500000);
+        $status = trim($shell->exec('playerctl -p spotify status'));
+
+        if ($status === 'Playing') {
+            $song = $shell->exec('playerctl -p spotify metadata xesam:title');
+            $from->send(json_encode(['type' => 'response', 'value' => 'Playing: '.$song]));
+            $messageOutput->writeln('Spotify playing');
+        } else {
+            $from->send(json_encode(['type' => 'response', 'value' => 'Paused']));
+            $messageOutput->writeln('Spotify paused');
+        }
+    }
+});
+
+$server->addMessageHandler('keys', function (ConnectionInterface $from, array $data) use ($shell, $messageOutput) {
+    $value = $data['value'] ?? null;
+
+    if (!empty($value)) {
+        $keys = explode(',', $value);
+
+        foreach ($keys as $k => $v) {
+            if ($v === 'win') {
+                $keys[$k] = 'super';
+            } elseif ($v === 'ctrl') {
+                $keys[$k] = 'Control_L';
+            } elseif ($v === 'alt') {
+                $keys[$k] = 'Alt_L';
+            }
+        }
+
+        $value = implode('+', $keys);
+
+        $shell->exec('xdotool key %s', escapeshellarg($value));
+        $messageOutput->writeln('Key pressed');
+    }
+});
+
+$server->addMessageHandler('key', function (ConnectionInterface $from, array $data) use ($shell, $messageOutput) {
+    $value = $data['value'] ?? null;
+    $map = [
+        'up' => 'Up',
+        'down' => 'Down',
+        'left' => 'Left',
+        'right' => 'Right',
+        'tab' => 'Tab',
+        'backspace' => 'BackSpace',
+        'enter' => 'Return',
+        'space' => 'space',
+        'escape' => 'Escape',
+    ];
+
+    if (!empty($value) && isset($map[$value])) {
+        $shell->exec('xdotool key %s', $map[$value]);
+        $messageOutput->writeln('Key pressed');
+    }
+});
+
+$server->addMessageHandler('text', function (ConnectionInterface $from, array $data) use ($shell, $messageOutput) {
+    $value = $data['value'] ?? null;
+
+    if (trim($value) !== '') {
+        $shell->exec('xdotool type %s', escapeshellarg($value));
+        $messageOutput->writeln('Text wrote');
+    }
+});
+
+$server->addMessageHandler('screenshot', function (ConnectionInterface $from, array $data) use ($shell, $messageOutput) {
+    $tmpFilename = sprintf('%s/remote_i3wm_ws_screenshot.jpg', sys_get_temp_dir());
+    $shell->exec('import -window root -quality 10 -display :0 %1$s && chmod 600 %1$s', $tmpFilename);
+
+    if (file_exists($tmpFilename)) {
+        $base64 = base64_encode(file_get_contents($tmpFilename));
+
+        $from->send(json_encode([
+            'type' => 'screenshot',
+            'value' => $base64,
+        ]));
+
+        unlink($tmpFilename);
+    }
+});
+
+$server->addMessageHandler('messages', function (ConnectionInterface $from, array $data) use ($server) {
+    $value = $data['value'] ?? [];
+
+    foreach ($value as $msg) {
+        $server->onMessage($from, json_encode($msg));
+    }
+});
+
+$webSocker = IoServer::factory(
+    new HttpServer(new WsServer($server)),
+    14598
+);
+
+$webSocker->run();