Method add

packages/db/src/buffers/bot-buffer.ts:27–44

(event: IClickhouseBotEvent)

  }

  async add(event: IClickhouseBotEvent) {
    return this.timeAdd(async () => {
      try {
        const result = await this.redis
          .multi()
          .rpush(this.redisKey, JSON.stringify(event))
          .llen(this.redisKey)
          .exec();

        const bufferLength = (result?.[1]?.[1] as number) ?? 0;
        if (bufferLength >= this.batchSize) {
          await this.tryFlush({ trigger: 'add' });
        }
      } catch (error) {
        this.logger.error({ err: error }, 'Failed to add bot event');
      }
    });
  }

  async processBuffer() {
    const lrangeStart = performance.now();