feat(transcriber): Limit google transcribe sessions to the length of the cost interval.

This will avoid errors like: OUT_OF_RANGE: Exceeded maximum allowed stream duration of 305 seconds.

Author: damencho

src/main/java/org/jitsi/jigasi/transcription/GoogleCloudTranscriptionService.java

@@ -553,6 +553,18 @@ synchronized void increment(long ms)
             summedTime += ms;
         }
 
+        /**
+         * Check whether adding a certain duration to the already sent time
+         * would exceed the length of a cost interval.
+         * @param durationInMs the duration to check.
+         * @return true if the summed time plus the given duration
+         * would exceed the length of a cost interval, false otherwise.
+         */
+        boolean aboveCostInterval(long durationInMs)
+        {
+            return summedTime + durationInMs >= INTERVAL_LENGTH_MS;
+        }
+
         /**
          * Increments the Google Cloud Speech API requests counter.
          */
@@ -723,6 +735,12 @@ void sentRequest(TranscriptionRequest request)
             // ByteString
             byte[] audio = request.getAudio();
             ByteString audioBytes = ByteString.copyFrom(audio);
+            long durationInMs = request.getDurationInMs();
+
+            if (costLogger.aboveCostInterval(durationInMs))
+            {
+                this.terminateCurrentSession();
+            }
 
             synchronized(currentRequestObserverLock)
             {
@@ -735,7 +753,7 @@ void sentRequest(TranscriptionRequest request)
                         = createObserver(getRecognitionConfig(request));
                 }
 
-                costLogger.increment(request.getDurationInMs());
+                costLogger.increment(durationInMs);
                 costLogger.incrementRequestsCounter();
 
                 currentRequestObserver.onNext(