Deploying Your Algorithm to Railway

Railway Project
├── Service: ib-gateway        (Docker image: ghcr.io/gnzsnz/ib-gateway)
│   ├── Port 4002 (paper)      ← your bot connects here
│   ├── VNC port 5900          ← optional remote desktop
│   └── Env: TWS_USERID, TWS_PASSWORD, TRADING_MODE=paper
│
└── Service: sma-bot           (your GitHub repo)
    ├── scheduler.py           ← entry point
    ├── sma_strategy.py        ← signal + order logic
    ├── requirements.txt
    └── Env: IB_HOST, IB_PORT=4002, SYMBOL, FAST_PERIOD, SLOW_PERIOD

my-sma-bot/
├── sma_strategy.py      ← signal + IBKR execution logic
├── scheduler.py         ← daily run scheduler
├── requirements.txt     ← Python dependencies
├── Procfile             ← tells Railway what command to run
└── .gitignore           ← must include .env

# requirements.txt
ib_insync==0.9.86
pandas==2.2.2
schedule==1.2.1
pytz==2024.1

# Procfile — Railway reads this to know what to run
worker: python scheduler.py

# sma_strategy.py — top of file
import os

SYMBOL      = os.environ.get('SYMBOL',      'AAPL')
FAST_PERIOD = int(os.environ.get('FAST_PERIOD', '10'))
SLOW_PERIOD = int(os.environ.get('SLOW_PERIOD', '30'))
IB_HOST     = os.environ.get('IB_HOST',     '127.0.0.1')
IB_PORT     = int(os.environ.get('IB_PORT', '4002'))   # 4002 = IB Gateway paper
CLIENT_ID   = int(os.environ.get('CLIENT_ID', '1'))
CAPITAL_PCT = float(os.environ.get('CAPITAL_PCT', '0.95'))

# Railway Environment Variables — sma-bot service
SYMBOL=AAPL
FAST_PERIOD=10
SLOW_PERIOD=30
CAPITAL_PCT=0.95
IB_PORT=4002
CLIENT_ID=1

# Railway internal hostname for ib-gateway service:
# Go to ib-gateway service → Settings → copy "Private Domain"
# It looks like: ib-gateway.railway.internal
IB_HOST=ib-gateway.railway.internal

# Add this to sma_strategy.py run() function
def run_with_retry(max_attempts: int = 3):
    """Wrap run() with retry logic for dropped connections."""
    for attempt in range(1, max_attempts + 1):
        try:
            run()
            return          # Success — exit retry loop
        except Exception as exc:
            log.error('Attempt %d/%d failed: %s', attempt, max_attempts, exc)
            if attempt < max_attempts:
                log.info('Retrying in 30 seconds...')
                time.sleep(30)
            else:
                log.critical('All %d attempts failed. Alerting and exiting.', max_attempts)
                # Optional: send an alert via email/SMS here
                raise

# In scheduler.py, replace run() with run_with_retry()
from sma_strategy import run_with_retry

def job():
    if not is_market_day():
        return
    print(f'Running strategy...')
    run_with_retry(max_attempts=3)

# Add to scheduler.py — simple log-based monitoring
import smtplib
from email.mime.text import MIMEText

ALERT_EMAIL = os.environ.get('ALERT_EMAIL', '')
SMTP_HOST   = os.environ.get('SMTP_HOST', '')

def send_alert(subject: str, body: str):
    """Send email alert on critical failures."""
    if not ALERT_EMAIL or not SMTP_HOST:
        return
    try:
        msg = MIMEText(body)
        msg['Subject'] = f'[SMA Bot] {subject}'
        msg['From'] = ALERT_EMAIL
        msg['To']   = ALERT_EMAIL
        with smtplib.SMTP(SMTP_HOST) as server:
            server.send_message(msg)
    except Exception:
        pass  # Don't let alert failure crash the process

def job():
    if not is_market_day():
        return
    try:
        run_with_retry(max_attempts=3)
        send_alert('Daily Run OK', f'Strategy ran at {datetime.now(ET).strftime("%H:%M ET")}. Check IBKR for orders.')
    except Exception as exc:
        send_alert('CRITICAL — Bot Failed', str(exc))