Merge branch 'develop' into 'main'

Develop

See merge request digiresilience/link/link-stack!9

apps/bridge-frontend/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@link-stack/bridge-frontend",
-  "version": "2.1.0",
+  "version": "2.1.1",
   "type": "module",
   "scripts": {
     "dev": "next dev",
@@ -20,8 +20,8 @@
     "@mui/icons-material": "^5",
     "@mui/material": "^5",
     "@mui/material-nextjs": "^5.16.6",
-    "@mui/x-data-grid-pro": "^7.12.0",
+    "@mui/x-data-grid-pro": "^7.12.1",
-    "@mui/x-date-pickers-pro": "^7.12.0",
+    "@mui/x-date-pickers-pro": "^7.12.1",
     "@mui/x-license": "^7.12.0",
     "@link-stack/bridge-common": "*",
     "@link-stack/bridge-ui": "*",
@@ -43,7 +43,7 @@
     "react-timer-hook": "^3.0.7",
     "sharp": "^0.33.4",
     "tss-react": "^4.9.12",
-    "tsx": "^4.16.5",
+    "tsx": "^4.17.0",
     "@link-stack/ui": "*"
   },
   "devDependencies": {

apps/bridge-migrations/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@link-stack/bridge-migrations",
-  "version": "2.1.0",
+  "version": "2.1.1",
   "type": "module",
   "scripts": {
     "migrate:up:all": "tsx migrate.ts up:all",
@@ -12,7 +12,7 @@
     "dotenv": "^16.4.5",
     "kysely": "0.26.1",
     "pg": "^8.12.0",
-    "tsx": "^4.16.5"
+    "tsx": "^4.17.0"
   },
   "devDependencies": {
     "@types/node": "^22",

apps/bridge-whatsapp/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@link-stack/bridge-whatsapp",
-  "version": "2.1.0",
+  "version": "2.1.1",
   "main": "build/main/index.js",
   "author": "Darren Clarke <darren@redaranj.com>",
   "license": "AGPL-3.0-or-later",
@@ -20,7 +20,7 @@
     "@link-stack/typescript-config": "*",
     "@types/node": "*",
     "dotenv-cli": "^7.4.2",
-    "tsx": "^4.16.5",
+    "tsx": "^4.17.0",
     "typescript": "^5.5.4"
   },
   "scripts": {

apps/bridge-whatsapp/tsconfig.json

@@ -8,7 +8,7 @@
     "outDir": "build/main",
     "rootDir": "src",
     "skipLibCheck": true,
-    "types": ["jest", "node", "long"],
+    "types": ["node", "long"],
     "lib": ["es2020", "DOM"],
     "composite": true
   },

apps/bridge-worker/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@link-stack/bridge-worker",
-  "version": "2.1.0",
+  "version": "2.1.1",
   "type": "module",
   "main": "build/main/index.js",
   "author": "Darren Clarke <darren@redaranj.com>",
@@ -20,7 +20,7 @@
     "jest": "^29.7.0",
     "kysely": "^0.27.3",
     "pg": "^8.12.0",
-    "remeda": "^2.10.0",
+    "remeda": "^2.11.0",
     "twilio": "^5.2.2"
   },
   "devDependencies": {

apps/bridge-worker/tasks/leafcutter/import-leafcutter.ts

@@ -142,7 +142,7 @@ const sendToLeafcutter = async (tickets: LabelStudioTicket[]) => {
     },
     body: JSON.stringify({ tickets: finalTickets }),
   });
