Make your AI agents
multiplayer.

export default async (_ctx, client) => {
  return client.connections.list({ connector_key: "google.gmail" });
};

import {
  ConnectorRuntime, type RuntimeConnectorDefinition,
  type SyncCredentials,
} from "@lobu/connector-sdk";

type Checkpoint = { after?: string };
type Options = Record<string, never>;
type Usage = {
  id: string; customer: string; week: string;
  activeSeats: number; updatedAt: string;
};
// Application-specific Postgres adapter; implementation and auth omitted.
// It returns a stable cursor and only rows after the last checkpoint.
declare const usageDb: {
  changes(input: { after?: string; credentials: SyncCredentials | null }):
    Promise<{ rows: Usage[]; checkpoint: Checkpoint; more: boolean }>;
};

export default class AcmeUsage extends ConnectorRuntime<Checkpoint, Options> {
  readonly definition: RuntimeConnectorDefinition<Checkpoint, Options> = {
    key: "acme.usage", name: "Customer usage", version: "1.0.0",
    feeds: {
      usage: {
        key: "usage", name: "Weekly active seats",
        sync: async (ctx) => {
          const page = await usageDb.changes({
            after: ctx.checkpoint?.after, credentials: ctx.credentials,
          });
          await ctx.commit(page.rows.map((row) => ({
            origin_id: "usage:" + ctx.feedId + ":" + row.id,
            origin_type: "customer_usage",
            occurred_at: new Date(row.updatedAt),
            title: row.customer + " usage",
            payload_text: row.activeSeats + " active seats · " + row.week,
          })), page.checkpoint);
          return { status: page.more ? "more" : "complete" };
        },
      },
    },
  };
}

import { defineEntityType, defineRelationshipType } from "@lobu/cli/config";

export const customer = defineEntityType({
  key: "customer", name: "Customer",
  properties: {
    domain: { type: "string" },
    accountOwner: { type: "string" },
    renewalDate: { type: "string" },
    openIssue: { type: "string" },
  },
});
export const contact = defineEntityType({ key: "contact", name: "Contact" });
export const contactFor = defineRelationshipType({
  key: "contact-for", name: "Contact For",
  description: "A person is a contact for a customer.",
  rules: [{ source: contact, target: customer }],
});

export default async (_ctx, client) => {
  return client.query(`
    SELECT title, payload_text
    FROM events
    WHERE title = 'Meridian renewal'
    ORDER BY occurred_at DESC
    LIMIT 10
  `);
};

export default async (_ctx, client) => {
  const workspace = await client.org("acme-co");
  const saved = await workspace.knowledge.save({
    title: "Meridian renewal decision",
    author: "Maya Chen",
    semantic_type: "decision",
    content: "I’ll review Meridian. Alex should check SEC-142 before I contact the customer.",
    idempotency_key: "meridian-renewal-decision:v1",
  });
  return workspace.knowledge.read({ content_ids: [saved.id] });
};

export default async (_ctx, client) => {
  const workspace = await client.org("acme-co");
  return workspace.query(`
    SELECT title, payload_text
    FROM events
    WHERE title = 'Meridian renewal decision'
    ORDER BY occurred_at DESC
    LIMIT 1
  `);
};

export default async (_ctx, client) => {
  return client.automations.create({
    slug: "renewal-follow-up",
    name: "Renewal follow-up",
    managed_agent_id: "customer-success",
    prompt: "Draft a follow-up for the account owner. Nothing is sent until someone approves it.",
    triggers: [
      { kind: "schedule", cron: "0 9 * * 1-5" },
      { kind: "event", source: "workspace", event_types: ["observation"] },
    ],
  });
};

export default async (_ctx, client) => {
  const workspace = await client.org("acme-co");
  const { automations } = await workspace.automations.list({});
  const followUp = automations.find(item => item.slug === "renewal-follow-up");
  if (!followUp) throw new Error("Create the renewal follow-up first.");
  return workspace.automations.createVersion({
    automation_id: followUp.id,
    prompt: "Draft a follow-up for the account owner. Include the account owner and open issue. Do not predict churn. Nothing is sent until someone approves it.",
  });
};