Checkmate/server/test/unit/providers/notifications/signalgridProvider.test.ts

import { describe, expect, it, jest, beforeEach } from "@jest/globals";
import { createMockLogger } from "../../../helpers/createMockLogger.ts";
import { makeNotification, makeMessage, makeMessageWithThresholds, makeMessageWithIncident } from "../../../helpers/notificationMessage.ts";
import { testNotificationProviderContract } from "../../../helpers/notificationProviderContract.ts";

const mockGotPost = jest.fn().mockResolvedValue({});
jest.unstable_mockModule("got", () => ({ default: { post: mockGotPost } }));

const { SignalgridProvider } = await import("../../../../src/domain/notifications/providers/signalgrid.ts");

const createProvider = () => {
	const logger = createMockLogger();
	return { provider: new SignalgridProvider(logger as any), logger };
};

testNotificationProviderContract("SignalgridProvider", {
	create: () => {
		mockGotPost.mockResolvedValue({});
		return createProvider().provider;
	},
	makeNotification: () => makeNotification(),
});

describe("SignalgridProvider", () => {
	beforeEach(() => mockGotPost.mockReset().mockResolvedValue({}));

	describe("sendTestAlert", () => {
		it("sends to Signalgrid API and returns true", async () => {
			expect(await createProvider().provider.sendTestAlert(makeNotification())).toBe(true);
			expect(mockGotPost).toHaveBeenCalledWith(
				"https://api.signalgrid.co/v1/push",
				expect.objectContaining({
					form: expect.objectContaining({
						client_key: "token-abc",
						channel: "https://hooks.example.com/webhook",
						type: "INFO",
						critical: false,
					}),
				})
			);
		});

		it("returns false when address is missing", async () => {
			expect(await createProvider().provider.sendTestAlert(makeNotification({ address: "" }))).toBe(false);
		});

		it("returns false when accessToken is missing", async () => {
			expect(await createProvider().provider.sendTestAlert(makeNotification({ accessToken: undefined }))).toBe(false);
		});

		it("returns false and logs on error", async () => {
			mockGotPost.mockRejectedValue(new Error("fail"));
			const { provider, logger } = createProvider();
			expect(await provider.sendTestAlert(makeNotification())).toBe(false);
			expect(logger.warn).toHaveBeenCalledWith(expect.objectContaining({ method: "sendTestAlert", details: { error: "fail" } }));
		});

		it("handles non-Error thrown values in sendTestAlert", async () => {
			mockGotPost.mockRejectedValue("string error");
			const { provider, logger } = createProvider();
			expect(await provider.sendTestAlert(makeNotification())).toBe(false);
			expect(logger.warn).toHaveBeenCalledWith(expect.objectContaining({ stack: undefined, details: { error: "unknown error" } }));
		});
	});

	describe("sendMessage", () => {
		it("sends message and returns true", async () => {
			const { provider } = createProvider();
			expect(await provider.sendMessage(makeNotification() as any, makeMessage())).toBe(true);
			const form = mockGotPost.mock.calls[0][1].form;
			expect(form.body).toContain("Monitor Details:");
			expect(form.title).toBeDefined();
			expect(form.critical).toBe(false);
		});

		it("maps critical severity to CRIT", async () => {
			const { provider } = createProvider();
			const message = makeMessage();
			message.severity = "critical";
			await provider.sendMessage(makeNotification() as any, message);
			expect(mockGotPost.mock.calls[0][1].form.type).toBe("CRIT");
		});

		it("maps warning severity to WARN", async () => {
			const { provider } = createProvider();
			const message = makeMessage();
			message.severity = "warning";
			await provider.sendMessage(makeNotification() as any, message);
			expect(mockGotPost.mock.calls[0][1].form.type).toBe("WARN");
		});

		it("maps success severity to SUCCESS", async () => {
			const { provider } = createProvider();
			const message = makeMessage();
			message.severity = "success";
			await provider.sendMessage(makeNotification() as any, message);
			expect(mockGotPost.mock.calls[0][1].form.type).toBe("SUCCESS");
		});

		it("maps info severity to INFO", async () => {
			const { provider } = createProvider();
			const message = makeMessage();
			message.severity = "info";
			await provider.sendMessage(makeNotification() as any, message);
			expect(mockGotPost.mock.calls[0][1].form.type).toBe("INFO");
		});

		it("returns false when address is missing", async () => {
			expect(await createProvider().provider.sendMessage(makeNotification({ address: "" }) as any, makeMessage())).toBe(false);
		});

		it("returns false when accessToken is missing", async () => {
			expect(await createProvider().provider.sendMessage(makeNotification({ accessToken: undefined }) as any, makeMessage())).toBe(false);
		});

		it("returns false and logs on error", async () => {
			mockGotPost.mockRejectedValue(new Error("fail"));
			const { provider, logger } = createProvider();
			expect(await provider.sendMessage(makeNotification() as any, makeMessage())).toBe(false);
			expect(logger.warn).toHaveBeenCalledWith(expect.objectContaining({ method: "sendMessage" }));
		});

		it("handles non-Error thrown values in sendMessage", async () => {
			mockGotPost.mockRejectedValue(42);
			const { provider, logger } = createProvider();
			expect(await provider.sendMessage(makeNotification() as any, makeMessage())).toBe(false);
			expect(logger.warn).toHaveBeenCalledWith(expect.objectContaining({ details: { error: "unknown error" } }));
		});

		it("includes thresholds in text", async () => {
			const { provider } = createProvider();
			await provider.sendMessage(makeNotification() as any, makeMessageWithThresholds());
			expect(mockGotPost.mock.calls[0][1].form.body).toContain("CPU");
		});

		it("includes incident link in text", async () => {
			const { provider } = createProvider();
			await provider.sendMessage(makeNotification() as any, makeMessageWithIncident());
			expect(mockGotPost.mock.calls[0][1].form.body).toContain("View Incident");
		});

		it("links the incident to the monitor's incidents page", async () => {
			const { provider } = createProvider();
			await provider.sendMessage(makeNotification() as any, makeMessageWithIncident());
			expect(mockGotPost.mock.calls[0][1].form.body).toContain("View Incident: https://app.example.com/incidents/mon-1");
		});

		it("omits optional sections when not present", async () => {
			const { provider } = createProvider();
			const msg = makeMessage();
			msg.content.thresholds = undefined;
			msg.content.details = undefined;
			msg.content.incident = undefined;
			await provider.sendMessage(makeNotification() as any, msg);
			const text = mockGotPost.mock.calls[0][1].form.body;
			expect(text).not.toContain("Threshold");
			expect(text).not.toContain("Additional");
			expect(text).not.toContain("View Incident");
		});
	});
});