Integration Platform

Design, run, and monitor data-integration flows from a visual canvas — connect databases, APIs, message queues, and file servers without writing glue code.

Integration Platform is a self-hostable, open-source iPaaS (integration platform as a service). Build pipelines by dragging nodes onto a canvas, wire them together, then schedule them, trigger them on events, or publish them as REST APIs — all from one app. It ships with 20+ connectors, an OpenAPI publisher, a cron scheduler, batch file processing, and an MCP server so AI agents can build and run flows for you.

📸 Add a screenshot or GIF of the Flow Designer here to show it off.

---

✨ Why Integration Platform?

• Visual, not boilerplate — compose flows on a drag-and-drop canvas instead of writing and maintaining one-off integration scripts.
• Batteries included — 20+ built-in connectors for databases, message brokers, file servers, and web APIs, with an extensible connector registry.
• Turn any flow into an API — publish flows as versioned, documented REST endpoints (OpenAPI 3.0 + Swagger UI) with API-key auth.
• Schedule & automate — cron schedules, event triggers, and webhooks with live execution monitoring and per-node logs.
• AI-native — a built-in MCP server lets assistants like Claude inspect, edit, and execute your flows.
• Self-hosted & open — AGPL-3.0, runs anywhere via Docker or Kubernetes. Your data and credentials stay on your infrastructure.

---

🔌 Connectors

Category	Connectors
Databases	PostgreSQL · MySQL · MSSQL · Oracle · SQLite · MongoDB · Redis
Messaging & streaming	Apache Kafka · RabbitMQ · MQTT
Files & storage	SFTP · FTP · Amazon S3 · Google Drive · Dropbox
APIs & web	REST · GraphQL · SOAP · Webhooks

Need something else? The connection registry is pluggable — add your own type in client/src/lib/connection-sdk.

---

🧩 Features

🎨 Visual Flow Designer

• Drag-and-drop canvas with 15+ node types (input/output, database, HTTP, SFTP, transform, condition, loop, aggregate, delay…).
• Animated connection lines, zoom/pan navigation, and live validation.
• {{template}} interpolation across node configs, SQL parameters, and a Buddhist-calendar date helper.

📊 API Publishing

• Author OpenAPI 3.0 specs and bind them to multi-step flows.
• One-click public deployment with Swagger UI documentation.
• Per-key auth: Bearer tokens, HMAC signatures, IP allow/deny lists, rate limits, and scopes.

⏰ Scheduler & Triggers

• Cron-based scheduling with timezone support.
• Event and webhook triggers, plus basket (file-arrival) triggers.
• Real-time execution monitoring with per-node, timestamped logs.

📁 File Baskets

• Batch file ingestion and processing with a session lifecycle (open → published → processing → completed → archived).
• CSV/TSV/JSON parsing, configurable encodings, and pattern-based naming.
• SFTP upload/download with ZIP extraction and file-status tracking.

🔐 Security

• JWT authentication with role-based access control (Admin / User).
• First-class API-key management (client / server / webhook / service keys).
• Session management with configurable timeouts.

🤖 AI / MCP Integration

• A Model Context Protocol server exposes 10 tools (get_flow, update_flow_nodes, update_database_sql, execute_flow, analyze_flow, …) so AI agents can build, modify, run, and debug flows programmatically.

---

🚀 Quick Start

The fastest way to try it — a self-contained stack (PostgreSQL + server + frontend) in one command:

git clone https://github.com/EnterpriseX-Platform/IntegrationHub.git
cd IntegrationHub

# (optional) review/override defaults
cp .env.example .env

# build & start everything
docker compose -f docker-compose.full.yml up -d --build

Then open http://localhost:3000/integration.

The database starts empty. To create an admin user and load generic sample projects/flows (e-commerce, CRM, analytics, …):

cd server
npm install
npm run db:seed      # creates admin@integration.local / admin123 + sample data

⚠️ Change the default admin password and set a strong AUTH_JWT_SECRET before exposing an instance. See SECURITY.md.

For local development (hot reload) and other run modes, see CONTRIBUTING.md and docs/DATABASE_SETUP.md.

---

🏗️ Architecture

┌─────────────────────────────────────────────────────────────┐
│                        Docker Compose                        │
├─────────────────────────────────────────────────────────────┤
│  ┌──────────────┐         ┌──────────────┐                  │
│  │   Frontend   │         │    Server    │                  │
│  │   (React)    │◄───────►│  (Express)   │                  │
│  │  Port: 3000  │         │  Port: 8080  │                  │
│  └──────────────┘         └──────┬───────┘                  │
│                                  │                           │
│                         ┌────────▼────────┐                 │
│                         │   PostgreSQL    │                 │
│                         │   Port: 5432    │                 │
│                         └─────────────────┘                 │
└─────────────────────────────────────────────────────────────┘

A monorepo with four sub-projects:

• client/ — React 18 + TypeScript + Vite + Tailwind CSS frontend (the Flow Designer).
• server/ — Express + TypeScript + Prisma ORM backend and the flow execution engine.
• mcp-server/ — Model Context Protocol server for AI-agent integration.
• sftp-server/ — optional bundled SFTP server for local testing.

🧱 Tech stack

React · TypeScript · Vite · Tailwind CSS · Node.js · Express · Prisma · PostgreSQL · Docker · Kubernetes

---

📚 Documentation

• Flow Creation Guide
• Node Types Reference
• API Reference
• Database Setup
• Backup Strategy
• Migration Guide
• Architecture & dev notes (CLAUDE.md)

🤝 Contributing

Contributions are welcome! Please read CONTRIBUTING.md and our Code of Conduct to get started.

🔐 Security

Found a vulnerability? Please report it privately — see SECURITY.md.

📝 License

This project is licensed under the GNU Affero General Public License v3.0 (AGPL-3.0). See the LICENSE file for the full text.