ditto/src/cron.ts

import * as eventsDB from '@/db/events.ts';
import { cron } from '@/deps.ts';
import { Time } from '@/utils/time.ts';

/** Clean up old remote events. */
async function cleanupEvents() {
  console.log('Cleaning up old remote events...');

  const [result] = await eventsDB.deleteFilters([{
    until: Math.floor((Date.now() - Time.days(7)) / 1000),
    local: false,
  }]);

  console.log(`Cleaned up ${result?.numDeletedRows ?? 0} old remote events.`);
}

await cleanupEvents();

cron.every15Minute(cleanupEvents);