Mémoires appartenant à une source

Utilisez la surface de cycle de vie lorsque les mémoires reflètent des enregistrements dont votre base de données est propriétaire — lignes de CRM, champs de profil, tickets. Contrairement au save en append-only, ces mémoires ont une identité durable et un historique de versions, de sorte que les corrections et suppressions issues de la source de vérité s’appliquent exactement une fois, dans l’ordre, quelle que soit la qualité de la livraison.

Le modèle d’identité

Une mémoire appartenant à une source est identifiée par (endUserId, source, externalId). version doit augmenter chaque fois que l’enregistrement source change.

await conare.memories.upsertSource({
  endUserId: "u_123",
  source: "crm-profile",
  externalId: "profile_123",
  version: 7,
  occurredAt: "2026-07-16T10:30:00Z",
  content: "User prefers smaller islands.",
  idempotencyKey: "profile_123:v7",
});

Garanties de livraison

Les mutations sont synchrones, et les règles sont simples :

Réessayer la même version + payload renvoie le même reçu durable. Renvoyer après un crash est sûr — c’est ça, la stratégie de reprise après crash.
Un payload différent pour une version existante renvoie 409. Les versions sont immuables.
Une version plus ancienne retardée renvoie 409 et n’écrase jamais un contenu plus récent ni ne ressuscite une mémoire supprimée.

Les suppressions suivent le même versioning :

await conare.memories.deleteSource({
  endUserId: "u_123",
  source: "crm-profile",
  externalId: "profile_123",
  version: 8,
  occurredAt: "2026-07-17T09:00:00Z",
  idempotencyKey: "profile_123:v8",
});

La suppression est durable : les retries convergent vers le reçu original, et les upserts retardés avec des versions inférieures ne peuvent pas recréer la mémoire.

Amorçage avec un outbox

Miroir en masse d’enregistrements existants via lifecycleBatch — jusqu’à 100 éléments et 1 Mio de contenu agrégé par appel. Il n’y a pas de tâche d’import côté serveur ; un outbox côté client qui renvoie après un crash constitue toute la stratégie de reprise :

const result = await conare.memories.lifecycleBatch({
  endUserId: "u_123",
  items: [{
    source: "crm-profile",
    externalId: "profile_123",
    version: 7,
    occurredAt: "2026-07-16T10:30:00Z",
    content: "User prefers smaller islands.",
  }],
});

for (const [index, item] of result.items.entries()) {
  if (item.success || item.code === "stale_source_version") {
    outbox.markDone(index); // that version (or newer) is durable
  } else {
    outbox.scheduleRetry(index, item.code);
  }
}

result.success signifie seulement « le lot a été traité » — vérifiez toujours les résultats par élément. Marquez une ligne comme terminée sur success ou stale_source_version (les deux signifient que la version est déjà durable), puis envoyez le lot suivant.

Relecture

GET /api/v1/memories/{externalId} renvoie la mémoire et son dernier reçu appliqué — utile pour vérifier la convergence après une migration.

​Le modèle d’identité

​Garanties de livraison

​Amorçage avec un outbox

​Relecture

Le modèle d’identité

Garanties de livraison

Amorçage avec un outbox

Relecture