From 6ce6d034a8d7bdbbbf119a680d2b1503908587ce Mon Sep 17 00:00:00 2001 From: Jeffrey Koehler Date: Sun, 24 Oct 2021 04:51:35 -0500 Subject: [PATCH] octopush tests --- server/notification-providers/octopush.js | 7 +- .../notification-providers/octopush.spec.js | 237 +++++++++++++++++- 2 files changed, 235 insertions(+), 9 deletions(-) diff --git a/server/notification-providers/octopush.js b/server/notification-providers/octopush.js index 9d77aa5..6ef8e39 100644 --- a/server/notification-providers/octopush.js +++ b/server/notification-providers/octopush.js @@ -6,7 +6,6 @@ class Octopush extends NotificationProvider { name = "octopush"; async send(notification, msg, monitorJSON = null, heartbeatJSON = null) { - let okMsg = "Sent Successfully."; try { // Default - V2 @@ -30,7 +29,7 @@ class Octopush extends NotificationProvider { "purpose": "alert", "sender": notification.octopushSenderName }; - await axios.post("https://api.octopush.com/v1/public/sms-campaign/send", data, config) + await axios.post("https://api.octopush.com/v1/public/sms-campaign/send", data, config); } else if (notification.octopushVersion == 1) { let data = { "user_login": notification.octopushDMLogin, @@ -49,12 +48,12 @@ class Octopush extends NotificationProvider { }, params: data }; - await axios.post("https://www.octopush-dm.com/api/sms/json", {}, config) + await axios.post("https://www.octopush-dm.com/api/sms/json", {}, config); } else { throw new Error("Unknown Octopush version!"); } - return okMsg; + return this.sendSuccess; } catch (error) { this.throwGeneralAxiosError(error); } diff --git a/server/notification-providers/octopush.spec.js b/server/notification-providers/octopush.spec.js index 3c16c3a..75ac667 100644 --- a/server/notification-providers/octopush.spec.js +++ b/server/notification-providers/octopush.spec.js @@ -1,13 +1,15 @@ -// jest.mock("nodemailer", () => ({ -// createTransport: jest.fn(), -// })); +jest.mock("axios", () => ({ + post: jest.fn(), +})); -// const mockNodeMailer = require("nodemailer"); +const axios = require("axios"); +const { UP, DOWN } = require("../../src/util"); +const NotificationSend = require("../notification"); const Octopush = require("./octopush"); beforeEach(() => { - // mockNodeMailer.createTransport.mockReset(); + axios.post.mockReset(); }); describe("notification default information", () => { @@ -16,3 +18,228 @@ describe("notification default information", () => { expect(notification.name).toBe("octopush"); }); }); + +describe("notification to act properly on send", () => { + it("should call axios with the proper default data when version 2", async () => { + + let response = { + data: { + Message: "OK" + } + }; + axios.post.mockResolvedValueOnce(response); + + let notif = new Octopush(); + let notificationConf = { + type: "octopush", + octopushVersion: 2, + octopushAPIKey: "key", + octopushLogin: "login", + octopushPhoneNumber: "number", + octopushSMSType: "type", + octopushSenderName: "sender" + }; + let monitorConf = { + type: "http", + url: "https://www.google.com", + name: "testing", + }; + let heartbeatConf = { + status: UP, + msg: "some message", + time: "example time", + }; + let msg = "PassedInMessage😀"; + let res = await notif.send(notificationConf, msg, monitorConf, heartbeatConf); + + expect(axios.post).toHaveBeenCalledWith("https://api.octopush.com/v1/public/sms-campaign/send", { + "purpose": "alert", + "recipients": [{ "phone_number": "number" }], + "sender": "sender", + "text": "PassedInMessage", + "type": "type" + }, { + "headers": { + "api-key": "key", + "api-login": "login", + "cache-control": "no-cache" + } + }); + expect(res).toBe("Sent Successfully."); + }); + it("should call axios with the proper default data when version 1", async () => { + + let response = { + data: { + Message: "OK" + } + }; + axios.post.mockResolvedValueOnce(response); + + let notif = new Octopush(); + let notificationConf = { + type: "octopush", + octopushVersion: 1, + octopushDMAPIKey: "key", + octopushDMLogin: "login", + octopushDMPhoneNumber: "number", + octopushDMSMSType: "sms_premium", + octopushDMSenderName: "sender" + }; + let monitorConf = { + type: "http", + url: "https://www.google.com", + name: "testing", + }; + let heartbeatConf = { + status: UP, + msg: "some message", + time: "example time", + }; + let msg = "PassedInMessage😀"; + + let res = await notif.send(notificationConf, msg, monitorConf, heartbeatConf); + + expect(axios.post).toHaveBeenCalledWith("https://www.octopush-dm.com/api/sms/json", { + + }, { + "headers": { + "cache-control": "no-cache" + }, + "params": { + "api_key": "key", + "sms_recipients": "number", + "sms_sender": "sender", + "sms_text": "PassedInMessage", + "sms_type": "FR", + "transactional": "1", + "user_login": "login" + } + }); + expect(res).toBe("Sent Successfully."); + }); + + it("should call axios with the proper data when monitor nil", async () => { + let response = { + data: { + Message: "OK" + } + }; + axios.post.mockResolvedValueOnce(response); + + let notif = new Octopush(); + let notificationConf = { + type: "lunasea", + lunaseaDevice: "1234", + }; + let msg = "PassedInMessage"; + + let res = await notif.send(notificationConf, msg, null, null); + + expect(axios.post).toHaveBeenCalledWith("https://api.octopush.com/v1/public/sms-campaign/send", { + "purpose": "alert", + "recipients": [{ "phone_number": undefined }], + "sender": undefined, + "text": "PassedInMessage", + "type": undefined + }, { + "headers": { + "api-key": undefined, + "api-login": undefined, + "cache-control": "no-cache" + } + }); + expect(res).toBe("Sent Successfully."); + }); + +}); + +describe("notification to act properly on error", () => { + it("should respond with an axios error on error", async () => { + + axios.post.mockImplementation(() => { + throw new Error("Test Error"); + }); + let notif = new Octopush(); + let notificationConf = { + type: "octopush", + octopushVersion: 2, + octopushAPIKey: "key", + octopushLogin: "login", + octopushPhoneNumber: "number", + octopushSMSType: "type", + octopushSenderName: "sender" + }; + let msg = "PassedInMessage"; + + try { + await notif.send(notificationConf, msg, null, null); + expect("Error thrown").toBe(false); + } catch (e) { + expect(e.message).toBe("Error: Error: Test Error "); + } + + expect(axios.post).toHaveBeenCalledWith("https://api.octopush.com/v1/public/sms-campaign/send", { + "purpose": "alert", + "recipients": [{ "phone_number": "number" }], + "sender": "sender", + "text": "PassedInMessage", + "type": "type" + }, { + "headers": { + "api-key": "key", + "api-login": "login", + "cache-control": "no-cache" + } + }); + }); + +}); + +describe("notification to get proper data from Notification.send", () => { + it("should call axios with proper data", async () => { + let response = { + data: { + Message: "OK" + } + }; + axios.post.mockResolvedValueOnce(response); + let notificationConf = { + type: "octopush", + octopushVersion: 2, + octopushAPIKey: "key", + octopushLogin: "login", + octopushPhoneNumber: "number", + octopushSMSType: "type", + octopushSenderName: "sender" + }; + let monitorConf = { + type: "http", + url: "https://www.google.com", + name: "testing", + }; + let heartbeatConf = { + status: UP, + msg: "some message", + time: "example time", + }; + + NotificationSend.Notification.init(); + let res = await NotificationSend.Notification.send(notificationConf, "Passed😀InMessage", monitorConf, heartbeatConf); + expect(axios.post).toHaveBeenCalledWith("https://api.octopush.com/v1/public/sms-campaign/send", { + "purpose": "alert", + "recipients": [{ "phone_number": "number" }], + "sender": "sender", + "text": "PassedInMessage", + "type": "type" + }, { + "headers": { + "api-key": "key", + "api-login": "login", + "cache-control": "no-cache" + } + }); + expect(res).toBe("Sent Successfully."); + }); + +});