Store persistente

​

Elegir un store

• Un proceso del bot en un VPS o en un contenedor: SQLiteStore. Sin servidor que mantener, un archivo que respaldar.
• Varios procesos del mismo bot (réplicas), o estado que leen otros servicios: RedisStore. Todas las réplicas deben ver los mismos datos, así que MemoryStore y SQLiteStore no sirven ahí. Si ya tienes PostgreSQL, MySQL/MariaDB o MongoDB, el store correspondiente hace lo mismo.
• Pasa siempre una instancia de store (store: new SQLiteStore({ … })). Un string como store: 'sqlite' solo se acepta por compatibilidad y sigue creando un MemoryStore.

​

MemoryStore

import { Bot, MemoryStore } from '@botmesh/core'

const bot = new Bot({
  provider,
  store: new MemoryStore({
    file: './store.json',     // snapshot opcional
    autoSaveInterval: '1m',   // una duración o ms; 0 desactiva el temporizador
    maxMessagesPerChat: 1000, // el valor por defecto; Infinity quita el tope
  }),
})

​

SQLiteStore

pnpm add @botmesh/sqlite-store better-sqlite3

import { Bot } from '@botmesh/core'
import { BaileysProvider } from '@botmesh/baileys'
import { SQLiteStore } from '@botmesh/sqlite-store'

const bot = new Bot({
  provider: new BaileysProvider({ session: 'mi-bot' }),
  store: new SQLiteStore({ file: './data/bot.db' }),
})

​

Instalar better-sqlite3

​

Opciones

​

Qué almacena

​

Versiones del esquema y actualizaciones

• Respalda el archivo antes de actualizar @botmesh/sqlite-store si puedes necesitar volver atrás.
• Si varios procesos comparten un archivo, para los de la versión antigua antes de que uno nuevo lo abra.

​

Ciclo de vida

​

Flujos persistentes

import { Bot, flow } from '@botmesh/core'
import { SQLiteStore } from '@botmesh/sqlite-store'

const bot = new Bot({ provider, store: new SQLiteStore({ file: './data/bot.db' }) })

bot.use(
  flow('registro')
    .persistent()                 // checkpoint guardado tras cada paso
    .ask('¿Cómo te llamas?', 'name')
    .ask('¿Y tu email?', 'email')
    .say((_ctx, c) => `¡Gracias, ${c.state.name}!`),
)

​

RedisStore

pnpm add @botmesh/redis-store redis

import { Bot } from '@botmesh/core'
import { RedisStore } from '@botmesh/redis-store'

const bot = new Bot({
  provider,
  store: new RedisStore({ url: process.env.REDIS_URL, prefix: 'mybot', sessionTtl: '7d' }),
})

​

PostgreSQL, MySQL y MongoDB

pnpm add @botmesh/postgres-store pg      # PostgreSQL
pnpm add @botmesh/mysql-store mysql2     # MySQL 8.x o MariaDB
pnpm add @botmesh/mongo-store mongodb    # MongoDB (driver 6.x o 7.x)

import { PostgresStore } from '@botmesh/postgres-store'
import { MysqlStore } from '@botmesh/mysql-store'
import { MongoStore } from '@botmesh/mongo-store'

const store = new PostgresStore({ connectionString: process.env.DATABASE_URL, tablePrefix: 'mybot_' })
// o: new MysqlStore({ uri: process.env.MYSQL_URL, tablePrefix: 'mybot_' })
// o: new MongoStore({ url: process.env.MONGO_URL, dbName: 'mybot' })

const bot = new Bot({ provider, store, scheduler: { store: store.schedules() } })

​

Tablas de datos de usuario

​

Escribir tu propio store

import type { MessageRef } from '@botmesh/core'
import type { IStore, StoredMessage } from '@botmesh/core/spi'

class MyStore implements IStore {
  async start(): Promise<void> { /* conectar */ }
  async stop(): Promise<void> { /* desconectar */ }
  async saveMessage(msg: StoredMessage): Promise<void> { /* … */ }
  async getMessage(ref: MessageRef): Promise<StoredMessage | undefined> { /* … */ }
  // …el resto de métodos obligatorios de IStore
}

• upsertChat / upsertContact hacen merge superficial sobre el registro guardado. Un campo propio con valor undefined borra ese campo, así que un upsert parcial debe omitir lo que no conoce. El bot ya lo hace: un mensaje sin nombre visible nunca borra el guardado.
• deleteChat borra también el log de mensajes de ese chat.
• getMessagesByChat(chatId, limit) devuelve los limit mensajes más recientes, del más antiguo al más nuevo (por defecto 50). Un limit de 0 o menos no devuelve nada, una fracción se redondea hacia arriba e Infinity devuelve todo el log. Los stores persistentes ordenan por timestamp, así que volver a guardar un mensaje con otro timestamp lo mueve; MemoryStore lo deja en la posición de su primer guardado.
• saveMessage ignora un mensaje sin ref.id o sin chatId (los providers mandan ref.id: '' cuando no tienen un id estable), y getMessage de esa ref resuelve undefined. Volver a guardar un id reemplaza el mensaje.
• maxMessagesPerChat es opcional en los stores persistentes. Rechaza un tope negativo o decimal con un RangeError.
• setUserData rechaza con un TypeError un valor que no es JSON (undefined) y no escribe nada.
• Las filas de mensajes se indexan con messageKey(ref) (de @botmesh/core/spi): {chatId}:{id} con % y : escapados en cada parte (%25, %3A), para que los ids con : (los chat ids whatsapp:+1… de Twilio) nunca choquen. Las filas escritas con la clave antigua sin escapar (legacyMessageKey(ref)) deben seguir leyéndose y borrándose, comprobando que el ref.id y el ref.chatId guardados son los del mensaje pedido, y al volver a guardarlas pasan a la clave nueva.

• Datos de usuario (getUserData, setUserData, deleteUserData, listUserData, purgeExpiredUserData): sin ellos, ctx.user rechaza con UNSUPPORTED_STORE. Compruébalos con test-utils/user-data-conformance.ts.
• Cursores (getCursor/setCursor): además persisten las marcas de WELCOME y el índice de handoff.
• Checkpoints condicionales (setCheckpointIf/clearCheckpointIf): necesarios para un relevo seguro entre réplicas. Sin ellos, el bot avisa en el log cuando la coordinación está activa.

​

Docker