Full TDX integration

api/index.js

@@ -378,6 +378,68 @@
 
   // app.use("/api", await router());
 
+  // Routes for TDX Web API
+
+  app.get('/api/tdx-auth', async (req, res) => {
+    const { shopId } = req.query;
+
+    try {
+      const response = await fetch(`${process.env.TDX_URL}/auth/loginSSO`);
+      const r = await response.text();
+
+      // gets token from html code returned from fetch (matches token characters)
+      // basically an extraction (thanks, Gemini)
+      // eslint-disable-next-line max-len
+      const t = r.match(/([A-Za-z0-9-_]{20,}\.){2}[A-Za-z0-9-_]{20,}|[A-Za-z0-9]{32,}/);
+
+      if (t) {
+        const token = t[0];
+
+        const destination = `${process.env.BASE_URL}/shops/${shopId}/jobs?token=${encodeURIComponent(token)}#`;
+
+        res.redirect(destination);
+      } else {
+        res.status(500).send("SSO Success, but no token found in HTML output.");
+        console.log(`${res.status(500)}: SSO Success, but no token found in HTML output.`);
+      }
+    } catch (error) {
+      res.status(500).send(error);  
+    }
+  });
+
+  app.get('/api/tdx-ticket', async (req, res) => {
+    const { ticketId, token } = req.query;
+
+    if (!token) {
+      return res.status(400).json({error: "Token is required"});
+    }
+
+    if (!ticketId) {
+      return res.status(400).json({ error: "Ticket ID is required" });
+    }
+
+    try {
+      const ticketRes = await fetch(`${process.env.TDX_URL}/${process.env.TDX_APP_ID}/tickets/${ticketId}`, {
+        headers: { 
+          'Authorization': `Bearer ${token}`,
+          'Content-Type': 'application/json'
+        }
+      });
+
+      if (!ticketRes.ok) {
+        return res.status(ticketRes.status).json({ error: "Ticket not found" });
+      }
+
+      const data = await ticketRes.json();
+
+      res.json(data);
+
+    } catch (error) {
+      console.error("TDX Proxy Error:", error);
+      res.status(500).json({ error: "Internal Server Error", details: error.message });
+    }
+  });
+
   // This route is used for training purposes only. It is not used in production.
   app.use((req, res, next) => {
     if (req.url.includes("joke/emoji")) {

api/routes/shop/[shopId]/job/index.js

@@ -100,45 +100,54 @@ export const post = [
         }
 
         if (onBehalfOfUserEmail) {
-          const user = await prisma.user.create({
-            data: {
-              email: onBehalfOfUserEmail,
-              firstName: onBehalfOfUserFirstName,
-              lastName: onBehalfOfUserLastName,
-            },
-          });
-
-          const shopsToJoin = await prisma.shop.findMany({
+          let user = await prisma.user.findFirst({
             where: {
-              autoJoin: true,
+              email: onBehalfOfUserEmail,
             },
           });
 
-          for (const shop of shopsToJoin) {
-            await prisma.userShop.create({
+          if (!user) {
+            const user = await prisma.user.create({
               data: {
-                userId: user.id,
-                shopId: shop.id,
-                active: true,
+                email: onBehalfOfUserEmail,
+                firstName: onBehalfOfUserFirstName,
+                lastName: onBehalfOfUserLastName,
+              },
+            });
+
+
+            const shopsToJoin = await prisma.shop.findMany({
+              where: {
+                autoJoin: true,
               },
             });
 
+            for (const shop of shopsToJoin) {
+              await prisma.userShop.create({
+                data: {
+                  userId: user.id,
+                  shopId: shop.id,
+                  active: true,
+                },
+              });
+
+              await prisma.logs.create({
+                data: {
+                  userId: user.id,
+                  type: LogType.USER_CONNECTED_TO_SHOP,
+                  shopId: shop.id,
+                },
+              });
+            }
+
             await prisma.logs.create({
               data: {
                 userId: user.id,
-                type: LogType.USER_CONNECTED_TO_SHOP,
-                shopId: shop.id,
+                type: LogType.USER_CREATED,
               },
             });
           }
 
-          await prisma.logs.create({
-            data: {
-              userId: user.id,
-              type: LogType.USER_CREATED,
-            },
-          });
-
           userToCreateJobAs = user.id;
         }
       }

app/src/hooks/index.jsx

@@ -25,5 +25,6 @@ export { useBillingGroup } from "./useBillingGroup";
 export { useBillingGroupInvitations } from "./useBillingGroupInvitations";
 export { useBillingGroupInvitation } from "./useBillingGroupInvitation";
 export { useBillingGroupUser } from "./useBillingGroupUser";
+export { useTDXTickets } from "./useTDXTickets";
 export { useBillingGroupLedger } from "./useBillingGroupLedger";
 export { useShopLedger } from "./useShopLedger";

app/src/hooks/useJobs.jsx

@@ -1,4 +1,5 @@
 import React, { useState, useEffect } from "react";
+import toast from "react-hot-toast";
 import { authFetch } from "#url";
 import { useModal } from "#modal";
 import { Input, Spinner, Util, Switch, Card } from "tabler-react-2";
@@ -8,6 +9,7 @@ import { useUserShop } from "./useUserShop";
 import { useAuth } from "#useAuth";
 import { ShopUserPicker } from "#shopUserPicker";
 import { BillingGroupPicker } from "../components/billingGroupPicker/BillingGroupPicker";
+import { useTDXTickets } from "./useTDXTickets";
 
 const toLocalDateInputValue = (date) => {
   const localDate = new Date(date);
@@ -185,6 +187,69 @@ const CreateJobModalContent = ({
   );
 };
 
+const CreateTDXImportModalContent = ({
+    onSubmit
+  }) => {
+  const {shopId} = useParams('');
+  const [auth] = useState({ tdxToken: localStorage.getItem('tdx_bearer_token') });
+  const [ticketId, setTicketId] = useState('');
+  const { loading, handleLogin, fetchTicket } = useTDXTickets();
+  if (!auth.tdxToken) {
+    return (
+      <div>
+          <div>
+              <Button
+                  loading={loading}
+                  onClick={async () => {
+                      handleLogin(shopId);
+                  }}
+              >
+                  Log Into TDNext
+              </Button>
+          </div>
+      </div>
+    )
+  }
+  return (
+    <div className="gap-2 border-b-5 border-b-black">
+        <Input
+            value={ticketId}
+            onChange={(e) => setTicketId(e)}
+            label="TDNext Ticket ID"
+            placeholder="Ticket ID"
+        />
+        <Button 
+            loading={loading}
+            onClick={async () => {
+                const data = await fetchTicket(ticketId);
+                toast.promise(data, {
+                    loading: "Fetching ticket from TDX...",
+                    success: "Successfully imported ticket.",
+                    error: "Error when fetching",
+                });
+                if (data && onSubmit) {
+                    // Call onSubmit with positional arguments to match _createJob
+                    onSubmit(
+                        data.title,
+                        data.description,
+                        data.dueDate,
+                        data.onBehalfOf,
+                        data.onBehalfOfUserId,
+                        data.onBehalfOfUserEmail,
+                        data.onBehalfOfUserFirstName,
+                        data.onBehalfOfUserLastName,
+                        data.onBehalfOfBillingGroup,
+                        data.onBehalfOfBillingGroupId
+                    );
+                }
+            }}
+        >
+            Import Ticket
+        </Button>
+    </div>
+  );
+};
+
 export const useJobs = (shopId) => {
   const [loading, setLoading] = useState(true);
   const [error, setError] = useState(null);
@@ -235,6 +300,11 @@ export const useJobs = (shopId) => {
     text: <CreateJobModalContent onSubmit={_createJob} />,
   });
 
+  const { modal: tdxModal, ModalElement: TDXModalElement } = useModal({
+    title: "Import from TDNext",
+    text: <CreateTDXImportModalContent onSubmit={_createJob}/>
+  });
+
   const CreateSimpleSubPage = () => {
     const [title, setTitle] = useState("");
     const [description, setDescription] = useState("");
@@ -337,6 +407,15 @@ export const useJobs = (shopId) => {
     });
   };
 
+  const importTDXJob = async () => {
+    tdxModal({
+      title: "Import ticket from TDNext",
+      text: (
+        <CreateTDXImportModalContent onSubmit={_createJob} />
+      )
+    })
+  };
+
   const updateJob = async (jobId, newJob) => {
     const job = jobs.find((j) => j.id === jobId);
     if (job.finalized) {
@@ -383,7 +462,9 @@ export const useJobs = (shopId) => {
     refetch: fetchJobs,
     CreateSimpleSubPage,
     ModalElement,
+    TDXModalElement,
     createJob,
+    importTDXJob,
     opLoading,
     updateJob,
   };

app/src/hooks/useTDXTickets.jsx

@@ -0,0 +1,99 @@
+import { useState } from 'react';
+import { authFetch } from "#url";
+import toast from 'react-hot-toast';
+
+export const useTDXTickets = () => {
+    const [auth, setAuth] = useState({ tdxToken: localStorage.getItem('tdx_bearer_token') });
+    const [ticketId, setTicketId] = useState('');
+    const [ticket, setTicket] = useState(null);
+    const [loading, setLoading] = useState(false);
+    const [error, setError] = useState(null);
+
+    const currentDate = new Date();
+    const nextWeekDate = new Date(currentDate);
+
+    const handleLogin = (shopId) => {
+        setLoading(true);
+
+        const relayUrl = `${import.meta.env.VITE_API_BASE_URL}/api/tdx-auth?shopId=${shopId}`; // update later
+        const loginWindow = window.open(relayUrl, "OktaLogin", "width=500,height=600");
+
+        const timer = setInterval(() => {
+            try {
+                if (loginWindow.location.href.includes(window.location.hostname)) {
+                    const urlParams = new URLSearchParams(loginWindow.location.search);
+                    const token = urlParams.get('token');
+
+                    if (token) {
+                        localStorage.setItem('tdx_bearer_token', token);
+                        setAuth({ tdxToken: token });
+
+                        loginWindow.close();
+                        clearInterval(timer);
+                        setLoading(false);
+                        toast.success("TDX Authenticated");
+                        window.location.reload();
+                    }
+                }
+            } catch (e) {
+                toast.error(e);
+                setError(e);
+            }
+        }, 1000);
+    };
+
+    const fetchTicket = async (id) => {
+        var ticket;
+
+        if (!id) {
+            toast.error("Please enter a Ticket ID");
+            return null;
+        }
+
+        try {
+            // Pointing to your proxy endpoint
+            try {
+                const r = await authFetch(`/api/tdx-ticket?ticketId=${id}&token=${auth.tdxToken}`);
+                ticket = await r.json();
+                setTicket(ticket);
+            } catch (error) {
+                setError(error);
+                toast.error(`Ticket fetch failed: ${error}`);
+            }
+
+            // Extract values from TDX Attributes
+            // const costAttr = ticket?.Attributes.find(item => item.ID === 2312)?.Value || 0.00;
+            const descriptionAttr = `${ticket?.Attributes.find(item => item.ID === 2328)?.Value}; ${ticket?.Attributes.find(item => item.ID === 2311)?.Value}`;
+
+            // Map the TDX response to the specific order _createJob expects
+            return {
+                title: ticket?.Title ? `TDX: ${ticket?.Title}` : "No Title Available",
+                description: descriptionAttr,
+                dueDate: nextWeekDate.setDate(currentDate.getDate() + 7), // Defaulting to week from current day
+                onBehalfOf: true,
+                onBehalfOfUserId: ticket?.RequestorUID || '',
+                onBehalfOfUserEmail: ticket?.RequestorEmail || '',
+                onBehalfOfUserFirstName: ticket?.RequestorFullName?.split(" ")[0] || "Unknown",
+                onBehalfOfUserLastName: ticket?.RequestorFullName?.split(" ")[1] || "Unknown",
+                onBehalfOfBillingGroup: false, // Defaulting as per your previous state
+                onBehalfOfBillingGroupId: null
+            };
+        } catch (error) {
+            setError(error.message);
+            toast.error(error.message);
+            return null;
+        } finally {
+            setLoading(false);
+        }
+    };
+
+    return {
+        ticket,
+        ticketId,
+        setTicketId,
+        loading,
+        handleLogin,
+        fetchTicket,
+        error
+    };
+};