User N8N workflows [WIP]

apps/hasura/metadata/databases/masterbots/tables/public_chatbot.yaml

@@ -5,9 +5,6 @@ object_relationships:
   - name: complexityEnum
     using:
       foreign_key_constraint_on: default_complexity
-  - name: department
-    using:
-      foreign_key_constraint_on: department_id
   - name: lengthEnum
     using:
       foreign_key_constraint_on: default_length
@@ -39,13 +36,6 @@ array_relationships:
         table:
           name: chatbot_domain
           schema: public
-  - name: organization_chatbots
-    using:
-      foreign_key_constraint_on:
-        column: chatbot_id
-        table:
-          name: organization_chatbot
-          schema: public
   - name: prompts
     using:
       foreign_key_constraint_on:
@@ -66,6 +56,7 @@ select_permissions:
       columns:
         - avatar
         - chatbot_id
+        - chatbot_id
         - created_by
         - default_complexity
         - default_length
@@ -84,20 +75,20 @@ select_permissions:
   - role: moderator
     permission:
       columns:
+        - disabled
         - is_pro
         - pro_exclusive
-        - avatar
         - chatbot_id
+        - department_id
+        - order
+        - avatar
         - created_by
         - default_complexity
         - default_length
         - default_tone
         - default_type
-        - department_id
         - description
-        - disabled
         - name
-        - order
       filter: {}
       allow_aggregations: true
     comment: ""

apps/hasura/metadata/databases/masterbots/tables/public_n8n_credentials.yaml

@@ -0,0 +1,3 @@
+table:
+  name: n8n_credentials
+  schema: public

apps/hasura/metadata/databases/masterbots/tables/public_preference.yaml

@@ -24,8 +24,6 @@ insert_permissions:
       columns:
         - deep_expertise
         - favorite
-        - font_size
-        - lang
         - preferred_complexity
         - preferred_length
         - preferred_tone
@@ -35,16 +33,10 @@ insert_permissions:
     comment: ""
   - role: user
     permission:
-      check:
-        user_id:
-          _eq: X-Hasura-User-Id
-      set:
-        user_id: X-Hasura-User-Id
+      check: {}
       columns:
         - deep_expertise
         - favorite
-        - font_size
-        - lang
         - preferred_complexity
         - preferred_length
         - preferred_tone
@@ -99,9 +91,7 @@ select_permissions:
         - preferred_type
         - user_id
         - web_search
-      filter:
-        user_id:
-          _eq: X-Hasura-User-Id
+      filter: {}
     comment: ""
 update_permissions:
   - role: moderator

apps/hasura/metadata/databases/masterbots/tables/public_thread.yaml

@@ -42,7 +42,6 @@ insert_permissions:
         - is_blocked
         - is_pro
         - is_public
-        - metadata
         - model
         - parent_thread_id
         - short_link
@@ -63,7 +62,6 @@ insert_permissions:
         - is_blocked
         - is_pro
         - is_public
-        - metadata
         - model
         - parent_thread_id
         - short_link

apps/hasura/metadata/databases/masterbots/tables/public_user_oauth_connections.yaml

@@ -0,0 +1,3 @@
+table:
+  name: user_oauth_connections
+  schema: public

apps/hasura/metadata/databases/masterbots/tables/public_user_workflows.yaml

@@ -0,0 +1,3 @@
+table:
+  name: user_workflows
+  schema: public

apps/hasura/metadata/databases/masterbots/tables/tables.yaml

@@ -4,16 +4,14 @@
 - "!include public_chatbot_category.yaml"
 - "!include public_chatbot_domain.yaml"
 - "!include public_complexity_enum.yaml"
-- "!include public_department.yaml"
 - "!include public_domain_enum.yaml"
 - "!include public_example.yaml"
 - "!include public_length_enum.yaml"
 - "!include public_message.yaml"
 - "!include public_message_type_enum.yaml"
 - "!include public_models.yaml"
 - "!include public_models_enum.yaml"
-- "!include public_organization.yaml"
-- "!include public_organization_chatbot.yaml"
+- "!include public_n8n_credentials.yaml"
 - "!include public_preference.yaml"
 - "!include public_prompt.yaml"
 - "!include public_prompt_chatbot.yaml"
@@ -28,4 +26,6 @@
 - "!include public_tone_enum.yaml"
 - "!include public_type_enum.yaml"
 - "!include public_user.yaml"
