feat: implement execution logging for workflows

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

@@ -29,23 +29,75 @@ execRouter.post('/node', userMiddleware,  async(req: AuthRequest, res: Response)
         if(nodeData){
             const type = nodeData.AvailableNode.type
             const config = dataSafe.data.Config ? dataSafe.data.Config : nodeData.config // for test api data prefered fist then config in db 
-            console.log(`config and type: ${JSON.stringify(config)} & ${type}`)
+            // // console.log(`config and type: ${JSON.stringify(config)} & ${type}`)
 
             const context = {
                 userId: req.user.sub,
                 config: config,
                 credentialId: nodeData.CredentialsID || config?.credentialId || ""
             }
-
-            console.log(`Execution context: ${JSON.stringify(context)}`)
-            const executionResult = await ExecutionRegister.execute(type, context)
-
-            console.log(`Execution result: ${executionResult}`)
-
-            if(executionResult.success)
-                return res.status(statusCodes.ACCEPTED).json({
-                message: `${nodeData.name} node execution done` ,
-                data: executionResult       
+            const result = await prismaClient.$transaction(async(tx)=>{
+                // // console.log(`Execution context: ${JSON.stringify(context)}`)
+                const workflowExecution = await tx.workflowExecution.create({
+                    data:{
+                        workflowId: nodeData.workflowId || "",
+                        status: "Start",
+                        startAt: new Date(),
+                        metadata:{"isTesting": true},
+                    }
+                })
+                const NodeExecution = await tx.nodeExecution.create({
+                    data:{
+                        status: "Start",
+                        nodeId: nodeData.id,
+                        workflowExecId: workflowExecution.id,
+                        startedAt: new Date(),
+                        inputData: context,
+                        isTest: true
+                    }
+                })
+                const executionResult = await ExecutionRegister.execute(type, context)
+
+
+                // console.log(`Execution result: ${executionResult}`)
+
+                if(executionResult.success){
+                    await tx.nodeExecution.update({
+                        where: { id: NodeExecution.id},
+                        data:{
+                            status: "Completed",
+                            outputData: executionResult.output,
+                            completedAt: new Date()
+                        }
+                    })
+                    await tx.workflowExecution.update({
+                        where: {id: workflowExecution.id},
+                        data: {
+                            status: "Completed",
+                            completedAt: new Date()
+                        }
+                    })
+                    return res.status(statusCodes.ACCEPTED).json({
+                        message: `${nodeData.name} node execution done` ,
+                        data: executionResult       
+                        })
+                }
+                await tx.nodeExecution.update({
+                    where: {id : NodeExecution.id},
+                    data:{
+                        status: "Failed",
+                        completedAt: new Date(),
+                        error: executionResult.error
+                    }
+                })
+                await tx.workflowExecution.update({
+                    where: {id: workflowExecution.id},
+                    data:{
+                        status: "Failed",
+                        completedAt: new Date(),
+                        error: executionResult.output
+                    }
+                })
             })
 
             return res.status(statusCodes.FORBIDDEN).json({
@@ -57,7 +109,7 @@ execRouter.post('/node', userMiddleware,  async(req: AuthRequest, res: Response)
         })      
 
     }catch(e){
-    console.log("This is the error from executing node", e);
+    // console.log("This is the error from executing node", e);
       return res.status(statusCodes.INTERNAL_SERVER_ERROR).json({
         message: "Internal server Error from node execution ",
       });