feat: enhance workflow execution logging, add Gmail node, and update …

apps/http-backend/tsconfig.tsbuildinfo

@@ -1 +1 @@
-{"root":["./src/index.ts","./src/routes/google_callback.ts","./src/routes/nodes.routes.ts","./src/routes/userRoutes/userMiddleware.ts","./src/routes/userRoutes/userRoutes.ts"],"version":"5.7.3"}
+{"root":["./src/index.ts","./src/routes/google_callback.ts","./src/routes/nodes.routes.ts","./src/routes/userroutes/usermiddleware.ts","./src/routes/userroutes/userroutes.ts","./src/scheduler/token-scheduler.ts","./src/services/token-refresh.service.ts"],"version":"5.7.3"}

apps/web/next.config.mjs

@@ -1,6 +1,7 @@
 /** @type {import('next').NextConfig} */
 const nextConfig = {
-  transpilePackages: ["@workspace/ui"],
+  transpilePackages: ["@workspace/ui", "@repo/db"],
+  serverExternalPackages: ["@prisma/client", "prisma"],
 }
 
 export default nextConfig

apps/worker/src/engine/executor.ts

@@ -34,32 +34,36 @@ export async function executeWorkflow(
       status: "InProgress",
     },
   });
+  if(!update.error) console.log('updated the workflow execution')
 
   const nodes = data?.workflow.nodes;
 
+  console.log(`Total nodes - ${nodes.length}`)
   for (const node of nodes) {
+    console.log(`${node.name}, ${node.position}th - started Execution`)
     const nodeType = node.AvailableNode.type;
     const context = {
-      nodeId: node.id,
+      // nodeId: node.id,
       userId: data.workflow.userId,
-      credentialId: node.credentials[0]?.id,
+      credId: node.credentials[0]?.id,
       config: node.config as Record<string, any>,
       inputData: currentInputData,
     };
-
+    console.log(`Executing with context: ${context}`)
     const execute = await register.execute(nodeType, context);
-    if (!execute.success) {
-      await prismaClient.workflowExecution.update({
-        where: { id: workflowExecutionId },
-        data: {
-          status: "Failed",
-          error: execute.error,
-          completedAt: new Date(),
-        },
-      });
-      return;
-    }
+    // if (!execute.success) {
+    //   await prismaClient.workflowExecution.update({
+    //     where: { id: workflowExecutionId },
+    //     data: {
+    //       status: "Failed",
+    //       error: execute.error,
+    //       completedAt: new Date(),
+    //     },
+    //   });
+    //   return;
+    // }
     currentInputData = execute.output;
+    console.log("output: ", JSON.stringify(execute))
   }
   const updatedStatus = await prismaClient.workflowExecution.update({
     where: { id: workflowExecutionId },

apps/worker/src/engine/registory.ts

@@ -1,5 +1,6 @@
 import { ExecutionContext, ExecutionResult, NodeExecutor } from "../types.js";
 import { GmailExecutor } from "@repo/nodes/nodeClient";
+import {GoogleSheetsNodeExecutor} from "@repo/nodes/nodeClient";
 class ExecutionRegistry {
   private executors = new Map<string, NodeExecutor>();
 
@@ -19,7 +20,7 @@ class ExecutionRegistry {
       };
     }
     try {
-      const result = await executor.execute(context);
+      const result = await executor.execute(context)
       console.log("Execute result:", result);
 
       return result;
@@ -38,6 +39,7 @@ class ExecutionRegistry {
 
     //wehen visits this next time make sure chang gmail executor implements NodeExecutor
     this.register("gmail", new GmailExecutor() as unknown as NodeExecutor);
+    this.register("google_sheet", new GoogleSheetsNodeExecutor() as unknown as NodeExecutor)
     console.log(`The current Executors are ${this.executors.size}`);
   }
 }

apps/worker/src/index.ts

@@ -1,12 +1,15 @@
 import { Kafka } from "kafkajs";
 import { executeWorkflow } from "./engine/executor.js";
+import { register } from "./engine/registory.js";
 const kafka = new Kafka({
   // clientId: "Processing App",
   clientId: "BuildFlow-Worker",
   brokers: ["localhost:9092"],
 });
 const TOPIC_NAME = "First-Client";
 
+register.initialize()
+
 async function main() {
   const consumer = kafka.consumer({ groupId: "test-group" });
   await consumer.connect();

apps/worker/src/types.ts

@@ -1,5 +1,5 @@
 export interface ExecutionContext {
-  nodeId: string;
+  nodeId?: string;
   userId: string;
   credentialsId?: string;
   config: Record<string, any>;

apps/worker/tsconfig.tsbuildinfo

@@ -1 +1 @@
-{"root":["./src/index.ts","./src/test.ts","./src/types.ts","./src/engine/executor.ts","./src/engine/registory.ts"],"version":"5.7.3"}
+{"root":["./src/index.ts","./src/types.ts","./src/engine/executor.ts","./src/engine/registory.ts","./src/tests/create-execution.ts","./src/tests/setup-test.ts","./src/tests/test.ts","./src/tests/update-node.ts"],"version":"5.7.3"}

package.json

@@ -15,7 +15,7 @@
     "turbo": "^2.7.2",
     "typescript": "5.7.3"
   },
-  "packageManager": "pnpm@10.26.2",
+  "packageManager": "pnpm@10.27.0",
   "engines": {
     "node": ">=20"
   }

packages/db/package.json

@@ -24,4 +24,4 @@
     "dotenv": "^17.2.3",
     "prisma": "^6.19.0"
   }
-}
+}

