feat: update

.devcontainer/Dockerfile

@@ -0,0 +1,9 @@
+FROM mcr.microsoft.com/devcontainers/javascript-node:0-18
+ARG MONGO_TOOLS_VERSION=6.0
+RUN . /etc/os-release \
+    && curl -sSL "https://www.mongodb.org/static/pgp/server-${MONGO_TOOLS_VERSION}.asc" | gpg --dearmor > /usr/share/keyrings/mongodb-archive-keyring.gpg \
+    && echo "deb [arch=$(dpkg --print-architecture) signed-by=/usr/share/keyrings/mongodb-archive-keyring.gpg] http://repo.mongodb.org/apt/debian ${VERSION_CODENAME}/mongodb-org/${MONGO_TOOLS_VERSION} main" | tee /etc/apt/sources.list.d/mongodb-org-${MONGO_TOOLS_VERSION}.list \
+    && apt-get update && export DEBIAN_FRONTEND=noninteractive \
+    && apt-get install -y mongodb-mongosh \
+    && if [ "$(dpkg --print-architecture)" = "amd64" ]; then apt-get install -y mongodb-database-tools; fi \
+    && apt-get clean -y && rm -rf /var/lib/apt/lists/*

.devcontainer/devcontainer.json

@@ -0,0 +1,15 @@
+{
+	"name": "Node.js & Mongo DB",
+	"dockerComposeFile": "docker-compose.yml",
+	"service": "app",
+	"workspaceFolder": "/workspaces/${localWorkspaceFolderBasename}",
+	"customizations": {
+		"vscode": {
+			"extensions": [
+				"mongodb.mongodb-vscode"
+			]
+		}
+	},
+	"forwardPorts": [3000, 3500, 8081],
+	"postCreateCommand": "npm install"
+}

.devcontainer/docker-compose.yml

@@ -0,0 +1,27 @@
+version: '3.8'
+
+services:
+  app:
+    build: 
+      context: .
+      dockerfile: Dockerfile
+    container_name: local-app
+    volumes:
+      - ../..:/workspaces:cached
+    command: sleep infinity
+    network_mode: service:mongo
+
+  mongo:
+    image: mongo:latest
+    container_name: local-mongo
+    restart: unless-stopped
+
+  express:
+    image: mongo-express:latest
+    container_name: local-express
+    restart: unless-stopped
+    environment:
+      ME_CONFIG_BASICAUTH_USERNAME: developer
+      ME_CONFIG_BASICAUTH_PASSWORD: developer
+      ME_CONFIG_MONGODB_SERVER: local-mongo
+    network_mode: service:mongo

.env.sample

@@ -1,13 +1,19 @@
+# node env ('production' or 'development')
+NODE_ENV="development"
+
+# general
+MONGODB_URI="mongodb://local-mongo:27017/app"
+GOOGLE_AI_API_KEY="your_google_ai_api_key"
+
+# discord integration
 DISCORD_APP_ID="00000"
 DISCORD_BOT_TOKEN="your_discord_bot_token"
-
 DISCORD_GUILD_ID="00000"
-DISCORD_ROLE_ID_ADMIN="00000"
-DISCORD_CHANNEL_ID_TERMINAL="00000"
+DISCORD_GUILD_ROLE_ID_ADMIN="00000"
+DISCORD_GUILD_CHANNEL_ID_TERMINAL="00000"
 
+# matrix integration
 MATRIX_HOMESERVER="https://matrix.org"
 MATRIX_USERNAME="your_matrix_username" # e.g. @nymph57021218:matrix.org
 MATRIX_PASSWORD="your_matrix_password"
 MATRIX_ACCESS_TOKEN="your_matrix_access_token"
-
-GOOGLE_AI_API_KEY="your_google_ai_api_key"

.gitignore

@@ -4,6 +4,9 @@ prompts.json
 relay.json
 roles.json
 
+# App data files
+data/
+
 # Finder config file
 .DS_Store
 

app.js

@@ -1,20 +1,30 @@
 "use strict";
 
-require("dotenv").config();
+const {
+    runLoader,
+    getMust,
+} = require("./src/config");
+const {
+    prepare,
+} = require("./src/clients/database");
 
-const runners = [];
+runLoader();
 
-if (process.env.MATRIX_ACCESS_TOKEN) {
+const runners = [];
+if (getMust("MATRIX_ACCESS_TOKEN")) {
     runners.push(require("./src/matrix"));
 }
-if (process.env.DISCORD_BOT_TOKEN) {
+if (getMust("DISCORD_BOT_TOKEN")) {
     runners.push(require("./src/discord"));
 }
 
-Promise.all(runners.map(
-    (runner) => runner(),
-)).then(() => {
-    console.info("Nymph 系統 成功啟動");
-}).catch((e) => {
-    console.error("Nymph 系統 啟動失敗：", e);
-});
+(async () => {
+    await prepare();
+    await Promise.all(runners.map(
+        (runner) => runner(),
+    )).then(() => {
+        console.info("Nymph 系統 成功啟動");
+    }).catch((e) => {
+        console.error("Nymph 系統 啟動失敗：", e);
+    });
+})();

matrix_access.js

@@ -1,33 +0,0 @@
-"use strict";
-
-require("dotenv").config();
-
-const {
-    createClient,
-} = require("matrix-js-sdk");
-
-const {
-    MATRIX_HOMESERVER: homeserverUrl,
-    MATRIX_USERNAME: username,
-    MATRIX_PASSWORD: password,
-} = process.env;
-
-console.info(
-    "Get the AccessToken from Matrix",
-    `(homeserver: ${homeserverUrl || "undefined"})`,
-    "\n",
-);
-
-const client = createClient({baseUrl: homeserverUrl});
-client.login("m.login.password", {
-    identifier: {
-        type: "m.id.user",
-        user: username,
-    },
-    password,
-}).then((response) => {
-    console.info("UserId:", response.user_id);
-    console.info("AccessToken:", response.access_token);
-}).catch((e) => {
-    console.error("Unauthorized", e);
-});

nodemon.json

@@ -0,0 +1,5 @@
+{   
+    "ignore": [
+        "data"
+    ] 
+}

package.json

@@ -20,13 +20,15 @@
   "dependencies": {
     "@discordjs/rest": "^2.2.0",
     "@google/generative-ai": "^0.2.1",
+    "@matrix-org/matrix-sdk-crypto-nodejs": "^0.1.0-beta.12",
     "discord-api-types": "^0.37.65",
     "discord.js": "^14.14.1",
     "discordjs-reaction-role": "^3.1.0",
     "dotenv": "^16.3.1",
     "express": "^4.18.2",
     "jsonwebtoken": "^9.0.2",
-    "matrix-js-sdk": "^32.1.0"
+    "matrix-bot-sdk": "^0.7.1",
+    "mongoose": "^8.3.4"
   },
   "devDependencies": {
     "@commitlint/cli": "^17.6.5",

register_commands.js

@@ -1,6 +1,8 @@
 "use strict";
 
-require("dotenv").config();
+const {
+    getMust,
+} = require("./src/config");
 
 const {useRestClient} = require("./src/clients/discord");
 const {Routes} = require("discord-api-types/v9");
@@ -30,8 +32,8 @@ console.info(commands);
 
         await client.put(
             Routes.applicationGuildCommands(
-                process.env.DISCORD_APP_ID,
-                process.env.GUILD_ID,
+                getMust("DISCORD_APP_ID"),
+                getMust("DISCORD_GUILD_ID"),
             ),
             {body: commands},
         );

relay.sample.json

@@ -2,6 +2,6 @@
     {
         "name": "Arona",
         "discordChannelId": "996069746514612235",
-        "matrixRoomId": "#line:matrix.org"
+        "matrixRoomId": "!yTRzUDNyviBhrMwYGG:matrix.org"
     }
 ]

src/bridges/discord_matrix.js

@@ -3,10 +3,6 @@
 
 const discord = require("discord.js");
 
-const {
-    MsgType,
-} = require("matrix-js-sdk");
-
 const {
     useClient,
 } = require("../clients/matrix");
@@ -15,15 +11,15 @@ const {
     find,
 } = require("./utils");
 
-const client = useClient();
-
 /**
  * This function is called when a message is created in Discord.
  *
  * @param {discord.Message} message
  * @return {void}
  */
 module.exports = async (message) => {
+    const client = await useClient();
+
     const {channelId} = message;
 
     const relayTarget = find("discordChannelId", channelId);
@@ -38,7 +34,7 @@ module.exports = async (message) => {
     const {content: text} = message;
 
     await client.sendMessage(roomId, {
-        msgtype: MsgType.Text,
+        msgtype: "m.text",
         format: "plain/text",
         body: `${username} ⬗ Discord\n${text}`,
     });

src/bridges/matrix_discord.js

@@ -1,11 +1,6 @@
 "use strict";
 // Trasnfer messages from Discord to Matrix.
 
-const {
-    RoomEvent,
-    Room,
-} = require("matrix-js-sdk");
-
 const {
     useClient,
 } = require("../clients/discord");
@@ -14,18 +9,15 @@ const {
     find,
 } = require("./utils");
 
-const client = useClient();
-
 /**
  * This function is called when a new event is added to the timeline of a room.
  *
- * @param {RoomEvent} roomEvent - The event that triggered this function.
- * @param {Room} room - The room that the event was sent in.
- * @param {Date} _toStartOfTimeline - The date of the first event.
+ * @param {string} roomId - The room that the event was sent in.
+ * @param {any} event - The event that triggered this function.
  * @return {void}
  */
-module.exports = async (roomEvent, room, _toStartOfTimeline) => {
-    const {roomId} = room;
+module.exports = async (roomId, event) => {
+    const client = await useClient();
 
     const relayTarget = find("matrixRoomId", roomId);
     if (!relayTarget) {
@@ -35,8 +27,8 @@ module.exports = async (roomEvent, room, _toStartOfTimeline) => {
         discordChannelId: channelId,
     } = relayTarget;
 
-    const {sender: username} = roomEvent.event;
-    const {body: text} = roomEvent.event.content;
+    const {sender: username, content} = event;
+    const {body: text} = content;
 
     const channel = await client.channels.fetch(channelId);
     await channel.send(`\`${username}\` ⬗ Matrix\n${text}`);

src/clients/database.js

@@ -0,0 +1,18 @@
+"use strict";
+// mongoose is an ODM library for MongoDB.
+
+// Import config
+const {getMust} = require("../config");
+
+// Import mongoose
+const database = require("mongoose");
+
+// Configure mongose
+database.set("strictQuery", true);
+
+// Connect to MongoDB
+exports.prepare = () =>
+    database.connect(getMust("MONGODB_URI"));
+
+// Export as useFunction
+exports.useDatabase = () => database;

src/clients/discord.js

@@ -1,6 +1,10 @@
 "use strict";
 // Discord is a proprietary instant messaging platform.
 
+const {
+    getMust,
+} = require("../config");
+
 const {
     REST,
 } = require("@discordjs/rest");
@@ -11,7 +15,9 @@ const {
     GatewayIntentBits,
 } = require("discord.js");
 
-const newClient = () => {
+const botToken = getMust("DISCORD_BOT_TOKEN");
+
+const newClient = async () => {
     const client = new Client({
         partials: [
             Partials.Channel,
@@ -28,28 +34,32 @@ const newClient = () => {
             GatewayIntentBits.MessageContent,
         ],
     });
-    client.login(process.env.DISCORD_BOT_TOKEN);
+    client.login(botToken);
     return client;
 };
 
+/**
+ * The cached client.
+ * @type {Client|undefined}
+ */
 let client;
 /**
  * Use Discord client
  *
  * @param {boolean} cached - Use the cached client
  * @return {Client} - The client
  */
-exports.useClient = (cached = true) => {
+exports.useClient = async (cached = true) => {
     if (cached && client) {
         return client;
     }
-    client = newClient();
+    client = await newClient();
     return client;
 };
 
 exports.useRestClient = () => {
     const restClient = new REST({version: "10"});
-    restClient.setToken(process.env.DISCORD_BOT_TOKEN);
+    restClient.setToken(botToken);
     return restClient;
 };
 

src/clients/gemini.js

@@ -1,9 +1,10 @@
 "use strict";
 // Gemini is a generative AI model developed by Google.
 
+const {getMust} = require("../config");
 const {GoogleGenerativeAI} = require("@google/generative-ai");
 
-const client = new GoogleGenerativeAI(process.env.GOOGLE_AI_API_KEY);
+const client = new GoogleGenerativeAI(getMust("GOOGLE_AI_API_KEY"));
 const model = client.getGenerativeModel({model: "gemini-pro"});
 
 const chatSessions = {};