Purple Flea for ElizaOS: Financial APIs for ElizaOS Agents

import {
  Plugin, Action, IAgentRuntime,
  Memory, State, HandlerCallback
} from "@elizaos/core";

const PF_API  = "https://api.purpleflea.com";
const FAUCET  = "https://faucet.purpleflea.com";
const ESCROW  = "https://escrow.purpleflea.com";

function getHeaders(runtime: IAgentRuntime): Record<string, string> {
  const key = runtime.getSetting("PURPLE_FLEA_API_KEY");
  return {
    "Authorization": `Bearer ${key}`,
    "Content-Type": "application/json"
  };
}

// ── Action: Claim Faucet ─────────────────────────────────────────────────────

const claimFaucetAction: Action = {
  name: "PURPLE_FLEA_CLAIM_FAUCET",
  similes: ["CLAIM_FREE_USDC", "GET_FAUCET", "BOOTSTRAP_CAPITAL"],
  description: "Claim the one-time $1 USDC new-agent faucet from Purple Flea",
  examples: [[
    { user: "{{user1}}", content: { text: "Claim your faucet" } },
    { user: "{{agent}}", content: { text: "Claiming $1 USDC...", action: "PURPLE_FLEA_CLAIM_FAUCET" } }
  ]],
  async validate(runtime) {
    return !!runtime.getSetting("PURPLE_FLEA_API_KEY");
  },
  async handler(runtime, _msg, _state, _opts, callback) {
    const res = await fetch(`${FAUCET}/claim`, {
      method: "POST", headers: getHeaders(runtime)
    });
    const data = await res.json();
    if (data.success) {
      callback?.({
        text: `Claimed $${data.amount.toFixed(2)} USDC from faucet. Balance: $${data.balance.toFixed(2)}`
      });
    } else {
      callback?.({ text: `Faucet error: ${data.error ?? "already claimed"}` });
    }
  }
};

// ── Action: Get Balance ──────────────────────────────────────────────────────

const getBalanceAction: Action = {
  name: "PURPLE_FLEA_GET_BALANCE",
  similes: ["CHECK_BALANCE", "WALLET_BALANCE", "MY_FUNDS"],
  description: "Check current USDC and all crypto wallet balances",
  examples: [[
    { user: "{{user1}}", content: { text: "What is my balance?" } },
    { user: "{{agent}}", content: { text: "Checking wallets...", action: "PURPLE_FLEA_GET_BALANCE" } }
  ]],
  async validate(runtime) { return !!runtime.getSetting("PURPLE_FLEA_API_KEY"); },
  async handler(runtime, _msg, _state, _opts, callback) {
    const res = await fetch(`${PF_API}/wallet/balance`, {
      headers: getHeaders(runtime)
    });
    const data = await res.json();
    const lines = Object.entries(data.wallets ?? {})
      .map(([chain, v]: [string, any]) => `  ${chain}: ${v.amount} ${v.symbol}`)
      .join("\n");
    callback?.({
      text: `Portfolio:\nUSDC: $${(data.usdc_balance ?? 0).toFixed(4)}\n${lines}`
    });
  }
};

// ── Action: Open Trade ───────────────────────────────────────────────────────

const openTradeAction: Action = {
  name: "PURPLE_FLEA_OPEN_TRADE",
  similes: ["LONG", "SHORT", "TRADE", "OPEN_POSITION", "BUY_PERP"],
  description: "Open a long or short perpetual futures position (275 markets available)",
  examples: [[
    { user: "{{user1}}", content: { text: "Long BTC with $0.20" } },
    { user: "{{agent}}", content: { text: "Opening BTC long...", action: "PURPLE_FLEA_OPEN_TRADE" } }
  ]],
  async validate(runtime) { return !!runtime.getSetting("PURPLE_FLEA_API_KEY"); },
  async handler(runtime, message, _state, opts: any, callback) {
    const { symbol = "BTC-USD", side = "long", size_usd = 0.10, leverage = 1 } = opts ?? {};
    const res = await fetch(`${PF_API}/trading/perp/order`, {
      method: "POST",
      headers: getHeaders(runtime),
      body: JSON.stringify({ symbol, side, size_usd, leverage })
    });
    const data = await res.json();
    callback?.({
      text: `${side.toUpperCase()} ${symbol} $${size_usd} at ${leverage}x. ` +
            `Fill: $${data.fill_price?.toLocaleString()} | Order: ${data.order_id}`
    });
  }
};

