Give a coded agent memory with Rail

from caura_rail import MemoryScope, Rail, RestMemoryStore, Visibility

scope = MemoryScope(agent_id="ops-writer", fleet_id="ops-tutorial", visibility=Visibility.TEAM)

with RestMemoryStore.from_env() as store:
    rail = Rail(store, scope)
    with rail.turn("Remember: Our plan is to migrate billing to Postgres in Q4.") as turn:
        # Your model call goes here; turn.context.text is prompt-ready context.
        turn.reply = "Noted the Q4 billing migration."
    for write in turn.writes:
        print(write.status, write.id)   # written <id>; deduplicated <id> if it already existed

import { MemoryScope, Rail, RestMemoryStore } from "@caura/rail";

const scope = new MemoryScope({ agentId: "ops-writer", fleetId: "ops-tutorial", visibility: "scope_team" });
const rail = new Rail({ store: RestMemoryStore.fromEnv(process.env), scope });

const turn = await rail.turn("Remember: Our plan is to migrate billing to Postgres in Q4.", async () => {
  // Your model call goes here; the second callback argument is the context.
  return "Noted the Q4 billing migration.";
});
for (const write of turn.writes) console.log(write.status, write.id); // written <id>; deduplicated on a rerun

from caura_rail import MemoryScope, Rail, RestMemoryStore, Visibility

team = MemoryScope(agent_id="ops-writer", fleet_id="ops-tutorial", visibility=Visibility.TEAM)
with RestMemoryStore.from_env() as store:
    reader = Rail(store, team.for_agent("ops-reader"))
    context = reader.recall("When are we moving billing off the old database?")
    assert any("Postgres" in fact.content for fact in context.facts), context.facts
    print(context.text)

import assert from "node:assert/strict";
import { MemoryScope, Rail, RestMemoryStore } from "@caura/rail";

const team = new MemoryScope({ agentId: "ops-writer", fleetId: "ops-tutorial", visibility: "scope_team" });
const reader = new Rail({ store: RestMemoryStore.fromEnv(process.env), scope: team.forAgent("ops-reader") });
const context = await reader.recall("When are we moving billing off the old database?");
assert.ok(context.facts.some(f => f.content.includes("Postgres")), JSON.stringify(context.facts));
console.log(context.text);

from caura_rail import MemoryScope, Rail, RestMemoryStore


def decisions_only(message: str, reply: str) -> list[str]:
    return [line.strip() for line in message.splitlines() if line.lower().startswith("decision:")]


with RestMemoryStore.from_env() as store:
    rail = Rail(store, MemoryScope(agent_id="ops-writer", fleet_id="ops-tutorial"), extractor=decisions_only)
    with rail.turn("Decision: billing cutover happens on the first Sunday of December.") as turn:
        turn.reply = "Recorded."
    print([w.status for w in turn.writes])   # ['written'] or ['deduplicated']

import { MemoryScope, Rail, RestMemoryStore } from "@caura/rail";

const decisionsOnly = (message: string, _reply: string): string[] =>
  message.split("\n").map(l => l.trim()).filter(l => l.toLowerCase().startsWith("decision:"));

const rail = new Rail({
  store: RestMemoryStore.fromEnv(process.env),
  scope: new MemoryScope({ agentId: "ops-writer", fleetId: "ops-tutorial" }),
  extractor: decisionsOnly,
});
const turn = await rail.turn("Decision: billing cutover happens on the first Sunday of December.", () => "Recorded.");
console.log(turn.writes.map(w => w.status)); // ['written'] or ['deduplicated']