From 27916b63566bf5a8e472259aa6f8b2ae778db972 Mon Sep 17 00:00:00 2001
From: Christian Richter <crichter@owncloud.com>
Date: Tue, 19 Jul 2022 09:00:09 +0200
Subject: [PATCH 1/2] make domains configurable & extend webserver

Signed-off-by: Christian Richter <crichter@owncloud.com>
---
 .gitignore                 |  3 ++-
 assets/index.html          | 16 +++++-----------
 config/config.json.example |  2 ++
 weirdradio.js              | 23 +++++++++++++++++++----
 4 files changed, 28 insertions(+), 16 deletions(-)

diff --git a/.gitignore b/.gitignore
index 930b811..23d8de0 100644
--- a/.gitignore
+++ b/.gitignore
@@ -1,3 +1,4 @@
 **/*.json
 node_modules
-.drone.yml
\ No newline at end of file
+.drone.yml
+assets/baseurl.js
\ No newline at end of file
diff --git a/assets/index.html b/assets/index.html
index 39424e7..52c9987 100644
--- a/assets/index.html
+++ b/assets/index.html
@@ -4,6 +4,10 @@
       type="text/javascript"
       src="http://www.youtube.com/player_api"
     ></script>
+    <script
+      type="text/javascript"
+      src="baseurl.js"
+    ></script>
     <title>Weirdradio</title>
   </head>
   <style>
@@ -108,8 +112,7 @@
       }
       console.log("Connecting to socket");
       socketSemaphore = true;
-      baseUrl = window.location.host.replace("8080", "8090");
-      let socket = new WebSocket("ws://" + baseUrl);
+      let socket = new WebSocket("ws://" + wsBaseUrl);
       socket.onopen = function (e) {
         clearInterval(socketConnector);
         socketConnector = null;
@@ -167,8 +170,6 @@
     }
 
     function playNext() {
-        console.log(playlist)
-        console.log(playlist[0].videoId)
       if (playlist[0] != null && playlist[0] != "") {
         player.loadVideoById(playlist[0].videoId);
         player.playVideo();
@@ -190,12 +191,5 @@
         console.log(`item ${data.videoId} already exists in playlist skipping`);
       }
     }
-
-    //function myDebugger() {
-    //    console.log(socketSemaphore);
-    //    console.log(socketConnector);
-    //    console.log("=================");
-    //}
-    //myDebugger = setInterval(myDebugger, 2000);
   </script>
 </html>
diff --git a/config/config.json.example b/config/config.json.example
index 36e642c..fb951f8 100644
--- a/config/config.json.example
+++ b/config/config.json.example
@@ -1,6 +1,8 @@
 {
   "homeServerUrl": "https://matrix.your-homeserver.org",
   "accessToken": "youraccesstokencanbeobtainedthroughriot",
+  "domain": "yourdomain.tld",
+  "webSocketDomain": "ws.yourdomain.tld",
   "storage": "config/bot.json",
   "assetDir": "assets/",
   "webServerPort": "8080",
diff --git a/weirdradio.js b/weirdradio.js
index 3cb704c..17266c6 100644
--- a/weirdradio.js
+++ b/weirdradio.js
@@ -20,14 +20,22 @@ const client = new MatrixClient(
   new SimpleFsStorageProvider(config.storage)
 );
 
+// write javascript for baseurl
+fs.writeFileSync(
+  config.assetDir + "/baseurl.js",
+  `var baseUrl = "${config.domain}";\nvar wsBaseUrl = "${config.webSocketDomain}";\n`,
+  function (err) {
+    if (err) return console.log(err);
+  }
+);
 // load assets
-console.log("Reading assets...")
+console.log("Reading assets...");
 let assets = [];
 var files = fs.readdirSync(config.assetDir);
 files.forEach((name) => {
   assets[name] = fs.readFileSync("assets/" + name);
 });
-console.log("[DONE]")
+ console.log("[DONE]");
 // create server, this is for delivering the iframe page
 const webServer = http
   .createServer((req, res) => {
@@ -36,7 +44,14 @@ const webServer = http
       reqFileName = "index.html";
     }
     if (assets[reqFileName] != undefined && assets[reqFileName] != null) {
-      res.writeHead(200, { "Content-Type": "text/html" });
+      extension = reqFileName.split(".").pop();
+      if (extension == "html" || extension == "html") {
+        res.writeHead(200, { "Content-Type": "text/html" });
+      } else if (extension == "js") {
+        res.writeHead(200, { "Content-Type": "text/javascript" });
+      } else {
+        res.writeHead(200, { "Content-TYpe": "text/plain" });
+      }
       res.end(assets[reqFileName]);
     } else {
       res.writeHead(404, { "Content-Type": "text/plain" });
@@ -85,7 +100,7 @@ client.on("room.message", (roomId, event) => {
     //link_matches = body.match(/https?:\/\/[^\ ]*youtu[^\ ]*/g);
     var r = new RegExp(/https?:\/\/[^\ ]*youtube.com\/watch\?v=([^\ ]*)/g);
     link_matches = r.exec(body);
-    if (link_matches && link_matches.length > 1) {
+    if (link_matches && link_matches.length > 1 && link_matches[0] != null) {
       // get title
       request(link_matches[0], function (err, _res, body) {
         if (err) return console.error(err);
-- 
2.49.1


From a023fbed871459f5776ba411d4d06deecc5fa7f0 Mon Sep 17 00:00:00 2001
From: Christian Richter <crichter@owncloud.com>
Date: Tue, 19 Jul 2022 09:03:37 +0200
Subject: [PATCH 2/2] add listener count to ws message

Signed-off-by: Christian Richter <crichter@owncloud.com>
---
 weirdradio.js | 1 +
 1 file changed, 1 insertion(+)

diff --git a/weirdradio.js b/weirdradio.js
index 17266c6..7e257e6 100644
--- a/weirdradio.js
+++ b/weirdradio.js
@@ -115,6 +115,7 @@ client.on("room.message", (roomId, event) => {
           link: link_matches[0],
           videoId: link_matches[1],
           title: title,
+          listeners: sockets.length,
         };
         console.log("Relaying: " + obj.link);
         sockets.forEach((s) => s.send(JSON.stringify(obj)));
-- 
2.49.1