/**
 * Task xử lý mỗi dòng CSV
 */
export const handleCSVRow = task({
  id: "handle-csv-row",
  run: async (row: CSVRow) => {
    logger.info("Handling CSV row", { row });
    const result = await processRow(row);
    // Cập nhật thông tin tổng đã xử lý ở parent task
    metadata.parent.increment("totalProcessed", 1);
    // Cập nhật metadata của task hiện tại
    metadata.set("result", result);
    return { result };
  },
});

export function CSVProgress({ runId, accessToken }: { runId: string; accessToken: string }) {
  const { run } = useRealtimeRun<typeof csvProcessor>(runId, { accessToken });
  const processed = run?.metadata.get("totalProcessed") ?? 0;
  const total = run?.metadata.get("total") ?? 1;
  return <span>{Math.round((processed / total) * 100)}%</span>;
}

const publicToken = await auth.createPublicToken({
  scopes: {
    read: { runs: ["run_1234", "run_5678"] }, // Token chỉ được phép đọc các run cụ thể
  },
});