Feature/config fixes

apps/hooks/src/index.ts

@@ -7,6 +7,8 @@ app.use(express.json());
 
 app.post("/hooks/catch/:userId/:workflowId", async (req, res) => {
   try {
+
+    console.log("THIS LOG IS FROM HOOKS BACKEND THAT WE HAVE RECIEVED THE REQUEST")
     const { userId, workflowId } = req.params;
     const { triggerData } = req.body;
 
@@ -24,7 +26,7 @@ app.post("/hooks/catch/:userId/:workflowId", async (req, res) => {
       const workflowExecution = await tx.workflowExecution.create({
         data: {
           workflowId: workflow.id,
-// next time you see this line  validate the trigger data thinnnnnnnnnn
+          // next time you see this line  validate the trigger data thinnnnnnnnnn
           status: "Pending",
           metadata: triggerData,
         },
@@ -39,13 +41,13 @@ app.post("/hooks/catch/:userId/:workflowId", async (req, res) => {
     });
     return res.status(200).json({
       success: true,
-      workflowExecutionId:  result.workflowExecution.id,
+      workflowExecutionId: result.workflowExecution.id,
     });
   } catch (error: any) {
     console.log(error);
-    res.status(500).json({ 
-      success: false, 
-      error: "Failed to process webhook" 
+    res.status(500).json({
+      success: false,
+      error: "Failed to process webhook"
     });
   }
 });

apps/http-backend/src/routes/google_callback.ts

@@ -72,6 +72,7 @@ googleAuth.get(
   "/callback",
   userMiddleware,
   async (req: Request, res: Response) => {
+    console.log("Request recieved to the callback from fronted ")
     const code = req.query.code;
     const state = req.query.state;
     const Oauth = new GoogleOAuthService();

apps/http-backend/src/routes/userRoutes/userRoutes.ts

@@ -13,8 +13,11 @@ import {
   NodeUpdateSchema,
   TriggerUpdateSchema,
   workflowUpdateSchema,
+  ExecuteWorkflow,
+  HOOKS_URL,
 } from "@repo/common/zod";
 import { GoogleSheetsNodeExecutor } from "@repo/nodes";
+import axios, { Axios } from "axios";
 const router: Router = Router();
 
 router.post("/createAvaliableNode", async (req: AuthRequest, res: Response) => {
@@ -140,15 +143,16 @@ router.get(
   userMiddleware,
   async (req: AuthRequest, res) => {
     try {
-      console.log("user from getcredentials: ", req.user);
+      // console.log("user from getcredentials: ", req.user);
       if (!req.user) {
         return res.status(statusCodes.BAD_REQUEST).json({
           message: "User is not Loggedin",
         });
       }
       const userId = req.user.sub;
       const type = req.params.type;
-      console.log(userId, " -userid");
+      console.log("The type of data comming to backed is ", type)
+      // console.log(userId, " -userid");
 
       if (!type || !userId) {
         return res.status(statusCodes.BAD_REQUEST).json({
@@ -182,8 +186,6 @@ router.get(
       if (credentials.length === 0) {
         return res.status(200).json({
           message: "No credentials found",
-          data: [], // always array
-          hasCredentials: false,
         });
       }
 
@@ -278,9 +280,9 @@ router.post(
         error: e instanceof Error ? e.message : "Unknown error"
       });
     }
-    }
+  }
+
 
-
 );
 
 // ------------------------------------ FETCHING WORKFLOWS -----------------------------------
@@ -519,13 +521,17 @@ router.post(
       // Use an empty array for credentials (if required) or don't pass it at all
       // Config must be valid JSON (not an empty string)
       // const stage = dataSafe.data.Position
+      console.log("This is from the backend log of positions", dataSafe.data.position)
       const createdNode = await prismaClient.node.create({
         data: {
           name: dataSafe.data.Name,
           workflowId: dataSafe.data.WorkflowId,
           config: dataSafe.data.Config || {},
           stage: Number(dataSafe.data.stage ?? 0),
-          position: {},
+          position: {
+            x: dataSafe.data.position.x,
+            y: dataSafe.data.position.y
+          },
           AvailableNodeID: dataSafe.data.AvailableNodeId,
         },
       });
@@ -626,6 +632,74 @@ router.put(
   }
 );
 
+router.post("/executeWorkflow", userMiddleware, async (req: AuthRequest, res) => {
+  console.log("REcieved REquest to the  execute route ")
+  const Data = req.body
+  if (!req.user) {
+    return res.status(statusCodes.UNAUTHORIZED).json({
+      message: "User Not Authorized"
+    })
+  }
+  const parsedData = ExecuteWorkflow.safeParse(Data);
+  console.log("This is the log data of execute work flow zod", parsedData.error)
+  if (!parsedData.success) {
+    return res.status(statusCodes.FORBIDDEN).json({
+      message: "Error in Zod Schma",
+      Data: parsedData.error
+    })
+  }
+  const workflowId = parsedData.data.workflowId;
+  const userId = req.user.id
+  try {
+    const trigger = await prismaClient.workflow.findFirst({
+      where: { id: workflowId, userId: userId },
+      include: {
+        Trigger: true
+      }
+    })
+    if (!trigger) {
+      return res.status(statusCodes.NOT_FOUND).json({
+        message: "Workflow not found or not authorized"
+      });
+    }
+    console.log("This is the Trigger Name of  the workflow", trigger?.Trigger?.name)
+    console.log("This is the Trigger Data of  the workflow", trigger)
+
+    if (trigger?.Trigger?.name === "webhook") {
+      const data = await axios.post(`${HOOKS_URL}/hooks/catch/${userId}/${workflowId}`, {
+        triggerData: "",
+
+      },
+        { timeout: 30000 },)
+      console.log("Workflow Execution for webhook  started with Execution Id is ", data.data.workflowExecutionId)
+      const workflowExecutionId = data.data.workflowExecutionId;
+      if (!workflowExecutionId) {
+        return res.status(statusCodes.INTERNAL_SERVER_ERROR).json({
+          message: "Failed to start workflow execution"
+        }
+        )
+      }
+      return res.status(200).json({
+        success: true,
+        workflowExecutionId: data.data.workflowExecutionId
+      });
+    }
+    else {
+
+      return res.status(statusCodes.FORBIDDEN).json({
+        message: "Trigger is not webhook"
+      });
+    }
+
+
+  } catch (error: any) {
+    return res.status(statusCodes.INTERNAL_SERVER_ERROR).json({
+      message: "Internal Server Error ",
+      Error: error instanceof Error ? error.message : "Unknown Error"
+    })
+  }
+
+})
 router.get("/protected", userMiddleware, (req: AuthRequest, res) => {
   return res.json({
     ok: true,

apps/web/app/components/ui/Design/WorkflowButton.tsx

@@ -9,7 +9,13 @@ export default function ParentComponent() {
 
   return (
     <div className="flex flex-wrap items-center gap-2 md:flex-row">
-      <Button onClick={() => setIsOpen(true)} variant={"outline"}>Create WorkFlow</Button>
+      <Button 
+        onClick={() => setIsOpen(true)} 
+        variant={"outline"}
+        className="hover:cursor-pointer"
+      >
+        Create WorkFlow
+      </Button>
 
       {/* The Modal is conditionally rendered here */}
       {isOpen && <CardDemo onClose={() => setIsOpen(false)} />}

apps/web/app/hooks/useCredential.ts

@@ -18,7 +18,8 @@ export const useCredentials = (type: string, workflowId?: string): any => {
         }
 
         const response = await getCredentials(type);
-
+        const data = JSON.stringify(response)
+        console.log("This is the log from usecredentials" , data)
         // Backend should ONLY return stored credentials
         if (Array.isArray(response)) {
           setCred(response);

apps/web/app/lib/api.ts

@@ -8,11 +8,11 @@ import { getCredentials } from "../workflow/lib/config";
 export const api = {
   user: {
     get: async () => {
-      return await axios.get(`${BACKEND_URL}/user/workflows`, 
+      return await axios.get(`${BACKEND_URL}/user/workflows`,
         {
-        withCredentials: true,
-        headers: { "Content-Type": "application/json" },
-      })
+          withCredentials: true,
+          headers: { "Content-Type": "application/json" },
+        })
     }
   },
   workflows: {
@@ -38,6 +38,12 @@ export const api = {
           withCredentials: true,
           headers: { "Content-Type": "application/json" },
         })
+    },
+    execute: async (data: any) => {
+      return await axios.post(`${BACKEND_URL}/user/executeWorkflow`, data, {
+        withCredentials: true,
+        headers: { "Content-Type": "application/json" },
+      })
     }
   },
   triggers: {

apps/web/app/lib/nodeConfigs/gmail.action.ts

@@ -6,7 +6,7 @@ export const gmailActionConfig: NodeConfig = {
   label: "Gmail",           // ✅ Clean name
   icon: "📧",               // ✅ Email icon
   description: "Send emails via Gmail",
-  credentials: "google",
+  credentials: "google_oauth",
 
   fields: [
     {

apps/web/app/login/page.tsx

@@ -59,7 +59,7 @@ const Page = () => {
       }
       if(result?.ok){
         toast.success("Login successful!")
-        router.push('/workflow')
+        router.push('/workflows')
       }
     } catch(e) {
       setError({...newErrors, auth:"Login failed. Please try again"})

apps/web/app/page.tsx

@@ -31,7 +31,7 @@ export default async function Home() {
         ) : (
           <>
             <p>Status: Not authenticated</p>
-            <form action="/api/auth/signin" method="post">
+            <form action="/login" method="post">
               <button
                 type="submit"
                 className="px-4 py-2 mt-4 bg-green-500 text-white rounded"

apps/web/app/workflows/[id]/components/ConfigModal.tsx

@@ -388,6 +388,9 @@ export default function ConfigModal({
           >
             {loading ? "Saving..." : "Save"}
           </button>
+
+
+
         </div>
       </div>
     </div>