import { loadLatestState, retrieve } from "../retrieval";
import type { TopicResult } from "../retrieval";

export async function execute(query: string, limit: number, options: { recent?: boolean } = {}): Promise<TopicResult[]> {
  const state = await loadLatestState();
  if (!state) {
    console.error("No saved state found. Is EI_DATA_PATH set correctly?");
    return [];
  }

  const topics = state.human.topics;
  if (topics.length === 0) {
    return [];
  }

  const results = await retrieve(topics, query, limit, options);
  
  return results.map(topic => ({
    id: topic.id,
    name: topic.name,
    description: topic.description,
    category: topic.category,
    sentiment: topic.sentiment,
    sources: topic.sources,
  }));
}