import { MySQLDatabases, sql } from '@simplyq/database/mysql';
import { NotFoundError } from '@simplyq/errors';
import { Queues } from '@simplyq/queues';

import { VideoAdded, VideoProcessed } from '../events';
import { videos, videoSummaries } from '../db/pinkPilgrim/schema';


@EventHandler(VideoAdded)
class HandleVideoAdded {
  @Inject
  private readonly youtubeAdapter: YoutubeAdapter;

  @Inject
  private readonly llmAdapter: LLMAdapter;

  public async handle(event: VideoAdded, c: Context): Promise<void> {
    const { videoId } = event;

    const video = await MySQLDatabases.PinkPilgrimDB.execute(sql`SELECT * FROM videos WHERE id = ${videoId}`);

    for await (const comment of this.youtubeAdapter.iterateAllComments(videoId)) {
      // Process the comments
    }

    ...

    // Run LLM on summary
    const summaryLLMOutput = await this.llmAdapter.run(summaryLLMInput);

    // Save summary to database
    await MySQLDatabases.PinkPilgrimDB.insert(videoSummaries).values({
      video_id: videoId,
      text: summaryLLMOutput,
    });

    // Publish video processed event
    await Queues.Default.publish(
      new VideoProcessed({
        videoId: videoId,
        accountId: video.accountId,
        summaryId: videoSummaries.id,
        summary: summaryLLMOutput,
      })
    );
  }
}