Памʼять, керована джерелом

Використовуйте поверхню життєвого циклу, коли памʼять дзеркалить записи, якими володіє ваша база — рядки CRM, поля профілю, тикети. На відміну від append-only save, ці памʼяті мають довговічну ідентичність та історію версій, тож виправлення та видалення з джерела істини застосовуються рівно один раз, у порядку, як би безлад не був у постачанні.

Модель ідентичності

Памʼять, керована джерелом, ідентифікується за (endUserId, source, externalId). version має збільшуватися щоразу, коли запис у джерелі змінюється.

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",
});

Гарантії доставки

Мутації синхронні, а правила прості:

Повтор тієї ж версії + payload повертає ту саму довговічну квитанцію. Повторна відправка після крашу безпечна — це і є історія відновлення після крашу.
Інший payload для наявної версії повертає 409. Версії незмінні.
Затримана старіша версія повертає 409 і ніколи не перезаписує новіший контент, ані не воскрешає видалену памʼять.

Видалення підпорядковується тому ж версіонуванню:

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",
});

Видалення довговічне: ретраї сходяться до оригінальної квитанції, а затримані upsert-и з нижчими версіями не можуть відтворити памʼять.

Бутстрап через outbox

Масово дзеркальте наявні записи через lifecycleBatch — до 100 елементів і 1 МіБ сукупного контенту на виклик. Немає серверного імпорт-джобу; клієнтський outbox, який повторює після крашу, — це вся історія відновлення:

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 означає лише «пакет опрацьовано» — завжди перевіряйте результати попозиційно. Позначайте рядок як готовий за success або stale_source_version (обидва означають, що версія вже довговічна), потім надсилайте наступний батч.

Читання назад

GET /api/v1/memories/{externalId} повертає памʼять і її останню застосовану квитанцію — корисно для верифікації збіжності після міграції.

​Модель ідентичності

​Гарантії доставки

​Бутстрап через outbox

​Читання назад

Модель ідентичності

Гарантії доставки

Бутстрап через outbox

Читання назад