feat(landing): per-use-case snippet tabs, connector logo wall, drop asciinema, simplify nav

AGENTS.md

@@ -14,6 +14,7 @@
 - TypeScript sources in `packages/*/src`, tests in `packages/*/src/__tests__`.
 - Always prefer `bun` over `npm`.
 - When fixing unused-parameter errors, delete the parameter rather than prefixing with `_`.
+- Landing page copy (`packages/landing`): never use em dashes (`—`) in user-facing text. Rephrase with commas, periods, or restructure the sentence.
 
 ### Submodules
 `packages/owletto` is a submodule of `lobu-ai/owletto`. Push the submodule change to a reachable branch first, then bump the pointer in the parent — an unreachable SHA breaks production cloning.

examples/finance/models/reactions/reconciliation-monitor.reaction.ts

@@ -1,40 +1,50 @@
 /**
  * Reaction for the `reconciliation-monitor` watcher.
  *
- * Persists any variance flagged during the daily 6am sweep as a durable
- * `variance_flag` event tied to the affected account. Downstream agents
- * (close-of-month rollup, audit prep) consume these events instead of
- * re-extracting variances from the raw transaction stream.
+ * Persists variance events when unreconciled transactions or new anomalies
+ * are detected during the daily reconciliation pass.
  */
-import type { ReactionContext } from "@lobu/connector-sdk";
+import type { ReactionClient, ReactionContext } from "@lobu/connector-sdk";
 
 interface ReconciliationData {
-  variances?: Array<{
-    account: string;
-    amount: number;
-    direction: "over" | "under";
-    reason: string;
-  }>;
-  unreconciled_count?: number;
+  unreconciled_count: number;
+  new_variances: string[];
+  approaching_deadlines: string[];
+  payment_risks?: string[];
 }
 
