import 'package:drift/drift.dart';
import '../app_database.dart';
import '../tables.dart';

part 'insight_dao.g.dart';

@DriftAccessor(tables: [LlmInsights])
class InsightDao extends DatabaseAccessor<AppDatabase> with _$InsightDaoMixin {
  InsightDao(super.db);

  Future<LlmInsight?> getCached(String promptHash) => (select(llmInsights)
        ..where((t) => t.promptHash.equals(promptHash))
        ..limit(1))
      .getSingleOrNull();

  Future<void> upsertInsight(LlmInsightsCompanion insight) =>
      into(llmInsights).insertOnConflictUpdate(insight);

  // Purge cached insights older than 7 days
  Future<void> purgeStale() {
    final cutoff = DateTime.now().subtract(const Duration(days: 7));
    return (delete(llmInsights)
          ..where((t) => t.generatedAt.isSmallerThanValue(cutoff)))
        .go();
  }
}