start cleanning

.github/workflows/main.yml

@@ -152,4 +152,5 @@ jobs:
           kubectl apply -f ia-worker-service.yaml
           kubectl apply -f slimfaas-deployment.yaml
           kubectl apply -f slimfaas-ingress.yaml
-          kubectl apply -f redis-deployment.yaml
+          kubectl apply -f redis-deployment.yaml
+          kubectl apply -f hpas.yaml

README.md

@@ -43,7 +43,9 @@ docker-compose up
 # Roadmap
 - [infrastructure] Configure a URL with HTTPS on Kubernetes
 - [ia-worker] Set up GPU on Kubernetes
-- [infrastructure] For scaling, add keda to scale from GPU consumption or queue length
+- [infrastructure] For scaling, add keda to scale from GPU consumption or queue length or wait Slimfaas to add this feature
+- Set up Redis with high availability
+- Set up Slimfaas with high availability
 - Add monitoring
 - Add alerting
 - Add logging

deploy/kubernetes/hpas.yaml

@@ -0,0 +1,32 @@
+apiVersion: autoscaling/v2
+kind: HorizontalPodAutoscaler
+metadata:
+  name: ia-worker-hpa
+  namespace: transcriptor
+spec:
+  scaleTargetRef:
+    apiVersion: apps/v1
+    kind: Deployment
+    name: ia-worker
+  minReplicas: 1
+  maxReplicas: 5
+  metrics:
+    - type: Resource
+      resource:
+        name: cpu
+        target:
+          type: Utilization
+          averageUtilization: 50
+  behavior:
+    scaleUp:
+      stabilizationWindowSeconds: 400
+      policies:
+        - type: Pods
+          value: 1
+          periodSeconds: 15
+    scaleDown:
+      stabilizationWindowSeconds: 600
+      policies:
+        - type: Percent
+          value: 50
+          periodSeconds: 60

deploy/kubernetes/ia-worker-deployment.yaml

@@ -40,9 +40,9 @@ spec:
               value: "production"
           resources:
             limits:
-              memory: "2000Mi"
+              memory: "2400Mi"
               cpu: "2000m"
             requests:
               ephemeral-storage: "1000Mi"
-              memory: "2000Mi"
+              memory: "2400Mi"
               cpu: "500m"

production/webapp/src/AudioRecorder.js

@@ -13,8 +13,8 @@ class AudioRecorder {
         this.onDataAvailable = options.onDataAvailable || function() {};
         this.onError = options.onError || function() {};
         this.silenceDelay = options.silenceDelay || 200;
-        this.speechThreshold = options.speechThreshold || 10;
-        this.silenceThreshold = options.silenceThreshold || 4;
+        this.speechThreshold = options.speechThreshold || 12;
+        this.silenceThreshold = options.silenceThreshold || 8;
 
         // Nouvelle propriété pour contrôler la détection de la parole
         this.isDetectingSpeech = false;

production/webapp/src/AudioRecorderComponent.jsx

@@ -27,6 +27,8 @@ const sendAudioChunk= (fetch, baseUrl) => (chunk, clientId, chunkIndex) => {
     });
 }
 
+let iniAsyncPromise = null;
+
 const AudioRecorderComponent = ({}) => {
     const [status, setStatus] = useState('En attente de la parole...');
     const [isRecording, setIsRecording] = useState(false);
@@ -39,6 +41,9 @@ const AudioRecorderComponent = ({}) => {
     const { fetch } = useOidcFetch();
 
     useEffect(() => {
+        if (iniAsyncPromise) {
+            return;
+        }
         console.log('Initialisation de l\'enregistreur audio');
         console.log('URL de base :', baseUrl);
         // Nettoyage des ressources précédentes
@@ -79,8 +84,7 @@ const AudioRecorderComponent = ({}) => {
                     const updatedTranscripts = [...prev, data];
                     console.log('Transcription reçue :', data.transcript);
 
-                    const ordered_transcripts = updatedTranscripts.sort((a, b) => a.chunk_index - b.chunk_index);
-                    return ordered_transcripts;
+                    return updatedTranscripts.sort((a, b) => a.chunk_index - b.chunk_index);
                 });
             };
 
@@ -131,7 +135,10 @@ const AudioRecorderComponent = ({}) => {
             recorderRef.current = recorder;
             recorder.init();
         }
-        initAsync();
+        iniAsyncPromise = initAsync();
+        iniAsyncPromise.then(() => {
+            iniAsyncPromise = null;
+        });
 
         return () => {
             if (recorderRef.current) {