Method cleanup

packages/db/src/buffers/session-buffer.ts:182–207

* Remove a closed session from Redis. Atomically gated on `sessionId` via * Lua: if a different session now occupies the `(projectId, deviceId)` * slot (because a boundary already overwrote it with a new session), the * call is a no-op — the new session still needs its blob and sorted-set

({
    projectId,
    deviceId,
    sessionId,
    profileId,
  }: {
    projectId: string;
    deviceId: string;
    sessionId: string;
    profileId?: string | null;
  })

   * fails (worker crash, network partition).
   */
  async cleanup({
    projectId,
    deviceId,
    sessionId,
    profileId,
  }: {
    projectId: string;
    deviceId: string;
    sessionId: string;
    profileId?: string | null;
  }): Promise<void> {
    const pointerKey =
      profileId && profileId !== deviceId
        ? profileIndexKey(projectId, profileId)
        : '';

    await this.redis.eval(
      CLEANUP_LUA,
      3,
      sessionKey(projectId, deviceId),
      wallclockSetKey(projectId),
      pointerKey,
      sessionId,
      deviceId
    );
  }

  /**
   * Extend an in-flight session with a new event. Returns the updated