element-call/src/otel/OTelCallTransceiverMediaStreamSpan.ts

/*
Copyright 2023, 2024 New Vector Ltd.

SPDX-License-Identifier: AGPL-3.0-only OR LicenseRef-Element-Commercial
Please see LICENSE in the repository root for full details.
*/

import { type Span } from "@opentelemetry/api";
import {
  type TrackStats,
  type TransceiverStats,
} from "matrix-js-sdk/lib/webrtc/stats/statsReport";

import { type ElementCallOpenTelemetry } from "./otel";
import { OTelCallAbstractMediaStreamSpan } from "./OTelCallAbstractMediaStreamSpan";

export class OTelCallTransceiverMediaStreamSpan extends OTelCallAbstractMediaStreamSpan {
  private readonly prev: {
    direction: string;
    currentDirection: string;
  };

  public constructor(
    protected readonly oTel: ElementCallOpenTelemetry,
    protected readonly callSpan: Span,
    stats: TransceiverStats,
  ) {
    super(oTel, callSpan, `matrix.call.transceiver.${stats.mid}`);
    this.span.setAttribute("transceiver.mid", stats.mid);

    this.prev = {
      direction: stats.direction,
      currentDirection: stats.currentDirection,
    };
    this.span.addEvent("matrix.call.transceiver.initState", this.prev);
  }

  public update(stats: TransceiverStats): void {
    if (this.prev.currentDirection !== stats.currentDirection) {
      this.span.addEvent("matrix.call.transceiver.currentDirection", {
        currentDirection: stats.currentDirection,
      });
      this.prev.currentDirection = stats.currentDirection;
    }
    if (this.prev.direction !== stats.direction) {
      this.span.addEvent("matrix.call.transceiver.direction", {
        direction: stats.direction,
      });
      this.prev.direction = stats.direction;
    }

    const trackStats: TrackStats[] = [];
    if (stats.sender) {
      trackStats.push(stats.sender);
    }
    if (stats.receiver) {
      trackStats.push(stats.receiver);
    }
    this.upsertTrackSpans(trackStats);
  }
}