Feedback

import { callable, workflow, z } from "@croft/sdk";

/**
 * Feedback — the write engine behind the CSAT feedback app.
 *
 * Every entity lives in an append-only record stream as an event log: each
 * append is a full snapshot of the row, and the newest row per `id` wins.
 * Removals append a tombstone (`_op: "gone"`) rather than erasing history.
 * The artifact pages read current state with a `row_number()` window query.
 *
 * `_op` is "live"/"gone" and never the word "delete", because `records.query`
 * rejects COPY EXPORT INSTALL LOAD ATTACH CREATE INSERT UPDATE DELETE PRAGMA
 * as whole words anywhere in the SQL text — string literals included.
 *
 * The appends are written out one stream at a time, rather than through a
 * computed stream name, so the analyzer can name every stream this workflow
 * touches and an install plan can list them.
 */

const Input = z.object({
  entity: z
    .enum(["responses"])
    .describe("Which record stream to write"),
  action: z
    .enum(["save", "remove"])
    .describe("save writes a full snapshot of the row; remove appends a tombstone"),
  id: z
    .string()
    .describe("Stable id for the row. Reuse it to update; omit on create to mint one.")
    .optional(),
  data: z
    .record(z.string(), z.any())
    .describe(
      "Flat field map. responses{rating,comment,name,contact,channel,reference,submitted_on}. rating is a whole number from 1 to 5.",
    )
    .optional(),
});

export default workflow(
  "feedback",
  {
    trigger: callable({
      description:
        "Record a customer satisfaction response: a 1 to 5 rating with an optional comment, or update or remove an existing one.",
      input: Input,
    }),
    connections: [],
    description:
      "Write engine for the CSAT feedback app: a public form appends a 1 to 5 rating with an optional comment, and the private dashboard averages them.",
  },
  async (ctx) => {
    const { entity, action, id, data } = ctx.input;

    const row = await ctx.step("Build row", () => {
      const rowId = id ?? `${entity.slice(0, 3)}_${Math.random().toString(36).slice(2, 10)}`;
      const fields = action === "remove" ? {} : (data ?? {});
      const rating = Number((fields as Record<string, unknown>).rating ?? 0);
      return {
        ...fields,
        ...(action === "remove"
          ? {}
          : { rating: Number.isFinite(rating) ? Math.min(5, Math.max(1, Math.round(rating))) : null }),
        id: rowId,
        _op: action === "remove" ? "gone" : "live",
        _ts: new Date().toISOString(),
      };
    });

    if (entity === "responses") {
      await ctx.records.append("responses", [row]);
    }

    return { id: row.id, entity, action, ts: row._ts };
  },
);