-  console.log({ result });
+
 };
  */
 const importLeafcutterTask = async (): Promise<void> => {

apps/leafcutter/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@link-stack/leafcutter",
-  "version": "2.1.0",
+  "version": "2.1.1",
   "scripts": {
     "dev": "next dev -p 3001",
     "login": "aws sso login --sso-session cdr",
@@ -22,8 +22,8 @@
     "@mui/icons-material": "^5",
     "@mui/material": "^5",
     "@mui/material-nextjs": "^5.16.6",
-    "@mui/x-data-grid-pro": "^7.12.0",
+    "@mui/x-data-grid-pro": "^7.12.1",
-    "@mui/x-date-pickers-pro": "^7.12.0",
+    "@mui/x-date-pickers-pro": "^7.12.1",
     "@opensearch-project/opensearch": "^2.11.0",
     "cryptr": "^6.3.0",
     "date-fns": "^3.6.0",
@@ -43,7 +43,7 @@
   },
   "devDependencies": {
     "@babel/core": "^7.25.2",
-    "@types/node": "^22.1.0",
+    "@types/node": "^22.2.0",
     "@types/react": "18.3.3",
     "@types/uuid": "^10.0.0",
     "babel-loader": "^9.1.3",

apps/link/app/(main)/overview/[overview]/_components/TicketCreateDialog.tsx

@@ -50,7 +50,6 @@ export const TicketCreateDialog: FC<TicketCreateDialogProps> = ({
   );
   const [liveFormState, setLiveFormState] = useState(formState);
   const updateFormState = (field: string, value: any) => {
-    console.log({ value });
     const newState = { ...liveFormState };
     newState.values[field] = value;
     setLiveFormState(newState);
@@ -59,7 +58,6 @@ export const TicketCreateDialog: FC<TicketCreateDialogProps> = ({
   useEffect(() => {
     const fetchUsers = async () => {
       const result = await getCustomersAction();
-      console.log({ result });
       setCustomers(result);
     };
 
@@ -69,7 +67,6 @@ export const TicketCreateDialog: FC<TicketCreateDialogProps> = ({
   useEffect(() => {
     const fetchGroups = async () => {
       const result = await getGroupsAction();
-      console.log({ result });
       setGroups(result);
     };
 

apps/link/app/_actions/groups.ts

@@ -3,14 +3,19 @@
 import { executeREST } from "app/_lib/zammad";
 
 export const getGroupsAction = async () => {
-  const groups = await executeREST({
+  try {
-    path: "/api/v1/groups",
+    const groups = await executeREST({
-  });
+      path: "/api/v1/groups",
-  const allGroups = groups ?? [];
+    });
-  const formattedGroups = allGroups.map((group: any) => ({
+    const allGroups = groups ?? [];
-    label: group.name,
+    const formattedGroups = allGroups.map((group: any) => ({
-    value: `gid://zammad/Group/${group.id}`,
+      label: group.name,
-  }));
+      value: `gid://zammad/Group/${group.id}`,
+    }));
 
-  return formattedGroups;
+    return formattedGroups;
+  } catch (e) {
+    console.error(e.message);
+    return [];
+  }
 };

apps/link/app/_actions/overviews.ts

@@ -16,75 +16,82 @@ const overviewLookup = {
 };
 
 export const getOverviewTicketCountsAction = async () => {
-  const recent = await executeREST({ path: "/api/v1/recent_view" });
+  try {
-  const countResult = await executeGraphQL({
+    const recent = await executeREST({ path: "/api/v1/recent_view" });
-    query: getTicketOverviewCountsQuery,
+    const countResult = await executeGraphQL({
-  });
+      query: getTicketOverviewCountsQuery,
-  const overviews = countResult?.ticketOverviews?.edges ?? [];
+    });
-  const counts = overviews.reduce((acc: any, overview: any) => {
+    const overviews = countResult?.ticketOverviews?.edges ?? [];
-    const name = overview.node.name;
+    const counts = overviews.reduce((acc: any, overview: any) => {
-    const key = Object.keys(overviewLookup)
+      const name = overview.node.name;
-      .find((k) => overviewLookup[k] === name)
+      const key = Object.keys(overviewLookup)
-      ?.toLowerCase();
+        .find((k) => overviewLookup[k] === name)
-    if (key) {
+        ?.toLowerCase();
-      acc[key] = overview.node.ticketCount ?? 0;
+      if (key) {
-    }
+        acc[key] = overview.node.ticketCount ?? 0;
-    return acc;
+      }
-  }, {});
+      return acc;
-  counts.recent = recent.length;
+    }, {});
+    counts.recent = recent.length;
 
-  return counts;
+    return counts;
+  } catch (e) {
+    console.error(e.message);
+    return {};
+  }
 };
 
 export const getOverviewTicketsAction = async (name: string) => {
   let tickets = [];
-  let error = null;
 
-  if (name === "Recent") {
+  try {
-    const recent = await executeREST({ path: "/api/v1/recent_view" });
+    if (name === "Recent") {
+      const recent = await executeREST({ path: "/api/v1/recent_view" });
 
-    for (const rec of recent) {
+      for (const rec of recent) {
-      const tkt = await executeREST({
+        const tkt = await executeREST({
-        path: `/api/v1/tickets/${rec.o_id}`,
+          path: `/api/v1/tickets/${rec.o_id}`,
+        });
+        tickets.push({
+          ...tkt,
+          internalId: tkt.id,
+          createdAt: tkt.created_at,
+          updatedAt: tkt.updated_at,
+        });
+      }
+    } else {
+      const fullName = overviewLookup[name];
+      const countResult = await executeGraphQL({
+        query: getTicketOverviewCountsQuery,
       });
-      tickets.push({
+      const overviewID = countResult?.ticketOverviews?.edges?.find(
-        ...tkt,
+        (overview: any) => overview.node.name === fullName,
-        internalId: tkt.id,
+      )?.node?.id;
-        createdAt: tkt.created_at,
+
-        updatedAt: tkt.updated_at,
+      const ticketsResult = await executeGraphQL({
+        query: getTicketsByOverviewQuery,
+        variables: { overviewId: overviewID, pageSize: 250 },
       });
+
+      const edges = ticketsResult?.ticketsByOverview?.edges;
+      if (edges) {
+        tickets = edges.map((edge: any) => edge.node);
+      }
     }
-  } else {
-    const fullName = overviewLookup[name];
-    const countResult = await executeGraphQL({
-      query: getTicketOverviewCountsQuery,
-    });
-    const overviewID = countResult?.ticketOverviews?.edges?.find(
-      (overview: any) => overview.node.name === fullName,
-    )?.node?.id;
 
-    console.log({ overviewID });
+    const sortedTickets = tickets.sort((a: any, b: any) => {
-
+      if (a.internalId < b.internalId) {
-    const ticketsResult = await executeGraphQL({
+        return 1;
-      query: getTicketsByOverviewQuery,
+      }
-      variables: { overviewId: overviewID, pageSize: 250 },
+      if (a.internalId > b.internalId) {
+        return -1;
+      }
+      return 0;
     });
 
-    const edges = ticketsResult?.ticketsByOverview?.edges;
+    return { tickets: sortedTickets };
-    if (edges) {
+  } catch (e) {
-      tickets = edges.map((edge: any) => edge.node);
+    console.error(e.message);
-    }
+    return { tickets, message: e.message ?? "" };
   }
-
-  const sortedTickets = tickets.sort((a: any, b: any) => {
-    if (a.internalId < b.internalId) {
-      return 1;
-    }
-    if (a.internalId > b.internalId) {
-      return -1;
-    }
-    return 0;
-  });
-
-  return { tickets: sortedTickets, error };
 };

apps/link/app/_actions/search.ts

@@ -3,10 +3,15 @@ import { executeGraphQL } from "app/_lib/zammad";
 import { searchQuery } from "@/app/_graphql/searchQuery";
 
 export const searchAllAction = async (query: string, limit: number) => {
-  const result = await executeGraphQL({
+  try {
-    query: searchQuery,
+    const result = await executeGraphQL({
-    variables: { search: query, limit },
+      query: searchQuery,
-  });
+      variables: { search: query, limit },
+    });
 
-  return result?.search;
+    return result?.search;
+  } catch (e) {
+    console.error(e.message);
+    return [];
+  }
 };

apps/link/app/_actions/tickets.ts

@@ -15,7 +15,7 @@ export const createTicketAction = async (
   try {
     const ticket = {
       groupId: formData.get("groupId"),
-      customerId: `gid://zammad/User/3`, // { email: formData.get("customerId") },
+      customerId: formData.get("customerId"),
       title: formData.get("title"),
       article: {
         internal: true,
@@ -23,23 +23,20 @@ export const createTicketAction = async (
       },
     };
 
-    console.log({ ticket });
+    await executeGraphQL({
-
-    const result = await executeGraphQL({
       query: createTicketMutation,
       variables: {
         input: ticket,
       },
     });
 
-    console.log({ result });
     return {
       ...currentState,
       values: ticket,
       success: true,
     };
   } catch (e: any) {
-    console.log({ e });
+    console.error(e.message);
     return {
       success: false,
       values: {},
@@ -61,13 +58,12 @@ export const createTicketArticleAction = async (
       },
     });
 
-    console.log({ result });
     return {
       result,
       success: true,
     };
   } catch (e: any) {
-    console.log({ e });
+    console.error(e.message);
     return {
       success: false,
       message: e?.message ?? "Unknown error",
@@ -114,16 +110,14 @@ export const updateTicketAction = async (
           tags: ticketInfo.tags,
         },
       });
-      console.log({ tagsResult });
     }
 
-    console.log({ result });
     return {
       result,
       success: true,
     };
   } catch (e: any) {
-    console.log({ e });
+    console.error(e.message);
     return {
       success: false,
       message: e?.message ?? "Unknown error",
@@ -132,55 +126,80 @@ export const updateTicketAction = async (
 };
 
 export const getTicketAction = async (id: string) => {
-  const ticketData = await executeGraphQL({
+  try {
-    query: getTicketQuery,
+    const ticketData = await executeGraphQL({
-    variables: { ticketId: `gid://zammad/Ticket/${id}` },
+      query: getTicketQuery,
-  });
+      variables: { ticketId: `gid://zammad/Ticket/${id}` },
-  console.log({ td: ticketData.ticket });
+    });
-  return ticketData?.ticket;
+
+    return ticketData?.ticket;
+  } catch (e) {
+    console.error(e.message);
+    return {};
+  }
 };
 
 export const getTicketArticlesAction = async (id: string) => {
-  const ticketData = await executeGraphQL({
+  try {
-    query: getTicketArticlesQuery,
+    const ticketData = await executeGraphQL({
-    variables: { ticketId: `gid://zammad/Ticket/${id}` },
+      query: getTicketArticlesQuery,
-  });
+      variables: { ticketId: `gid://zammad/Ticket/${id}` },
+    });
 
-  return ticketData?.ticketArticles;
+    return ticketData?.ticketArticles;
+  } catch (e) {
+    console.error(e.message);
+    return {};
+  }
 };
 
 export const getTicketStatesAction = async () => {
-  const states = await executeREST({
+  try {
-    path: "/api/v1/ticket_states",
+    const states = await executeREST({
-  });
+      path: "/api/v1/ticket_states",
+    });
 
-  const formattedStates =
+    const formattedStates =
-    states?.map((state: any) => ({
+      states?.map((state: any) => ({
-      value: `gid://zammad/Ticket::State/${state.id}`,
+        value: `gid://zammad/Ticket::State/${state.id}`,
-      label: state.name,
+        label: state.name,
-    })) ?? [];
+      })) ?? [];
 
-  return formattedStates;
+    return formattedStates;
+  } catch (e) {
+    console.error(e.message);
+    return [];
+  }
 };
 
 export const getTagsAction = async () => {
-  const { tags } = await executeREST({
+  try {
-    path: "/api/v1/tags",
+    const { tags } = await executeREST({
-  });
+      path: "/api/v1/tags",
+    });
 
-  return tags;
+    return tags;
+  } catch (e) {
+    console.error(e.message);
+    return [];
+  }
 };
 
 export const getTicketPrioritiesAction = async () => {
-  const priorities = await executeREST({
+  try {
-    path: "/api/v1/ticket_priorities",
+    const priorities = await executeREST({
-  });
+      path: "/api/v1/ticket_priorities",
+    });
 
-  const formattedPriorities =
+    const formattedPriorities =
-    priorities?.map((priority: any) => ({
+      priorities?.map((priority: any) => ({
-      value: `gid://zammad/Ticket::Priority/${priority.id}`,
+        value: `gid://zammad/Ticket::Priority/${priority.id}`,
-      label: priority.name,
+        label: priority.name,
-    })) ?? [];
+      })) ?? [];
 
-  return formattedPriorities;
+    return formattedPriorities;
+  } catch (e) {
+    console.error(e.message);
+    return [];
+  }
 };

apps/link/app/_actions/users.ts

@@ -3,48 +3,63 @@
 import { executeREST } from "app/_lib/zammad";
 
 export const getAgentsAction = async () => {
-  const users = await executeREST({
+  try {
-    path: "/api/v1/users",
+    const users = await executeREST({
-  });
+      path: "/api/v1/users",
-  const agents = users?.filter((user: any) => user.role_ids.includes(2)) ?? [];
+    });
-  const formattedAgents = agents
+    const agents =
-    .map((agent: any) => ({
+      users?.filter((user: any) => user.role_ids.includes(2)) ?? [];
-      label: `${agent.firstname} ${agent.lastname}`,
+    const formattedAgents = agents
-      value: `gid://zammad/User/${agent.id}`,
+      .map((agent: any) => ({
-    }))
+        label: `${agent.firstname} ${agent.lastname}`,
-    .sort((a: any, b: any) => a.label.localeCompare(b.label));
+        value: `gid://zammad/User/${agent.id}`,
+      }))
+      .sort((a: any, b: any) => a.label.localeCompare(b.label));
 
-  return formattedAgents;
+    return formattedAgents;
+  } catch (e) {
+    console.error(e.message);
+    return [];
+  }
 };
 
 export const getCustomersAction = async () => {
-  const users = await executeREST({
+  try {
-    path: "/api/v1/users",
+    const users = await executeREST({
-  });
+      path: "/api/v1/users",
-  console.log({ users });
+    });
-  const customers =
+    const customers =
-    users?.filter((user: any) => user.role_ids.includes(3)) ?? [];
+      users?.filter((user: any) => user.role_ids.includes(3)) ?? [];
-  const formattedCustomers = customers
+    const formattedCustomers = customers
-    .map((customer: any) => ({
+      .map((customer: any) => ({
-      label: customer.login,
+        label: customer.login,
-      value: `gid://zammad/User/${customer.id}`,
+        value: `gid://zammad/User/${customer.id}`,
-    }))
+      }))
-    .sort((a: any, b: any) => a.label.localeCompare(b.label));
+      .sort((a: any, b: any) => a.label.localeCompare(b.label));
 
-  return formattedCustomers;
+    return formattedCustomers;
+  } catch (e) {
+    console.error(e.message);
+    return [];
+  }
 };
 
 export const getUsersAction = async () => {
-  const users = await executeREST({
+  try {
-    path: "/api/v1/users",
+    const users = await executeREST({
-  });
+      path: "/api/v1/users",
-  console.log({ users });
+    });
-  const formattedUsers = users
+    console.log({ users });
-    .map((customer: any) => ({
+    const formattedUsers = users
-      label: customer.login,
+      .map((customer: any) => ({
-      value: `gid://zammad/User/${customer.id}`,
+        label: customer.login,
-    }))
+        value: `gid://zammad/User/${customer.id}`,
-    .sort((a: any, b: any) => a.label.localeCompare(b.label));
+      }))
+      .sort((a: any, b: any) => a.label.localeCompare(b.label));
 
-  return formattedUsers;
+    return formattedUsers;
+  } catch (e) {
+    console.error(e.message);
+    return [];
+  }
 };

apps/link/app/_components/CSRFProvider.tsx

@@ -1,22 +1,36 @@
 "use client";
 
 import { FC, PropsWithChildren, useEffect } from "react";
+import { useRouter } from "next/navigation";
 import { useSession } from "next-auth/react";
 
 export const CSRFProvider: FC<PropsWithChildren> = ({ children }) => {
   const { data: session, status, update } = useSession();
+  const router = useRouter();
 
   useEffect(() => {
-    const interval = setInterval(async () => {
+    const checkSession = async () => {
+      console.log("Checking session status...");
+      console.log(status);
       if (status === "authenticated") {
-        const response = await fetch("/api/v1/users/me");
+        const response = await fetch("/api/v1/users/me", {
-        const token = response.headers.get("CSRF-Token");
+          method: "GET",
-        update({ csrfToken: token });
+        });
+
+        if (response.status !== 200 && !!router) {
+          console.log("redirecting");
+          window.location.href = "/auth/sso";
+        } else {
+          const token = response.headers.get("CSRF-Token");
+          update({ zammadCsrfToken: token });
+        }
       }
-    }, 30000);
+    };
+
+    const interval = setInterval(checkSession, 15000);
 
     return () => clearInterval(interval);
-  }, [session, status, update]);
+  }, [session, status, update, router]);
 
   return children;
 };

apps/link/app/_lib/authentication.ts

@@ -123,7 +123,7 @@ export const authOptions: NextAuthOptions = {
       }
 
       if (session && trigger === "update") {
-        token.zammadCsrfToken = session.csrfToken;
+        token.zammadCsrfToken = session.zammadCsrfToken;
       }
       return token;
     },

apps/link/app/_lib/zammad.ts

@@ -1,4 +1,5 @@
 import { getServerSession } from "app/_lib/authentication";
+import { redirect } from "next/navigation";
 import { cookies } from "next/headers";
 
 const getHeaders = async () => {
@@ -9,6 +10,7 @@ const getHeaders = async () => {
     Accept: "application/json",
     // @ts-ignore
     "X-CSRF-Token": session.user.zammadCsrfToken,
+    "X-Browser-Fingerprint": `${session.expires}`,
     Cookie: allCookies
       .map((cookie: any) => `${cookie.name}=${cookie.value}`)
       .join("; "),

apps/link/middleware.ts

@@ -10,12 +10,12 @@ const rewriteURL = (
   const destinationURL = request.url.replace(originBaseURL, destinationBaseURL);
   console.log(`Rewriting ${request.url} to ${destinationURL}`);
   const requestHeaders = new Headers(request.headers);
-  //  console.log({ beforeHeaders: requestHeaders });
+
   for (const [key, value] of Object.entries(headers)) {
     requestHeaders.set(key, value as string);
   }
   requestHeaders.delete("connection");
-  //  console.log({ afterHeaders: requestHeaders });
+
   return NextResponse.rewrite(new URL(destinationURL), {
     request: { headers: requestHeaders },
   });
@@ -26,7 +26,15 @@ const checkRewrites = async (request: NextRequestWithAuth) => {
   const zammadURL = process.env.ZAMMAD_URL ?? "http://zammad-nginx:8080";
   const opensearchDashboardsURL =
     process.env.OPENSEARCH_DASHBOARDS_URL ?? "http://macmini:5601";
-  const zammadPaths = ["/zammad", "/api/v1", "/auth/sso", "/assets", "/mobile"];
+  const zammadPaths = [
+    "/zammad",
+    "/api/v1",
+    "/auth/sso",
+    "/assets",
+    "/mobile",
+    "/graphql",
+    "/cable",
+  ];
   const { token } = request.nextauth;
   const email = token?.email?.toLowerCase() ?? "unknown";
   let headers = { "x-forwarded-user": email };

apps/link/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@link-stack/link",
-  "version": "2.1.0",
+  "version": "2.1.1",
   "type": "module",
   "scripts": {
     "dev": "next dev",
@@ -24,8 +24,8 @@
     "@mui/icons-material": "^5",
     "@mui/material": "^5",
     "@mui/material-nextjs": "^5.16.6",
-    "@mui/x-data-grid-pro": "^7.12.0",
+    "@mui/x-data-grid-pro": "^7.12.1",
-    "@mui/x-date-pickers-pro": "^7.12.0",
+    "@mui/x-date-pickers-pro": "^7.12.1",
     "date-fns": "^3.6.0",
     "graphql": "^16.9.0",
     "graphql-request": "^7.1.0",
@@ -42,7 +42,7 @@
   },
   "devDependencies": {
     "@babel/core": "^7.25.2",
-    "@types/node": "^22.1.0",
+    "@types/node": "^22.2.0",
     "@types/react": "18.3.3",
     "@types/uuid": "^10.0.0",
     "babel-loader": "^9.1.3",

apps/link/tsconfig.json

@@ -3,6 +3,7 @@
     "lib": ["dom", "dom.iterable", "esnext"],
     "allowJs": true,
     "skipLibCheck": true,
+    "target": "esnext",
     "strict": false,
     "forceConsistentCasingInFileNames": true,
     "noEmit": true,

package.json

@@ -1,15 +1,16 @@
 {
   "name": "@link-stack",
-  "version": "2.1.0",
+  "version": "2.1.1",
   "description": "Link from the Center for Digital Resilience",
   "scripts": {
     "dev": "dotenv -- turbo dev",
     "build": "dotenv -- turbo build",
     "migrate": "dotenv -- npm run migrate --workspace=database",
     "lint": "dotenv turbo lint",
+    "update-version": "find . -name 'package.json' -exec sed -i -E 's/\"version\": \"[^\"]+\"/\"version\": \"2.1.1\"/' {} +",
     "upgrade:setup": "npm i -g npm-check-updates",
     "upgrade:check": "ncu && ncu -ws",
-    "upgrade:all": "ncu -u -x eslint -x kysely && ncu -ws -u -x eslint -x kysely && npm i",
+    "upgrade": "ncu -u -x eslint -x kysely && ncu -ws -u -x eslint -x kysely && npm i",
     "clean": "rm -f package-lock.json && rm -rf node_modules && rm -rf .turbo && rm -rf apps/*/node_modules && rm -rf apps/*/package-lock.json && rm -rf apps/*/.next && rm -rf packages/*/node_modules && rm -rf apps/*/.next && rm -rf packages/*/.turbo && rm -rf packages/*/build && rm -rf docker/zammad/addons/*",
     "docker:all:up": "node docker/scripts/docker.js all up",
     "docker:all:down": "node docker/scripts/docker.js all down",
@@ -50,7 +51,8 @@
   "license": "AGPL-3.0-or-later",
   "devDependencies": {
     "dotenv-cli": "latest",
-    "eslint": "^8"
+    "eslint": "^8",
+    "typescript": "latest"
   },
   "overrides": {
     "eslint-config-next": {

packages/bridge-common/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@link-stack/bridge-common",
-  "version": "2.2.0",
+  "version": "2.1.1",
   "main": "build/main/index.js",
   "type": "module",
   "author": "Darren Clarke <darren@redaranj.com>",
@@ -20,7 +20,7 @@
     "@babel/preset-typescript": "7.24.7",
     "prettier": "^3.3.3",
     "@link-stack/typescript-config": "*",
-    "tsx": "^4.16.5",
+    "tsx": "^4.17.0",
     "typescript": "^5.5.4"
   }
 }

packages/bridge-ui/lib/service.ts

@@ -81,6 +81,12 @@ export class Service {
     req: NextRequest,
     { params: { service, token } }: ServiceParams,
   ): Promise<NextResponse> {
+    const table = getServiceTable(service);
+    const row = await db
+      .selectFrom(table)
+      .selectAll()
+      .where("token", "=", token ?? "NEVER_MATCH")
+      .executeTakeFirstOrThrow();
     const json = await req.json();
     const worker = await getWorkerUtils();
     await worker.addJob(`${service}/send-${service}-message`, {
@@ -88,7 +94,17 @@ export class Service {
       ...json,
     });
 
-    return NextResponse.json({ response: "ok" });
+    const response = {
+      response: "ok",
+      result: {
+        to: json.to,
+        from: row?.phoneNumber ?? null,
+        timestamp: new Date().toISOString(),
+      },
+    };
+
+    console.log(response);
+    return NextResponse.json(response);
   }
 
   async receiveMessage(

packages/bridge-ui/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@link-stack/bridge-ui",
-  "version": "0.2.0",
+  "version": "2.1.1",
   "scripts": {
     "build": "tsc -p tsconfig.json"
   },
@@ -13,8 +13,8 @@
     "@link-stack/signal-api": "*",
     "@mui/icons-material": "^5",
     "@mui/material": "^5",
-    "@mui/x-data-grid-pro": "^7.12.0",
+    "@mui/x-data-grid-pro": "^7.12.1",
-    "@mui/x-date-pickers-pro": "^7.12.0",
+    "@mui/x-date-pickers-pro": "^7.12.1",
     "date-fns": "^3.6.0",
     "kysely": "0.26.1",
     "material-ui-popup-state": "^5.1.2",
@@ -32,7 +32,7 @@
   },
   "devDependencies": {
     "@babel/core": "^7.25.2",
-    "@types/node": "^22.1.0",
+    "@types/node": "^22.2.0",
     "@types/react": "18.3.3",
     "@types/react-dom": "^18.3.0",
     "@types/uuid": "^10.0.0",

packages/eslint-config/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@link-stack/eslint-config",
-  "version": "0.3.10",
+  "version": "2.1.1",
   "description": "amigo's eslint config",
   "author": "Abel Luck <abel@guardianproject.info>",
   "license": "AGPL-3.0-or-later",
@@ -10,14 +10,14 @@
   },
   "dependencies": {
     "@rushstack/eslint-patch": "^1.10.4",
-    "@typescript-eslint/eslint-plugin": "^8.0.1",
+    "@typescript-eslint/eslint-plugin": "^8.1.0",
-    "@typescript-eslint/parser": "^8.0.1",
+    "@typescript-eslint/parser": "^8.1.0",
     "eslint-config-prettier": "^9.1.0",
     "eslint-config-xo-space": "^0.35.0",
-    "eslint-plugin-cypress": "^3.4.0",
+    "eslint-plugin-cypress": "^3.5.0",
     "eslint-plugin-eslint-comments": "^3.2.0",
     "eslint-plugin-import": "^2.29.1",
-    "eslint-plugin-jest": "^28.7.0",
+    "eslint-plugin-jest": "^28.8.0",
     "eslint-plugin-promise": "^7.1.0",
     "eslint-plugin-unicorn": "55.0.0",
     "@babel/eslint-parser": "7.25.1"

packages/jest-config/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@link-stack/jest-config",
-  "version": "0.0.1",
+  "version": "2.1.1",
   "description": "",
   "author": "Abel Luck <abel@guardianproject.info>",
   "license": "AGPL-3.0-or-later",

packages/leafcutter-ui/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@link-stack/leafcutter-ui",
-  "version": "0.2.0",
+  "version": "2.1.1",
   "scripts": {
     "build": "tsc -p tsconfig.json"
   },
@@ -11,8 +11,8 @@
     "@emotion/styled": "^11.13.0",
     "@mui/icons-material": "^5",
     "@mui/material": "^5",
-    "@mui/x-data-grid-pro": "^7.12.0",
+    "@mui/x-data-grid-pro": "^7.12.1",
-    "@mui/x-date-pickers-pro": "^7.12.0",
+    "@mui/x-date-pickers-pro": "^7.12.1",
     "@link-stack/opensearch-common": "*",
     "date-fns": "^3.6.0",
     "material-ui-popup-state": "^5.1.2",
@@ -29,7 +29,7 @@
   },
   "devDependencies": {
     "@babel/core": "^7.25.2",
-    "@types/node": "^22.1.0",
+    "@types/node": "^22.2.0",
     "@types/react": "18.3.3",
     "@types/uuid": "^10.0.0",
     "babel-loader": "^9.1.3",

packages/opensearch-common/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@link-stack/opensearch-common",
-  "version": "0.2.0",
+  "version": "2.1.1",
   "scripts": {
     "build": "tsc -p tsconfig.json"
   },
@@ -10,7 +10,7 @@
   },
   "devDependencies": {
     "@babel/core": "^7.25.2",
-    "@types/node": "^22.1.0",
+    "@types/node": "^22.2.0",
     "@types/react": "18.3.3",
     "@types/uuid": "^10.0.0",
     "babel-loader": "^9.1.3",

packages/signal-api/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@link-stack/signal-api",
-  "version": "1.0.0",
+  "version": "2.1.1",
   "type": "module",
   "main": "build/index.js",
   "exports": {

packages/typescript-config/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@link-stack/typescript-config",
-  "version": "0.1.4",
+  "version": "2.1.1",
   "description": "Shared TypeScript config",
   "license": "AGPL-3.0-or-later",
   "author": "Abel Luck <abel@guardianproject.info>",

packages/ui/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@link-stack/ui",
-  "version": "1.0.0",
+  "version": "2.1.1",
   "description": "",
   "scripts": {
     "build": "tsc -p tsconfig.json"
@@ -9,14 +9,14 @@
   "dependencies": {
     "@mui/icons-material": "^5",
     "@mui/material": "^5",
-    "@mui/x-data-grid-pro": "^7.12.0",
+    "@mui/x-data-grid-pro": "^7.12.1",
-    "@mui/x-date-pickers-pro": "^7.12.0",
+    "@mui/x-date-pickers-pro": "^7.12.1",
     "next": "14.2.5",
     "react": "18.3.1",
     "react-dom": "18.3.1"
   },
   "devDependencies": {
-    "@types/node": "^22.1.0",
+    "@types/node": "^22.2.0",
     "@types/react": "18.3.3",
     "typescript": "^5.5.4"
   }

packages/zammad-addon-bridge/package.json

@@ -1,7 +1,7 @@
 {
   "name": "@link-stack/zammad-addon-bridge",
   "displayName": "Bridge",
-  "version": "2.0.0",
+  "version": "2.1.1",
   "description": "An addon that adds CDR Bridge channels to Zammad.",
   "scripts": {
     "build": "node '../../node_modules/@link-stack/zammad-addon-common/dist/build.js'",

packages/zammad-addon-bridge/src/app/jobs/communicate_cdr_signal_job.rb

@@ -61,16 +61,16 @@ class CommunicateCdrSignalJob < ApplicationJob
 
     return if has_error
 
-    article.to = result['result']['recipient']
+    article.to = result['result']['to']
-    article.from = result['result']['source']
+    article.from = result['result']['from']
 
-    message_id = format('%<source>s@%<timestamp>s', source: result['result']['source'],
+    message_id = format('%<from>s@%<timestamp>s', from: result['result']['from'],
                                                     timestamp: result['result']['timestamp'])
     article.preferences['cdr_signal'] = {
       timestamp: result['result']['timestamp'],
       message_id: message_id,
-      from: result['result']['source'],
+      from: result['result']['from'],
-      to: result['result']['recipient']
+      to: result['result']['to']
     }
 
     # set delivery status

packages/zammad-addon-bridge/src/app/jobs/communicate_cdr_whatsapp_job.rb

@@ -61,16 +61,16 @@ class CommunicateCdrWhatsappJob < ApplicationJob
 
     return if has_error
 
-    article.to = result['result']['recipient']
+    article.to = result['result']['to']
-    article.from = result['result']['source']
+    article.from = result['result']['from']
 
-    message_id = format('%<source>s@%<timestamp>s', source: result['result']['source'],
+    message_id = format('%<from>s@%<timestamp>s', from: result['result']['from'],
                                                     timestamp: result['result']['timestamp'])
     article.preferences['cdr_whatsapp'] = {
       timestamp: result['result']['timestamp'],
       message_id: message_id,
-      from: result['result']['source'],
+      from: result['result']['from'],
-      to: result['result']['recipient']
+      to: result['result']['to']
     }
 
     # set delivery status

packages/zammad-addon-bridge/src/lib/cdr_signal.rb

@@ -118,7 +118,7 @@ class CdrSignal
   end
 
   def self.message_id(message_raw)
-    format('%<source>s@%<timestamp>s', source: message_raw['source'], timestamp: message_raw['timestamp'])
+    format('%<from>s@%<timestamp>s', from: message_raw['from'], timestamp: message_raw['timestamp'])
   end
 
   #

packages/zammad-addon-bridge/src/lib/cdr_whatsapp.rb

@@ -118,7 +118,7 @@ class CdrWhatsapp
   end
 
   def self.message_id(message_raw)
-    format('%<source>s@%<timestamp>s', source: message_raw['source'], timestamp: message_raw['timestamp'])
+    format('%<from>s@%<timestamp>s', from: message_raw['from'], timestamp: message_raw['timestamp'])
   end
 
   #

packages/zammad-addon-common/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@link-stack/zammad-addon-common",
-  "version": "1.0.0",
+  "version": "2.1.1",
   "description": "",
   "bin": {
     "zpm-build": "./dist/build.js",
@@ -9,6 +9,10 @@
   "scripts": {
     "build": "tsc"
   },
+  "devDependencies": {
+    "typescript": "^5",
+    "@types/node": "^22"
+  },
   "author": "",
   "license": "AGPL-3.0-or-later"
 }

packages/zammad-addon-common/tsconfig.json

@@ -2,9 +2,7 @@
   "compilerOptions": {
     "incremental": true,
     "target": "es2020",
-    "lib": [
+    "lib": ["es2020"],
-      "es2020"
-    ],
     "moduleResolution": "node",
     "module": "commonjs",
     "declaration": true,
@@ -22,9 +20,6 @@
     "experimentalDecorators": true,
     "emitDecoratorMetadata": true,
     "outDir": "dist",
-    "types": [
+    "types": ["node"]
-      "node",
-      "jest"
-    ]
   }
 }

packages/zammad-addon-hardening/package.json

@@ -1,7 +1,7 @@
 {
   "name": "@link-stack/zammad-addon-hardening",
   "displayName": "Hardening",
-  "version": "2.0.0",
+  "version": "2.1.1",
   "description": "A Zammad addon that hardens a Zammad instance according to CDR's needs.",
   "scripts": {
     "build": "node '../../node_modules/@link-stack/zammad-addon-common/dist/build.js'",

packages/zammad-addon-leafcutter/package.json

@@ -1,7 +1,7 @@
 {
   "name": "@link-stack/zammad-addon-leafcutter",
   "displayName": "Leafcutter",
-  "version": "2.0.0",
+  "version": "2.1.1",
   "description": "Adds a common set of tags for Leafcutter uses.",
   "scripts": {
     "build": "node '../../node_modules/@link-stack/zammad-addon-common/dist/build.js'",