-export default async (ctx: ReactionContext, client: any): Promise<void> => {
+export default async (
+  ctx: ReactionContext,
+  client: ReactionClient
+): Promise<void> => {
   const data = ctx.extracted_data as ReconciliationData;
-  const variances = data.variances ?? [];
-  if (variances.length === 0) return;
 
-  for (const v of variances) {
-    await client.knowledge.save({
-      entity_ids: ctx.entities.map((e) => e.id),
-      content: `Variance ${v.direction} on ${v.account}: ${v.amount} — ${v.reason}`,
-      semantic_type: "variance_flag",
-      metadata: {
-        account: v.account,
-        amount: v.amount,
-        direction: v.direction,
-        window_id: ctx.window.id,
-        unreconciled_count: data.unreconciled_count ?? null,
-      },
-    });
+  const hasIssues =
+    data.unreconciled_count > 0 ||
+    (data.new_variances?.length ?? 0) > 0 ||
+    (data.approaching_deadlines?.length ?? 0) > 0;
+
+  if (!hasIssues) return;
+
+  const parts: string[] = [];
+  if (data.unreconciled_count > 0) {
+    parts.push(`${data.unreconciled_count} unreconciled transactions`);
+  }
+  if (data.new_variances?.length) {
+    parts.push(`Variances: ${data.new_variances.join("; ")}`);
   }
+  if (data.approaching_deadlines?.length) {
+    parts.push(`Deadlines: ${data.approaching_deadlines.join("; ")}`);
+  }
+
+  await client.knowledge.save({
+    entity_ids: ctx.entities.map((e) => e.id),
+    content: parts.join("\n"),
+    semantic_type: "reconciliation_alert",
+    metadata: {
+      window_id: ctx.window.id,
+      unreconciled_count: data.unreconciled_count,
+      variance_count: data.new_variances?.length ?? 0,
+    },
+  });
 };

examples/lobu-crm/README.md

@@ -0,0 +1,37 @@
+# lobu-crm — Reference example
+
+A funnel CRM agent that tracks GitHub stars, X mentions, HN posts, and demo-form submissions.
+Use this as a starting point for new projects — it shows every Lobu concept in one place.
+
+## Structure
+
+```
+lobu-crm/
+├── lobu.toml                              # Agent + memory config
+├── connectors/
+│   ├── github.yaml                        # Built-in connector (just config)
+│   ├── x.yaml                             # Built-in connector
+│   ├── hackernews.yaml                    # Built-in connector
+│   ├── changelog-watch.yaml               # Built-in connector (website)
+│   ├── funnel-form.yaml                   # Custom connector manifest
+│   └── funnel-form.connector.ts           # Custom connector implementation
+├── models/
+│   ├── schema.yaml                        # Entities, relationships, watchers
+│   └── reactions/
+│       ├── inbound-triage.reaction.ts     # Runs after watcher extraction
+│       └── funnel-digest.reaction.ts      # Runs after watcher extraction
+└── agents/crm/
+    ├── SOUL.md                            # Agent personality
+    ├── IDENTITY.md                        # Agent identity
+    ├── USER.md                            # User context
+    └── skills/crm-ops/SKILL.md            # Agent skill
+```
+
+## Key files to read
+
+| File | What it shows |
+|------|--------------|
+| `lobu.toml` | Agent config, providers, network allowlist |
+| `models/schema.yaml` | Entity definitions + watcher cron + extraction schema |
+| `connectors/funnel-form.connector.ts` | Custom connector with typed checkpoint + config |
+| `models/reactions/inbound-triage.reaction.ts` | Reaction script with typed `ReactionClient` |

examples/lobu-crm/connectors/funnel-form.connector.ts

@@ -1,12 +1,28 @@
-// biome-ignore-all format: stays compact for the landing-page code panel
-import { ConnectorRuntime, type SyncContext } from "@lobu/connector-sdk";
+import {
+  ConnectorRuntime,
+  type SyncContext,
+  type SyncResult,
+} from "@lobu/connector-sdk";
+
+interface FunnelCheckpoint {
+  seen_ids: string[];
+}
+
+interface FunnelConfig {
+  endpoint: string;
+}
 
 /**
  * Funnel-form connector — polls a small JSON API (`config.endpoint` returns
  * `{ submissions: [...] }`) and emits one event per new submission. Dedup
  * via a rolling checkpoint of seen IDs. Auto-discovered by `lobu apply`.
+ *
+ * Demonstrates: ConnectorRuntime<C, F> with typed checkpoint + config.
  */
-export default class FunnelFormConnector extends ConnectorRuntime {
+export default class FunnelFormConnector extends ConnectorRuntime<
+  FunnelCheckpoint,
+  FunnelConfig
+> {
   readonly definition = {
     key: "funnel-form",
     name: "Funnel form",
@@ -15,21 +31,28 @@ export default class FunnelFormConnector extends ConnectorRuntime {
     feeds: { submissions: { key: "submissions", name: "Form submissions" } },
   };
 
-  async sync(ctx: SyncContext) {
-    const seen = new Set<string>((ctx.checkpoint as any)?.seen_ids ?? []);
-    const subs: any[] = (await (await fetch(String(ctx.config.endpoint))).json()).submissions ?? [];
+  async sync(
+    ctx: SyncContext<FunnelCheckpoint, FunnelConfig>
+  ): Promise<SyncResult<FunnelCheckpoint>> {
+    const seen = new Set<string>(ctx.checkpoint?.seen_ids ?? []);
+    const subs: any[] =
+      (await (await fetch(ctx.config.endpoint)).json()).submissions ?? [];
     const fresh = subs.filter((s) => s?.id && !seen.has(s.id));
     return {
       events: fresh.map((s) => ({
         origin_id: s.id,
         origin_type: "form_submission",
-        title: s.company ? `Demo request — ${s.company}` : `Demo request — ${s.name ?? s.email ?? s.id}`,
+        title: s.company
+          ? `Demo request — ${s.company}`
+          : `Demo request — ${s.name ?? s.email ?? s.id}`,
         payload_text: s.message ?? "",
         author_name: s.name,
         occurred_at: s.submitted_at ? new Date(s.submitted_at) : new Date(),
         metadata: { company: s.company, email: s.email },
       })),
-      checkpoint: { seen_ids: [...seen, ...fresh.map((s) => s.id)].slice(-1000) },
+      checkpoint: {
+        seen_ids: [...seen, ...fresh.map((s) => s.id)].slice(-1000),
+      },
     };
   }
 

examples/lobu-crm/models/reactions/inbound-triage.reaction.ts

@@ -2,11 +2,10 @@
  * Reaction for the `inbound-triage` watcher.
  *
  * Fires every 2h after the watcher LLM extracts new and enriched leads from
- * GitHub/X/HN signals. The script writes a `lead_interaction` event per
- * recommended action so the next digest can count them — the watcher itself
- * already creates the `lead` rows, so we don't duplicate that here.
+ * GitHub/X/HN signals. Persists a `lead_interaction` event per run so the
+ * next digest can count them.
  */
-import type { ReactionContext } from "@lobu/connector-sdk";
+import type { ReactionClient, ReactionContext } from "@lobu/connector-sdk";
 
 interface TriageData {
   new_leads?: Array<{
@@ -19,10 +18,11 @@ interface TriageData {
   notable?: boolean;
 }
 
-export default async (ctx: ReactionContext, client: any): Promise<void> => {
+export default async (
+  ctx: ReactionContext,
+  client: ReactionClient
+): Promise<void> => {
   const data = ctx.extracted_data as TriageData;
-  // Nothing notable → nothing to persist. The watcher's prompt is explicit
-  // about not manufacturing noise; we mirror that here.
   if (!data.notable) return;
 
   const actions = data.recommended_actions ?? [];

examples/office-bot/agents/food-ordering/skills/deliveroo-order/SKILL.md

@@ -10,12 +10,16 @@ network:
     - playwright.azureedge.net
     - cdn.playwright.dev
   judge:
-    - deliveroo.co.uk
-    - .deliveroo.co.uk
-    - deliveroo.com
-    - .deliveroo.com
+    - domain: deliveroo.co.uk
+      judge: deliveroo
+    - domain: .deliveroo.co.uk
+      judge: deliveroo
+    - domain: deliveroo.com
+      judge: deliveroo
+    - domain: .deliveroo.com
+      judge: deliveroo
 judges:
-  default: >
+  deliveroo: >
     Allow GET requests that read restaurant listings, menus, item details, and
     the current basket. Allow POST/PUT requests whose effect is limited to
     building or modifying a basket / group order (add, remove, change quantity;

examples/office-bot/lobu.toml

@@ -50,13 +50,16 @@ allowed = [
 ]
 # Deliveroo goes through the egress judge — reading menus and assembling a
 # basket is fine; touching payment, addresses, or the account profile is not.
+# Each domain names the "deliveroo" policy below.
 judge = [
-  "deliveroo.co.uk", ".deliveroo.co.uk",
-  "deliveroo.com", ".deliveroo.com",
+  { domain = "deliveroo.co.uk", judge = "deliveroo" },
+  { domain = ".deliveroo.co.uk", judge = "deliveroo" },
+  { domain = "deliveroo.com", judge = "deliveroo" },
+  { domain = ".deliveroo.com", judge = "deliveroo" },
 ]
 
 [agents.food-ordering.network.judges]
-default = """
+deliveroo = """
 Allow GET requests that read restaurant listings, menus, item details, and the
 current basket. Allow POST/PUT requests whose effect is limited to building or
 modifying a basket / group order (adding, removing, changing quantity of items;

examples/sales/models/reactions/account-health-monitor.reaction.ts

@@ -5,7 +5,7 @@
  * persist a `health_change` event so the renewal-risk view + weekly digest
  * have a stable record without re-extracting from the CRM stream.
  */
-import type { ReactionContext } from "@lobu/connector-sdk";
+import type { ReactionClient, ReactionContext } from "@lobu/connector-sdk";
 
 interface HealthData {
   account_changes?: Array<{
@@ -18,11 +18,12 @@ interface HealthData {
 
 const RISK_ORDER = { low: 0, medium: 1, high: 2 } as const;
 
-export default async (ctx: ReactionContext, client: any): Promise<void> => {
+export default async (
+  ctx: ReactionContext,
+  client: ReactionClient
+): Promise<void> => {
   const data = ctx.extracted_data as HealthData;
   const changes = data.account_changes ?? [];
-  // Only persist *worsening* transitions — improvements are visible in the
-  // CRM stream and don't need a durable flag.
   const escalations = changes.filter(
     (c) => RISK_ORDER[c.current_risk] > RISK_ORDER[c.previous_risk]
   );