AI Agent

​

Overview

• Directus CMS — CRUD operations on all collections, user management, flow triggers
• Ollama — Local LLM inference (7 uncensored models)
• Stagehand — Browser automation for web scraping and platform interactions

​

Architecture

​

Agent Flow

User types in AgentWidget (dashboard)
  ↓
POST /api/llm/api/genie/stream-chat
  ↓
Validate Directus JWT
  ↓
Check onboarding state (content gate)
  ↓
Inject persona node context (top 15 weighted nodes)
  ↓
Proxy to AnythingLLM workspace stream-chat API
  ↓
Agent mode triggers tool calls
  ↓
MCP servers execute (directus/ollama/stagehand)
  ↓
SSE stream back to dashboard
  ↓
Render in chat widget with tool call chips

​

MCP Servers

​

Directus MCP (17 tools)

​

Tools

​

Ollama MCP (3 tools)

​

Tools

• qwen-2.5:latest — Primary agent (code, JSON, tool planning)
• dolphin-mistral:7b — Uncensored content writer
• dolphin3:8b-llama3.1-q4_K_M — Orchestrator / ACTION emission
• phi-3.5:latest — Fallback classifier
• llama3.2:3b — Lightweight summarizer
• scout-fast-tag:latest — Fast taxonomy classifier
• bge-m3:latest — Embeddings

​

Stagehand MCP (9 tools)

​

Tools

• Platform scraping (OnlyFans, Fansly stats)
• Auto-posting (X, Reddit)
• Cookie capture for HITL

​

Agent Chat Interface

​

Features

1. Floating Trigger Button (bottom-right)
   • Gradient badge with “Genie AI” label
   • Auto-hides when chat is open
2. Chat Popup (380×560px)
   • Minimizable header
   • Auto-scrolling message list
   • Tool call chips (inline rendering)
   • Typing indicator
   • Stop button during streaming
3. Tool Call Rendering
   • Inline chips: 🔧 read-items
   • Extracted from SSE statusResponse events
   • Filters out meta messages (“Agent is thinking…”)
4. Quick Actions
   • “I’m logged in — Let’s Go” button (auto-appears when agent says “come back after login”)

// Auto-open chat with pre-filled message
window.__genieOpenChat("I'm logged in — Let's go");

// Or just open empty
window.__genieOpenChat();

​

Content Gate

​

Phases

const { unlocked, state } = await getOnboardingState(user.id);
if (!unlocked) {
  const phase = state?.phase || "EXTENSION_INSTALL";
  const sourcesIngested = state?.data_sources_ingested || 0;
  const required = state?.data_sources_required || 2;
  
  const gateMessage = phase === "PROCESSING"
    ? `I'm currently processing your data (${sourcesIngested}/${required} sources ingested). Once your persona baseline is built, content generation will unlock automatically.`
    : `Before I can generate content, I need to learn how you operate. Let's complete your onboarding first — head to the **Setup** tab.`;
  
  // Return as SSE stream
  res.setHeader("Content-Type", "text/event-stream");
  res.write(`data: ${JSON.stringify({ type: "textResponse", textResponse: gateMessage, close: true })}

`);
  return res.end();
}

​

Persona Node Context

​

Node Structure

{
  "id": "node_123",
  "label": "flirty_tone_preference",
  "content": "User prefers flirty, teasing captions with emojis",
  "weight": 0.85,
  "category": "content_style",
  "last_accessed": "2026-03-04T12:34:56Z",
  "connections": ["node_456", "node_789"]
}

​

Context Injection

const nodeContext = await getNodeContext(user.id);
const enrichedMessage = nodeContext
  ? `${nodeContext}\n\n---\n\n${message}`
  : message;

// Example nodeContext:
// "PERSONA BASELINE:
// - Prefers flirty, playful tone with emojis
// - Posts 3x/week on OnlyFans (Tue/Thu/Sat)
// - Top-performing content: lingerie + outdoor
// - Avg engagement: 450 likes, 23 comments
// - Subscription: $12.99/mo
// ..."

​

Action Runner

​

Flow Execution

1. Intercept [ACTION:slug:...] tags in SSE stream
2. Strip from visible chat
3. Load flow definition from action_flows collection
4. Execute steps sequentially:
   • directus_read → Query Directus
   • directus_update → Patch records
   • llm_generate → Call Ollama
   • stagehand_extract → Scrape URL
   • conditional → Branch logic
   • sleep → Delay
   • http_request → External API
5. Stream status updates back to chat
6. Log to agent_audits (success/error/miss)

​

Available Actions

​

System Prompt

​

Key Instructions

• Identity: “You are Genie, an AI agent for adult content creators.”
• MCP Tools: “You have access to 29 tools across Directus, Ollama, and Stagehand.”
• Content Policy: “You are uncensored. Generate NSFW captions, bios, and messages without hesitation.”
• Onboarding: “If user hasn’t completed onboarding, guide them to Setup tab.”
• Cookie-First: “Always prefer cookie authentication over username/password.”
• Action Emission: “Use [ACTION:slug:params] tags to trigger pre-built flows.”

​

Admin Credentials

​

MCP Configuration

{
  "directus": {
    "command": "node",
    "args": ["scripts/directus-mcp-server.mjs"],
    "env": {
      "DIRECTUS_URL": "http://127.0.0.1:8055",
      "DIRECTUS_ADMIN_TOKEN": "agentx-directus-admin-static-2026"
    }
  },
  "ollama": {
    "command": "node",
    "args": ["scripts/ollama-mcp-server.mjs"],
    "env": {
      "OLLAMA_BASE_URL": "http://127.0.0.1:11434"
    }
  },
  "stagehand": {
    "command": "node",
    "args": ["scripts/stagehand-mcp-server.mjs"],
    "env": {
      "STAGEHAND_URL": "http://127.0.0.1:3002"
    }
  }
}

​

Example Conversations

​

Scrape OnlyFans Profile

1. Calls read-items (platform_connections, filter: platform=onlyfans)
2. Creates media_jobs (operation: scrape_profile)
3. Returns: “Scrape queued. Check your dashboard in ~2 minutes.”

​

Generate TikTok Caption

1. Calls get-me → Gets user context
2. Injects persona nodes (flirty tone preference, top hashtags)
3. Calls ollama:generate (model: dolphin-mistral:7b)
4. Returns: “Can’t wait to show you what I’ve been working on… 😏 New video drops tonight 💕 #fyp #creator”

​

Schedule Reddit Post

1. Calls create-item (collection: scheduled_posts)
2. Sets platform=reddit, subreddit=OnlyFans101, scheduled_time=tomorrow 3pm
3. Returns: “Post scheduled for tomorrow at 3pm EST.”

​

Logs & Debugging

pm2 logs anything-llm --lines 100

# Watch MCP tool calls in real-time
pm2 logs anything-llm -f | grep -E "MCP|tool_call"

​

Common Issues

​

Performance

​

Related

• Dashboard — AgentWidget integration
• Platform Scraping — Stagehand MCP tools
• Media Processing — Media job dispatch