Create Dynamic Workflows Programmatically via Webhooks & n8n API

Description

Overview

This workflow exposes an HTTP endpoint (webhook) that accepts a JSON definition of an n8n workflow, validates it, and—if everything is correct—dynamically creates that workflow in the n8n instance via its internal API. If any validation fails or the API call encounters an error, an explanatory message with details is returned.

Workflow Diagram

Webhook
│
▼
Validate JSON ── fails validation ──► Validation Error
│
└─ passes ─► Validation Successful?
│
├─ true ─► Create Workflow ──► API Successful? ──► Success Response
│ │
│ └─ false ─► API Error
└─ false ─► Validation Error

Step-by-Step Details

1. Webhook

Type**: Webhook (POST)
Path**: /webhook/create-workflow
Purpose**: Expose a URL to receive a JSON definition of a workflow.
Expected Input**: JSON containing the main workflow fields (name, nodes, connections, settings).

2. Validate JSON

Type**: Code Node (JavaScript)
Validations Performed**:

Ensure that payload exists and contains both name and nodes.
Verify that nodes is an array with at least one item.
Check that each node includes the required fields: id, name, type, position.
If missing, initialize connections, settings, parameters, and typeVersion.
Output if Error**:

{ "success": false, "message": "<error description>" }
Output if Valid**:

{
"success": true,
"apiWorkflow": {
"name": payload.name,
"nodes": payload.nodes,
"connections": payload.connections,
"settings": payload.settings
}
}
3. Validation Successful?

Type**: IF Node
Condition**: $json.success === true
Branches**:

true: proceed to Create Workflow
false: route to Validation Error

4. Create Workflow

Type**: HTTP Request (POST)
URL**: http://127.0.0.1:5678/api/v1/workflows
Authentication**: Header Auth with internal credentials
Body**: The apiWorkflow object generated earlier
Options**: continueOnFail: true (to handle failures in the next IF)

5. API Successful?

Type**: IF Node
Condition**: $response.statusCode <= 299
Branches**:

true: proceed to Success Response
false: route to API Error

6. Success Response

Type**: SET Node
Output**:

{
"success": "true",
"message": "Workflow created successfully",
"workflowId": "{{ $json.data[0].id }}",
"workflowName": "{{ $json.data[0].name }}",
"createdAt": "{{ $json.data[0].createdAt }}",
"url": "http://localhost:5678/workflow/{{ $json.data[0].id }}"
}
7. API Error

Type**: SET Node
Output**:

{
"success": "false",
"message": "Error creating workflow",
"error": "{{ JSON.stringify($json) }}",
"statusCode": "{{ $response.statusCode }}"
}
8. Validation Error

Type**: SET Node
Output**:

{ "success": false, "message": "{{ $json.message }}" }
Example Webhook Request

curl --location --request POST 'http://localhost:5678/webhook/create-workflow' \
--header 'Content-Type: application/json' \
--data-raw '{
"name": "My Dynamic Workflow",
"nodes": [
{
"id": "start-node",
"name": "Start",
"type": "n8n-nodes-base.manualTrigger",
"typeVersion": 1,
"position": [100, 100],
"parameters": {}
},
{
"id": "set-node",
"name": "Set",
"type": "n8n-nodes-base.set",
"typeVersion": 1,
"position": [300, 100],
"parameters": {
"values": {
"string": [
{ "name": "message", "value": "Hello from a webhook-created workflow!" }
]
}
}
}
],
"connections": {
"Start": {
"main": [
[ { "node": "Set", "type": "main", "index": 0 } ]
]
}
},
"settings": {}
}'

Expected Success Response

{
"success": "true",
"message": "Workflow created successfully",
"workflowId": "abcdef1234567890",
"workflowName": "My Dynamic Workflow",
"createdAt": "2025-05-31T12:34:56.789Z",
"url": "http://localhost:5678/workflow/abcdef1234567890"
}

Validation Error Response

{
"success": false,
"message": "The 'name' field is required in the workflow"
}

API Error Response

{
"success": "false",
"message": "Error creating workflow",
"error": "{ ...full API response details... }",
"statusCode": 401
}