feat(landing): dev-focused rebuild — pinned examples, animated architecture, real cast

config/biome.config.json

@@ -32,7 +32,8 @@
       "!**/apps/**",
       "!**/scripts/lobu/**",
       "!**/benchmarks/**",
-      "!**/skills/**"
+      "!**/skills/**",
+      "!**/packages/landing/public/**"
     ]
   },
   "formatter": {

examples/agent-community/connectors/discourse-posts.connector.ts

@@ -0,0 +1,33 @@
+// biome-ignore-all format: stays compact for the landing-page code panel
+import { ConnectorRuntime, type SyncContext } from "@lobu/connector-sdk";
+
+export default class DiscoursePostsConnector extends ConnectorRuntime {
+  readonly definition = {
+    key: "discourse-posts",
+    name: "Discourse posts",
+    version: "1.0.0",
+    authSchema: { methods: [{ type: "env" as const, fields: [{ name: "api_key" }] }] },
+    feeds: { posts: { key: "posts", name: "Forum posts" } },
+  };
+
+  async sync(ctx: SyncContext) {
+    const cursor = (ctx.checkpoint as any)?.last_post_id ?? 0;
+    const r = await fetch(`${ctx.config.base_url}/posts.json?before=${cursor + 50}`);
+    const posts: any[] = ((await r.json() as any).latest_posts ?? []).filter((p: any) => p.id > cursor).sort((a: any, b: any) => a.id - b.id);
+    return {
+      events: posts.map((p) => ({
+        origin_id: String(p.id),
+        origin_type: "post_created",
+        title: p.topic_title ?? `Post by ${p.username}`,
+        author_name: p.username,
+        source_url: `${ctx.config.base_url}/t/${p.topic_slug}/${p.topic_id}/${p.id}`,
+        occurred_at: new Date(p.created_at),
+      })),
+      checkpoint: { last_post_id: posts.at(-1)?.id ?? cursor },
+    };
+  }
+
+  async execute() {
+    return { success: false, error: "no actions" };
+  }
+}

examples/delivery/connectors/shopify-orders.connector.ts

@@ -0,0 +1,32 @@
+// biome-ignore-all format: stays compact for the landing-page code panel
+import { ConnectorRuntime, type SyncContext } from "@lobu/connector-sdk";
+
+export default class ShopifyOrdersConnector extends ConnectorRuntime {
+  readonly definition = {
+    key: "shopify-orders",
+    name: "Shopify orders",
+    version: "1.0.0",
+    authSchema: { methods: [{ type: "env" as const, fields: [{ name: "access_token" }] }] },
+    feeds: { orders: { key: "orders", name: "Order updates" } },
+  };
+
+  async sync(ctx: SyncContext) {
+    const since = (ctx.checkpoint as any)?.updated_at_min ?? "2000-01-01T00:00:00Z";
+    const r = await fetch(`https://${ctx.config.shop}/admin/api/2024-10/orders.json?status=any&updated_at_min=${encodeURIComponent(since)}&limit=100`);
+    const orders: any[] = ((await r.json() as any).orders ?? []).sort((a: any, b: any) => new Date(a.updated_at).getTime() - new Date(b.updated_at).getTime());
+    return {
+      events: orders.map((o) => ({
+        origin_id: `${o.id}:${o.updated_at}`,
+        origin_type: "order_updated",
+        title: `Order ${o.name} — ${o.fulfillment_status ?? "unfulfilled"}`,
+        source_url: `https://${ctx.config.shop}/admin/orders/${o.id}`,
+        occurred_at: new Date(o.updated_at),
+      })),
+      checkpoint: { updated_at_min: orders.at(-1)?.updated_at ?? since },
+    };
+  }
+
+  async execute() {
+    return { success: false, error: "no actions" };
+  }
+}

examples/ecommerce/connectors/stripe-charges.connector.ts

@@ -0,0 +1,39 @@
+// biome-ignore-all format: stays compact for the landing-page code panel
+import { ConnectorRuntime, type ConnectorDefinition, type EventEnvelope, type SyncContext, type SyncResult } from "@lobu/connector-sdk";
+
+interface StripeCharge { id: string; amount: number; currency: string; created: number; refunded: boolean }
+interface Checkpoint { last_created: number }
+
+export default class StripeChargesConnector extends ConnectorRuntime {
+  readonly definition: ConnectorDefinition = {
+    key: "stripe-charges",
+    name: "Stripe charges",
+    version: "1.0.0",
+    // Stripe secret key collected per connection; exposed to sync() as ctx.config.secret_key.
+    authSchema: { methods: [{ type: "env_keys", fields: [{ key: "secret_key", label: "Stripe secret key", secret: true, required: true }] }] },
+    feeds: { charges: { key: "charges", name: "Charges" } },
+  };
+
+  async sync(ctx: SyncContext): Promise<SyncResult> {
+    const cursor = ((ctx.checkpoint ?? {}) as Partial<Checkpoint>).last_created ?? 0;
+    const secretKey = String(ctx.config.secret_key ?? "");
+    const r = await fetch(`https://api.stripe.com/v1/charges?limit=100&created[gt]=${cursor}`, {
+      headers: { Authorization: `Bearer ${secretKey}` },
+    });
+    if (!r.ok) throw new Error(`Stripe ${r.status}: ${await r.text()}`);
+    const data = (((await r.json()) as { data?: StripeCharge[] }).data ?? []).sort((a, b) => a.created - b.created);
+    const events: EventEnvelope[] = data.map((c) => ({
+      origin_id: c.refunded ? `${c.id}:refund` : c.id,
+      origin_type: c.refunded ? "charge_refunded" : "charge_succeeded",
+      title: `${c.refunded ? "Refund" : "Charge"} — ${(c.amount / 100).toFixed(2)} ${c.currency.toUpperCase()}`,
+      payload_text: `${c.refunded ? "Refund" : "Charge"} of ${(c.amount / 100).toFixed(2)} ${c.currency.toUpperCase()} (stripe id ${c.id})`,
+      source_url: `https://dashboard.stripe.com/payments/${c.id}`,
+      occurred_at: new Date(c.created * 1000),
+    }));
+    return { events, checkpoint: { last_created: data.at(-1)?.created ?? cursor } satisfies Checkpoint };
+  }
+
+  async execute() {
+    return { success: false, error: "no actions" };
+  }
+}

examples/finance/connectors/quickbooks-transactions.connector.ts

@@ -0,0 +1,32 @@
+// biome-ignore-all format: stays compact for the landing-page code panel
+import { ConnectorRuntime, type SyncContext } from "@lobu/connector-sdk";
+
+export default class QuickBooksTransactionsConnector extends ConnectorRuntime {
+  readonly definition = {
+    key: "quickbooks-transactions",
+    name: "QuickBooks transactions",
+    version: "1.0.0",
+    authSchema: { methods: [{ type: "oauth" as const, provider: "intuit" }] },
+    feeds: { transactions: { key: "transactions", name: "Posted transactions" } },
+  };
+
+  async sync(ctx: SyncContext) {
+    const since = (ctx.checkpoint as any)?.last_txn_date ?? "1970-01-01";
+    const q = `SELECT * FROM Transaction WHERE TxnDate > '${since}' ORDERBY TxnDate ASC MAXRESULTS 500`;
+    const r = await fetch(`https://quickbooks.api.intuit.com/v3/company/${ctx.config.realm_id}/query?query=${encodeURIComponent(q)}`);
+    const txns: any[] = (await r.json() as any).QueryResponse?.Transaction ?? [];
+    return {
+      events: txns.map((t) => ({
+        origin_id: t.Id,
+        origin_type: "transaction_posted",
+        title: `${t.AccountRef?.name ?? "Bank"} — $${t.Amount.toFixed(2)}`,
+        occurred_at: new Date(`${t.TxnDate}T00:00:00Z`),
+      })),
+      checkpoint: { last_txn_date: txns.at(-1)?.TxnDate ?? since },
+    };
+  }
+
+  async execute() {
+    return { success: false, error: "no actions" };
+  }
+}

examples/leadership/connectors/linear-cycles.connector.ts

@@ -0,0 +1,34 @@
+// biome-ignore-all format: stays compact for the landing-page code panel
+import { ConnectorRuntime, type SyncContext } from "@lobu/connector-sdk";
+
+const QUERY = `query($t:ID!,$a:DateTimeOrDuration!){issues(first:100,filter:{team:{id:{eq:$t}},updatedAt:{gt:$a},cycle:{isActive:{eq:true}}},orderBy:updatedAt){nodes{id identifier title url updatedAt state{name}}}}`;
+
+export default class LinearCyclesConnector extends ConnectorRuntime {
+  readonly definition = {
+    key: "linear-cycles",
+    name: "Linear cycles",
+    version: "1.0.0",
+    authSchema: { methods: [{ type: "oauth" as const, provider: "linear" }] },
+    feeds: { cycle_issues: { key: "cycle_issues", name: "Cycle issues" } },
+  };
+
+  async sync(ctx: SyncContext) {
+    const since = (ctx.checkpoint as any)?.updated_at ?? "2000-01-01T00:00:00Z";
+    const r = await fetch("https://api.linear.app/graphql", { method: "POST", headers: { "Content-Type": "application/json" }, body: JSON.stringify({ query: QUERY, variables: { t: ctx.config.team_id, a: since } }) });
+    const issues: any[] = ((await r.json()) as any).data?.issues?.nodes ?? [];
+    return {
+      events: issues.map((i) => ({
+        origin_id: `${i.id}:${i.state.name}`,
+        origin_type: "issue_state_changed",
+        title: `${i.identifier} ${i.title} → ${i.state.name}`,
+        source_url: i.url,
+        occurred_at: new Date(i.updatedAt),
+      })),
+      checkpoint: { updated_at: issues.at(-1)?.updatedAt ?? since },
+    };
+  }
+
+  async execute() {
+    return { success: false, error: "no actions" };
+  }
+}

examples/legal/connectors/docusign-envelopes.connector.ts

@@ -0,0 +1,32 @@
+// biome-ignore-all format: stays compact for the landing-page code panel
+import { ConnectorRuntime, type SyncContext } from "@lobu/connector-sdk";
+
+export default class DocuSignEnvelopesConnector extends ConnectorRuntime {
+  readonly definition = {
+    key: "docusign-envelopes",
+    name: "DocuSign envelopes",
+    version: "1.0.0",
+    authSchema: { methods: [{ type: "oauth" as const, provider: "docusign" }] },
+    feeds: { envelopes: { key: "envelopes", name: "Envelope status changes" } },
+  };
+
+  async sync(ctx: SyncContext) {
+    const since = (ctx.checkpoint as any)?.last_status_changed ?? "2000-01-01T00:00:00Z";
+    const base = String(ctx.config.base_path ?? "https://www.docusign.net/restapi").replace(/\/$/, "");
+    const r = await fetch(`${base}/v2.1/accounts/${ctx.config.account_id}/envelopes?from_date=${encodeURIComponent(since)}&count=100`);
+    const envelopes: any[] = ((await r.json() as any).envelopes ?? []).sort((a: any, b: any) => new Date(a.statusChangedDateTime).getTime() - new Date(b.statusChangedDateTime).getTime());
+    return {
+      events: envelopes.map((e) => ({
+        origin_id: `${e.envelopeId}:${e.status}`,
+        origin_type: "envelope_status_changed",
+        title: `${e.emailSubject ?? e.envelopeId} → ${e.status}`,
+        occurred_at: new Date(e.statusChangedDateTime),
+      })),
+      checkpoint: { last_status_changed: envelopes.at(-1)?.statusChangedDateTime ?? since },
+    };
+  }
+
+  async execute() {
+    return { success: false, error: "no actions" };
+  }
+}