Schemas and dbConnect added

Author: sincerelyyyash

app/workflow/page.tsx

@@ -1,12 +1,12 @@
 "use client"
 import React from 'react';
-import WorkflowExecutor from '@/components/WorkflowExecutor';
+import WorkflowBuilder from '@/components/WorkflowBuilder';
 
-export default function RunWorkflowPage() {
+export default function BuildWorkflowPage() {
   return (
     <div className="flex flex-col min-h-screen">
       <main className="flex-grow p-4">
-        <WorkflowExecutor />
+        <WorkflowBuilder />
       </main>
     </div>
   );

lib/dbConnect.ts

@@ -0,0 +1,28 @@
+import mongoose from "mongoose";
+
+type ConnectionObject = {
+  isConnected?: number
+}
+
+const connection: ConnectionObject = {}
+
+async function dbConnect(): Promise<void> {
+  if (connection.isConnected) {
+    console.log("Already connected to database")
+    return
+  }
+
+  try {
+    const db = await mongoose.connect(process.env.MONGODB_URI || '')
+
+    connection.isConnected = db.connections[0].readyState
+
+    console.log("Database connected successfully")
+  } catch (error) {
+    console.log("Database connection failed", error)
+
+    process.exit(1)
+  }
+}
+
+export default dbConnect;

schemas/WorkFlowExecutionSchema.ts

@@ -0,0 +1,40 @@
+
+import { Schema, model, models } from 'mongoose';
+
+const ExecutionSchema = new Schema({
+  workflowId: {
+    type: Schema.Types.ObjectId,
+    ref: 'Workflow',
+    required: true,
+  },
+  userId: {
+    type: Schema.Types.ObjectId,
+    ref: 'User',
+    required: true,
+  },
+  fileName: {
+    type: String,
+    required: true,
+  },
+  status: {
+    type: String,
+    enum: ['pending', 'processing', 'completed', 'failed'],
+    default: 'pending',
+  },
+  result: {
+    type: Schema.Types.Mixed,
+  },
+  errorMessage: {
+    type: String,
+  },
+  createdAt: {
+    type: Date,
+    default: Date.now,
+  },
+  updatedAt: {
+    type: Date,
+    default: Date.now,
+  },
+});
+
+export default models.Execution || model('Execution', ExecutionSchema);

schemas/fileSchema.ts

@@ -0,0 +1,24 @@
+
+import { Schema, model, models } from 'mongoose';
+
+const FileSchema = new Schema({
+  userId: {
+    type: Schema.Types.ObjectId,
+    ref: 'User',
+    required: true,
+  },
+  fileName: {
+    type: String,
+    required: true,
+  },
+  filePath: {
+    type: String,
+    required: true,
+  },
+  uploadedAt: {
+    type: Date,
+    default: Date.now,
+  },
+});
+
+export default models.File || model('File', FileSchema);

schemas/userSchema.ts

@@ -0,0 +1,24 @@
+
+import { Schema, model, models } from 'mongoose';
+
+const UserSchema = new Schema({
+  email: {
+    type: String,
+    required: true,
+    unique: true,
+  },
+  name: {
+    type: String,
+  },
+  image: {
+    type: String,
+  },
+  workflows: [
+    {
+      type: Schema.Types.ObjectId,
+      ref: 'Workflow',
+    },
+  ],
+});
+
+export default models.User || model('User', UserSchema);

schemas/workflowSchema.ts

@@ -0,0 +1,59 @@
+
+import { Schema, model, models } from 'mongoose';
+
+const NodeSchema = new Schema({
+  id: {
+    type: String,
+    required: true,
+  },
+  type: {
+    type: String,
+    enum: ['filterData', 'wait', 'convertFormat', 'sendPostRequest'],
+    required: true,
+  },
+  position: {
+    x: { type: Number, required: true },
+    y: { type: Number, required: true },
+  },
+  data: {
+    label: { type: String },
+    additionalData: { type: Schema.Types.Mixed },
+  },
+});
+
+const EdgeSchema = new Schema({
+  id: {
+    type: String,
+    required: true,
+  },
+  source: {
+    type: String,
+    required: true,
+  },
+  target: {
+    type: String,
+    required: true,
+  },
+  sourceHandle: String,
+  targetHandle: String,
+});
+
+const WorkflowSchema = new Schema({
+  userId: {
+    type: Schema.Types.ObjectId,
+    ref: 'User',
+    required: true,
+  },
+  name: {
+    type: String,
+    required: true,
+  },
+  nodes: [NodeSchema],
+  edges: [EdgeSchema],
+  createdAt: {
+    type: Date,
+    default: Date.now,
+  },
+});
+
+export default models.Workflow || model('Workflow', WorkflowSchema);