+-------------------+      +-------------------+      +-------------------+
|   Agent Process   | ---> |   Agnost Collector| ---> |   Agnost Backend |
| (LLM + tool layer)|      | (sidecar / lib)   |      | (metrics, alerts)|
+-------------------+      +-------------------+      +-------------------+
        ^                         ^                         ^
        |                         |                         |
   HTTP/gRPC hooks          Async batcher               Dashboard &
   (any provider)           (Redis / Kafka)             Alert engine

name: CI
on: [push, pull_request]

jobs:
  test:
    runs-on: ubuntu-latest
    services:
      agnost:
        image: agnost/collector:latest
        env:
          AGNOST_API_KEY: ${{ secrets.AGNOST_API_KEY }}
    steps:
      - uses: actions/checkout@v3
      - name: Install deps
        run: pip install -r requirements.txt
      - name: Run tests with collector
        env:
          AGNOST_ENDPOINT: http://localhost:8000
        run: |
          export AGNOST_ENABLED=1
          pytest tests/
      - name: Publish metrics
        run: |
          curl -X POST "$AGNOST_ENDPOINT/flush" -H "Authorization: Bearer ${{ secrets.AGNOST_API_KEY }}"

stages:
  - test
  - report

test:
  stage: test
  image: python:3.11
  services:
    - name: agnost/collector:latest
      alias: agnost
  variables:
    AGNOST_ENDPOINT: http://agnost:8000
    AGNOST_ENABLED: "1"
  script:
    - pip install -r requirements.txt
    - pytest -q
  artifacts:
    paths:
      - .agnost/report.json

report:
  stage: report
  image: curlimages/curl:latest
  script:
    - curl -X POST "$AGNOST_ENDPOINT/upload" \
        -H "Authorization: Bearer $AGNOST_API_KEY" \
        -F "file=@.agnost/report.json"

version: "3.9"
services:
  agent:
    build: .
    environment:
      AGNOST_ENABLED: "1"
      AGNOST_ENDPOINT: http://collector:8000
    depends_on: [collector]

  collector:
    image: agnost/collector:latest
    ports: ["8000:8000"]
    environment:
      AGNOST_API_KEY: ${AGNOST_API_KEY}

# agnost_wrapper.py
import os, json, requests
from functools import wraps

AGNOST_ENDPOINT = os.getenv("AGNOST_ENDPOINT", "http://localhost:8000")
AGNOST_ENABLED  = os.getenv("AGNOST_ENABLED", "0") == "1"

def agnost_capture(func):
    @wraps(func)
    def wrapper(*args, **kwargs):
        request_payload = {"args": args, "kwargs": kwargs}
        resp = func(*args, **kwargs)
        if AGNOST_ENABLED:
            event = {
                "timestamp": int(time.time()*1000),
                "tool": func.__name__,
                "request": request_payload,
                "response": resp,
                "metadata": {"service": "my-agent"}
            }
            try:
                requests.post(f"{AGNOST_ENDPOINT}/event",
                              json=event,
                              timeout=0.5)
            except Exception:
                pass  # fire‑and‑forget; never break the agent
        return resp
    return wrapper

# Example usage
@agnost_capture
def call_search_api(query: str) -> dict:
    # real HTTP request to a search service
    return {"results": ["a", "b", "c"]}

# In your agent loop
answer = call_search_api("latest AI regulations")

#!/usr/bin/env bash
# agnost_alert.sh – runs inside a sidecar container
while read -r line; do
  if echo "$line" | jq -e '.drift > 0.8' > /dev/null; then
    payload=$(jq -n \
      --arg msg "⚠️ High drift detected in ${AGENT_NAME}" \
      '{text:$msg}')
    curl -X POST -H "Content-Type: application/json" \
      -d "$payload" "$SLACK_WEBHOOK_URL"
  fi
done < <(tail -F /var/log/agnost/events.log)