version: "2"
logs:
  sink: file
  max_bytes: 10485760
  max_files: 5
status:
  snapshot_mode: summary
  snapshot_interval_secs: 5

services:
  fastapi_server:
    command: "uv run uvicorn main:app --host 0.0.0.0 --port 8888"
    restart_policy: "on-failure"
    max_restarts: 10
    backoff: "5s"

import random
from datetime import datetime, timezone
from typing import Dict, Optional

from fastapi import FastAPI, HTTPException
from pydantic import BaseModel, Field

app = FastAPI(title="CRUD API", version="0.1.0")

class Todo(BaseModel):
    title: str = Field(..., min_length=1, max_length=200)
    description: str = Field(..., min_length=1, max_length=1000)
    id: Optional[int] = Field(default=None)
    timestamp: Optional[datetime] = Field(default=None)
    is_completed: bool = Field(default=False)

todos_db: Dict[int, Todo] = {}
next_id = 1

@app.get("/")
async def root():
    return {"status": "healthy", "timestamp": datetime.now(timezone.utc).isoformat()}

@app.post("/todos", response_model=Todo)
async def create_todo(todo: Todo) -> Todo:
    global next_id
    todo.id = next_id
    todo.timestamp = datetime.now(timezone.utc)
    next_id += 1
    todos_db[todo.id] = todo
    return todo

@app.get("/todos", response_model=list[Todo])
async def read_todos() -> list[Todo]:
    return list(todos_db.values())

@app.get("/todos/{todo_id}", response_model=Todo)
async def read_todo(todo_id: int) -> Todo:
    if todo_id not in todos_db:
        raise HTTPException(status_code=404, detail=f"Todo with id {todo_id} not found")
    return todos_db[todo_id]

@app.put("/todos/{todo_id}", response_model=Todo)
async def update_todo(todo_id: int, todo_update: Todo) -> Todo:
    if todo_id not in todos_db:
        raise HTTPException(status_code=404, detail=f"Todo with id {todo_id} not found")

    existing_todo = todos_db[todo_id]
    existing_todo.title = todo_update.title
    existing_todo.description = todo_update.description
    existing_todo.is_completed = todo_update.is_completed
    return existing_todo

@app.delete("/todos/{todo_id}")
async def delete_todo(todo_id: int):
    if todo_id not in todos_db:
        raise HTTPException(status_code=404, detail=f"Todo with id {todo_id} not found")

    del todos_db[todo_id]
    return {"message": f"Todo {todo_id} deleted successfully"}

@app.get("/chaos")
async def chaos_endpoint():
    if random.random() < 0.7:
        raise HTTPException(
            status_code=500,
            detail="Chaos monkey struck! Random failure to test recovery."
        )
    return {"message": "Lucky you! The chaos monkey was sleeping."}

[project]
name = "crud-example"
version = "0.1.0"
description = "Simple CRUD API with FastAPI demonstrating systemg recovery"
requires-python = ">=3.11"
dependencies = [
    "fastapi>=0.115.0",
    "uvicorn[standard]>=0.32.0",
    "pydantic>=2.10.0",
    "httpx>=0.27.0",
]

[build-system]
requires = ["hatchling"]
build-backend = "hatchling.build"

[tool.hatch.build.targets.wheel]
packages = ["."]

$ cd examples/crud
$ uv sync
$ sysg start --config crud.sysg.yaml

$ uv run python test_api.py

$ sysg stop --config crud.sysg.yaml

$ sysg logs --service fastapi_server

$ sysg status

curl -X POST http://localhost:8888/todos \
  -H "Content-Type: application/json" \
  -d '{
    "title": "Test systemg",
    "description": "Verify systemg service management",
    "is_completed": false
  }'

curl http://localhost:8888/todos

curl -X PUT http://localhost:8888/todos/1 \
  -H "Content-Type: application/json" \
  -d '{
    "title": "Test systemg",
    "description": "Successfully tested systemg!",
    "is_completed": true
  }'

curl http://localhost:8888/chaos