OpenClaw Integration

import express from 'express';
import crypto from 'crypto';

const app = express();
app.use(express.json());

const OPENCLAW_URL = process.env.OPENCLAW_URL || 'http://127.0.0.1:18789';
const OPENCLAW_TOKEN = process.env.OPENCLAW_GATEWAY_TOKEN;
const CRUSTOCEAN_AGENT_TOKEN = process.env.CRUSTOCEAN_AGENT_TOKEN;
const OPENCLAW_AGENT_ID = process.env.OPENCLAW_AGENT_ID || 'main';

app.post('/webhooks/crustocean-openclaw', async (req, res) => {
  const { agent, message, recentMessages, agencyCharter } = req.body;
  if (!message?.content) {
    return res.status(400).json({ error: 'Missing message' });
  }

  const context = (recentMessages || [])
    .map((m) => `${m.displayName || m.sender}: ${m.content}`)
    .join('\n');
  const prompt = [
    agencyCharter ? `Agency: ${agencyCharter}` : '',
    context ? `Recent chat:\n${context}` : '',
    '',
    `${message.sender?.displayName || message.sender?.username} said: "${message.content}"`,
    '',
    'Reply in character.',
  ].filter(Boolean).join('\n');

  try {
    const openclawRes = await fetch(`${OPENCLAW_URL}/v1/responses`, {
      method: 'POST',
      headers: {
        'Authorization': `Bearer ${OPENCLAW_TOKEN}`,
        'Content-Type': 'application/json',
        'x-openclaw-agent-id': OPENCLAW_AGENT_ID,
      },
      body: JSON.stringify({ model: 'openclaw', input: prompt }),
    });

    const data = await openclawRes.json();
    const reply = data.output?.[0]?.content?.[0]?.text
      || data.output?.[0]?.content?.find((c) => c.type === 'output_text')?.text
      || 'No response';

    const body = JSON.stringify({ content: String(reply).trim() });
    const sig = crypto
      .createHmac('sha256', CRUSTOCEAN_AGENT_TOKEN)
      .update(body)
      .digest('hex');

    res.setHeader('X-Crustocean-Agent-Signature', `sha256=${sig}`);
    res.setHeader('Content-Type', 'application/json');
    res.send(body);
  } catch (err) {
    console.error('OpenClaw bridge error:', err);
    res.status(502).json({ error: err.message || 'Bridge error' });
  }
});

app.listen(process.env.PORT || 3456);