Slopshop for
Grok & xAI Agents

# Slopshop + Grok: Agent Mode with session persistence
# Uses xAI-compatible request format + enhanced response envelope

import os, json, uuid, requests
from openai import OpenAI  # xAI API is OpenAI-compatible

# xAI client (Grok)
grok = OpenAI(
    api_key=os.environ["XAI_API_KEY"],
    base_url="https://api.x.ai/v1"
)

SLOP_KEY    = os.environ["SLOPSHOP_API_KEY"]
SLOP_URL    = "https://slopshop.gg"
SESSION_ID  = f"sess_grok_{uuid.uuid4().hex[:12]}"


def call_slopshop_agent(tool_name: str, args: dict) -> dict:
    """Call Slopshop in Agent Mode — returns enhanced envelope."""
    slug = tool_name.replace("_", "-")
    resp = requests.post(
        f"{SLOP_URL}/v1/{slug}",
        headers={
            "Authorization":  f"Bearer {SLOP_KEY}",
            "Content-Type":    "application/json",
            "X-Agent-Mode":    "grok",          # Enable Agent Mode
            "X-Session-Id":    SESSION_ID,           # Bind to session
            "X-Auto-Persist":  "true"              # Auto-save to memory
        },
        json={**args, "session_id": SESSION_ID, "mode": "grok"}
    )
    result = resp.json()

    # Log what Agent Mode gave us
    if agent_meta := result.get("_agent"):
        print(f"  [agent] persisted={agent_meta['persisted']}")
        print(f"  [agent] fingerprint={agent_meta['cache_fingerprint'][:16]}...")
        if agent_meta.get("suggestions"):
            print(f"  [agent] suggestions: {agent_meta['suggestions']}")

    return result


def run_grok_agent(task: str) -> str:
    """Run Grok in Agent Mode with Slopshop tools."""
    # Fetch tools as OpenAI-compatible function definitions
    tools_resp = requests.get(
        f"{SLOP_URL}/v1/openapi.json",
        headers={"Authorization": f"Bearer {SLOP_KEY}"}
    )
    # ... (convert to OpenAI tool format, see integrate-openai.html)

    messages = [{"role": "user", "content": task}]
    print(f"Session: {SESSION_ID}")

    while True:
        response = grok.chat.completions.create(
            model="grok-3",
            messages=messages,
            tools=tools,           # Slopshop tools
            tool_choice="auto"
        )
        msg = response.choices[0].message
        messages.append(msg)

        if msg.tool_calls:
            for tc in msg.tool_calls:
                print(f"Grok calling: {tc.function.name}")
                result = call_slopshop_agent(
                    tc.function.name,
                    json.loads(tc.function.arguments)
                )
                messages.append({
                    "role": "tool",
                    "tool_call_id": tc.id,
                    "content": json.dumps(result)
                })
        else:
            return msg.content


# All tool results are auto-persisted to SESSION_ID memory namespace
answer = run_grok_agent(
    "Audit api.x.ai — DNS records, SSL cert grade, and HTTP security headers"
)
print(answer)