Roadmap

Vision del proyecto

Velo nace como un ejercicio educativo de bajo nivel: construir desde cero, sin dependencias, un almacen de datos en memoria accesible por red con el protocolo RESP. El objetivo no es reemplazar soluciones de produccion, sino entender exactamente como funcionan por dentro: TCP, parsing binario, Clean Architecture, TTL, pub/sub, y eventual distribucion.

Fases de desarrollo

Diagrama — Roadmap de Velo: Fase 1 completada, Fases 2-6 planificadas

Fase 1 — Strings y Servidor Completada v0.1.0

La primera fase establece la base tecnica completa: protocolo, arquitectura, transporte y las operaciones mas fundamentales de cualquier almacen clave-valor.

Fase 2 — Listas Pendiente

Las listas son la estructura de datos mas versatil: colas, stacks, logs de actividad, historial de eventos. Se implementaran como arrays de JavaScript vinculados a una KeyEntry con type: TipoDato.LIST.

Fase 3 — Hashes y Sets Pendiente

Hashes

Objetos de campo/valor almacenados como Map<string, string>. Utiles para representar entidades como usuarios o sesiones.

Sets

Colecciones de strings unicos sin orden. Implementados como Set<string> de JavaScript.

Fase 4 — Persistencia Pendiente

Sin persistencia, todos los datos mueren con el proceso. Hay dos estrategias clasicas:

Fase 5 — Pub/Sub Pendiente

El sistema de publicacion y suscripcion permite que los clientes reciban mensajes en tiempo real sin hacer polling. Ideal para notificaciones, colas de eventos y comunicacion entre servicios.

La implementacion usara un PubSubBroker como singleton que mantiene un Map<canal, Set<socket>>. Cuando llega un PUBLISH, el broker itera el Set y escribe a cada socket activo.

Fase 6 — Cluster Pendiente

La fase final introduce distribucion real: multiples nodos, tolerancia a fallos y escalabilidad horizontal.

Como agregar un nuevo comando

Agregar un comando en Velo es un proceso de 3 pasos. La arquitectura asegura que cada paso sea aislado y no afecte al resto del sistema.

import { RespSerializer  } from '../../../infrastructure/protocol/RespSerializer.js';
import { KeyEntry, TipoDato } from '../../../domain/entities/KeyEntry.js';

export class LpushCommand {
  /** @type {string} */
  nombre = 'LPUSH';

  /**
   * Inserta valores al inicio de una lista.
   * @param {import('../../../domain/ports/IDataStore.js').IDataStore} store
   * @param {string[]} args
   * @param {number} db
   */
  execute(store, args, db) {
    if (args.length < 2) {
      return RespSerializer.error('ERR wrong number of arguments for LPUSH');
    }

    const [clave, ...valores] = args;
    let entrada = store.get(db, clave);

    if (!entrada) {
      entrada = new KeyEntry([], TipoDato.LIST);
    } else if (entrada.type !== TipoDato.LIST) {
      return RespSerializer.error('WRONGTYPE Operation against a key holding the wrong kind of value');
    }

    // LPUSH inserta al inicio (unshift)
    entrada.value.unshift(...valores.reverse());
    store.set(db, clave, entrada);

    return RespSerializer.integer(entrada.value.length);
  }
}

import { LpushCommand } from './usecases/phase2/lists/LpushCommand.js';

export class CommandRegistry {
  constructor() {
    this._handlers = new Map();
    this._registrar();
  }

  _registrar() {
    // ... comandos existentes ...

    // Fase 2 — Listas
    const listaComandos = [new LpushCommand()];
    for (const cmd of listaComandos) {
      this._handlers.set(cmd.nombre.toUpperCase(), cmd);
    }
  }
}

velo[0]> LPUSH tareas "leer docs" "escribir tests" "hacer PR"
:3
velo[0]> LRANGE tareas 0 -1
1) "hacer PR"
2) "escribir tests"
3) "leer docs"

Convenciones del proyecto