Method set

packages/cache/src/service.ts:134–171

* Set a value in cache with automatic JSON serialization and optional TTL * @param key - Cache key to store under * @param value - Value to store * @param ttlMs - Time to live in milliseconds (optional - if omitted, key persists indefinitely) * @returns Result containing void or an error

(key: CacheKey, value: unknown, ttlMs?: number)

   * @returns Result containing void or an error
   */
  async set(key: CacheKey, value: unknown, ttlMs?: number): Promise<Result<void, CacheError>> {
    // Check Redis availability first
    if (!this.isRedisClientReady()) {
      return err({
        code: ErrorCode.RedisConnectionError,
      });
    }

    // Validate key and optional TTL
    const validation = validateInputs([key, ZCacheKey], [ttlMs, ZTtlMsOptional]);
    if (!validation.ok) {
      return validation;
    }

    // Undefined is a caller bug, not a cacheable null.
    if (value === undefined) {
      logger.warn({ key, ttlMs }, "cache.set called with undefined; skipping write");
      return ok(undefined);
    }

    try {
      const serialized = JSON.stringify(value);

      if (ttlMs === undefined) {
        // Set without expiration (persists indefinitely)
        await this.withTimeout(this.redis.set(key, serialized));
      } else {
        // Set with expiration
        await this.withTimeout(this.redis.setEx(key, Math.floor(ttlMs / 1000), serialized));
      }
      return ok(undefined);
    } catch (error) {
      logger.error({ error, key, ttlMs }, "Cache set operation failed");
      return err({
        code: ErrorCode.RedisOperationError,
      });
    }
  }

  /**
   * Delete one or more keys from cache (idempotent)