ottonova – Agentic AI Platform on AWS

TOKEN='<YOUR-SIGN-IN-TOKEN>'
curl -s -X POST https://api-dev.jovial-ottonova.de/api-keys -H "Authorization: Bearer $TOKEN" \
  -H 'x-amz-content-sha256: e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855'

201 with id, key and prefix; the key is in this answer only.

TOKEN='<YOUR-SIGN-IN-TOKEN>'
curl -s -X DELETE https://api-dev.jovial-ottonova.de/api-keys/<KEY-ID> -H "Authorization: Bearer $TOKEN"

204; from then on the door refuses the key.

curl -s https://ottonova-ai-assistant-dev.jovial-ottonova.de/a2a/orchestrator/.well-known/agent-card.json

Public, no key: the card names the endpoint, the skills and the personalApiKey scheme.

KEY='<YOUR-API-KEY>'
BODY=$(printf '{"jsonrpc":"2.0","id":"1","method":"SendMessage","params":{"message":{"messageId":"%s","role":"ROLE_USER","parts":[{"data":{"text":"Hallo, was kannst du für mich tun?"}}]}}}' "$(uuidgen)")
curl -s https://ottonova-ai-assistant-dev.jovial-ottonova.de/a2a/orchestrator \
  -H "Authorization: Bearer $KEY" \
  -H 'A2A-Version: 1.0' \
  -H 'Content-Type: application/json' \
  -H "x-amz-content-sha256: $(printf %s "$BODY" | shasum -a 256 | cut -d' ' -f1)" \
  --data "$BODY"

Waits for the answer: result.task with status.state TASK_STATE_COMPLETED and the orchestrator_response artifact, whose data holds kind and text.

KEY='<YOUR-API-KEY>'
BODY=$(printf '{"jsonrpc":"2.0","id":"1","method":"SendStreamingMessage","params":{"message":{"messageId":"%s","role":"ROLE_USER","parts":[{"data":{"text":"Hallo, was kannst du für mich tun?"}}]}}}' "$(uuidgen)")
curl -sN https://ottonova-ai-assistant-dev.jovial-ottonova.de/a2a/orchestrator \
  -H "Authorization: Bearer $KEY" \
  -H 'A2A-Version: 1.0' \
  -H 'Content-Type: application/json' \
  -H 'Accept: text/event-stream' \
  -H "x-amz-content-sha256: $(printf %s "$BODY" | shasum -a 256 | cut -d' ' -f1)" \
  --data "$BODY"

Server-sent events, each a JSON-RPC result: the task first, then artifactUpdate chunks of answer-stream, then a statusUpdate with TASK_STATE_COMPLETED.

KEY='<YOUR-API-KEY>'
BODY='{"jsonrpc":"2.0","id":"2","method":"GetTask","params":{"id":"<TASK-ID>"}}'
curl -s https://ottonova-ai-assistant-dev.jovial-ottonova.de/a2a/orchestrator \
  -H "Authorization: Bearer $KEY" \
  -H 'A2A-Version: 1.0' \
  -H 'Content-Type: application/json' \
  -H "x-amz-content-sha256: $(printf %s "$BODY" | shasum -a 256 | cut -d' ' -f1)" \
  --data "$BODY"

The task with its state and artifacts; CancelTask takes the same params to stop a running task.

import asyncio, hashlib, uuid
import httpx
from a2a.client import ClientConfig, create_client
from a2a.helpers.proto_helpers import new_data_part
from a2a.types import a2a_pb2 as pb

async def add_body_hash(request: httpx.Request) -> None:
    request.headers["x-amz-content-sha256"] = hashlib.sha256(request.content).hexdigest()

async def main() -> None:
    http = httpx.AsyncClient(timeout=180, headers={"Authorization": "Bearer <YOUR-API-KEY>"},
                             event_hooks={"request": [add_body_hash]})
    client = await create_client("https://ottonova-ai-assistant-dev.jovial-ottonova.de", ClientConfig(httpx_client=http, streaming=False))
    message = pb.Message(message_id=str(uuid.uuid4()), role=pb.Role.ROLE_USER,
                         parts=[new_data_part({"text": "Hallo, was kannst du für mich tun?"})])
    async for response in client.send_message(pb.SendMessageRequest(message=message)):
        print(response.task.artifacts[0].parts[0].data)

asyncio.run(main())

pip install a2a-sdk httpx; prints the orchestrator's answer.

{
  "code": "UNAUTHENTICATED",
  "message": "No valid token or key was sent.",
  "hint": "Send a valid service token, JWT or personal API key in the Authorization header.",
  "retryable": false,
  "details": {
    "reason": "personal API key required"
  }
}