renaming

chatbothubs.js

@@ -0,0 +1,157 @@
+const WebSocket = require("ws");
+const { Client } = require("node-osc");
+
+const ws = new WebSocket(
+  "wss://relaxed-werewolf.reticulum.io/socket/websocket?vsn=2.0.0"
+);
+
+const STATE_STARTING = "starting";
+const STATE_JOINING = "joining";
+const STATE_CONNECTED = "connected";
+
+let state = STATE_STARTING;
+let hubId = "qPxWfFA";
+let fullHubId = `hub:${hubId}`;
+let receiveId = 1;
+let sendId = 1;
+let botSessionId;
+let vapidPublicKey;
+let avatarId = "qPxWfFA";
+let displayName = "000";
+// Members keyed by session ID.
+let members = {};
+let chatStates = {};
+
+const oscClient = new Client("127.0.0.1", 3333);
+
+let dialogOptions = [
+  ["START", /(hello|hi)/, "Welcome to the attic, you are getting close.", "START"],
+
+
+  ["START", /(shell)/, "One correct!", "SHELL"],
+  ["START", /(mirror)/, "One correct!", "MIRROR"],
+  ["START", /(computer)/, "One correct!", "COMPUTER"],
+ 
+  ["SHELL", /(shell)/, "You already said that!!", "SHELL"],
+  ["SHELL", /(mirror)/, "Two correct!", "SHELL_MIRROR"],
+  ["SHELL", /(computer)/, "Two correct!", "SHELL_COMPUTER"],
+ 
+  [ "SHELL_COMPUTER", /(shell|computer)/, "You already said that!", "SHELL_COMPUTER"],
+  [ "SHELL_COMPUTER", /(mirror)/, "Ahhhhh...... the number of the portal is... 32!", "WIN"],
+  [ "SHELL_MIRROR", /(shell|mirror)/, "You already said that!", "SHELL_MIRROR"],
+  [ "SHELL_MIRROR", /(computer)/, "Ahhhhh...... the number of the portal is... 32!", "WIN"],
+ 
+  ["MIRROR", /(mirror)/, "You already said that!!", "MIRROR"],
+  ["MIRROR", /(shell)/, "Two correct!", "MIRROR_SHELL"],
+  ["MIRROR", /(computer)/, "Two correct!", "MIRROR_COMPUTER"],
+ 
+  [ "MIRROR_COMPUTER", /(mirror|computer)/, "You already said that!", "MIRROR_COMPUTER"],
+  [ "MIRROR_COMPUTER", /(shell)/, "Ahhhhh...... the number of the portal is... 32!", "WIN"],
+  [ "MIRROR_SHELL", /(shell|mirror)/, "You already said that!", "MIRROR_COMPUTER"],
+  [ "MIRROR_SHELL", /(computer)/, "Ahhhhh...... the number of the portal is... 32!", "WIN"],
+ 
+  ["COMPUTER", /(comptuer)/, "You already said that!!", "COMPUTER"],
+  ["COMPUTER", /(mirror)/, "Two correct!", "COMPUTER_MIRROR"],
+  ["COMPUTER", /(shell)/, "Two correct!", "COMPUTER_SHELL"],
+ 
+  [ "COMPUTER_SHELL", /(shell|computer)/, "You already said that!", "COMPUTER_SHELL"],
+  [ "COMPUTER_SHELL", /(mirror)/, "Ahhhhh...... the number of the portal is... 32!", "WIN"],
+  [ "COMPUTER_MIRROR", /(computer|mirror)/, "You already said that!", "COMPUTER_MIRROR"],
+  [ "COMPUTER_MIRROR", /(shell)/, "Ahhhhh...... the number of the portal is... 32!", "WIN"],
+
+  // Guessing game
+
+];
+
+ 
+   
+
+
+
+function sendMessage(roomId, command, body) {
+  const message = JSON.stringify([receiveId, sendId, roomId, command, body]);
+  ws.send(message);
+  sendId++;
+}
+
+function receiveMessage(data) {
+  const [n1, n2, channel, command, body] = JSON.parse(data);
+  if (Number.isInteger(n1)) {
+    receiveId = n1;
+  }
+  if (command === "phx_reply" && state === STATE_STARTING) {
+    if (body.status === "ok") {
+      console.log("Joining Hubs...");
+      state = STATE_JOINING;
+      botSessionId = body.response.session_id;
+      vapidPublicKey = body.response.vapid_public_key;
+      sendMessage(fullHubId, "phx_join", {
+        profile: { avatarId, displayName },
+        auth_token: null,
+        perms_token: null,
+        context: { mobile: false, embed: false },
+      });
+    } else {
+      console.log(`ERROR WHILE STARTING: ${JSON.stringify(body)}`);
+    }
+  } else if (command === "phx_reply" && state == STATE_JOINING) {
+    if (body.status === "ok") {
+      const hub = body.response.hubs[0];
+      console.log(`Connected to ${hub.name}.`);
+      state = STATE_CONNECTED;
+      setInterval(sendHeartbeat, 30000);
+    } else {
+      console.log(`ERROR WHILE JOINING: ${JSON.stringify(body)}`);
+    }
+  } else if (command === "message" && state === STATE_CONNECTED) {
+    console.log(body);
+    handleChatMessage(body);
+  } else if (command === "presence_diff") {
+    for (const sessionId of Object.keys(body.joins)) {
+      if (sessionId === botSessionId) continue;
+      const meta =body.joins[sessionId].metas[0];
+      if (meta.presence !== 'room') continue;
+      const displayName = meta.profile.displayName;
+      const message = `Welcome, dear ${displayName}, to my attic..I like to listen here for any sounds from the outside.. So few come in… Stay here among the paintings for a while, you will see there is no way out..But let’s play a game! In each of these images, there is one element which you must name… For each image, this will be the most central object. But beware! Name all of the elements, and I shall steal your voice. Lo, I shall join the other world. You shall also be set free, for I shall tell you the secret of the portal...`;
+      sendMessage(fullHubId, "message", { body: message, type: "chat" });
+    }
+  } else {
+    //console.log(`Unknown command ${command}`);
+  }
+}
+
+function handleChatMessage(message) {
+  if (message.type !== "chat") return;
+  // This is the user that sent the message.
+  const sessionId = message.session_id;
+  // Ignore messages we sent ourselves.
+  if (sessionId === botSessionId) return;
+  const body = message.body.trim();
+  let chatState = chatStates[sessionId] || "START";
+  // Find a suitable dialog option.
+  for (const [startState, input, output, endState] of dialogOptions) {
+    if (startState !== chatState) continue;
+    if (body.match(input)) {
+      console.log(sessionId, chatState, output);
+      setTimeout(() => {
+        sendMessage(fullHubId, "message", { body: output, type: "chat" });
+        chatState = endState;
+        chatStates[sessionId] = chatState;
+        if (chatState === 'WIN') {
+          oscClient.send("/win");
+          chatStates[sessionId] = 'START';
+        }
+      }, 500 + Math.random() * 1000);
+      break;
+    }
+  }
+}
+
+function sendHeartbeat() {
+  sendMessage("phoenix", "heartbeat", {});
+}
+
+ws.on("open", function () {
+  sendMessage("ret", "phx_join", { hub_id: hubId });
+});
+ws.on("message", receiveMessage);