b3nd — digital spellcraft. A data substrate for apps built with AI.

$ npx jsr add @bandeira-tech/b3nd-core @bandeira-tech/b3nd-save @bandeira-tech/b3nd-move

import { connection, Rig } from "@bandeira-tech/b3nd-core";
import { LocalStorageStore } from "@bandeira-tech/b3nd-save/localstorage";
import { passThroughRecord, SaveClient } from "@bandeira-tech/b3nd-save/clients";
import { TYPE_TAGS } from "@bandeira-tech/b3nd-save/entity";
import { httpClient } from "@bandeira-tech/b3nd-move/http";

const notes = {
  name: "notes",
  fields: [{ name: "text", type: [TYPE_TAGS.STRING] }],
};

const save = new SaveClient(passThroughRecord, notes, new LocalStorageStore());
await save.init();

const rig = new Rig({
  routes: {
    receive: [connection(save, ["local://**"])],
    read:    [connection(save, ["local://**"])],
    send:    [connection(httpClient("https://api.example.com"), ["api://**"])],
  },
});

await rig.receive([["local://notes/hello", { text: "hi" }]]);

$ deno add jsr:@bandeira-tech/b3nd-core jsr:@bandeira-tech/b3nd-save jsr:@bandeira-tech/b3nd-move

import { connection, FunctionalClient, Rig } from "@bandeira-tech/b3nd-core";
import { MemoryStore } from "@bandeira-tech/b3nd-save/memory";
import { passThroughRecord, SaveClient } from "@bandeira-tech/b3nd-save/clients";
import { TYPE_TAGS } from "@bandeira-tech/b3nd-save/entity";
import { httpService } from "@bandeira-tech/b3nd-move/http";
import { mcpService }  from "@bandeira-tech/b3nd-move/mcp";

const messages = {
  name: "messages",
  fields: [{ name: "payload", type: [TYPE_TAGS.JSON] }],
};

const save = new SaveClient(passThroughRecord, messages, new MemoryStore());
await save.init();

const log = new FunctionalClient({
  receive: (msgs) => {
    for (const [uri, payload] of msgs) console.log("received:", uri, payload);
    return Promise.resolve(msgs.map(() => ({ accepted: true })));
  },
});

const rig = new Rig({
  routes: {
    receive: [
      connection(log,  ["**"]),
      connection(save, ["**"]),
    ],
    read: [connection(save, ["**"])],
  },
});

httpService(rig).listen({ port: 8080 });
mcpService(rig).serve();

$ deno add jsr:@bandeira-tech/b3nd-core jsr:@bandeira-tech/b3nd-move

import { connection, Rig } from "@bandeira-tech/b3nd-core";
import { mcpClient } from "@bandeira-tech/b3nd-move/mcp";

const upstream = mcpClient("https://network.example");

const rig = new Rig({
  routes: {
    observe: [connection(upstream, ["event://**"])],
    read:    [connection(upstream, ["event://**"])],
  },
});

const ac = new AbortController();
for await (const uris of rig.observe(["event://**"], ac.signal)) {
  const events = await rig.read(uris);
  for (const [uri, payload] of events) {
    await fetch("https://hooks.slack.com/...", {
      method: "POST",
      body: JSON.stringify({ text: `${uri}: ${JSON.stringify(payload)}` }),
    });
  }
}