implements google form node

Author: empav

mprocs.yaml

@@ -5,4 +5,8 @@ procs:
 
   next:
     description: Run Next.js development server
-    cmd: ["npm", "run", "dev"]
+    cmd: ["npm", "run", "dev"]
+
+  ngrok:  
+    description: Run Next.js development server
+    cmd: ["npm", "run", "ngrok:dev"]

package-lock.json

@@ -9,7 +9,8 @@
     "lint": "biome check",
     "format": "biome format --write",
     "inngest:dev": "inngest-cli dev",
-    "dev:all": "mprocs"
+    "dev:all": "dotenv -- mprocs",
+    "ngrok:dev": "dotenv -- ngrok http --url=$NGROK_URL 3000"
   },
   "dependencies": {
     "@ai-sdk/google": "^2.0.26",
@@ -93,6 +94,7 @@
     "@types/react": "^19",
     "@types/react-dom": "^19",
     "@types/toposort": "^2.0.7",
+    "dotenv-cli": "^11.0.0",
     "inngest-cli": "^1.13.2",
     "mprocs": "^0.7.3",
     "prisma": "^6.18.0",

package.json

@@ -0,0 +1,2 @@
+-- AlterEnum
+ALTER TYPE "NodeType" ADD VALUE 'GOOGLE_FORM_TRIGGER';

prisma/migrations/20251117131014_add_google_form_node_type/migration.sql

@@ -83,6 +83,7 @@ enum NodeType {
   INITIAL
   MANUAL_TRIGGER
   HTTP_REQUEST
+  GOOGLE_FORM_TRIGGER
 }
 
 model Node {

prisma/schema.prisma

@@ -0,0 +1,43 @@
+import { sendWorkflowExecution } from "@/inngest/utils";
+import { NextResponse, type NextRequest } from "next/server";
+
+export async function POST(req: NextRequest) {
+  try {
+    const url = new URL(req.url);
+    const workflowId = url.searchParams.get("workflowId");
+
+    if (!workflowId) {
+      return NextResponse.json({
+        success: false,
+        error: "Query Parameter workflowId is required",
+        status: 400,
+      });
+    }
+
+    const body = await req.json();
+
+    const formData = {
+      ...body,
+      raw: body,
+    };
+
+    await sendWorkflowExecution({
+      workflowId,
+      initialData: {
+        googleForm: formData,
+      },
+    });
+
+    return NextResponse.json({
+      success: true,
+      status: 200,
+    });
+  } catch (error) {
+    console.error("Google from webhook error: ", error);
+    return NextResponse.json({
+      success: false,
+      error: "Failed to process google form submission",
+      status: 500,
+    });
+  }
+}

public/googleform.svg public/logos/googleform.svgpublic/googleform.svg renamed to public/logos/googleform.svg

@@ -29,6 +29,12 @@ const triggerNodes: NodeTypeOption[] = [
       "Runs flow when clicking a button. Good for getting started quickly",
     icon: MousePointerIcon,
   },
+  {
+    type: NodeType.GOOGLE_FORM_TRIGGER,
+    label: "Google Form",
+    description: "Runs flow when a Google Form is submitted",
+    icon: "/logos/googleform.svg",
+  },
 ];
 
 const execNodes: NodeTypeOption[] = [

src/app/api/webhooks/google_form/route.ts

@@ -1,4 +1,5 @@
 import InitialNode from "@/components/react-flow/InitialNode";
+import GoogleFormTriggerNode from "@/features/executions/components/google-form-trigger/Node";
 import HttpRequestNode from "@/features/executions/components/http-request/Node";
 import ManualTriggerNode from "@/features/executions/components/manual-trigger/Node";
 import { NodeType } from "@prisma/client";
@@ -8,6 +9,7 @@ export const nodeTypes = {
   [NodeType.INITIAL]: InitialNode,
   [NodeType.MANUAL_TRIGGER]: ManualTriggerNode,
   [NodeType.HTTP_REQUEST]: HttpRequestNode,
+  [NodeType.GOOGLE_FORM_TRIGGER]: GoogleFormTriggerNode,
 } as const satisfies NodeTypes;
 
 export type RegisteredNodeType = keyof typeof nodeTypes;

src/components/react-flow/NodeSelector.tsx

@@ -1,8 +1,9 @@
 import { NodeType } from "@prisma/client";
 import { manualTriggerExecutor } from "@/features/executions/components/manual-trigger/Executor";
-import { HttpRequestExecutor } from "./components/http-request/Executor";
+import { httpRequestExecutor } from "./components/http-request/Executor";
 import type { GetStepTools, Inngest } from "inngest";
 import type { Realtime } from "@inngest/realtime";
+import { googleFormTriggerExecutor } from "./components/google-form-trigger/Executor";
 
 export type WorkflowContext = Record<string, unknown>;
 
@@ -23,7 +24,8 @@ export type NodeExecutor<TData = Record<string, unknown>> = (
 const executorRegistry: Record<NodeType, NodeExecutor> = {
   [NodeType.MANUAL_TRIGGER]: manualTriggerExecutor,
   [NodeType.INITIAL]: manualTriggerExecutor,
-  [NodeType.HTTP_REQUEST]: HttpRequestExecutor as NodeExecutor,
+  [NodeType.HTTP_REQUEST]: httpRequestExecutor as NodeExecutor,
+  [NodeType.GOOGLE_FORM_TRIGGER]: googleFormTriggerExecutor,
 };
 
 export const getExecutor = (type: NodeType): NodeExecutor => {