A workspace,
defined in code.

9const supportConnector = connectorFromFile(
10  "./connectors/supportdesk.connector.ts"
11);
12const supportAccount = defineAuthProfile({
13  slug: "support-account", connector: supportConnector,
14  authKind: "oauth_account",
15});
16const support = defineConnection({
17  slug: "support", connector: supportConnector,
18  authProfile: supportAccount,
19  feeds: [{
20    feed: "tickets", name: "Enterprise tickets",
21    config: { queue: "enterprise" },
22    schedule: "*/15 * * * *", // Optional collection cadence
23  }],
24});

55        sync: async (ctx) => {
56          const page = await supportApi.changes({
57            queue: ctx.config.queue, after: ctx.checkpoint?.after,
58            credentials: ctx.credentials,
59          });
60          await ctx.commit(page.tickets.map(ticket => ({
61            origin_id: `tickets:${ctx.feedId}:${ticket.id}`,
62            origin_type: "ticket", title: ticket.title,
63            payload_text: ticket.body,
64            metadata: { account_domain: ticket.verifiedAccountDomain },
65            occurred_at: new Date(ticket.updatedAt),
66            automation_signals: [{
67              event_type: "ticket.updated", label: ticket.title,
68              input_text: ticket.body, resource_ref: ticket.id,
69              resource_type: "ticket",
70            }],
71          })), page.checkpoint);
72          return { status: page.more ? "more" : "complete" };
73        },

7export const accountHealth = (agent: Agent, support: Connection) =>
8  defineAutomation({
9    slug: "account-health", agent, skills: ["account-health"],
10    prompt: "Assess account risk; preserve evidence and summarize changes.",
11    triggers: [
12      every("0 9 * * 1-5", { timezone: "Europe/London" }),
13      on("demo.support", "ticket.updated", {
14        connection: support, execution: "window",
15      }),
16    ],
17    sources: {
18      tickets: "SELECT id, payload_text, metadata FROM events WHERE origin_type = 'ticket' AND connector_key = 'demo.support'",
19      accounts: context("SELECT id, name, metadata FROM entities WHERE entity_type = 'company'"),
20    },
21    outputs: {
22      accounts: { entity: company, key: ["domain"] },
23      summaries: { event: "summary", key: ["account_domain"] },
24      observations: { event: "observation" },
25    },
26  });

4export const company = defineEntityType({
5  key: "company", name: "Company",
6  required: ["domain", "risk"],
7  properties: {
8    domain: { type: "string" },
9    risk: { type: "string", enum: ["healthy", "at_risk"] },
10  },
11  eventKinds: {
12    summary: { description: "Current account assessment with evidence." },
13    observation: { description: "A material change in account risk." },
14  },
15});
16export const person = defineEntityType({ key: "person", name: "Person" });
17export const ownerOf = defineRelationshipType({
18  key: "account-owner-of", name: "Account owner of",
19  rules: [{ source: person, target: company }],
20});

1---
2name: account-health
3description: Maintain evidence-backed account health.
4---
5
6# Account health
7Read the triggering tickets and company context; use feeds.readMany for fresh detail.
8Resolve account_domain from the provider-verified domain; never match names alone.
9Return accounts, summaries and observations arrays; omit unchanged observations.
10Each accounts row contains domain and risk (healthy or at_risk).
11Each summary/observation has title, explicit entity_ids and content citing evidence IDs.
12Set summary metadata.account_domain to the verified domain for stable identity.
13Preserve useful evidence and unresolved questions; avoid copying whole threads.
14Respect entity write policy and human-owned fields. Inspect pending approvals.
15
16# Provider actions
17Discover add_note with operations.listAvailable; check its target and input schema.
18Request only an allowed escalation via operations.execute when follow-up is needed.
19Use a stable idempotency key: account domain + ticket ID + action + revision.
20When policy requires review, report pending_approval and obtain get_approval review UI.
21Wait for approval or rejection; inspect operations.getRun for completed or failed.
22Pending or approved is never proof that the provider action completed.

2import { defineView, useScope, useQuery, tool } from "@lobu/views";
3type Assessment = { title: string; payload_text: string };
4export const view = defineView({
5  key: "account-health",
6  attach: [{ type: "company", surface: "record", placement: "tab" }],
7});
8export default function AccountHealth() {
9  const { entity } = useScope();
10  const read = useQuery<{ content: Assessment[] }>(
11    typeof entity === "number" ? tool("read_knowledge", {
12      entity_id: entity, semantic_type: "summary", sort_by: "date", limit: 1,
13    }) : null
14  );
15  const assessment = read.data?.content[0];
16  const body = read.loading ? "Loading…" : assessment?.payload_text ?? "No summary yet.";
17  return <article>
18    <h2>{assessment?.title ?? "Account health"}</h2>
19    {read.error ? <p role="alert">{read.error}</p> : <p>{body}</p>}
20    {read.truncated && <p>Partial result. Open the source record.</p>}
21    <button onClick={read.refetch} disabled={read.loading}>Refresh</button>
22  </article>;
23}