`agents/twitter-agent/server.js`

78 lines
/**
 * Norma Twitter/X Agent — Port 9804
 *
 * Discovers, posts, replies, and monitors Twitter/X for advocacy topics.
 * Skills: discover, post, reply, monitor, report
 */

require('dotenv').config();
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 = 9804;
const AGENT_NAME = 'twitter-agent';

const { app, start, scheduler } = createAgentServer({
  name: AGENT_NAME,
  port: PORT,
  skills: {
    discover,
    post,
    reply,
    monitor,
    report,
  },
  cronJobs: [
    {
      name: 'monitor-hashtags',
      schedule: '*/30 * * * *', // every 30 minutes
      fn: async () => {
        console.log(`[${AGENT_NAME}] Cron: monitoring hashtags...`);
        try {
          const result = await monitor({ max_results: 10, push_to_pulse: true });
          console.log(`[${AGENT_NAME}] Cron monitor complete: ${result.total_tweets} tweets found`);
        } catch (err) {
          console.error(`[${AGENT_NAME}] Cron monitor error:`, err.message);
        }
      },
    },
    {
      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`);
        } catch (err) {
          console.error(`[${AGENT_NAME}] Cron report error:`, err.message);
        }
      },
    },
    {
      name: 'discover-trending',
      schedule: '15 */3 * * *', // every 3 hours at :15
      fn: async () => {
        console.log(`[${AGENT_NAME}] Cron: discovering trending topics...`);
        try {
          const result = await discover({
            max_results: 20,
            push_to_pulse: true,
          });
          console.log(`[${AGENT_NAME}] Cron discover complete: ${result.count} tweets, ${result.trending.length} trending`);
        } catch (err) {
          console.error(`[${AGENT_NAME}] Cron discover error:`, err.message);
        }
      },
    },
  ],
});

start();