Revert x-request-id changes - out of scope

Author: prassanna-ravishankar

examples/tutorials/00_sync/030_header_test/.dockerignore

@@ -0,0 +1,43 @@
+# Python
+__pycache__/
+*.py[cod]
+*$py.class
+*.so
+.Python
+build/
+develop-eggs/
+dist/
+downloads/
+eggs/
+.eggs/
+lib/
+lib64/
+parts/
+sdist/
+var/
+wheels/
+*.egg-info/
+.installed.cfg
+*.egg
+
+# Environments
+.env**
+.venv
+env/
+venv/
+ENV/
+env.bak/
+venv.bak/
+
+# IDE
+.idea/
+.vscode/
+*.swp
+*.swo
+
+# Git
+.git
+.gitignore
+
+# Misc
+.DS_Store

examples/tutorials/00_sync/030_header_test/Dockerfile

@@ -0,0 +1,40 @@
+# syntax=docker/dockerfile:1.3
+FROM python:3.12-slim
+COPY --from=ghcr.io/astral-sh/uv:0.6.4 /uv /uvx /bin/
+
+# Install system dependencies
+RUN apt-get update && apt-get install -y \
+    htop \
+    vim \
+    curl \
+    tar \
+    python3-dev \
+    postgresql-client \
+    build-essential \
+    libpq-dev \
+    gcc \
+    cmake \
+    netcat-openbsd \
+    && apt-get clean \
+    && rm -rf /var/lib/apt/lists/*
+
+RUN uv pip install --system --upgrade pip setuptools wheel
+
+ENV UV_HTTP_TIMEOUT=1000
+
+# Copy just the requirements file to optimize caching
+COPY 030_header_test/requirements.txt /app/requirements.txt
+
+WORKDIR /app/
+
+# Install the required Python packages
+RUN uv pip install --system -r requirements.txt
+
+# Copy the project code
+COPY 030_header_test/project /app/project
+
+# Set environment variables
+ENV PYTHONPATH=/app
+
+# Run the agent using uvicorn
+CMD ["uvicorn", "project.acp:acp", "--host", "0.0.0.0", "--port", "8000"]

examples/tutorials/00_sync/030_header_test/README.md

@@ -0,0 +1,24 @@
+# Header Test Agent
+
+This agent tests header forwarding from the AgentEx backend to the agent.
+
+## Features
+
+- Receives events with forwarded HTTP headers
+- Validates that custom headers (like auth keys) are properly forwarded
+- Logs header information for debugging
+
+## Testing
+
+The agent will log:
+- ✅ When headers are successfully received
+- ⚠️  When expected headers are missing
+- ❌ When no headers are forwarded at all
+
+## Expected Headers
+
+The agent looks for:
+- `x-test-auth-key`: Test authentication key
+- `x-custom-header`: Custom header for testing
+
+All headers starting with `x-` should be forwarded (except security-sensitive ones filtered by the backend).

examples/tutorials/00_sync/030_header_test/manifest.yaml

@@ -0,0 +1,41 @@
+# Agent Manifest Configuration for Header Test Agent
+# ---------------------------
+
+build:
+  context:
+    root: ../
+    include_paths:
+      - 030_header_test
+    dockerfile: 030_header_test/Dockerfile
+    dockerignore: 030_header_test/.dockerignore
+
+local_development:
+  agent:
+    port: 8003
+    host_address: host.docker.internal
+  paths:
+    acp: project/acp.py
+
+agent:
+  name: s030-header-test
+  acp_type: agentic
+  description: Test agent for validating header forwarding from backend to agent
+  temporal:
+    enabled: false
+
+deployment:
+  image:
+    repository: ""
+    tag: "latest"
+  global:
+    agent:
+      name: "s030-header-test"
+      description: "Test agent for validating header forwarding from backend to agent"
+    replicaCount: 1
+    resources:
+      requests:
+        cpu: "500m"
+        memory: "1Gi"
+      limits:
+        cpu: "1000m"
+        memory: "2Gi"

examples/tutorials/00_sync/030_header_test/project/__init__.py

@@ -0,0 +1 @@
+# Header test agent project

examples/tutorials/00_sync/030_header_test/project/acp.py

@@ -0,0 +1,68 @@
+from typing import Union, AsyncGenerator
+
+from agentex.lib.types.acp import SendMessageParams, SendEventParams
+from agentex.lib.utils.logging import make_logger
+from agentex.types.task_message import TaskMessageContent
+from agentex.lib.sdk.fastacp.fastacp import FastACP
+from agentex.types.task_message_update import TaskMessageUpdate
+from agentex.types.task_message_content import TextContent
+
+logger = make_logger(__name__)
+
+
+# Create an ACP server (agentic type to support event/send)
+from agentex.lib.types.fastacp import AgenticACPConfig
+
+acp = FastACP.create(
+    acp_type="agentic",
+    config=AgenticACPConfig(type="base"),
+)
+
+
+@acp.on_message_send
+async def handle_message_send(
+    params: SendMessageParams
+) -> Union[TaskMessageContent, AsyncGenerator[TaskMessageUpdate, None]]:
+    """Message handler - simple echo response"""
+    message_text = ""
+    if hasattr(params.content, 'content'):
+        content_val = getattr(params.content, 'content', '')
+        if isinstance(content_val, str):
+            message_text = content_val
+
+    return TextContent(
+        author="agent",
+        content=f"Message received: {message_text}",
+    )
+
+
+@acp.on_task_event_send
+async def handle_event_send(params: SendEventParams) -> None:
+    """Event handler that validates header forwarding"""
+    logger.info(f"=== EVENT RECEIVED ===")
+    logger.info(f"Event ID: {params.event.id}")
+    logger.info(f"Task ID: {params.task.id}")
+    logger.info(f"Agent ID: {params.agent.id}")
+
+    # Check if request headers were forwarded
+    if params.request:
+        logger.info(f"✅ Request headers present!")
+        logger.info(f"Headers: {params.request}")
+
+        # Headers are nested in params.request['headers']
+        headers = params.request.get('headers', {})
+
+        # Look for specific test headers
+        if 'x-test-auth-key' in headers:
+            logger.info(f"✅ Found x-test-auth-key: {headers['x-test-auth-key']}")
+        else:
+            logger.warning("⚠️  x-test-auth-key not found in request headers")
+
+        if 'x-custom-header' in headers:
+            logger.info(f"✅ Found x-custom-header: {headers['x-custom-header']}")
+        else:
+            logger.warning("⚠️  x-custom-header not found in request headers")
+    else:
+        logger.error("❌ No request headers forwarded!")
+
+    logger.info(f"=== END EVENT ===")

examples/tutorials/00_sync/030_header_test/pyproject.toml

@@ -0,0 +1,33 @@
+[build-system]
+requires = ["hatchling"]
+build-backend = "hatchling.build"
+
+[project]
+name = "s030-header-test"
+version = "0.1.0"
+description = "Test agent for validating header forwarding from backend to agent"
+readme = "README.md"
+requires-python = ">=3.12"
+dependencies = [
+    "agentex-sdk",
+    "scale-gp",
+]
+
+[project.optional-dependencies]
+dev = [
+    "pytest",
+    "black",
+    "isort",
+    "flake8",
+]
+
+[tool.hatch.build.targets.wheel]
+packages = ["project"]
+
+[tool.black]
+line-length = 88
+target-version = ['py312']
+
+[tool.isort]
+profile = "black"
+line_length = 88

examples/tutorials/00_sync/030_header_test/requirements.txt

@@ -0,0 +1,3 @@
+agentex-sdk
+scale-gp
+uvicorn[standard]