+- "!include public_user_oauth_connections.yaml"
 - "!include public_user_token.yaml"
+- "!include public_user_workflows.yaml"

apps/hasura/migrations/masterbots/1766065373919_create_table_public_user_workflows/down.sql

@@ -0,0 +1 @@
+DROP TABLE "public"."user_workflows";

apps/hasura/migrations/masterbots/1766065373919_create_table_public_user_workflows/up.sql

@@ -0,0 +1 @@
+CREATE TABLE "public"."user_workflows" ("id" uuid NOT NULL, "user_id" uuid NOT NULL, "workflow_name" text NOT NULL, "workflow_id" text NOT NULL, "service" text NOT NULL, "folder_path" text NOT NULL, "created_at" timestamptz NOT NULL, PRIMARY KEY ("id") , FOREIGN KEY ("user_id") REFERENCES "public"."user"("user_id") ON UPDATE restrict ON DELETE restrict, UNIQUE ("id"), UNIQUE ("user_id"), UNIQUE ("created_at"));

apps/hasura/migrations/masterbots/1766066591567_create_table_public_user_oauth_connections/down.sql

@@ -0,0 +1 @@
+DROP TABLE "public"."user_oauth_connections";

apps/hasura/migrations/masterbots/1766066591567_create_table_public_user_oauth_connections/up.sql

@@ -0,0 +1 @@
+CREATE TABLE "public"."user_oauth_connections" ("id" uuid NOT NULL, "user_id" uuid NOT NULL, "provider" text NOT NULL, "service" text NOT NULL, "scopes" text NOT NULL, "status" text NOT NULL, "connected_at" timestamptz NOT NULL, "revoked_at" timestamptz NOT NULL, PRIMARY KEY ("id") , FOREIGN KEY ("user_id") REFERENCES "public"."user"("user_id") ON UPDATE restrict ON DELETE restrict, UNIQUE ("id"), UNIQUE ("user_id"));

apps/hasura/migrations/masterbots/1766066981705_create_table_public_n8n_credentials/down.sql

@@ -0,0 +1 @@
+DROP TABLE "public"."n8n_credentials";

apps/hasura/migrations/masterbots/1766066981705_create_table_public_n8n_credentials/up.sql

@@ -0,0 +1 @@
+CREATE TABLE "public"."n8n_credentials" ("id" uuid NOT NULL, "user_id" uuid NOT NULL, "provider" text NOT NULL, "service" text NOT NULL, "n8n_credential_id" text NOT NULL, "created_at" timestamptz NOT NULL, PRIMARY KEY ("id") , FOREIGN KEY ("user_id") REFERENCES "public"."user"("user_id") ON UPDATE restrict ON DELETE restrict, UNIQUE ("id"), UNIQUE ("user_id"), UNIQUE ("n8n_credential_id"));

apps/web/app/api/automations/gmail/disable.ts

@@ -0,0 +1,42 @@
+import { getHasuraClient, getUserWorkflowByService } from '@/services/hasura'
+import type { NextApiRequest, NextApiResponse } from 'next'
+
+export default async function handler(
+	req: NextApiRequest,
+	res: NextApiResponse,
+) {
+	try {
+		const { userId, jwt } = req.body
+		if (!userId) return res.status(400).json({ error: 'Missing userId' })
+
+		const client = getHasuraClient({ jwt })
+
+		const userWorkflows = await getUserWorkflowByService(userId, 'gmail', jwt)
+		const workflowId = userWorkflows?.workflow_id
+
+		if (userWorkflows) {
+			return res.status(200).json({
+				message: 'Workflow already enabled',
+				workflowId: userWorkflows.workflow_id,
+			})
+		}
+
+		if (!userWorkflows) {
+			return res.status(400).json({ error: 'No workflow found for this user' })
+		}
+
+		// Delete the workflow record from Hasura
+		await client.mutation({
+			deleteUserWorkflows: {
+				__args: { where: { workflowId: { _eq: workflowId } } },
+				affected_rows: true,
+			},
+		})
+
+		res.status(200).json({ message: 'Workflow disabled successfully' })
+		// biome-ignore lint/suspicious/noExplicitAny: <explanation>
+	} catch (error: any) {
+		console.error('Error disabling Gmail workflow:', error)
+		res.status(500).json({ error: error.message || 'Internal server error' })
+	}
+}

apps/web/app/api/automations/gmail/enable.ts

