process()

in conversational-webgpu/src/play-worklet.js [21:66]

• 38 lines of code
• 7 McCabe index (conditional complexity)

    process(inputs, outputs) {
      const channel = outputs[0][0];
      if (!channel) return true;

      const numSamples = channel.length;
      let outputIndex = 0;

      if (this.hadData && this.bufferQueue.length === 0) {
        this.port.postMessage({ type: "playback_ended" });
        this.hadData = false;
      }

      while (outputIndex < numSamples) {
        if (this.bufferQueue.length > 0) {
          const currentChunk = this.bufferQueue[0];
          const remainingSamples =
            currentChunk.length - this.currentChunkOffset;
          const samplesToCopy = Math.min(
            remainingSamples,
            numSamples - outputIndex,
          );

          channel.set(
            currentChunk.subarray(
              this.currentChunkOffset,
              this.currentChunkOffset + samplesToCopy,
            ),
            outputIndex,
          );

          this.currentChunkOffset += samplesToCopy;
          outputIndex += samplesToCopy;

          // Remove the chunk if fully consumed.
          if (this.currentChunkOffset >= currentChunk.length) {
            this.bufferQueue.shift();
            this.currentChunkOffset = 0;
          }
        } else {
          // If no data is available, fill the rest of the buffer with silence.
          channel.fill(0, outputIndex);
          outputIndex = numSamples;
        }
      }
      return true;
    }