Merge branch 'master' into async-fs

.github/workflows/auto-test.yml

@@ -45,7 +45,7 @@ jobs:
     needs: [ check-linters ]
     runs-on: ${{ matrix.os }}
     timeout-minutes: 15
-    if: ${{ github.repository == 'louislam/uptime-kuma' }}
+
     strategy:
       matrix:
         os: [ ARMv7 ]

CONTRIBUTING.md

@@ -427,33 +427,7 @@ Currently, there are 3 maintainers:
 ### Procedures
 
 We have a few procedures we follow. These are documented here:
-- <details><summary>Set up a Docker Builder</summary>
-  <p>
 
-  - amd64, armv7 using local.
-  - arm64 using remote arm64 cpu, as the emulator is too slow and can no longer pass the `npm ci` command.
-     1. Add the public key to the remote server.
-     2. Add the remote context. The remote machine must be arm64 and installed Docker CE. 
-        ```
-        docker context create oracle-arm64-jp --docker "host=ssh://root@100.107.174.88"
-        ```
-     3. Create a new builder.
-        ```
-        docker buildx create --name kuma-builder --platform linux/amd64,linux/arm/v7
-        docker buildx use kuma-builder
-        docker buildx inspect --bootstrap
-        ```
-     4. Append the remote context to the builder.
-        ```
-        docker buildx create --append --name kuma-builder --platform linux/arm64 oracle-arm64-jp
-        ```
-     5. Verify the builder and check if the builder is using `kuma-builder`.
-        ```
-        docker buildx inspect kuma-builder
-        docker buildx ls
-        ```
-  </p>
-  </details>
 - <details><summary>Release</summary>
   <p>
 
@@ -516,3 +490,28 @@ We have a few procedures we follow. These are documented here:
   
   </p>
   </details>
+
+### Set up a Docker Builder
+
+- amd64, armv7 using local.
+- arm64 using remote arm64 cpu, as the emulator is too slow and can no longer pass the `npm ci` command.
+   1. Add the public key to the remote server.
+   2. Add the remote context. The remote machine must be arm64 and installed Docker CE. 
+      ```
+      docker context create oracle-arm64-jp --docker "host=ssh://root@100.107.174.88"
+      ```
+   3. Create a new builder.
+      ```
+      docker buildx create --name kuma-builder --platform linux/amd64,linux/arm/v7
+      docker buildx use kuma-builder
+      docker buildx inspect --bootstrap
+      ```
+   4. Append the remote context to the builder.
+      ```
+      docker buildx create --append --name kuma-builder --platform linux/arm64 oracle-arm64-jp
+      ```
+   5. Verify the builder and check if the builder is using `kuma-builder`.
+      ```
+      docker buildx inspect kuma-builder
+      docker buildx ls
+      ```

db/knex_migrations/2023-10-13-1200-add-custom-html.js

@@ -1,14 +0,0 @@
-exports.up = function (knex) {
-    // Insert column for custom HTML code
-    return knex.schema
-        .alterTable("status_page", function (table) {
-            table.text("custom_html").nullable().defaultTo(null);
-        });
-};
-
-exports.down = function (knex) {
-    return knex.schema
-        .alterTable("status_page", function (table) {
-            table.dropColumn("custom_html");
-        });
-};

package-lock.json

@@ -74,7 +74,7 @@
                 "socket.io": "~4.6.1",
                 "socket.io-client": "~4.6.1",
                 "socks-proxy-agent": "6.1.1",
-                "sqlite3": "~5.1.7",
+                "sqlite3": "^5.1.7",
                 "tar": "~6.2.1",
                 "tcp-ping": "~0.1.1",
                 "thirty-two": "~1.0.2",

server/docker.js

@@ -1,10 +1,10 @@
 const axios = require("axios");
 const { R } = require("redbean-node");
 const https = require("https");
-const fs = require("fs");
+const fs = require("fs/promises");
 const path = require("path");
 const Database = require("./database");
