fix: send notifications to test channel

src/actions/artifact.ts

@@ -1,4 +1,4 @@
-import { Context, Event, TransactionEvent } from "@tenderly/actions";
+import { Context, Event, Network, TransactionEvent } from "@tenderly/actions";
 import { emitter } from "./emitter";
 import { getHardwareRentedEvent } from "./logParsing";
 import { HardwareRented } from "./types";
@@ -8,7 +8,8 @@ import { formatEther } from "ethers/lib/utils";
 
 const handleHardwareRentedEvent = async (
   transactionEvent: TransactionEvent,
-  hardwareRentedEvent: HardwareRented
+  hardwareRentedEvent: HardwareRented, 
+  network?: Network
 ) => {
   const { user, nodeID, hardwareProviderName, duration, payment } =
     hardwareRentedEvent;
@@ -31,16 +32,17 @@ const handleHardwareRentedEvent = async (
     duration: duration.toString(),
     payment: payment.toString(),
   };
-  await emitter.emit(undefined, workflowData);
+  await emitter.emit(undefined, workflowData, undefined, network);
 };
 
 export const hardwareRented = async (context: Context, event: Event) => {
   await initServices(context);
   const transactionEvent = event as TransactionEvent;
+  const network = context.metadata.getNetwork()
 
   const hardwareRentedEvent = await getHardwareRentedEvent(transactionEvent);
   if (hardwareRentedEvent) {
-    await handleHardwareRentedEvent(transactionEvent, hardwareRentedEvent);
+    await handleHardwareRentedEvent(transactionEvent, hardwareRentedEvent, network);
   } else {
     throw new Error("No Withdraw or Deposit event found");
   }

src/actions/emitter.ts

@@ -1,7 +1,8 @@
+import { Network } from "@tenderly/actions";
 import { WebhookMessageCreateOptions } from "discord.js";
 
 export abstract class Client {
-  abstract sendMessage(message?: WebhookMessageCreateOptions, workflowData?: any, body?: any): Promise<void>;
+  abstract sendMessage(message?: WebhookMessageCreateOptions, workflowData?: any, body?: any, network?: Network): Promise<void>;
   abstract clientId: string; // This should be a unique id to identify the client
 }
 
@@ -19,9 +20,9 @@ export class Emitter {
     this._clients.set(client.clientId, client);
   }
 
-  async emit(message?: WebhookMessageCreateOptions, workflowData?: any, body?: any) {
+  async emit(message?: WebhookMessageCreateOptions, workflowData?: any, body?: any, network?: Network) {
     const messagePromises = Array.from(this._clients.values()).map((client) =>
-      client.sendMessage(message, workflowData, body)
+      client.sendMessage(message, workflowData, body, network)
     );
     await Promise.all(messagePromises);
   }

src/actions/knock.ts

@@ -1,5 +1,6 @@
 import { Client } from "./emitter";
 import { Knock } from "@knocklabs/node";
+import { Network } from "@tenderly/actions";
 import { WebhookMessageCreateOptions } from "discord.js";
 
 export class KnockClient extends Client {
@@ -20,7 +21,12 @@ export class KnockClient extends Client {
     return this._knockClient;
   }
 
-  async sendMessage(_message: WebhookMessageCreateOptions, workflowData?: any) {
+  async sendMessage(
+    _message: WebhookMessageCreateOptions,
+    workflowData?: any,
+    body?: any,
+    network?: Network
+  ) {
     if (!workflowData) {
       console.log("workflowData is undefined");
       return;
@@ -29,17 +35,22 @@ export class KnockClient extends Client {
       throw new Error("Knock client not initialized");
     } else if (workflowData) {
       console.log("Sending message to knock");
-      await this._knockClient.workflows.trigger("new-oneclick-minipool", {
-        recipients: [
-          {
-            collection: "webhook-users",
-            id: "tenderly",
+      await this._knockClient.workflows.trigger(
+        network === Network.FUJI
+          ? "new-oneclick-minipool-fuji"
+          : "new-oneclick-minipool",
+        {
+          recipients: [
+            {
+              collection: "webhook-users",
+              id: "tenderly",
+            },
+          ],
+          data: {
+            ...workflowData,
           },
-        ],
-        data: {
-          ...workflowData,
-        },
-      });
+        }
+      );
     }
   }
 }

src/actions/minipoolLaunch.ts

@@ -12,7 +12,7 @@ const HARDWARE_PROVIDERS: Record<string, string> = {
 const handleMinipoolLaunchedEvent = async (
   context: Context,
   transactionEvent: TransactionEvent,
-  minipoolLaunchedEvent: MinipoolLaunched
+  minipoolLaunchedEvent: MinipoolLaunched,
 ) => {
   const { nodeID, hardwareProvider } = minipoolLaunchedEvent;
   const hardwareProviderName = HARDWARE_PROVIDERS[hardwareProvider.toLowerCase()];
@@ -35,7 +35,7 @@ const handleMinipoolLaunchedEvent = async (
     nodeIDHex: nodeID.toString(),
     hardwareProviderName,
   };
-  await emitter.emit(undefined, workflowData);
+  await emitter.emit(undefined, workflowData, undefined, network);
 };
 
 export const minipoolLaunched = async (context: Context, event: Event) => {

src/actions/templates.ts

@@ -1135,9 +1135,9 @@ export const SLACK_HARDWARE_RENTED_TEMPLATE = async ({
   payment: string;
 }) => {
   const headerText =
-    network === Network.MAINNET
-      ? ":computer: Hardware Rented"
-      : ":female-construction-worker::computer: Hardware Rented (Testnet)";
+    network === Network.FUJI
+      ? ":female-construction-worker::computer: Hardware Rented (Testnet)"
+      : ":computer: Hardware Rented";
   const displayDuration = Math.floor(parseInt(duration) / 86400);
   return {
     blocks: [
@@ -1222,9 +1222,9 @@ export const SLACK_MINIPOOL_LAUNCHED_TEMPLATE = async ({
   hardwareProviderName: string;
 }) => {
   const headerText =
-    network === Network.MAINNET
-      ? ":rocket: Minipool Launched"
-      : ":female-construction-worker: :rocket: Minipool Launched (Testnet)";
+    network === Network.FUJI
+      ? ":female-construction-worker: :rocket: Minipool Launched (Testnet)"
+      : ":rocket: Minipool Launched";
   return {
     blocks: [
       {