diff --git a/apps/base/customer1/trade-dashboard/Dockerfile b/apps/base/customer1/trade-dashboard/Dockerfile new file mode 100644 index 0000000..6968d40 --- /dev/null +++ b/apps/base/customer1/trade-dashboard/Dockerfile @@ -0,0 +1,18 @@ +FROM python:3.13-slim AS base + +WORKDIR /app + +RUN apt-get update && apt-get install -y --no-install-recommends \ + gcc libpq-dev \ + && rm -rf /var/lib/apt/lists/* + +COPY app/requirements.txt . +RUN pip install --no-cache-dir -r requirements.txt + +COPY app/ ./app/ +COPY alembic.ini ./alembic.ini +COPY alembic/ ./alembic/ + +EXPOSE 8000 + +CMD ["uvicorn", "app.main:app", "--host", "0.0.0.0", "--port", "8000"] diff --git a/apps/base/customer1/trade-dashboard/alembic.ini b/apps/base/customer1/trade-dashboard/alembic.ini new file mode 100644 index 0000000..60ba74e --- /dev/null +++ b/apps/base/customer1/trade-dashboard/alembic.ini @@ -0,0 +1,36 @@ +[alembic] +script_location = alembic +sqlalchemy.url = postgresql+asyncpg://trading:CHANGE_ME@hermes-pgdb-rw.customer1.svc.cluster.local:5432/trading_data + +[loggers] +keys = root,sqlalchemy,alembic + +[handlers] +keys = console + +[formatters] +keys = generic + +[logger_root] +level = WARN +handlers = console + +[logger_sqlalchemy] +level = WARN +handlers = +qualname = sqlalchemy.engine + +[logger_alembic] +level = INFO +handlers = +qualname = alembic + +[handler_console] +class = StreamHandler +args = (sys.stderr,) +level = NOTSET +formatter = generic + +[formatter_generic] +format = %(levelname)-5.5s [%(name)s] %(message)s +datefmt = %H:%M:%S diff --git a/apps/base/customer1/trade-dashboard/alembic/env.py b/apps/base/customer1/trade-dashboard/alembic/env.py new file mode 100644 index 0000000..e474716 --- /dev/null +++ b/apps/base/customer1/trade-dashboard/alembic/env.py @@ -0,0 +1,61 @@ +"""Alembic environment configuration.""" + +import sys +from logging.config import fileConfig +from pathlib import Path + +from alembic import context +from sqlalchemy import engine_from_config, pool +from sqlalchemy.ext.asyncio import AsyncEngine + +sys.path.insert(0, str(Path(__file__).parent.parent / "app")) + +config = context.config + +if config.config_file_name is not None: + fileConfig(config.config_file_name) + +from models import metadata # noqa: E402 + +target_metadata = metadata + + +def run_migrations_offline() -> None: + """Run migrations in 'offline' mode.""" + url = config.get_main_option("sqlalchemy.url") + context.configure( + url=url, + target_metadata=target_metadata, + literal_binds=True, + dialect_opts={"paramstyle": "named"}, + ) + with context.begin_transaction(): + context.run_migrations() + + +def do_run_migrations(connection): + context.configure(connection=connection, target_metadata=target_metadata) + with context.begin_transaction(): + context.run_migrations() + + +async def run_migrations_online() -> None: + """Run migrations in 'online' mode.""" + connectable = AsyncEngine( + engine_from_config( + config.get_section(config.config_ini_section) or {}, + prefix="sqlalchemy.", + poolclass=pool.NullPool, + future=True, + ) + ) + async with connectable.connect() as connection: + await connection.run_sync(do_run_migrations) + await connectable.dispose() + + +if context.is_offline_mode(): + run_migrations_offline() +else: + from sqlalchemy.ext.asyncio import run_async # noqa: E402 + run_async(run_migrations_online()) diff --git a/apps/base/customer1/trade-dashboard/alembic/script.py.mako b/apps/base/customer1/trade-dashboard/alembic/script.py.mako new file mode 100644 index 0000000..d458e51 --- /dev/null +++ b/apps/base/customer1/trade-dashboard/alembic/script.py.mako @@ -0,0 +1,2 @@ +# Alembic migration script - DO NOT EDIT MANUALLY +# Use: alembic revision --autogenerate -m "description" diff --git a/apps/base/customer1/trade-dashboard/alembic/versions/001_initial.py b/apps/base/customer1/trade-dashboard/alembic/versions/001_initial.py new file mode 100644 index 0000000..51ed0d7 --- /dev/null +++ b/apps/base/customer1/trade-dashboard/alembic/versions/001_initial.py @@ -0,0 +1,43 @@ +"""initial schema — positions table + +Revision ID: 001_initial +Create Date: 2026-05-02 +""" + +from alembic import op +import sqlalchemy as sa +from sqlalchemy.dialects import postgresql + +revision = "001_initial" +down_revision = None +branch_labels = None +depends_on = None + + +def upgrade() -> None: + op.create_enum("position_direction", "long", "short", schema="public", create_type=True) + + op.create_table( + "positions", + sa.Column("id", postgresql.UUID(as_uuid=True), primary_key=True, server_default=sa.text("gen_random_uuid()")), + sa.Column("symbol", sa.String(32), nullable=False), + sa.Column("direction", postgresql.ENUM("long", "short", name="position_direction", create_type=False), nullable=False), + sa.Column("entry_price", sa.Numeric(precision=16, scale=8), nullable=False), + sa.Column("exit_price", sa.Numeric(precision=16, scale=8)), + sa.Column("quantity", sa.Numeric(precision=16, scale=8), nullable=False), + sa.Column("exchange", sa.String(32), nullable=False), + sa.Column("opened_at", sa.DateTime(timezone=True), server_default=sa.func.now(), nullable=False), + sa.Column("closed_at", sa.DateTime(timezone=True)), + sa.Column("pnl", sa.Numeric(precision=16, scale=2)), + sa.Column("metadata", sa.JSON), + ) + + op.create_index(op.f("ix_positions_symbol"), "positions", ["symbol"]) + op.create_index(op.f("ix_positions_exchange"), "positions", ["exchange"]) + + +def downgrade() -> None: + op.drop_index(op.f("ix_positions_exchange"), table_name="positions") + op.drop_index(op.f("ix_positions_symbol"), table_name="positions") + op.drop_table("positions") + op.execute("DROP TYPE IF EXISTS position_direction") diff --git a/apps/base/customer1/trade-dashboard/app/database.py b/apps/base/customer1/trade-dashboard/app/database.py new file mode 100644 index 0000000..2101b78 --- /dev/null +++ b/apps/base/customer1/trade-dashboard/app/database.py @@ -0,0 +1,25 @@ +from sqlalchemy.ext.asyncio import AsyncSession, async_sessionmaker, create_async_engine +from sqlalchemy import MetaData + +# Connection to hermes-pgdb CNPG cluster +DATABASE_URL = ( + f"postgresql+asyncpg://{db_user}:{db_pass}" + f"@hermes-pgdb-rw.customer1.svc.cluster.local:5432/trading_data" +).format( + db_user="trading", + db_pass="TRADING_DB_PASSWORD", # overridden by env +) + +import os + +DB_USER = os.getenv("DB_USER", "trading") +DB_PASS = os.getenv("DB_PASSWORD", "") +DB_HOST = os.getenv("DB_HOST", "hermes-pgdb-rw.customer1.svc.cluster.local") +DB_PORT = os.getenv("DB_PORT", "5432") +DB_NAME = os.getenv("DB_NAME", "trading_data") + +DATABASE_URL = f"postgresql+asyncpg://{DB_USER}:{DB_PASS}@{DB_HOST}:{DB_PORT}/{DB_NAME}" + +engine = create_async_engine(DATABASE_URL, echo=False, pool_size=5, max_overflow=10) +async_session = async_sessionmaker(engine, class_=AsyncSession, expire_on_commit=False) +metadata = MetaData() diff --git a/apps/base/customer1/trade-dashboard/app/main.py b/apps/base/customer1/trade-dashboard/app/main.py new file mode 100644 index 0000000..a2be8ef --- /dev/null +++ b/apps/base/customer1/trade-dashboard/app/main.py @@ -0,0 +1,253 @@ +"""Trade Dashboard — FastAPI service for tracking PnL and open positions.""" + +from __future__ import annotations + +from datetime import datetime, timedelta, timezone +from decimal import Decimal +from pathlib import Path +from uuid import UUID + +from fastapi import FastAPI, HTTPException, Query +from fastapi.responses import FileResponse, HTMLResponse +from sqlalchemy import and_, func, select +from sqlalchemy.ext.asyncio import AsyncSession + +from database import async_session +from models import positions +from schemas import ( + Direction, + PnLSnapshot, + PositionCreate, + PositionOut, + PositionUpdate, + WebhookTrade, +) + +app = FastAPI(title="Trade Dashboard", version="0.1.0") + +STATIC_DIR = Path(__file__).parent / "static" + + +# ── Helpers ───────────────────────────────────────────────────────────── + +def position_to_out(row: dict) -> PositionOut: + return PositionOut( + id=row["id"], + symbol=row["symbol"], + direction=row["direction"], + entry_price=row["entry_price"], + exit_price=row["exit_price"], + quantity=row["quantity"], + exchange=row["exchange"], + opened_at=row["opened_at"], + closed_at=row["closed_at"], + pnl=row["pnl"], + metadata=row["metadata"], + ) + + +# ── Health ───────────────────────────────────────────────────────────── + +@app.get("/api/health") +async def health(): + async with async_session() as session: + result = await session.execute(select(func.now())) + db_time = result.scalar() + return {"status": "ok", "db_time": db_time.isoformat()} + + +# ── Positions ──────────────────────────────────────────────────────────── + +@app.get("/api/positions", response_model=list[PositionOut]) +async def list_positions( + open_only: bool = Query(True, description="Only show open positions"), +): + async with async_session() as session: + if open_only: + stmt = select(positions).where(positions.c.closed_at.is_(None)).order_by(positions.c.opened_at.desc()) + else: + stmt = select(positions).order_by(positions.c.opened_at.desc()) + rows = (await session.execute(stmt)).mappings().all() + return [position_to_out(r) for r in rows] + + +@app.post("/api/positions", status_code=201) +async def create_position(payload: PositionCreate): + async with async_session() as session: + values = payload.model_dump() + result = await session.execute(positions.insert().values(**values)) + session.commit() + pk = result.inserted_primary_key[0] + return {"id": str(pk)} + + +@app.patch("/api/positions/{position_id}") +async def update_position(position_id: UUID, payload: PositionUpdate): + async with async_session() as session: + row = await session.execute( + select(positions).where(positions.c.id == position_id) + ) + row = row.mappings().one_or_none() + if not row: + raise HTTPException(404, "Position not found") + + updates = payload.model_dump(exclude_unset=True) + + # Auto-compute PnL if closing + if "exit_price" in updates: + entry = row["entry_price"] + qty = row["quantity"] + exit_p = updates["exit_price"] + direction = row["direction"] + if direction == "long": + updates["pnl"] = float((exit_p - entry) * qty) + else: + updates["pnl"] = float((entry - exit_p) * qty) + updates["closed_at"] = datetime.now(timezone.utc) + + await session.execute( + positions.update().where(positions.c.id == position_id).values(**updates) + ) + session.commit() + + return {"ok": True} + + +@app.delete("/api/positions/{position_id}") +async def close_position(position_id: UUID, exit_price: Decimal = Query(None)): + async with async_session() as session: + row = await session.execute( + select(positions).where(positions.c.id == position_id) + ) + row = row.mappings().one_or_none() + if not row: + raise HTTPException(404, "Position not found") + + if row["closed_at"]: + raise HTTPException(400, "Position already closed") + + exit_p = exit_price or row["entry_price"] # breakeven default + entry = row["entry_price"] + qty = row["quantity"] + direction = row["direction"] + + if direction == "long": + pnl = float((exit_p - entry) * qty) + else: + pnl = float((entry - exit_p) * qty) + + await session.execute( + positions.update() + .where(positions.c.id == position_id) + .values(exit_price=exit_p, closed_at=datetime.now(timezone.utc), pnl=pnl) + ) + session.commit() + + return {"ok": True, "pnl": pnl, "exit_price": float(exit_p)} + + +# ── PnL ───────────────────────────────────────────────────────────────── + +@app.get("/api/pnl", response_model=PnLSnapshot) +async def get_pnl(): + async with async_session() as session: + now = datetime.now(timezone.utc) + today = now.replace(hour=0, minute=0, second=0, microsecond=0) + week_start = today - timedelta(days=now.weekday()) + month_start = today.replace(day=1) + + # Summary for closed trades + closed = select( + func.coalesce(func.sum(positions.c.pnl), 0).label("total"), + func.count(positions.c.id).label("count"), + ).where(positions.c.closed_at.isnot(None)) + + result = (await session.execute(closed)).mappings().one() + all_time_pnl = float(result["total"]) + total_trades = result["count"] + + # PnL by period + def period_query(start): + return select( + func.coalesce(func.sum(positions.c.pnl), 0) + ).where( + and_( + positions.c.closed_at.isnot(None), + positions.c.closed_at >= start, + ) + ) + + today_pnl = float((await session.execute(period_query(today))).scalar()) + week_pnl = float((await session.execute(period_query(week_start))).scalar()) + month_pnl = float((await session.execute(period_query(month_start))).scalar()) + + # Open count + open_count = (await session.execute( + select(func.count()).where(positions.c.closed_at.is_(None)) + )).scalar() + + return PnLSnapshot( + today_pnl=Decimal(str(today_pnl)), + week_pnl=Decimal(str(week_pnl)), + month_pnl=Decimal(str(month_pnl)), + all_time_pnl=Decimal(str(all_time_pnl)), + total_trades=total_trades, + open_positions=open_count, + ) + + +@app.get("/api/pnl/history", response_model=list[PositionOut]) +async def pnl_history( + limit: int = Query(50, ge=1, le=500), +): + async with async_session() as session: + stmt = ( + select(positions) + .where(positions.c.closed_at.isnot(None)) + .order_by(positions.c.closed_at.desc()) + .limit(limit) + ) + rows = (await session.execute(stmt)).mappings().all() + return [position_to_out(r) for r in rows] + + +# ── Webhook (for scanner scripts) ─────────────────────────────────────── + +@app.post("/webhook/trade", status_code=201) +async def webhook_trade(payload: WebhookTrade): + meta = {"strategy": payload.strategy} if payload.strategy else {} + async with async_session() as session: + result = await session.execute(positions.insert().values(**{ + "symbol": payload.symbol, + "direction": payload.direction, + "entry_price": payload.entry_price, + "quantity": payload.quantity, + "exchange": payload.exchange, + "metadata": meta, + })) + session.commit() + pk = result.inserted_primary_key[0] + return {"id": str(pk)} + + +# ── Frontend ──────────────────────────────────────────────────────────── + +@app.get("/", response_class=HTMLResponse) +async def index(): + return FileResponse(str(STATIC_DIR / "index.html")) + + +# ── Startup: run Alembic migrations ────────────────────────────────────── + +@app.on_event("startup") +async def startup(): + import alembic.config + cfg = alembic.config.AlembicConfig( + str(Path(__file__).parent.parent / "alembic.ini") + ) + alembic.config.main.main(command="upgrade", args=["head"], config=cfg) + + +if __name__ == "__main__": + import uvicorn + uvicorn.run(app, host="0.0.0.0", port=8000) diff --git a/apps/base/customer1/trade-dashboard/app/models.py b/apps/base/customer1/trade-dashboard/app/models.py new file mode 100644 index 0000000..8169975 --- /dev/null +++ b/apps/base/customer1/trade-dashboard/app/models.py @@ -0,0 +1,21 @@ +from sqlalchemy import Column, String, Numeric, Enum, DateTime, JSON, func +from sqlalchemy.dialects.postgresql import UUID +import uuid + +from database import metadata + +positions = Table( + "positions", + metadata, + Column("id", UUID(as_uuid=True), primary_key=True, default=uuid.uuid4), + Column("symbol", String(32), nullable=False, index=True), + Column("direction", Enum("long", "short", name="position_direction"), nullable=False), + Column("entry_price", Numeric(precision=16, scale=8), nullable=False), + Column("exit_price", Numeric(precision=16, scale=8)), + Column("quantity", Numeric(precision=16, scale=8), nullable=False), + Column("exchange", String(32), nullable=False, index=True), + Column("opened_at", DateTime(timezone=True), server_default=func.now(), nullable=False), + Column("closed_at", DateTime(timezone=True)), + Column("pnl", Numeric(precision=16, scale=2)), + Column("metadata", JSON), +) diff --git a/apps/base/customer1/trade-dashboard/app/requirements.txt b/apps/base/customer1/trade-dashboard/app/requirements.txt new file mode 100644 index 0000000..51462ea --- /dev/null +++ b/apps/base/customer1/trade-dashboard/app/requirements.txt @@ -0,0 +1,7 @@ +fastapi==0.115.0 +uvicorn[standard]==0.32.0 +sqlalchemy[asyncio]==2.0.35 +asyncpg==0.30.0 +alembic==1.14.0 +pydantic==2.9.2 +python-dotenv==1.0.1 diff --git a/apps/base/customer1/trade-dashboard/app/schemas.py b/apps/base/customer1/trade-dashboard/app/schemas.py new file mode 100644 index 0000000..f911657 --- /dev/null +++ b/apps/base/customer1/trade-dashboard/app/schemas.py @@ -0,0 +1,70 @@ +from __future__ import annotations + +from datetime import datetime +from decimal import Decimal +from enum import Enum +from typing import Optional +from uuid import UUID + +from pydantic import BaseModel + + +class Direction(str, Enum): + long = "long" + short = "short" + + +# ─── Request schemas ────────────────────────────────────────────── + +class PositionCreate(BaseModel): + symbol: str + direction: Direction + entry_price: Decimal + quantity: Decimal + exchange: str + metadata: Optional[dict] = None + + +class PositionUpdate(BaseModel): + entry_price: Optional[Decimal] = None + exit_price: Optional[Decimal] = None + quantity: Optional[Decimal] = None + metadata: Optional[dict] = None + + +class WebhookTrade(BaseModel): + """Payload from automated scanner scripts.""" + symbol: str + direction: Direction + entry_price: Decimal + quantity: Decimal + exchange: str + strategy: Optional[str] = None + + +# ─── Response schemas ───────────────────────────────────────────── + +class PositionOut(BaseModel): + id: UUID + symbol: str + direction: Direction + entry_price: Decimal + exit_price: Optional[Decimal] + quantity: Decimal + exchange: str + opened_at: datetime + closed_at: Optional[datetime] + pnl: Optional[Decimal] + metadata: Optional[dict] + + model_config = {"from_attributes": True} + + +class PnLSnapshot(BaseModel): + today_pnl: Decimal + week_pnl: Decimal + month_pnl: Decimal + all_time_pnl: Decimal + total_trades: int + open_positions: int + diff --git a/apps/base/customer1/trade-dashboard/app/static/index.html b/apps/base/customer1/trade-dashboard/app/static/index.html new file mode 100644 index 0000000..8795aba --- /dev/null +++ b/apps/base/customer1/trade-dashboard/app/static/index.html @@ -0,0 +1,158 @@ + + + + + +Trade Dashboard + + + +

📊 Trade Dashboard

+ + +
+
Today PnL
+
Week PnL
+
Month PnL
+
All Time
+
+ + +
+

Open Positions 0

+ + + +
SymbolDirEntryQtyExchangeOpenedAction
+
+ + +
+

Open New Position

+
+ + + + + + +
+
+ + +
+

Trade History

+ + + +
SymbolDirEntryExitQtyPnLExchangeClosed
+
+ + + + diff --git a/apps/base/customer1/trade-dashboard/configmap.yaml b/apps/base/customer1/trade-dashboard/configmap.yaml new file mode 100644 index 0000000..6d1616c --- /dev/null +++ b/apps/base/customer1/trade-dashboard/configmap.yaml @@ -0,0 +1,10 @@ +apiVersion: v1 +kind: ConfigMap +metadata: + name: trade-dashboard-config + namespace: customer1 +data: + DB_USER: "trading" + DB_HOST: "hermes-pgdb-rw.customer1.svc.cluster.local" + DB_PORT: "5432" + DB_NAME: "trading_data" diff --git a/apps/base/customer1/trade-dashboard/deployment.yaml b/apps/base/customer1/trade-dashboard/deployment.yaml new file mode 100644 index 0000000..ec5e0bb --- /dev/null +++ b/apps/base/customer1/trade-dashboard/deployment.yaml @@ -0,0 +1,58 @@ +apiVersion: apps/v1 +kind: Deployment +metadata: + name: trade-dashboard + namespace: customer1 + labels: + app: trade-dashboard +spec: + replicas: 1 + strategy: + type: Recreate + selector: + matchLabels: + app: trade-dashboard + template: + metadata: + labels: + app: trade-dashboard + annotations: + checksum/config: trade-dashboard-config + spec: + terminationGracePeriodSeconds: 30 + containers: + - name: dashboard + image: us-central1-docker.pkg.dev/devops-lab-cluster/customer1/trade-dashboard:latest + imagePullPolicy: Always + ports: + - containerPort: 8000 + name: http + resources: + requests: + cpu: 100m + memory: 128Mi + limits: + cpu: 500m + memory: 512Mi + envFrom: + - configMapRef: + name: trade-dashboard-config + env: + - name: DB_PASSWORD + valueFrom: + secretKeyRef: + name: trading-db-credentials + key: password + startupProbe: + httpGet: + path: /api/health + port: 8000 + initialDelaySeconds: 15 + periodSeconds: 5 + failureThreshold: 6 + livenessProbe: + httpGet: + path: /api/health + port: 8000 + initialDelaySeconds: 30 + periodSeconds: 30 diff --git a/apps/base/customer1/trade-dashboard/kustomization.yaml b/apps/base/customer1/trade-dashboard/kustomization.yaml new file mode 100644 index 0000000..b08a552 --- /dev/null +++ b/apps/base/customer1/trade-dashboard/kustomization.yaml @@ -0,0 +1,8 @@ +apiVersion: kustomize.config.k8s.io/v1beta1 +kind: Kustomization + +resources: + - deployment.yaml + - service.yaml + - configmap.yaml + - tsproxy.yaml diff --git a/apps/base/customer1/trade-dashboard/service.yaml b/apps/base/customer1/trade-dashboard/service.yaml new file mode 100644 index 0000000..2a94199 --- /dev/null +++ b/apps/base/customer1/trade-dashboard/service.yaml @@ -0,0 +1,12 @@ +apiVersion: v1 +kind: Service +metadata: + name: trade-dashboard + namespace: customer1 +spec: + selector: + app: trade-dashboard + ports: + - port: 80 + targetPort: 8000 + name: http diff --git a/apps/base/customer1/trade-dashboard/tsproxy.yaml b/apps/base/customer1/trade-dashboard/tsproxy.yaml new file mode 100644 index 0000000..b748657 --- /dev/null +++ b/apps/base/customer1/trade-dashboard/tsproxy.yaml @@ -0,0 +1,9 @@ +apiVersion: tailscale.com/v1 +kind: TsProxy +metadata: + name: trade-dashboard + namespace: customer1 +spec: + serviceName: trade-dashboard + servicePort: 80 + hostname: trade-dashboard diff --git a/apps/staging/customer1/kustomization.yaml b/apps/staging/customer1/kustomization.yaml index 974b250..7691ed9 100644 --- a/apps/staging/customer1/kustomization.yaml +++ b/apps/staging/customer1/kustomization.yaml @@ -9,3 +9,4 @@ resources: - ../../base/customer1/paaas-landing/ - ../../base/customer1/hermes-agent/ - ../../base/customer1/hermes-db/ + - ../../base/customer1/trade-dashboard/