-const { axiosAbortSignal } = require("./util-server");
+const { axiosAbortSignal, fileExists } = require("./util-server");
 
 class DockerHost {
 
@@ -81,7 +81,7 @@ class DockerHost {
             options.socketPath = dockerHost.dockerDaemon;
         } else if (dockerHost.dockerType === "tcp") {
             options.baseURL = DockerHost.patchDockerURL(dockerHost.dockerDaemon);
-            options.httpsAgent = new https.Agent(DockerHost.getHttpsAgentOptions(dockerHost.dockerType, options.baseURL));
+            options.httpsAgent = new https.Agent(await DockerHost.getHttpsAgentOptions(dockerHost.dockerType, options.baseURL));
         }
 
         try {
@@ -143,7 +143,7 @@ class DockerHost {
      * @param {string} url The docker host URL rewritten to https://
      * @returns {object} HTTP agent options
      */
-    static getHttpsAgentOptions(dockerType, url) {
+    static async getHttpsAgentOptions(dockerType, url) {
         let baseOptions = {
             maxCachedSessions: 0,
             rejectUnauthorized: true
@@ -156,10 +156,10 @@ class DockerHost {
         let certPath = path.join(Database.dockerTLSDir, dirName, DockerHost.CertificateFileNameCert);
         let keyPath = path.join(Database.dockerTLSDir, dirName, DockerHost.CertificateFileNameKey);
 
-        if (dockerType === "tcp" && fs.existsSync(caPath) && fs.existsSync(certPath) && fs.existsSync(keyPath)) {
-            let ca = fs.readFileSync(caPath);
-            let key = fs.readFileSync(keyPath);
-            let cert = fs.readFileSync(certPath);
+        if (dockerType === "tcp" && await fileExists(caPath) && await fileExists(certPath) && await fileExists(keyPath)) {
+            let ca = await fs.readFile(caPath);
+            let key = await fs.readFile(keyPath);
+            let cert = await fs.readFile(certPath);
             certOptions = {
                 ca,
                 key,

server/model/monitor.js

@@ -747,7 +747,7 @@ class Monitor extends BeanModel {
                     } else if (dockerHost._dockerType === "tcp") {
                         options.baseURL = DockerHost.patchDockerURL(dockerHost._dockerDaemon);
                         options.httpsAgent = new https.Agent(
-                            DockerHost.getHttpsAgentOptions(dockerHost._dockerType, options.baseURL)
+                            await DockerHost.getHttpsAgentOptions(dockerHost._dockerType, options.baseURL)
                         );
                     }
 
@@ -897,6 +897,7 @@ class Monitor extends BeanModel {
                 retries = 0;
 
             } catch (error) {
+
                 if (error?.name === "CanceledError") {
                     bean.msg = `timeout by AbortSignal (${this.timeout}s)`;
                 } else {
@@ -969,7 +970,6 @@ class Monitor extends BeanModel {
             } else if (bean.status === MAINTENANCE) {
                 log.warn("monitor", `Monitor #${this.id} '${this.name}': Under Maintenance | Type: ${this.type}`);
             } else {
-                beatInterval = this.retryInterval;
                 log.warn("monitor", `Monitor #${this.id} '${this.name}': Failing: ${bean.msg} | Interval: ${beatInterval} seconds | Type: ${this.type} | Down Count: ${bean.downCount} | Resend Interval: ${this.resendInterval}`);
             }
 

server/model/status_page.js

@@ -66,10 +66,6 @@ class StatusPage extends BeanModel {
             head.append($(escapedGoogleAnalyticsScript));
         }
 
-        if (process.env.UPTIME_KUMA_ALLOW_CUSTOM_HTML === "1") {
-            head.append(statusPage.customHtml);
-        }
-
         // OG Meta Tags
         let ogTitle = $("<meta property=\"og:title\" content=\"\" />").attr("content", statusPage.title);
         head.append(ogTitle);
@@ -251,7 +247,6 @@ class StatusPage extends BeanModel {
             showPoweredBy: !!this.show_powered_by,
             googleAnalyticsId: this.google_analytics_tag_id,
             showCertificateExpiry: !!this.show_certificate_expiry,
-            customHtml: this.custom_html
         };
     }
 
@@ -275,7 +270,6 @@ class StatusPage extends BeanModel {
             showPoweredBy: !!this.show_powered_by,
             googleAnalyticsId: this.google_analytics_tag_id,
             showCertificateExpiry: !!this.show_certificate_expiry,
-            customHtml: this.custom_html
         };
     }
 

server/notification-providers/feishu.js

@@ -25,29 +25,25 @@ class Feishu extends NotificationProvider {
 
             if (heartbeatJSON["status"] === DOWN) {
                 let downdata = {
-                    msg_type: "interactive",
-                    card: {
-                        config: {
-                            update_multi: false,
-                            wide_screen_mode: true,
-                        },
-                        header: {
-                            title: {
-                                tag: "plain_text",
-                                content: "UptimeKuma Alert: [Down] " + monitorJSON["name"],
+                    msg_type: "post",
+                    content: {
+                        post: {
+                            zh_cn: {
+                                title: "UptimeKuma Alert: [Down] " + monitorJSON["name"],
+                                content: [
+                                    [
+                                        {
+                                            tag: "text",
+                                            text:
+                                                "[Down] " +
+                                                heartbeatJSON["msg"] +
+                                                `\nTime (${heartbeatJSON["timezone"]}): ${heartbeatJSON["localDateTime"]}`
+                                        },
+                                    ],
+                                ],
                             },
-                            template: "red",
                         },
-                        elements: [
-                            {
-                                tag: "div",
-                                text: {
-                                    tag: "lark_md",
-                                    content: getContent(heartbeatJSON),
-                                },
-                            }
-                        ]
-                    }
+                    },
                 };
                 await axios.post(notification.feishuWebHookUrl, downdata);
                 return okMsg;
@@ -55,29 +51,25 @@ class Feishu extends NotificationProvider {
 
             if (heartbeatJSON["status"] === UP) {
                 let updata = {
-                    msg_type: "interactive",
-                    card: {
-                        config: {
-                            update_multi: false,
-                            wide_screen_mode: true,
-                        },
-                        header: {
-                            title: {
-                                tag: "plain_text",
-                                content: "UptimeKuma Alert: [UP] " + monitorJSON["name"],
+                    msg_type: "post",
+                    content: {
+                        post: {
+                            zh_cn: {
+                                title: "UptimeKuma Alert: [Up] " + monitorJSON["name"],
+                                content: [
+                                    [
+                                        {
+                                            tag: "text",
+                                            text:
+                                                "[Up] " +
+                                                heartbeatJSON["msg"] +
+                                                `\nTime (${heartbeatJSON["timezone"]}): ${heartbeatJSON["localDateTime"]}`,
+                                        },
+                                    ],
+                                ],
                             },
-                            template: "green",
                         },
-                        elements: [
-                            {
-                                tag: "div",
-                                text: {
-                                    tag: "lark_md",
-                                    content: getContent(heartbeatJSON),
-                                },
-                            },
-                        ]
-                    }
+                    },
                 };
                 await axios.post(notification.feishuWebHookUrl, updata);
                 return okMsg;
@@ -88,17 +80,4 @@ class Feishu extends NotificationProvider {
     }
 }
 
-/**
- * Get content
- * @param {?object} heartbeatJSON Heartbeat details (For Up/Down only)
- * @returns {string} Return Successful Message
- */
-function getContent(heartbeatJSON) {
-    return [
-        "**Message**: " + heartbeatJSON["msg"],
-        "**Ping**: " + (heartbeatJSON["ping"] == null ? "N/A" : heartbeatJSON["ping"] + " ms"),
-        `**Time (${heartbeatJSON["timezone"]})**: ${heartbeatJSON["localDateTime"]}`
-    ].join("\n");
-}
-
 module.exports = Feishu;

server/routers/api-router.js

@@ -44,8 +44,9 @@ router.get("/api/entry-page", async (request, response) => {
     response.json(result);
 });
 
-router.all("/api/push/:pushToken", async (request, response) => {
+router.get("/api/push/:pushToken", async (request, response) => {
     try {
+
         let pushToken = request.params.pushToken;
         let msg = request.query.msg || "OK";
         let ping = parseFloat(request.query.ping) || null;

server/socket-handlers/general-socket-handler.js

@@ -4,7 +4,7 @@ const { sendInfo } = require("../client");
 const { checkLogin } = require("../util-server");
 const GameResolver = require("gamedig/lib/GameResolver");
 const { testChrome } = require("../monitor-types/real-browser-monitor-type");
-const fs = require("fs");
+const fs = require("fs/promises");
 const path = require("path");
 
 let gameResolver = new GameResolver();
@@ -85,17 +85,17 @@ module.exports.generalSocketHandler = (socket, server) => {
         }
     });
 
-    socket.on("getPushExample", (language, callback) => {
+    socket.on("getPushExample", async (language, callback) => {
 
         try {
             let dir = path.join("./extra/push-examples", language);
-            let files = fs.readdirSync(dir);
+            let files = await fs.readdir(dir);
 
             for (let file of files) {
                 if (file.startsWith("index.")) {
                     callback({
                         ok: true,
-                        code: fs.readFileSync(path.join(dir, file), "utf8"),
+                        code: await fs.readFile(path.join(dir, file), "utf8"),
                     });
                     return;
                 }

server/socket-handlers/status-page-socket-handler.js

@@ -101,11 +101,10 @@ module.exports.statusPageSocketHandler = (socket) => {
             if (!statusPage) {
                 throw new Error("No slug?");
             }
-            const config = await statusPage.toJSON();
-            config.allowEditingCustomHtml = import.meta.env.UPTIME_KUMA_ALLOW_CUSTOM_HTML === "1";
+
             callback({
                 ok: true,
-                config,
+                config: await statusPage.toJSON(),
             });
         } catch (error) {
             callback({
@@ -168,9 +167,6 @@ module.exports.statusPageSocketHandler = (socket) => {
             statusPage.show_certificate_expiry = config.showCertificateExpiry;
             statusPage.modified_date = R.isoDateTime();
             statusPage.google_analytics_tag_id = config.googleAnalyticsId;
-            if (process.env.UPTIME_KUMA_ALLOW_CUSTOM_HTML === "1") {
-                statusPage.custom_html = config.customHtml;
-            }
 
             await R.store(statusPage);
 

server/util-server.js

@@ -19,6 +19,7 @@ const radiusClient = require("node-radius-client");
 const redis = require("redis");
 const oidc = require("openid-client");
 const tls = require("tls");
+const fs = require("fs");
 
 const {
     dictionaries: {
@@ -1062,3 +1063,9 @@ module.exports.axiosAbortSignal = (timeoutMs) => {
         }
     }
 };
+
+module.exports.fileExists = (file) => {
+    return fs.promises.access(file, fs.constants.F_OK)
+        .then(() => true)
+        .catch(() => false);
+};

src/lang/en.json

@@ -776,9 +776,6 @@
     "wayToGetClickSendSMSToken": "You can get API Username and API Key from {0} .",
     "Custom Monitor Type": "Custom Monitor Type",
     "Google Analytics ID": "Google Analytics ID",
-    "Custom HTML": "Custom HTML",
-    "customHtmlEnvVarDisabled": "environment variable {allow_custom_html} must be set to inject html to the head",
-    "customHtmlEnvVarEnabled": "Because the environment variable {allow_custom_html} is set, arbitrary html can be injected into the head. Make sure to remove the environment variable after use",
     "Edit Tag": "Edit Tag",
     "Server Address": "Server Address",
     "Learn More": "Learn More",

src/layouts/Layout.vue

@@ -211,20 +211,6 @@ export default {
 @import "../assets/vars.scss";
 
 .nav-link {
-    &:hover {
-        background-color: $primary;
-        color: #fff;
-
-        .dark & {
-            background-color: $primary;
-            color: #000;
-        }
-
-        &.active {
-            background-color: $highlight;
-        }
-    }
-
     &.status-page {
         background-color: rgba(255, 255, 255, 0.1);
     }

src/pages/EditMonitor.vue

@@ -370,10 +370,9 @@
                                     <label for="jsonPath" class="form-label">{{ $t("Json Query") }}</label>
                                     <input id="jsonPath" v-model="monitor.jsonPath" type="text" class="form-control" required>
 
-                                    <i18n-t tag="div" class="form-text" keypath="jsonQueryDescription">
-                                        <a href="https://jsonata.org/">jsonata.org</a>
-                                        <a href="https://try.jsonata.org/">{{ $t('here') }}</a>
-                                    </i18n-t>
+                                    <!-- eslint-disable-next-line vue/no-v-html -->
+                                    <div class="form-text" v-html="$t('jsonQueryDescription')">
+                                    </div>
                                     <br>
 
                                     <label for="expectedValue" class="form-label">{{ $t("Expected Value") }}</label>

src/pages/StatusPage.vue

@@ -104,22 +104,6 @@
                     <prism-editor v-model="config.customCSS" class="css-editor" :highlight="highlighter" line-numbers></prism-editor>
                 </div>
 
-                <!-- Custom HTML -->
-                <div class="my-3">
-                    <div class="mb-1">{{ $t("Custom HTML") }}</div>
-                    <prism-editor v-model="config.customHtml" class="css-editor" :highlight="highlighter" line-numbers :readonly="!config.allowEditingCustomHtml"></prism-editor>
-                    <i18n-t v-if="config.allowEditingCustomHtml" tag="div" class="form-text" keypath="customHtmlEnvVarEnabled">
-                        <template #allow_custom_html>
-                            <code>UPTIME_KUMA_ALLOW_CUSTOM_HTML</code>
-                        </template>
-                    </i18n-t>
-                    <i18n-t v-else tag="div" class="form-text" keypath="customHtmlEnvVarDisabled">
-                        <template #allow_custom_html>
-                            <code>UPTIME_KUMA_ALLOW_CUSTOM_HTML=1</code>
-                        </template>
-                    </i18n-t>
-                </div>
-
                 <div class="danger-zone">
                     <button class="btn btn-danger me-2" @click="deleteDialog">
                         <font-awesome-icon icon="trash" />