hctv/apps/web/src/lib/instrumentation/syncStreamKeys.ts

import { prisma, getRedisConnection } from '@hctv/db';
import { setCacheEntryCount, trackWebJob } from '../metrics';

export default async function syncStreamKeys() {
  console.log('Syncing stream keys to Redis...');
  try {
    await trackWebJob('sync_stream_keys', async () => {
      const keys = await prisma.streamKey.findMany({
        include: {
          channel: true,
        },
      });

      if (keys.length === 0) {
        setCacheEntryCount('stream_keys', 0);
        console.log('No stream keys found to sync.');
        return;
      }

      const redis = getRedisConnection();
      const pipeline = redis.pipeline();

      let syncedKeyCount = 0;
      for (const key of keys) {
        if (key.channel && key.channel.name) {
          pipeline.set(`streamKey:${key.channel.name}`, key.key);
          syncedKeyCount += 1;
        }
      }

      await pipeline.exec();
      setCacheEntryCount('stream_keys', syncedKeyCount);
      console.log(`Synced ${syncedKeyCount} stream keys to Redis`);
    });
  } catch (error) {
    console.error('Failed to sync stream keys to Redis:', error);
  }
}