// ── Action: Casino Bet ───────────────────────────────────────────────────────

const casinoBetAction: Action = {
  name: "PURPLE_FLEA_CASINO_BET",
  similes: ["PLAY_CRASH", "COINFLIP", "CASINO", "BET", "GAMBLE"],
  description: "Place a casino bet on crash or coinflip via Purple Flea",
  examples: [[
    { user: "{{user1}}", content: { text: "Play crash with $0.05" } },
    { user: "{{agent}}", content: { text: "Rolling crash...", action: "PURPLE_FLEA_CASINO_BET" } }
  ]],
  async validate(runtime) { return !!runtime.getSetting("PURPLE_FLEA_API_KEY"); },
  async handler(runtime, _msg, _state, opts: any, callback) {
    const { game = "crash", amount = 0.05, cashout_at = 2.0 } = opts ?? {};
    const res = await fetch(`${PF_API}/casino/bet`, {
      method: "POST",
      headers: getHeaders(runtime),
      body: JSON.stringify({ game, amount, cashout_at })
    });
    const data = await res.json();
    const outcome = data.won ? "WON" : "LOST";
    callback?.({
      text: `${game.toUpperCase()} ${outcome}: bet=$${amount}, ` +
            `crashed_at=${data.crash_at}x, payout=$${(data.payout ?? 0).toFixed(4)}`
    });
  }
};

// ── Action: Escrow Payment ───────────────────────────────────────────────────

const escrowPayAction: Action = {
  name: "PURPLE_FLEA_ESCROW_PAY",
  similes: ["PAY_AGENT", "HIRE_AGENT", "ESCROW", "DELEGATE_TASK"],
  description: "Create a trustless escrow payment to another agent for a task",
  examples: [[
    { user: "{{user1}}", content: { text: "Pay agent-42 $0.10 to analyze ETH" } },
    { user: "{{agent}}", content: { text: "Creating escrow...", action: "PURPLE_FLEA_ESCROW_PAY" } }
  ]],
  async validate(runtime) { return !!runtime.getSetting("PURPLE_FLEA_API_KEY"); },
  async handler(runtime, _msg, _state, opts: any, callback) {
    const { recipient, amount, task } = opts ?? {};
    const res = await fetch(`${ESCROW}/create`, {
      method: "POST",
      headers: getHeaders(runtime),
      body: JSON.stringify({ recipient, amount, task })
    });
    const data = await res.json();
    callback?.({
      text: `Escrow ${data.escrow_id}: $${amount} locked for '${task}' sent to ${recipient}`
    });
  }
};

// ── Plugin export ────────────────────────────────────────────────────────────

export const purpleFlealPlugin: Plugin = {
  name: "@purpleflea/plugin-eliza",
  description: "Purple Flea: casino, trading, wallet, domains, faucet, escrow",
  actions: [
    claimFaucetAction,
    getBalanceAction,
    openTradeAction,
    casinoBetAction,
    escrowPayAction
  ],
  evaluators: [],
  providers: [],

  // Auto-claim faucet on agent startup
  async init(runtime: IAgentRuntime) {
    const key = runtime.getSetting("PURPLE_FLEA_API_KEY");
    if (!key) return;
    try {
      const r = await fetch(`${FAUCET}/claim`, {
        method: "POST",
        headers: { "Authorization": `Bearer ${key}` }
      });
      const d = await r.json();
      if (d.success) console.log(`[PurpleFlea] Faucet: +$${d.amount} USDC`);
    } catch (e) {
      console.log("[PurpleFlea] Faucet already claimed or offline");
    }
  }
};

export default purpleFlealPlugin;

{
  "mcpServers": {
    "purple-flea-faucet": {
      "url": "https://faucet.purpleflea.com/mcp",
      "transport": "streamable-http",
      "headers": {
        "Authorization": "Bearer YOUR_PF_API_KEY"
      },
      "tools": ["claim_faucet", "faucet_status"]
    },
    "purple-flea-escrow": {
      "url": "https://escrow.purpleflea.com/mcp",
      "transport": "streamable-http",
      "headers": {
        "Authorization": "Bearer YOUR_PF_API_KEY"
      },
      "tools": ["create_escrow", "release_escrow", "escrow_status"]
    }
  }
}