`agents/facebook-agent/server.js`

75 lines
/**
 * Norma Facebook Agent — Port 9808
 *
 * Posts content to a Facebook Page via Meta Graph API.
 * Skills: discover, post, monitor, report
 *
 * Runs in simulation mode until FB_PAGE_ID and FB_PAGE_ACCESS_TOKEN are set.
 */

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

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

const PORT = 9808;
const AGENT_NAME = 'facebook-agent';

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

start();