Add test cases for notify reward amount notification type to the noti…

…ficationRouter.test.ts

config/test.env

@@ -23,6 +23,9 @@ GIVETH_IO_THIRD_PARTY_MICRO_SERVICE=givethio
 GIV_ECONOMY_THIRD_PARTY_SECRET=secret
 GIV_ECONOMY_THIRD_PARTY_MICRO_SERVICE=giveconomy-notification-service
 
+NOTIFY_REWARD_THIRD_PARTY_SECRET=secret
+NOTIFY_REWARD_THIRD_PARTY_MICRO_SERVICE=notifyreward
+
 # OPTIONAL - force logging to stdout when the value is true
 LOG_STDOUT=false
 

src/routes/v1/notificationRouter.test.ts

@@ -5,6 +5,7 @@ import {
   getAccessTokenForMockAuthMicroService,
   getGivEconomyBasicAuth,
   getGivethIoBasicAuth,
+  getNotifyRewardBasicAuth,
   serverUrl,
   sleep,
 } from '../../../test/testUtils';
@@ -2092,6 +2093,77 @@ function sendNotificationTestCases() {
     const createdNotification = await findNotificationByTrackId(trackId);
     assert.equal(createdNotification?.createdAt.getTime(), creationTime);
   });
+
+  it('should create *Notify reward amount* notification,  success', async () => {
+    const data = {
+      eventName: "Notify reward amount",
+      sendEmail: true,
+      sendSegment: true,
+      creationTime: 1667992708000,
+      email: "aliebrahimi2079@gmail.com",
+      segment: {
+        payload: {
+          round: 10,
+          date: "1667992708000",
+          amount: "12134",
+          contractAddress: "0xsfglsjfdflk",
+          farm: "test farm",
+          message: "test message",
+          network: "ethereum",
+          script: "test script",
+          transactionHash: "test txhash"
+        }
+      }
+    };
+
+    const result = await axios.post(sendNotificationUrl, data, {
+      headers: {
+        authorization: getNotifyRewardBasicAuth(),
+      },
+    });
+
+    assert.equal(result.status, 200);
+    assert.isOk(result.data);
+    assert.isTrue(result.data.success);
+  });
+  it('should create *Notify reward amount* notification, failed invalid payload', async () => {
+    try {
+      const data = {
+        eventName: "Notify reward amount",
+        sendEmail: true,
+        sendSegment: true,
+        creationTime: 1667992708000,
+        email: "aliebrahimi2079@gmail.com",
+        segment: {
+          payload: {
+            round: 10,
+            date: "1667992708000",
+            amount: "12134",
+            contractAddress: "0xsfglsjfdflk",
+            farm: "test farm",
+            message: "test message",
+            network: "ethereum",
+            script: "test script",
+            transactionHash: "test txhash",
+            invalidField: "invalid data"
+          }
+        }
+      };
+      await axios.post(sendNotificationUrl, data, {
+        headers: {
+          authorization: getNotifyRewardBasicAuth(),
+        },
+      });
+      // If request doesn't fail, it means this test failed
+      assert.isTrue(false);
+    } catch (e: any) {
+      assert.equal(
+        e.response.data.message,
+        errorMessagesEnum.IMPACT_GRAPH_VALIDATION_ERROR.message,
+      );
+      assert.equal(e.response.data.description, '"segment.payload.invalidField" is not allowed');
+    }
+  });
 }
 
 function sendBulkNotificationsTestCases() {

test/testUtils.ts

@@ -112,6 +112,13 @@ export const getGivEconomyBasicAuth = () => {
   });
 };
 
+export const getNotifyRewardBasicAuth = () => {
+  return createBasicAuthentication({
+    secret: process.env.NOTIFY_REWARD_THIRD_PARTY_SECRET as string,
+    username: process.env.NOTIFY_REWARD_THIRD_PARTY_MICRO_SERVICE as string,
+  });
+};
+
 export const getAccessTokenForMockAuthMicroService = (
   walletAddress: string,
 ) => {