import { Response } from "express";
import { RequestWithAuth } from "./types";
import {
  getDeepResearch,
  getDeepResearchExpiry,
} from "../../lib/deep-research/deep-research-redis";

export async function deepResearchStatusController(
  req: RequestWithAuth<{ jobId: string }, any, any>,
  res: Response,
) {
  const research = await getDeepResearch(req.params.jobId);

  if (!research) {
    return res.status(404).json({
      success: false,
      error: "Deep research job not found",
    });
  }

  return res.status(200).json({
    success: research.status === "failed" ? false : true,
    data: {
      finalAnalysis: research.finalAnalysis,
      sources: research.sources,
      activities: research.activities,
      json: research.json,
      // completedSteps: research.completedSteps,
      // totalSteps: research.totalExpectedSteps,
    },
    error: research?.error ?? undefined,
    expiresAt: (await getDeepResearchExpiry(req.params.jobId)).toISOString(),
    currentDepth: research.currentDepth,
    maxDepth: research.maxDepth,
    status: research.status,
    totalUrls: research.sources.length,
    // DO NOT remove - backwards compatibility
    //@deprecated
    activities: research.activities,
    //@deprecated
    sources: research.sources,
    // summaries: research.summaries,
  });
}