109 lines
4.4 KiB
TypeScript
109 lines
4.4 KiB
TypeScript
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 { WebhookProvider } = await import("../../../../src/domain/notifications/providers/webhook.ts");
|
|
|
|
const createProvider = () => {
|
|
const logger = createMockLogger();
|
|
return { provider: new WebhookProvider(logger as any), logger };
|
|
};
|
|
|
|
testNotificationProviderContract("WebhookProvider", {
|
|
create: () => {
|
|
mockGotPost.mockResolvedValue({});
|
|
return createProvider().provider;
|
|
},
|
|
makeNotification: () => makeNotification(),
|
|
});
|
|
|
|
describe("WebhookProvider", () => {
|
|
beforeEach(() => mockGotPost.mockReset().mockResolvedValue({}));
|
|
|
|
describe("sendTestAlert", () => {
|
|
it("returns true on success", async () => {
|
|
expect(await createProvider().provider.sendTestAlert(makeNotification())).toBe(true);
|
|
});
|
|
|
|
it("returns false when address is missing", async () => {
|
|
expect(await createProvider().provider.sendTestAlert(makeNotification({ address: "" }))).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).toHaveBeenCalled();
|
|
});
|
|
|
|
it("handles non-Error thrown values", async () => {
|
|
mockGotPost.mockRejectedValue(null);
|
|
const { provider } = createProvider();
|
|
expect(await provider.sendTestAlert(makeNotification())).toBe(false);
|
|
});
|
|
});
|
|
|
|
describe("sendMessage", () => {
|
|
it("sends payload with text and structured data", async () => {
|
|
const { provider } = createProvider();
|
|
expect(await provider.sendMessage(makeNotification() as any, makeMessage())).toBe(true);
|
|
const payload = mockGotPost.mock.calls[0][1].json;
|
|
expect(payload.text).toContain("Monitor Down");
|
|
expect(payload.severity).toBe("critical");
|
|
expect(payload.monitor.id).toBe("mon-1");
|
|
});
|
|
|
|
it("returns false when address is missing", async () => {
|
|
expect(await createProvider().provider.sendMessage(makeNotification({ address: "" }) 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).toHaveBeenCalled();
|
|
});
|
|
|
|
it("handles non-Error thrown values in sendMessage", async () => {
|
|
mockGotPost.mockRejectedValue(null);
|
|
const { provider } = createProvider();
|
|
expect(await provider.sendMessage(makeNotification() as any, makeMessage())).toBe(false);
|
|
});
|
|
|
|
it("includes threshold breaches in text", async () => {
|
|
const { provider } = createProvider();
|
|
await provider.sendMessage(makeNotification() as any, makeMessageWithThresholds());
|
|
expect(mockGotPost.mock.calls[0][1].json.text).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].json.text).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].json.text).toContain("[View Incident](https://app.example.com/incidents/mon-1)");
|
|
});
|
|
|
|
it("omits threshold and incident 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].json.text;
|
|
expect(text).not.toContain("Threshold");
|
|
expect(text).not.toContain("Additional Information");
|
|
expect(text).not.toContain("View Incident");
|
|
});
|
|
});
|
|
});
|