A visual workflow editor for trading automation with OpenAlgo integration. Build complex trading workflows with a drag-and-drop interface similar to n8n.

• Visual workflow editor with ReactFlow
• 30+ node types for comprehensive trading automation
• Options trading with multi-leg strategies (Iron Condor, Straddle, Strangle, Spreads)
• Schedule-based and price alert triggers
• Conditional branching (If/Else logic)
• Variable system for data passing between nodes
• Real-time LTP updates via WebSocket
• SQLite database (zero configuration)
• Dark theme optimized for trading

• Python 3.11+
• Node.js 18+
• uv (auto-installed by setup script)
• OpenAlgo running locally or remotely

1. Run setup (installs uv if needed):

setup.bat

2. Start the application:

start.bat

1. Run setup:

chmod +x setup.sh start.sh
./setup.sh

2. Start the application:

./start.sh

cd backend
uv run uvicorn app.main:app --host 127.0.0.1 --port 8000 --reload

cd frontend
npm run dev

Open http://localhost:5173 in your browser.

cd backend
cp .env.example .env    # Copy environment template
uv sync                 # Install dependencies
uv run migration/migrate_all.py  # Run database migrations

cd frontend
npm install

1. Open http://localhost:5173
2. Go to Settings
3. Enter your OpenAlgo credentials:
   • API Key: Your OpenAlgo API key
   • Host URL: OpenAlgo REST API URL (default: http://127.0.0.1:5000)
   • WebSocket URL: OpenAlgo WebSocket URL (default: ws://127.0.0.1:8765)
4. Click "Test Connection" to verify
5. Save settings

1. Click "New Workflow" on the Dashboard
2. Drag nodes from the left panel to the canvas
3. Connect nodes by dragging from one handle to another
4. Configure each node by clicking on it
5. Save the workflow
6. Click "Activate" to start the schedule

Use variables to pass data between nodes:

• Set variables with the Variable node
• Reference variables using {{variableName}} syntax
• Access nested properties: {{quote.ltp}}, {{position.quantity}}
• System variables: {{timestamp}}, {{date}}, {{time}}

• NSE (Equity)
• NFO (F&O)
• BSE (Equity)
• BFO (F&O)
• CDS (Currency)
• BCD (Currency)
• MCX (Commodity)
• NCDEX (Commodity)
• NSE_INDEX
• BSE_INDEX

Create backend/.env file:

cd backend
cp .env.example .env

Then edit the .env file:

# Debug mode (default: false)
DEBUG=false

# Server configuration
HOST=127.0.0.1
PORT=8000

# Database URL
DATABASE_URL=sqlite+aiosqlite:///./openalgo_flow.db

# Frontend URL (for CORS)
FRONTEND_URL=http://localhost:5173

# Webhook host URL (for generating webhook URLs)
# Set this to your public URL when deploying
WEBHOOK_HOST_URL=http://127.0.0.1:8000

When updating the database schema, run migrations:

cd backend
uv run migration/migrate_all.py

OpenAlgo Flow supports external webhook triggers, allowing you to trigger workflows from TradingView, Chartink, custom scripts, or any HTTP client.

1. Each workflow has a unique Webhook URL and Webhook Secret
2. External systems send a POST request with JSON payload
3. The secret is validated before execution (supports two auth methods)
4. Payload data is available as {{webhook.*}} variables

OpenAlgo Flow supports two authentication methods to accommodate different services:

Configure the authentication method from Dashboard > Workflow Menu > Webhook.

# Generic webhook (secret in payload)
POST https://your-host/api/webhook/{token}

# With secret in URL (for Chartink, etc.)
POST https://your-host/api/webhook/{token}?secret=your_secret

# With symbol in URL
POST https://your-host/api/webhook/{token}/{symbol}
POST https://your-host/api/webhook/{token}/{symbol}?secret=your_secret

From Dashboard:

1. Click the menu (⋮) on any workflow card
2. Select "Webhook"
3. Enable webhook and choose authentication method
4. Copy URL & secret

From Editor:

1. Add a "Webhook Trigger" node
2. URL and secret are displayed in the config panel
3. Set symbol for dynamic URL generation

1. Create workflow with Webhook Trigger node
2. Enable webhook from Dashboard (use "Secret in Payload" auth)
3. In TradingView, create alert with webhook URL
4. Set message body:

{
  "secret": "your_secret",
  "symbol": "{{ticker}}",
  "action": "{{strategy.order.action}}",
  "price": {{close}},
  "quantity": 10
}

1. Create workflow with Webhook Trigger node
2. Enable webhook from Dashboard (use "Secret in URL" auth)
3. Copy the "Webhook URL (with secret)" - includes ?secret=...
4. In Chartink, set the webhook URL with the secret query parameter

Chartink sends payloads in this format (cannot be modified):

{
  "stocks": "RELIANCE,INFY,TCS",
  "trigger_prices": "2500.50,1800.25,3500.00",
  "triggered_at": "9:30 am",
  "scan_name": "My Scanner",
  "scan_url": "my-scanner",
  "alert_name": "Buy Alert"
}

Access data in workflow using {{webhook.stocks}}, {{webhook.scan_name}}, etc.

• Each workflow has unique token (URL) and secret
• Secret is validated on every request
• Two auth methods: payload-based or URL-based
• Failed auth returns 401 Unauthorized
• Rate limit: 30 requests/minute per endpoint

OpenAlgo Flow supports real-time price monitoring using WebSocket streaming from OpenAlgo.

1. Add a Price Alert trigger node to your workflow
2. Configure the symbol, exchange, and price condition
3. Activate the workflow to start real-time monitoring
4. When the price condition is met, the workflow triggers automatically

• Real-time Monitoring: Uses WebSocket for instant price updates (not polling)
• Multiple Conditions: Support for various price conditions (crossing, channels, percentages)
• One-shot Trigger: Workflow triggers once when condition is met, then deactivates
• Multiple Alerts: Monitor multiple symbols across different workflows simultaneously

1. Breakout Alert: Trigger when NIFTY crosses above 26000
2. Stop Loss: Execute sell order when price drops below threshold
3. Range Trading: Alert when price enters or exits a channel
4. Momentum: Detect when price moves up/down by X%

When a price alert triggers, the following variables are available:

Check active price monitors:

GET /api/workflows/price-monitor/status

• Frontend: React, ReactFlow, shadcn/ui, TailwindCSS, Zustand
• Backend: FastAPI, SQLAlchemy, APScheduler
• Database: SQLite
• Integration: OpenAlgo Node SDK 1.0.5

• API keys are stored in the local SQLite database
• Run on localhost for development only
• Do not expose to public internet without proper authentication

AGPL V3