import { connect, transform, deliver } from "./system";
import { createWorkflow, schedule } from "./automation";

const sources = ["spreadsheets", "tasks", "data"];
const outputs = ["website", "system", "dashboard", "automation"];

export async function buildSolution(context) {
  const connection = await connect(context.workspace);
  const records = await connection.read(sources);

  const normalized = records.map((record) => ({
    id: record.id,
    name: record.name.trim(),
    status: record.status ?? "pending",
    updatedAt: new Date(record.updatedAt),
  }));

  const workflow = createWorkflow({
    input: normalized,
    steps: [validate, transform, synchronize],
    onComplete: (result) => deliver(result, outputs),
  });

  return workflow.run({ workspace: context.workspace });
}

function validate(records) {
  return records.filter(({ id, name }) => id && name);
}

import { connect, transform, deliver } from "./system";
import { createWorkflow, schedule } from "./automation";

const sources = ["spreadsheets", "tasks", "data"];
const outputs = ["website", "system", "dashboard", "automation"];

export async function buildSolution(context) {
  const connection = await connect(context.workspace);
  const records = await connection.read(sources);

  const normalized = records.map((record) => ({
    id: record.id,
    name: record.name.trim(),
    status: record.status ?? "pending",
    updatedAt: new Date(record.updatedAt),
  }));

  const workflow = createWorkflow({
    input: normalized,
    steps: [validate, transform, synchronize],
    onComplete: (result) => deliver(result, outputs),
  });

  return workflow.run({ workspace: context.workspace });
}

function validate(records) {
  return records.filter(({ id, name }) => id && name);
}