<ExtractPrompt>

import { ExtractPrompt } from "../components/extract-prompt";

type ExtractPromptProps = {
  idPrefix: string;
  prompt?: string;            // if non-trivial, used directly (passthrough)
  cached?: CachedPrompt;      // if present, used directly (cache hit)
  output: OutputTarget;       // where the draft lands (use rctfPromptSchema)
  agent: AgentLike | AgentLike[];
  schema?: "rctf" | "prd" | "freeform";  // default "rctf"
  stakes?: "high" | "low";    // resolves the threshold; default "low"
  threshold?: number;         // overrides stakes
  maxTurns?: number;          // default 10
  currentScore?: number | null;          // caller passes ctx.latest(output)?.score
  latestDraft?: RctfPromptOutput | null; // caller passes ctx.latest(output)
  context?: string;
  scorers?: ScorersMap;       // optional async observability scorers
  passthroughId?: string;
};

import {
  ExtractPrompt,
  MarkdownPromptCache,
  rctfPromptSchema,
} from "../components/extract-prompt";

const cache = new MarkdownPromptCache();

const { Workflow, smithers, outputs } = createSmithers({
  input: z.object({
    prompt: z.string().nullable().default(null),
    cacheKey: z.string().nullable().default(null),
    stakes: z.enum(["high", "low"]).default("low"),
  }),
  draft: rctfPromptSchema,
});

export default smithers((ctx) => {
  const cached = ctx.input.cacheKey ? cache.getSync(ctx.input.cacheKey) : undefined;
  const latest = ctx.latest("draft", "my-flow:extract:draft") as RctfPromptOutput | null;

  if (latest?.resolved && ctx.input.cacheKey) {
    cache.setSync(ctx.input.cacheKey, /* ... build CachedPrompt from latest ... */);
  }

  return (
    <Workflow name="my-flow">
      <ExtractPrompt
        idPrefix="my-flow"
        prompt={ctx.input.prompt ?? undefined}
        cached={cached}
        output={outputs.draft}
        agent={agents.smart}
        stakes={ctx.input.stakes}
        currentScore={latest?.score ?? null}
        latestDraft={latest}
      />
    </Workflow>
  );
});