`agents/twitch-agent/server.js`

79 lines
/**
 * Norma Twitch Agent — Port 9805
 *
 * Discovers relevant Twitch streams, monitors chat for keyword matches,
 * posts/replies in channels related to advocacy and financial literacy.
 * Skills: discover, post, reply, monitor, report
 */

const { createAgentServer } = require('../shared/agent-base');

// Import skills
const discover = require('./skills/discover');
const post = require('./skills/post');
const reply = require('./skills/reply');
const monitor = require('./skills/monitor');
const report = require('./skills/report');

const PORT = 9805;
const AGENT_NAME = 'twitch-agent';

const { app, start, scheduler } = createAgentServer({
  name: AGENT_NAME,
  port: PORT,
  skills: {
    discover,
    post,
    reply,
    monitor,
    report,
  },
  cronJobs: [
    {
      name: 'report-to-pulse',
      schedule: '0 */4 * * *', // every 4 hours
      fn: async () => {
        console.log(`[${AGENT_NAME}] Cron: reporting to Pulse...`);
        try {
          const result = await report({ hours_back: 4 });
          console.log(`[${AGENT_NAME}] Cron report complete: ${result.chat.channelsMonitored} channels monitored`);
        } catch (err) {
          console.error(`[${AGENT_NAME}] Cron report error:`, err.message);
        }
      },
    },
    {
      name: 'discover-streams',
      schedule: '0 */2 * * *', // every 2 hours
      fn: async () => {
        console.log(`[${AGENT_NAME}] Cron: discovering relevant streams...`);
        try {
          const queries = ['nonprofit advocacy', 'financial literacy', 'education policy', 'civic engagement', 'community organizing'];
          const randomQuery = queries[Math.floor(Math.random() * queries.length)];
          const result = await discover({ query: randomQuery, max_results: 15 });
          console.log(`[${AGENT_NAME}] Cron discover complete: ${result.count} streams found for "${randomQuery}"`);
        } catch (err) {
          console.error(`[${AGENT_NAME}] Cron discover error:`, err.message);
        }
      },
    },
    {
      name: 'monitor-channels',
      schedule: '*/30 * * * *', // every 30 minutes
      fn: async () => {
        console.log(`[${AGENT_NAME}] Cron: monitoring channels...`);
        try {
          const result = await monitor({ check_db: true, categories: ['Just Chatting'] });
          console.log(
            `[${AGENT_NAME}] Cron monitor complete: ${result.channels_joined.length} channels, ${result.recent_keyword_messages.length} keyword messages`
          );
        } catch (err) {
          console.error(`[${AGENT_NAME}] Cron monitor error:`, err.message);
        }
      },
    },
  ],
});

start();