Internal Server APIs
These are APIs the need to be run for data to get populated for testing the flow in local. These will not be necessary once we have the UI ready.
Health Check
Curl
curl --location '{{host-url}}/health'
Response
{
"status": "ok",
"timestamp": "2025-10-24T09:00:56.707Z",
"uptime": 4.655545752,
"services": {
"mongodb": "ok"
}
}
Create Organisation
Curl
curl --location '{{host-url}}/api/entities/organisation' \
--header 'Content-Type: application/json' \
--data '{
"organisationName": "{{organisation-name}}"
}'
Response
{
"organisationId": "{{organisation-id}}"
}
Update Organisation Processor ID (Optional)
Curl
curl --location --request PUT '{{host-url}}/api/entities/organisation/{{organisation-id}}/processor-id' \
--header 'Content-Type: application/json' \
--data '{
"processorId": "{{processor-id}}"
}'
Response
{
"success": true
}
Create Project
Curl
curl --location '{{host-url}}/api/entities/organisation/{{organisation-id}}/project' \
--header 'Content-Type: application/json' \
--data '{
"projectName": "{{project-name}}"
}'
Response
{
"projectId": "{{project-id}}"
}
Update Project Processor ID (Optional)
Curl
curl --location --request PUT '{{host-url}}/api/entities/organisation/{{organisation-id}}/project/{{project-id}}/processor-id' \
--header 'Content-Type: application/json' \
--data '{
"processorId": "{{processor-id}}"
}'
Response
{
"success": true
}
Create Pipeline
Curl
curl --location '{{host-url}}/api/entities/organisation/{{organisation-id}}/project/{{project-id}}/pipeline' \
--header 'Content-Type: application/json' \
--data '{
"pipelineName": "{{pipeline-name}}",
"pipelineCode": "{{pipeline-code}}",
"active": true
}'
Response
{
"pipelineId": "{{pipeline-id}}"
}
Update Pipeline Processor ID (Optional)
Curl
curl --location --request PUT '{{host-url}}/api/entities/organisation/{{organisation-id}}/project/{{project-id}}/pipeline/{{pipeline-id}}/processor-id' \
--data '{
"processorId": "{{processor-id}}"
}'
Response
{
"success": true
}
Update Pipeline Status (Optional)
Curl
curl --location --request PUT '{{host-url}}/api/entities/organisation/{{organisation-id}}/project/{{project-id}}/pipeline/{{pipeline-id}}/active-status' \
--header 'Content-Type: application/json' \
--data '{
"active": {{active-status}}
}'
Response
{
"success": true
}
Update Start Node ID
Curl
curl --location --request PUT '{{host-url}}/api/entities/organisation/{{organisation-id}}/project/{{project-id}}/pipeline/{{pipeline-id}}/start-node-id' \
--header 'Content-Type: application/json' \
--data '{
"startNodeId": "{{start-node-id}}"
}'
Response
{
"success": true
}
Insert Bulk Nodes
Curl
Curl for Inserting Bulk nodes
curl --location '{{host-url}}/api/entities/organisation/{{organisation-id}}/project/{{project-id}}/pipeline/{{pipeline-id}}/nodes/bulk' \
--header 'Content-Type: application/json' \
--data '{
"11111111-1111-1111-1111-111111111111": {
"name": "Validate Input Data",
"type": "condition-branching",
"filters": {
"valid-authenticated-user": {
"filter": {
"and": [
{
"check": {
"key": "$.user.id",
"value": null,
"operator": "ne"
}
},
{
"check": {
"key": "$.user.status",
"value": "active",
"operator": "et"
}
},
{
"check": {
"key": "$.user.email_verified",
"value": true,
"operator": "et"
}
}
]
},
"next": ["33333333-3333-3333-3333-333333333333"]
},
"guest-user": {
"filter": {
"and": [
{
"check": {
"key": "$.user.type",
"value": "guest",
"operator": "et"
}
},
{
"check": {
"key": "$.user.permissions.guest_allowed",
"value": true,
"operator": "et"
}
}
]
},
"next": ["44444444-4444-4444-4444-444444444444"]
},
"suspended-user": {
"filter": {
"or": [
{
"check": {
"key": "$.user.status",
"value": "suspended",
"operator": "et"
}
},
{
"check": {
"key": "$.user.violations",
"value": 3,
"operator": "gte"
}
}
]
},
"next": ["55555555-5555-5555-5555-555555555555"]
},
"all": {
"next": ["66666666-6666-6666-6666-666666666666"]
}
}
},
"22222222-2222-2222-2222-222222222222": {
"name": "Initialize System Logging",
"type": "transformation",
"transformation_fn": "Transformation.JSON.add_key",
"transformation_params": {
"key": "$.system.logs",
"value": ["Workflow initiated", "System logging started"]
},
"input_type": "json",
"output_type": "json",
"next": ["77777777-7777-7777-7777-777777777777"]
},
"33333333-3333-3333-3333-333333333333": {
"name": "User Permission Analysis",
"type": "condition-branching",
"filters": {
"super-admin": {
"filter": {
"and": [
{
"check": {
"key": "$.user.role",
"value": "super_admin",
"operator": "et"
}
},
{
"check": {
"key": "$.user.permissions.all_access",
"value": true,
"operator": "et"
}
}
]
},
"next": ["88888888-8888-8888-8888-888888888888", "99999999-9999-9999-9999-999999999999"]
},
"admin-user": {
"filter": {
"and": [
{
"check": {
"key": "$.user.role",
"value": "admin",
"operator": "et"
}
},
{
"check": {
"key": "$.user.department",
"value": null,
"operator": "ne"
}
}
]
},
"next": ["aaaaaaaa-aaaa-aaaa-aaaa-aaaaaaaaaaaa", "bbbbbbbb-bbbb-bbbb-bbbb-bbbbbbbbbbbb"]
},
"premium-subscriber": {
"filter": {
"and": [
{
"check": {
"key": "$.user.subscription.type",
"value": "premium",
"operator": "et"
}
},
{
"check": {
"key": "$.user.subscription.credits",
"value": 100,
"operator": "gte"
}
},
{
"check": {
"key": "$.user.subscription.expires_at",
"value": "2025-01-01",
"operator": "gte"
}
}
]
},
"next": ["cccccccc-cccc-cccc-cccc-cccccccccccc"]
},
"enterprise-user": {
"filter": {
"and": [
{
"check": {
"key": "$.user.organization.tier",
"value": "enterprise",
"operator": "et"
}
},
{
"check": {
"key": "$.user.organization.active",
"value": true,
"operator": "et"
}
}
]
},
"next": ["dddddddd-dddd-dddd-dddd-dddddddddddd"]
},
"regular-user": {
"filter": {
"check": {
"key": "$.user.subscription.type",
"value": "basic",
"operator": "et"
}
},
"next": ["eeeeeeee-eeee-eeee-eeee-eeeeeeeeeeee"]
},
"all": {
"next": ["ffffffff-ffff-ffff-ffff-ffffffffffff"]
}
}
},
"44444444-4444-4444-4444-444444444444": {
"name": "Guest User Limitations",
"type": "transformation",
"transformation_fn": "Transformation.JSON.add_key",
"transformation_params": {
"key": "$.processing.level",
"value": "guest"
},
"input_type": "json",
"output_type": "json",
"next": ["10101010-1010-1010-1010-101010101010"]
},
"55555555-5555-5555-5555-555555555555": {
"name": "Handle Suspended User",
"type": "transformation",
"transformation_fn": "Transformation.JSON.add_key",
"transformation_params": {
"key": "$.error.type",
"value": "user_suspended"
},
"input_type": "json",
"output_type": "json",
"next": ["end-failure"]
},
"66666666-6666-6666-6666-666666666666": {
"name": "Invalid User Handler",
"type": "transformation",
"transformation_fn": "Transformation.JSON.add_key",
"transformation_params": {
"key": "$.error.type",
"value": "invalid_user"
},
"input_type": "json",
"output_type": "json",
"next": ["end-failure"]
},
"77777777-7777-7777-7777-777777777777": {
"name": "Environment Configuration",
"type": "condition-branching",
"filters": {
"production-environment": {
"filter": {
"and": [
{
"check": {
"key": "$.environment.name",
"value": "production",
"operator": "et"
}
},
{
"check": {
"key": "$.environment.maintenance_mode",
"value": false,
"operator": "et"
}
}
]
},
"next": ["12121212-1212-1212-1212-121212121212", "13131313-1313-1313-1313-131313131313"]
},
"staging-environment": {
"filter": {
"and": [
{
"check": {
"key": "$.environment.name",
"value": "staging",
"operator": "et"
}
},
{
"check": {
"key": "$.environment.test_data_enabled",
"value": true,
"operator": "et"
}
}
]
},
"next": ["14141414-1414-1414-1414-141414141414"]
},
"development-environment": {
"filter": {
"check": {
"key": "$.environment.name",
"value": "development",
"operator": "et"
}
},
"next": ["15151515-1515-1515-1515-151515151515"]
},
"all": {
"next": ["16161616-1616-1616-1616-161616161616"]
}
}
},
"88888888-8888-8888-8888-888888888888": {
"name": "Super Admin Processing",
"type": "transformation",
"transformation_fn": "Transformation.JSON.add_key",
"transformation_params": {
"key": "$.processing.level",
"value": "super_admin"
},
"input_type": "json",
"output_type": "json",
"next": ["17171717-1717-1717-1717-171717171717", "18181818-1818-1818-1818-181818181818"]
},
"99999999-9999-9999-9999-999999999999": {
"name": "Advanced Security Audit",
"type": "condition-branching",
"filters": {
"critical-security-event": {
"filter": {
"or": [
{
"check": {
"key": "$.security.threat_level",
"value": "critical",
"operator": "et"
}
},
{
"check": {
"key": "$.security.anomaly_score",
"value": 90,
"operator": "gte"
}
},
{
"check": {
"key": "$.security.failed_attempts",
"value": 10,
"operator": "gte"
}
}
]
},
"next": ["19191919-1919-1919-1919-191919191919", "20202020-2020-2020-2020-202020202020"]
},
"high-security-event": {
"filter": {
"and": [
{
"check": {
"key": "$.security.threat_level",
"value": "high",
"operator": "et"
}
},
{
"check": {
"key": "$.security.anomaly_score",
"value": 70,
"operator": "gte"
}
}
]
},
"next": ["21212121-2121-2121-2121-212121212121"]
},
"medium-security-event": {
"filter": {
"and": [
{
"check": {
"key": "$.security.threat_level",
"value": "medium",
"operator": "et"
}
},
{
"check": {
"key": "$.security.anomaly_score",
"value": 40,
"operator": "gte"
}
},
{
"check": {
"key": "$.security.anomaly_score",
"value": 70,
"operator": "lt"
}
}
]
},
"next": ["22222222-2323-2323-2323-232323232323"]
},
"all": {
"next": ["23232323-2424-2424-2424-242424242424"]
}
}
},
"aaaaaaaa-aaaa-aaaa-aaaa-aaaaaaaaaaaa": {
"name": "Admin Processing Pipeline",
"type": "transformation",
"transformation_fn": "Transformation.JSON.add_key",
"transformation_params": {
"key": "$.processing.level",
"value": "admin"
},
"input_type": "json",
"output_type": "json",
"next": ["24242424-2525-2525-2525-252525252525"]
},
"bbbbbbbb-bbbb-bbbb-bbbb-bbbbbbbbbbbb": {
"name": "Department-Specific Processing",
"type": "condition-branching",
"filters": {
"finance-department": {
"filter": {
"check": {
"key": "$.user.department",
"value": "finance",
"operator": "et"
}
},
"next": ["25252525-2626-2626-2626-262626262626"]
},
"hr-department": {
"filter": {
"check": {
"key": "$.user.department",
"value": "hr",
"operator": "et"
}
},
"next": ["26262626-2727-2727-2727-272727272727"]
},
"engineering-department": {
"filter": {
"check": {
"key": "$.user.department",
"value": "engineering",
"operator": "et"
}
},
"next": ["27272727-2828-2828-2828-282828282828"]
},
"all": {
"next": ["28282828-2929-2929-2929-292929292929"]
}
}
},
"cccccccc-cccc-cccc-cccc-cccccccccccc": {
"name": "Premium Features Activation",
"type": "transformation",
"transformation_fn": "Transformation.JSON.add_key",
"transformation_params": {
"key": "$.features.premium_enabled",
"value": true
},
"input_type": "json",
"output_type": "json",
"next": ["29292929-3030-3030-3030-303030303030", "30303030-3131-3131-3131-313131313131"]
},
"dddddddd-dddd-dddd-dddd-dddddddddddd": {
"name": "Enterprise Features Setup",
"type": "transformation",
"transformation_fn": "Transformation.JSON.add_key",
"transformation_params": {
"key": "$.features.enterprise_enabled",
"value": true
},
"input_type": "json",
"output_type": "json",
"next": ["31313131-3232-3232-3232-323232323232", "32323232-3333-3333-3333-333333333333"]
},
"eeeeeeee-eeee-eeee-eeee-eeeeeeeeeeee": {
"name": "Basic User Processing",
"type": "transformation",
"transformation_fn": "Transformation.JSON.add_key",
"transformation_params": {
"key": "$.processing.level",
"value": "basic"
},
"input_type": "json",
"output_type": "json",
"next": ["33333333-3434-3434-3434-343434343434", "34343434-3535-3535-3535-353535353535"]
},
"ffffffff-ffff-ffff-ffff-ffffffffffff": {
"name": "Default Processing Path",
"type": "transformation",
"transformation_fn": "Transformation.JSON.add_key",
"transformation_params": {
"key": "$.processing.level",
"value": "default"
},
"input_type": "json",
"output_type": "json",
"next": ["35353535-3636-3636-3636-363636363636"]
},
"17171717-1717-1717-1717-171717171717": {
"name": "Super Admin Data Enrichment",
"type": "transformation",
"transformation_fn": "Transformation.JSON.add_key",
"transformation_params": {
"key": "$.data.super_admin_enriched",
"value": true
},
"input_type": "json",
"output_type": "json",
"next": ["36363636-3737-3737-3737-373737373737"]
},
"18181818-1818-1818-1818-181818181818": {
"name": "Global System Monitoring",
"type": "transformation",
"transformation_fn": "Transformation.JSON.add_key",
"transformation_params": {
"key": "$.monitoring.global_enabled",
"value": true
},
"input_type": "json",
"output_type": "json",
"next": ["37373737-3838-3838-3838-383838383838"]
},
"29292929-3030-3030-3030-303030303030": {
"name": "Advanced Analytics Pipeline",
"type": "condition-branching",
"filters": {
"machine-learning-enabled": {
"filter": {
"and": [
{
"check": {
"key": "$.features.ml_enabled",
"value": true,
"operator": "et"
}
},
{
"check": {
"key": "$.data.volume",
"value": 10000,
"operator": "gte"
}
},
{
"check": {
"key": "$.resources.gpu_available",
"value": true,
"operator": "et"
}
}
]
},
"next": ["38383838-3939-3939-3939-393939393939", "39393939-4040-4040-4040-404040404040"]
},
"statistical-analysis": {
"filter": {
"and": [
{
"check": {
"key": "$.data.type",
"value": "numerical",
"operator": "et"
}
},
{
"check": {
"key": "$.data.quality_score",
"value": 80,
"operator": "gte"
}
}
]
},
"next": ["40404040-4141-4141-4141-414141414141"]
},
"basic-analytics": {
"filter": {
"check": {
"key": "$.data.size",
"value": 100,
"operator": "gte"
}
},
"next": ["41414141-4242-4242-4242-424242424242"]
},
"all": {
"next": ["42424242-4343-4343-4343-434343434343"]
}
}
},
"38383838-3939-3939-3939-393939393939": {
"name": "Machine Learning Pipeline",
"type": "transformation",
"transformation_fn": "Transformation.JSON.add_key",
"transformation_params": {
"key": "$.ml.pipeline_started",
"value": true
},
"input_type": "json",
"output_type": "json",
"next": ["43434343-4444-4444-4444-444444444444", "44444444-4545-4545-4545-454545454545"]
},
"39393939-4040-4040-4040-404040404040": {
"name": "GPU Resource Allocation",
"type": "transformation",
"transformation_fn": "Transformation.JSON.add_key",
"transformation_params": {
"key": "$.resources.gpu_allocated",
"value": true
},
"input_type": "json",
"output_type": "json",
"next": ["45454545-4646-4646-4646-464646464646"]
},
"43434343-4444-4444-4444-444444444444": {
"name": "Feature Engineering",
"type": "transformation",
"transformation_fn": "Transformation.JSON.add_key",
"transformation_params": {
"key": "$.ml.features_engineered",
"value": true
},
"input_type": "json",
"output_type": "json",
"next": ["46464646-4747-4747-4747-474747474747"]
},
"44444444-4545-4545-4545-454545454545": {
"name": "Model Training Pipeline",
"type": "condition-branching",
"filters": {
"deep-learning-model": {
"filter": {
"and": [
{
"check": {
"key": "$.ml.model_type",
"value": "deep_learning",
"operator": "et"
}
},
{
"check": {
"key": "$.ml.training_data_size",
"value": 100000,
"operator": "gte"
}
}
]
},
"next": ["47474747-4848-4848-4848-484848484848"]
},
"traditional-ml-model": {
"filter": {
"and": [
{
"check": {
"key": "$.ml.model_type",
"value": "traditional",
"operator": "et"
}
},
{
"check": {
"key": "$.ml.training_data_size",
"value": 1000,
"operator": "gte"
}
}
]
},
"next": ["48484848-4949-4949-4949-494949494949"]
},
"all": {
"next": ["49494949-5050-5050-5050-505050505050"]
}
}
},
"46464646-4747-4747-4747-474747474747": {
"name": "Data Quality Assessment",
"type": "condition-branching",
"filters": {
"excellent-quality": {
"filter": {
"and": [
{
"check": {
"key": "$.data.quality.completeness",
"value": 95,
"operator": "gte"
}
},
{
"check": {
"key": "$.data.quality.accuracy",
"value": 90,
"operator": "gte"
}
},
{
"check": {
"key": "$.data.quality.consistency",
"value": 85,
"operator": "gte"
}
}
]
},
"next": ["50505050-5151-5151-5151-515151515151"]
},
"good-quality": {
"filter": {
"and": [
{
"check": {
"key": "$.data.quality.completeness",
"value": 80,
"operator": "gte"
}
},
{
"check": {
"key": "$.data.quality.accuracy",
"value": 75,
"operator": "gte"
}
}
]
},
"next": ["51515151-5252-5252-5252-525252525252"]
},
"needs-improvement": {
"filter": {
"or": [
{
"check": {
"key": "$.data.quality.completeness",
"value": 80,
"operator": "lt"
}
},
{
"check": {
"key": "$.data.quality.accuracy",
"value": 75,
"operator": "lt"
}
}
]
},
"next": ["52525252-5353-5353-5353-535353535353"]
},
"all": {
"next": ["53535353-5454-5454-5454-545454545454"]
}
}
},
"50505050-5151-5151-5151-515151515151": {
"name": "Advanced Processing Pipeline",
"type": "transformation",
"transformation_fn": "Transformation.JSON.add_key",
"transformation_params": {
"key": "$.processing.advanced_enabled",
"value": true
},
"input_type": "json",
"output_type": "json",
"next": ["54545454-5555-5555-5555-555555555555", "55555555-5656-5656-5656-565656565656"]
},
"54545454-5555-5555-5555-555555555555": {
"name": "Parallel Processing Execution",
"type": "transformation",
"transformation_fn": "Transformation.JSON.add_key",
"transformation_params": {
"key": "$.processing.parallel_execution",
"value": true
},
"input_type": "json",
"output_type": "json",
"next": ["56565656-5757-5757-5757-575757575757"]
},
"55555555-5656-5656-5656-565656565656": {
"name": "Real-time Analytics",
"type": "transformation",
"transformation_fn": "Transformation.JSON.add_key",
"transformation_params": {
"key": "$.analytics.realtime_enabled",
"value": true
},
"input_type": "json",
"output_type": "json",
"next": ["57575757-5858-5858-5858-585858585858"]
},
"56565656-5757-5757-5757-575757575757": {
"name": "Final Quality Check",
"type": "condition-branching",
"filters": {
"quality-excellent": {
"filter": {
"and": [
{
"check": {
"key": "$.final_quality.overall_score",
"value": 90,
"operator": "gte"
}
},
{
"check": {
"key": "$.final_quality.error_count",
"value": 2,
"operator": "lte"
}
}
]
},
"next": ["58585858-5959-5959-5959-595959595959"]
},
"quality-acceptable": {
"filter": {
"and": [
{
"check": {
"key": "$.final_quality.overall_score",
"value": 70,
"operator": "gte"
}
},
{
"check": {
"key": "$.final_quality.error_count",
"value": 10,
"operator": "lte"
}
}
]
},
"next": ["59595959-6060-6060-6060-606060606060"]
},
"all": {
"next": ["60606060-6161-6161-6161-616161616161"]
}
}
},
"58585858-5959-5959-5959-595959595959": {
"name": "Finalization and Cleanup",
"type": "transformation",
"transformation_fn": "Transformation.JSON.add_key",
"transformation_params": {
"key": "$.processing.finalized_at",
"value": "2025-01-13T09:20:00Z"
},
"input_type": "json",
"output_type": "json",
"next": ["61616161-6262-6262-6262-626262626262", "62626262-6363-6363-6363-636363636363"]
},
"61616161-6262-6262-6262-626262626262": {
"name": "Cleanup Temporary Resources",
"type": "transformation",
"transformation_fn": "Transformation.JSON.remove_key",
"transformation_params": {
"key": "$.temp_processing_data"
},
"input_type": "json",
"output_type": "json",
"next": ["63636363-6464-6464-6464-646464646464"]
},
"62626262-6363-6363-6363-636363636363": {
"name": "Generate Comprehensive Report",
"type": "transformation",
"transformation_fn": "Transformation.JSON.add_key",
"transformation_params": {
"key": "$.reports.comprehensive_generated",
"value": true
},
"input_type": "json",
"output_type": "json",
"next": ["64646464-6565-6565-6565-656565656565"]
},
"63636363-6464-6464-6464-646464646464": {
"name": "Complete Audit Trail",
"type": "transformation",
"transformation_fn": "Transformation.JSON.add_key",
"transformation_params": {
"key": "$.audit.complete_trail",
"value": true
},
"input_type": "json",
"output_type": "json",
"next": ["65656565-6666-6666-6666-666666666666"]
},
"64646464-6565-6565-6565-656565656565": {
"name": "Multi-Channel Notification System",
"type": "condition-branching",
"filters": {
"email-notification": {
"filter": {
"and": [
{
"check": {
"key": "$.user.preferences.notifications.email",
"value": true,
"operator": "et"
}
},
{
"check": {
"key": "$.user.email",
"value": null,
"operator": "ne"
}
}
]
},
"next": ["66666666-6767-6767-6767-676767676767"]
},
"sms-notification": {
"filter": {
"and": [
{
"check": {
"key": "$.user.preferences.notifications.sms",
"value": true,
"operator": "et"
}
},
{
"check": {
"key": "$.user.phone",
"value": null,
"operator": "ne"
}
}
]
},
"next": ["67676767-6868-6868-6868-686868686868"]
},
"push-notification": {
"filter": {
"check": {
"key": "$.user.preferences.notifications.push",
"value": true,
"operator": "et"
}
},
"next": ["68686868-6969-6969-6969-696969696969"]
},
"slack-notification": {
"filter": {
"and": [
{
"check": {
"key": "$.user.integrations.slack.enabled",
"value": true,
"operator": "et"
}
},
{
"check": {
"key": "$.user.integrations.slack.webhook",
"value": null,
"operator": "ne"
}
}
]
},
"next": ["69696969-7070-7070-7070-707070707070"]
},
"all": {
"next": ["70707070-7171-7171-7171-717171717171"]
}
}
},
"66666666-6767-6767-6767-676767676767": {
"name": "Send Email Notification",
"type": "transformation",
"transformation_fn": "Transformation.JSON.add_key",
"transformation_params": {
"key": "$.notifications.email_sent",
"value": true
},
"input_type": "json",
"output_type": "json",
"next": ["end-success"]
},
"67676767-6868-6868-6868-686868686868": {
"name": "Send SMS Notification",
"type": "transformation",
"transformation_fn": "Transformation.JSON.add_key",
"transformation_params": {
"key": "$.notifications.sms_sent",
"value": true
},
"input_type": "json",
"output_type": "json",
"next": ["end-success"]
},
"68686868-6969-6969-6969-696969696969": {
"name": "Send Push Notification",
"type": "transformation",
"transformation_fn": "Transformation.JSON.add_key",
"transformation_params": {
"key": "$.notifications.push_sent",
"value": true
},
"input_type": "json",
"output_type": "json",
"next": ["end-success"]
},
"69696969-7070-7070-7070-707070707070": {
"name": "Send Slack Notification",
"type": "transformation",
"transformation_fn": "Transformation.JSON.add_key",
"transformation_params": {
"key": "$.notifications.slack_sent",
"value": true
},
"input_type": "json",
"output_type": "json",
"next": ["end-success"]
},
"60606060-6161-6161-6161-616161616161": {
"name": "Quality Check Failed",
"type": "transformation",
"transformation_fn": "Transformation.JSON.add_key",
"transformation_params": {
"key": "$.error.type",
"value": "quality_check_failed"
},
"input_type": "json",
"output_type": "json",
"next": ["end-failure"]
},
"10101010-1010-1010-1010-101010101010": {
"name": "Guest Processing Complete",
"type": "transformation",
"transformation_fn": "Transformation.JSON.add_key",
"transformation_params": {
"key": "$.processing.guest_complete",
"value": true
},
"input_type": "json",
"output_type": "json",
"next": ["end-success"]
},
"35353535-3636-3636-3636-363636363636": {
"name": "Default Processing Complete",
"type": "transformation",
"transformation_fn": "Transformation.JSON.add_key",
"transformation_params": {
"key": "$.processing.default_complete",
"value": true
},
"input_type": "json",
"output_type": "json",
"next": ["end-success"]
},
"end-success": {
"name": "Workflow Success",
"type": "end",
"target_id": "{{target-id}}",
"message": "Complex multi-path workflow completed successfully with advanced processing and quality checks."
},
"end-failure": {
"name": "Workflow Failure",
"type": "end",
"target_id": "{{target-id}}",
"message": "Complex workflow failed due to validation errors, quality issues, or security concerns."
}
}'
Response
{
"nodeCount": 41,
"success": true
}
Create Integration Connector
Curl
curl --location '{{host-url}}/api/entities/organisation/{{organisation-id}}/project/{{project-id}}/integration-connector' \
--header 'Content-Type: application/json' \
--data '{
"connectorName": "{{connector-name}}",
"integrationType": "slack-bot",
"integrationParams": {
"slackBotToken": "{{slack-bot-token}}"
}
}'
Response
{
"connectorId": "{{connector-id}}"
}
Create Integration Target
Curl
curl --location '{{host-url}}/api/entities/organisation/{{organisation-id}}/project/{{project-id}}/pipeline/{{pipeline-id}}/integration-target' \
--header 'Content-Type: application/json' \
--data '{
"connectorId": "{{connector-id}}",
"destinationName": "{{destination-name}}",
"destinationParams": {
"action": "template-message",
"template": "Hello {{$.user.name}}",
"channel": "new-channel"
}
}'
Response
{
"targetId": "{{target-id}}"
}
Create API Key
Curl
curl --location '{{host-url}}/api/security/organisation/{{organisation-id}}/project/{{project-id}}/api-key' \
--header 'Content-Type: application/json'
Response
{
"apiKey": "{{api-key}}"
}
Validate API key
Curl
curl --location '{{host-url}}/api/security/api-key/validate' \
--header 'Content-Type: application/json' \
--data '{
"apiKey": "{{api-key}}"
}'
Response
{
"orgId": "{{organisation-id}}",
"projectId": "{{project-id}}"
}