How ali-repos/agentic_ai-flow works
Agentflow_AI turns an operator’s natural-language request into a visual workflow, then saves and runs that graph as a multi-agent automation. The documented execution stages are planning, step execution, output validation, recovery, and monitoring; operators can inspect live timelines and control runs. The README also describes encrypted SaaS integrations, notifications, dashboard metrics, and execution history. The excerpts confirm prompt compilation and orchestration calls; several other subsystem links reflect README capabilities and are shown only where their ownership is documented.
Main entry points: orchestrator.js Agent orchestrator · integrationService.js Integration service · workflowController.js Workflow controller · builder.js Workflow builder
Components 33
Operator interface
- Workflow builder
client/src/pages/workflows/builder.js - Visual editor
client/src/components/WorkflowCanvas/WorkflowCanvas.js - Node palette and config
client/src/components/NodePalette/NodePalette.js - Workflow state
client/src/store/workflowStore.js - Execution timeline
client/src/pages/executions/[id].js - API client
client/src/services/api.js - Live event client
client/src/services/socket.js
API and workflow domain
- Express API
server/src/index.js - Workflow routes
server/src/routes/workflowRoutes.js - Workflow controller
server/src/controllers/workflowController.js - Workflow service
server/src/services/workflowService.js - Prompt compiler
server/src/services/aiService.js - Execution service
server/src/services/executionService.js - Execution queue
server/src/queues/executionQueue.js
Execution orchestration
- Agent orchestrator
server/src/agents/orchestrator.js - Planner agent
server/src/agents/plannerAgent.js - Execution agent
server/src/agents/executionAgent.js - Validation agent
server/src/agents/validationAgent.js - Recovery agent
server/src/agents/recoveryAgent.js - Monitoring agent
server/src/agents/monitoringAgent.js
Integrations
- Integration service
server/src/services/integrationService.js - Gmail connector
server/src/integrations/gmailIntegration.js - Slack connector
server/src/integrations/slackIntegration.js - Discord connector
server/src/integrations/discordIntegration.js - Sheets connector
server/src/integrations/googleSheetsIntegration.js
Persistence and events
- MongoDB
server/src/config/db.js - Execution records
server/src/models/Execution.js - Logs and agent memory
server/src/models/ExecutionLog.js - Notification service
server/src/services/notificationService.js - Socket.IO server
server/src/config/socket.js
Other components
- Operator
- AI providers
- SaaS services
Connections 36
- Operator → Workflow builder: describe workflow
- Workflow builder → API client: submit prompt
- Workflow builder → Visual editor: edit graph
- Node palette and config → Visual editor: configure nodes
- Visual editor → Workflow state: update graph
- API client → Express API: HTTP requests
- Express API → Workflow routes: dispatch routes
- Workflow routes → Workflow controller: invoke handlers
- Workflow controller → Prompt compiler: generate graph
- Workflow controller → Workflow service: manage workflows
- Workflow controller → Execution service: trigger execution
- Prompt compiler → AI providers: request generation
- Execution service → Execution queue: enqueue run
- Execution queue → Agent orchestrator: dispatch run
- Agent orchestrator → Execution records: load and update
- Agent orchestrator → Planner agent: plan graph
- Agent orchestrator → Execution agent: execute steps
- Agent orchestrator → Validation agent: validate outputs
- Agent orchestrator → Recovery agent: handle failures
- Agent orchestrator → Monitoring agent: record run events
- Execution agent → Integration service: invoke integrations
- Integration service → Gmail connector: dispatch actions
- Integration service → Slack connector: dispatch actions
- Integration service → Discord connector: dispatch actions
- Integration service → Sheets connector: dispatch actions
- Gmail connector → SaaS services: call Gmail
- Slack connector → SaaS services: call Slack
- Discord connector → SaaS services: call Discord
- Sheets connector → SaaS services: call Sheets
- Monitoring agent → Logs and agent memory: persist timeline
- Monitoring agent → Socket.IO server: broadcast events
- Socket.IO server → Live event client: stream events
- Live event client → Execution timeline: update timeline
- Agent orchestrator → Notification service: create run alerts
- Workflow service → MongoDB: read and write workflows
- Execution records → MongoDB: persist executions