TypeScript/Express API for FlowForge. Handles workflow CRUD, DAG execution, node processors (swap, lending, social, AI, control flow), BullMQ workers, PostgreSQL and Redis.

Workflows are JSON-defined DAGs: nodes (triggers, swap, lending, IF/Switch, Telegram, Slack, Email, Wallet, LLM Transform, oracles) and edges (execution order, data flow). The engine walks the graph and runs the appropriate node processor for each step.

backend/
├── src/
│   ├── config/           # Database, Redis, chains
│   ├── controllers/      # Request handlers
│   ├── middleware/       # Privy auth, etc.
│   ├── migrations/       # Database migrations
│   ├── models/           # Data models
│   ├── routes/           # API routes
│   ├── services/         # Workflow engine, swap, lending, llm, workers
│   ├── types/            # TypeScript types
│   └── utils/            # Logger, encryption, template engine
├── examples/
├── docker-compose.yml    # PostgreSQL + Redis
└── package.json

Prerequisites: Node.js 20+, PostgreSQL 16+, Redis 7+

npm install
cp .env.example .env
# Edit .env (see Environment variables below)

docker-compose up -d postgres redis
npm run build && npm run migrate:up
npm run dev

Optional workers: npm run worker

Base URL: http://localhost:3000/api/v1

Health: GET /health, /health/live, /health/ready
Users: POST /users, GET /users, GET /users/:id, GET /users/address/:address, PUT /users/:id, DELETE /users/:id, GET /users/me
Workflows: POST /workflows, GET /workflows, GET /workflows/:id, PUT /workflows/:id, DELETE /workflows/:id, POST /workflows/:id/execute
Swaps: POST /swaps/quote, /swaps/build-transaction, /swaps/build-safe-transaction, /swaps/execute-with-signature, GET /swaps/providers, GET /swaps/executions
Lending: POST /lending/quote, GET /lending/position, /account, /asset, /assets, /providers, /executions
Integrations: Slack (OAuth, connections, webhooks, send, test), Telegram (connections, send, test, verification), Email (send, test)
Relay: POST /relay/create-safe, POST /relay/enable-module
Meta & Oracle: GET /meta/runtime-config, GET /oracle/feeds, /oracle/config

Response: success { "success": true, "data": {...}, "meta": { "timestamp": "..." } }, error { "success": false, "error": { "message", "code", "details" }, "meta": {...} }

docker-compose up -d postgres redis   # Start databases
docker-compose down                    # Stop
docker-compose logs -f postgres        # Logs

MIT License

npx ts-node scripts/test-uniswap-v4.ts --network uni-sepolia --direction usdc-weth --amount 10

Supported networks: eth-sepolia, arb-sepolia, uni-sepolia, eth-main, arb-main, uni-main Supported directions: weth-usdc, usdc-weth Supported amount: any positive number (wallet should have enough balance)