Method add

apps/collector/src/modules/collector/batch-buffer.ts:95–123

(backendId: number, update: TrafficUpdate)

  private logCounter = 0;

  add(backendId: number, update: TrafficUpdate) {
    const minuteKey = toMinuteKey(update.timestampMs);
    const fullChain = update.chains.join(" > ");
    const key = [
      backendId,
      minuteKey,
      update.domain,
      update.ip,
      update.chain,
      fullChain,
      update.rule,
      update.rulePayload,
      update.sourceIP || "",
    ].join(":");
    const existing = this.buffer.get(key);
    const connections = normalizeConnections(update.connections);

    if (existing) {
      existing.upload += update.upload;
      existing.download += update.download;
      existing.connections =
        normalizeConnections(existing.connections) + connections;
      if ((update.timestampMs ?? 0) > (existing.timestampMs ?? 0)) {
        existing.timestampMs = update.timestampMs;
      }
    } else {
      this.buffer.set(key, { ...update, connections });
    }
  }

  addGeoResult(result: GeoIPResult) {
    this.geoQueue.push(result);