Merge pull request #2200 from bluewave-labs/rb-sept-15-slack-integration

Rb sept 15 slack integration

Author: MuhammadKhalilzadeh

.env.dev

@@ -29,3 +29,7 @@ REFRESH_TOKEN_SECRET=e628d7938c76308774cecf87dcb9bee6b8cae80ed2d20731ef94e211cf9
 EMAIL_ID=your-email@gmail.com
 # Your password from: https://myaccount.google.com/apppasswords
 EMAIL_PASSWORD="aaaa bbbb cccc dddd"
+
+# Encryption Settings
+ENCRYPTION_ALGORITHM=YOUR_ENCRYPTION_ALGORITHM
+ENCRYPTION_PASSWORD=YOUR_ENCRYPTION_PASSWORD

.env.prod

@@ -31,3 +31,7 @@ REFRESH_TOKEN_SECRET=e628d7938c76308774cecf87dcb9bee6b8cae80ed2d20731ef94e211cf9
 EMAIL_ID=your-email@gmail.com
 # Your password from: https://myaccount.google.com/apppasswords
 EMAIL_PASSWORD="aaaa bbbb cccc dddd"
+
+# Encryption Settings
+ENCRYPTION_ALGORITHM=YOUR_ENCRYPTION_ALGORITHM
+ENCRYPTION_PASSWORD=YOUR_ENCRYPTION_PASSWORD

Clients/env.vars.ts

@@ -8,4 +8,6 @@ export const ENV_VARs = {
       : "http://localhost:3000/"), // final Node/SSR fallback
   IS_DEMO_APP: import.meta.env.VITE_IS_DEMO_APP === "true",
   IS_MULTI_TENANT: import.meta.env.VITE_IS_MULTI_TENANT === "true",
+  CLIENT_ID: import.meta.env.VITE_CLIENT_ID,
+  SLACK_URL: import.meta.env.VITE_SLACK_URL,
 };

Clients/src/application/constants/permissions.ts

@@ -41,6 +41,10 @@ const allowedRoles = {
     edit: ["Admin", "Editor"],
     delete: ["Admin", "Editor"],
   },
+  slack: {
+    view: ["Admin"],
+    manage: ["Admin"],
+  },
 };
 
 export default allowedRoles;

Clients/src/application/hooks/useSlackIntegrations.tsx

@@ -0,0 +1,87 @@
+import { useEffect, useState } from "react";
+import { getSlackIntegrations } from "../repository/slack.integration.repository";
+
+interface ISlackWebhook {
+  id?: number;
+  access_token_iv?: string;
+  access_token: string;
+  scope: string;
+  user_id?: number; // FK to users table
+  team_name: string;
+  team_id: string;
+  channel: string;
+  channel_id: string;
+  configuration_url: string; // configuration URL to manage the webhook
+  url_iv?: string;
+  url: string; // URL of the slack workspace
+  created_at?: string;
+  is_active?: boolean;
+}
+export interface SlackWebhook {
+  id?: number;
+  scope: string;
+  teamName: string;
+  teamId: string;
+  channel: string;
+  channelId: string;
+  createdAt?: string;
+  isActive?: boolean;
+}
+
+interface ApiResponse {
+  data: ISlackWebhook[];
+}
+
+const useSlackIntegrations = (userId: number | null) => {
+  const [slackIntegrations, setSlackIntegrations] = useState<SlackWebhook[]>(
+    [],
+  );
+  const [loading, setLoading] = useState(true);
+  const [error, setError] = useState<string | null>(null);
+
+  const fetchSlackIntegrations = async () => {
+    try {
+      const controller = new AbortController();
+      const signal = controller.signal;
+      setLoading(true);
+      const response = await getSlackIntegrations({ id: userId!, signal });
+
+      const integrations: SlackWebhook[] = (response as ApiResponse).data.map(
+        (item: ISlackWebhook): SlackWebhook => ({
+          id: item.id,
+          scope: item.scope,
+          teamName: item.team_name,
+          teamId: item.team_id,
+          channel: item.channel,
+          channelId: item.channel_id,
+          createdAt: item.created_at,
+          isActive: item.is_active,
+        }),
+      );
+
+      setSlackIntegrations(integrations);
+      setError(null);
+    } catch (err) {
+      setError(
+        err instanceof Error
+          ? err.message
+          : "Failed to fetch slack integrations",
+      );
+    } finally {
+      setLoading(false);
+    }
+  };
+
+  useEffect(() => {
+    fetchSlackIntegrations();
+  }, []);
+
+  return {
+    slackIntegrations,
+    loading,
+    error,
+    refreshSlackIntegrations: fetchSlackIntegrations,
+  };
+};
+
+export default useSlackIntegrations;

Clients/src/application/repository/slack.integration.repository.ts

@@ -0,0 +1,68 @@
+import { apiServices } from "../../infrastructure/api/networkServices";
+
+export async function getSlackIntegrations({
+  id,
+  channel,
+  signal,
+  responseType = "json",
+}: {
+  id: number;
+  channel?: string;
+  signal?: AbortSignal;
+  responseType?: string;
+}): Promise<any> {
+  const response = await apiServices.get(`/slackWebhooks`, {
+    userId: id,
+    channel,
+    signal,
+    responseType,
+  });
+  return response.data;
+}
+
+export async function getSlackIntegrationById({
+  id,
+  signal,
+  responseType = "json",
+}: {
+  id: string;
+  signal?: AbortSignal;
+  responseType?: string;
+}): Promise<any> {
+  const response = await apiServices.get(`/slackWebhooks/${id}`, {
+    signal,
+    responseType,
+  });
+  return response.data;
+}
+
+export async function createSlackIntegration({
+  body,
+}: {
+  body: any;
+}): Promise<any> {
+  const response = await apiServices.post("/slackWebhooks", body);
+  return response.data;
+}
+
+export async function updateSlackIntegration({
+  id,
+  body,
+}: {
+  id: string;
+  body: any;
+}): Promise<any> {
+  const response = await apiServices.patch(`/slackWebhooks/${id}`, body);
+  return response;
+}
+
+export async function sendSlackMessage({
+  id,
+  body,
+}: {
+  id: number;
+  body: { title: string; message: string };
+}): Promise<any> {
+  const response = await apiServices.post(`/slackWebhooks/${id}/send`, body);
+  return response.data;
+}