packages/db/prisma/schema.prisma

@@ -1,5 +1,6 @@
 generator client {
   provider = "prisma-client-js"
+  // output   = "../node_modules/.prisma/client"
 }
 
 datasource db {
@@ -117,8 +118,8 @@ model NodeExecution {
 model WorkflowExecutionTable {
   id                  String            @id @default(uuid())
   workflowExecutionId String            @unique
+  sent                Boolean           @default(false)
   workflowExecution   WorkflowExecution @relation(fields: [workflowExecutionId], references: [id])
-  sent                Boolean @default(false)
 }
 
 enum WorkflowStatus {

packages/db/tsconfig.tsbuildinfo

@@ -1 +1 @@
-{"root":["./src/index.ts","./src/seed.ts"],"version":"5.9.2"}
+{"root":["./src/index.ts","./src/seed.ts"],"version":"5.7.3"}

packages/nodes/src/common/google-oauth-service.ts

@@ -124,7 +124,7 @@ class GoogleOAuthService {
         `Failed to get all credentials: ${err instanceof Error ? err.message : "unknown error"}`
       );
     }
-
+  }
     async updateCredentials(credentialId: string, tokens: Partial<OAuthTokens>): Promise<void> {
         try{
             const existing = await this.prisma.credential.findUnique({
@@ -164,7 +164,7 @@ class GoogleOAuthService {
         }
     }
   }
-}
+
 
 export { GoogleOAuthService };
 export type { OAuthTokens };

packages/nodes/src/gmail/gmail.executor.ts

@@ -71,6 +71,6 @@ class GmailExecutor {
   }
 }
 
-export default GmailExecutor;
+export { GmailExecutor } ;
 // export { default as GmailExecutor } from "./gmail.executor.js";
 // export { GmailService } from "./gmail.service.js";

packages/nodes/src/gmail/gmail.node.ts

@@ -0,0 +1,43 @@
+import NodeRegistry from "../registry/node-registry.js";
+import { GmailExecutor } from "./gmail.executor.js";
+
+export class GmailNode {
+    static definition = {
+        name: "Gmail",
+        type: "gmail",
+        description: 'Communicate with Gmail',
+        config: {
+            fields:[
+                {
+                    name: "From",
+                    type: "email",
+                    require: true
+                },
+                {
+                    name: "To",
+                    type: "email",
+                    require: true
+                },
+                {
+                    name:"Body",
+                    type: "textArea",
+                    require: true
+                }
+            ]
+        },
+        requireAuth: true,
+        authType: 'google_oauth'
+
+    };
+
+    static async register(){
+        await NodeRegistry.register(this.definition)
+        // console.log(`✅ Registered node: ${this.definition.name}`);
+        await NodeRegistry.registerTrigger(this.definition)
+        // console.log(`✅ Registered Trigger: ${this.definition.name}`);
+    }
+
+    static getExecutor(){
+        return new GmailExecutor();
+    }
+}

packages/nodes/src/google-sheets/google-sheets.executor.ts

@@ -139,6 +139,7 @@ class GoogleSheetsNodeExecutor{
             }
 
             const operation = context.config.operation;
+            console.log("operation from sheet executor: ",operation)
             switch(operation){
                 case 'read_rows':
                     return await this.executeReadRows(sheetService,context);