@@ -0,0 +1,83 @@
+import { duplicateN8nWorkflow } from '@/lib/n8n'
+import {
+	getUserCredentialByService,
+	getUserWorkflowByService,
+	insertUserWorkflow,
+} from '@/services/hasura'
+import type { NextApiRequest, NextApiResponse } from 'next'
+
+const N8N_TEMPLATE_WORKFLOW_ID =
+	process.env.N8N_TEMPLATE_WORKFLOW_ID ||
+	(() => {
+		throw new Error('N8N_TEMPLATE_WORKFLOW_ID is not defined')
+	})()
+const N8N_MASTERBOTS_EMAIL_FOLDER_ID =
+	process.env.N8N_MASTERBOTS_EMAIL_FOLDER_ID ||
+	(() => {
+		throw new Error('N8N_MASTERBOTS_EMAIL_FOLDER_ID is not defined')
+	})()
+const N8N_WEBHOOK_BASE_URL =
+	process.env.N8N_WEBHOOK_BASE_URL ||
+	(() => {
+		throw new Error('N8N_WEBHOOK_BASE_URL is not defined')
+	})()
+
+export default async function handler(
+	req: NextApiRequest,
+	res: NextApiResponse,
+) {
+	try {
+		const { userId, jwt } = req.body
+		if (!userId) return res.status(400).json({ error: 'Missing userId' })
+
+		const existingWorkflow = await getUserWorkflowByService(
+			userId,
+			'gmail',
+			jwt,
+		)
+		if (existingWorkflow) {
+			return res.status(200).json({
+				message: 'Workflow already enabled',
+				workflowId: existingWorkflow.workflow_id,
+			})
+		}
+
+		const existingCredential = await getUserCredentialByService(
+			userId,
+			'gmail',
+			jwt,
+		)
+		if (!existingCredential) {
+			return res.status(400).json({
+				error:
+					'User has not connected Gmail OAuth yet. Please connect via /api/oauth/google/start',
+			})
+		}
+
+		const workflow = await duplicateN8nWorkflow(
+			userId,
+			existingCredential.n8n_credential_id,
+			N8N_TEMPLATE_WORKFLOW_ID,
+			N8N_MASTERBOTS_EMAIL_FOLDER_ID,
+			N8N_WEBHOOK_BASE_URL,
+		)
+
+		await insertUserWorkflow(
+			userId,
+			workflow.id,
+			workflow.name,
+			'gmail',
+			'Masterbots/Users Workflows/Email',
+			jwt,
+		)
+
+		res.status(200).json({
+			message: 'Workflow enabled successfully',
+			webhookUrl: workflow.webhookUrl,
+		})
+		// biome-ignore lint/suspicious/noExplicitAny: <explanation>
+	} catch (error: any) {
+		console.error('Error enabling Gmail workflow:', error)
+		res.status(500).json({ error: error.message || 'Internal server error' })
+	}
+}

apps/web/app/api/automations/gmail/execute.ts

@@ -0,0 +1,36 @@
+import { getHasuraClient, getUserWorkflowByService } from '@/services/hasura'
+import type { NextApiRequest, NextApiResponse } from 'next'
+import fetch from 'node-fetch'
+
+export default async function handler(
+	req: NextApiRequest,
+	res: NextApiResponse,
+) {
+	try {
+		const { userId, payload, jwt } = req.body
+		if (!userId) return res.status(400).json({ error: 'Missing userId' })
+
+		const userWorkflows = await getUserWorkflowByService(userId, 'gmail', jwt)
+
+		if (!userWorkflows) {
+			return res.status(400).json({ error: 'No workflow found for this user' })
+		}
+
+		const webhookUrl = `${process.env.N8N_WEBHOOK_BASE_URL}/webhook/${userWorkflows.workflow_id}`
+
+		// 2️⃣ Trigger workflow via POST
+		const triggerRes = await fetch(webhookUrl, {
+			method: 'POST',
+			headers: { 'Content-Type': 'application/json' },
+			body: JSON.stringify(payload || {}),
+		})
+
+		const triggerData = await triggerRes.json()
+
+		res.status(200).json({ message: 'Workflow executed', data: triggerData })
+		// biome-ignore lint/suspicious/noExplicitAny: <explanation>
+	} catch (error: any) {
+		console.error('Error executing Gmail workflow:', error)
+		res.status(500).json({ error: error.message || 'Internal server error' })
+	}
+}