Data Retention

// analytics-sync.ts - Run this daily via cron
import { CronJob } from 'cron';

const syncAnalytics = async () => {
  // 1. Fetch all teams
  const teams = await yourDatabase.teams.findAll();

  for (const team of teams) {
    // 2. For each social account, fetch current analytics
    for (const account of team.socialAccounts) {
      const analytics = await bundlesocial.analytics.getSocialAccountAnalytics({
        teamId: team.id,
        socialAccountId: account.id,
      });

      // 3. Store with timestamp for historical tracking
      await yourDatabase.analyticsHistory.upsert({
        socialAccountId: account.id,
        date: new Date().toISOString().split('T')[0], // YYYY-MM-DD
        ...analytics,
        fetchedAt: new Date(),
      });
    }

    // 4. Fetch post analytics too
    const posts = await bundlesocial.analytics.getBulkPostAnalytics({
      teamId: team.id,
    });

    for (const post of posts.data) {
      await yourDatabase.postAnalyticsHistory.upsert({
        postId: post.id,
        date: new Date().toISOString().split('T')[0],
        ...post.analytics,
        fetchedAt: new Date(),
      });
    }
  }
};

// Run daily at 2 AM UTC
new CronJob('0 2 * * *', syncAnalytics, null, true, 'UTC');