uptime-kuma/test/backend-test/monitors/test-mysql.js

const { describe, test } = require("node:test");
const assert = require("node:assert");
const { MariaDbContainer } = require("@testcontainers/mariadb");
const { MysqlMonitorType } = require("../../../server/monitor-types/mysql");
const { UP, PENDING } = require("../../../src/util");

/**
 * Helper function to create and start a MariaDB container
 * @returns {Promise<{container: MariaDbContainer, connectionString: string}>} The started container and connection string
 */
async function createAndStartMariaDBContainer() {
    const container = await new MariaDbContainer("mariadb:10.11")
        .withStartupTimeout(90000)
        .start();

    const connectionString = `mysql://${container.getUsername()}:${container.getUserPassword()}@${container.getHost()}:${container.getPort()}/${container.getDatabase()}`;

    return {
        container,
        connectionString
    };
}

describe(
    "MySQL/MariaDB Monitor",
    {
        skip:
            !!process.env.CI &&
            (process.platform !== "linux" || process.arch !== "x64"),
    },
    () => {
        test("check() sets status to UP when MariaDB server is reachable", async () => {
            const { container, connectionString } = await createAndStartMariaDBContainer();

            const mysqlMonitor = new MysqlMonitorType();
            const monitor = {
                databaseConnectionString: connectionString,
                conditions: "[]",
            };

            const heartbeat = {
                msg: "",
                status: PENDING,
            };

            try {
                await mysqlMonitor.check(monitor, heartbeat, {});
                assert.strictEqual(
                    heartbeat.status,
                    UP,
                    `Expected status ${UP} but got ${heartbeat.status}`
                );
            } finally {
                await container.stop();
            }
        });

        test("check() rejects when MariaDB server is not reachable", async () => {
            const mysqlMonitor = new MysqlMonitorType();
            const monitor = {
                databaseConnectionString:
                    "mysql://invalid:invalid@localhost:13306/test",
                conditions: "[]",
            };

            const heartbeat = {
                msg: "",
                status: PENDING,
            };

            await assert.rejects(
                mysqlMonitor.check(monitor, heartbeat, {}),
                (err) => {
                    assert.ok(
                        err.message.includes("Database connection/query failed"),
                        `Expected error message to include "Database connection/query failed" but got: ${err.message}`
                    );
                    return true;
                }
            );
            assert.notStrictEqual(
                heartbeat.status,
                UP,
                `Expected status should not be ${UP}`
            );
        });

        test("check() sets status to UP when custom query result meets condition", async () => {
            const { container, connectionString } = await createAndStartMariaDBContainer();

            const mysqlMonitor = new MysqlMonitorType();
            const monitor = {
                databaseConnectionString: connectionString,
                databaseQuery: "SELECT 42 AS value",
                conditions: JSON.stringify([
                    {
                        type: "expression",
                        andOr: "and",
                        variable: "result",
                        operator: "equals",
                        value: "42",
                    },
                ]),
            };

            const heartbeat = {
                msg: "",
                status: PENDING,
            };

            try {
                await mysqlMonitor.check(monitor, heartbeat, {});
                assert.strictEqual(
                    heartbeat.status,
                    UP,
                    `Expected status ${UP} but got ${heartbeat.status}`
                );
            } finally {
                await container.stop();
            }
        });

        test("check() rejects when custom query result does not meet condition", async () => {
            const { container, connectionString } = await createAndStartMariaDBContainer();

            const mysqlMonitor = new MysqlMonitorType();
            const monitor = {
                databaseConnectionString: connectionString,
                databaseQuery: "SELECT 99 AS value",
                conditions: JSON.stringify([
                    {
                        type: "expression",
                        andOr: "and",
                        variable: "result",
                        operator: "equals",
                        value: "42",
                    },
                ]),
            };

            const heartbeat = {
                msg: "",
                status: PENDING,
            };

            try {
                await assert.rejects(
                    mysqlMonitor.check(monitor, heartbeat, {}),
                    new Error(
                        "Query result did not meet the specified conditions (99)"
                    )
                );
                assert.strictEqual(
                    heartbeat.status,
                    PENDING,
                    `Expected status should not be ${heartbeat.status}`
                );
            } finally {
                await container.stop();
            }
        });
    }
);