add enableAmplitudeMonitoring

Author: jackbridger

src/index.ts

@@ -19,6 +19,7 @@ interface UseLayercodeAgentOptions {
 
   audioInput?: boolean;
   onAudioInputChanged?: (audioInput: boolean) => void;
+  enableAmplitudeMonitoring?: boolean;
 }
 
 /**
@@ -47,10 +48,13 @@ const useLayercodeAgent = (
     onAudioInputChanged,
   } = options;
   const websocketUrlOverride = options['_websocketUrl'];
+  const enableAmplitudeMonitoring = options.enableAmplitudeMonitoring ?? true;
 
   const [status, setStatus] = useState('initializing');
   const [userAudioAmplitude, setUserAudioAmplitude] = useState(0);
   const [agentAudioAmplitude, setAgentAudioAmplitude] = useState(0);
+  const [userSpeaking, setUserSpeaking] = useState(false);
+  const [assistantSpeaking, setAssistantSpeaking] = useState(false);
   const [audioInput, _setAudioInput] = useState<boolean>(options.audioInput ?? true);
   const [isMuted, setIsMuted] = useState(false);
   const [internalConversationId, setInternalConversationId] = useState<string | null | undefined>(conversationId);
@@ -67,6 +71,13 @@ const useLayercodeAgent = (
     }
   }, [conversationId]);
 
+  useEffect(() => {
+    if (!enableAmplitudeMonitoring) {
+      setUserAudioAmplitude(0);
+      setAgentAudioAmplitude(0);
+    }
+  }, [enableAmplitudeMonitoring]);
+
   const createClient = useCallback(
     (initialConversationId: string | null) => {
       console.log('Creating LayercodeClient instance');
@@ -105,22 +116,35 @@ const useLayercodeAgent = (
         onStatusChange: (newStatus: string) => {
           setStatus(newStatus);
         },
-        onUserAmplitudeChange: (amplitude: number) => {
-          setUserAudioAmplitude(amplitude);
+        onUserAmplitudeChange: enableAmplitudeMonitoring
+          ? (amplitude: number) => {
+              setUserAudioAmplitude(amplitude);
+            }
+          : undefined,
+        onAgentAmplitudeChange: enableAmplitudeMonitoring
+          ? (amplitude: number) => {
+              setAgentAudioAmplitude(amplitude);
+            }
+          : undefined,
+        onUserIsSpeakingChange: (isSpeaking: boolean) => {
+          setUserSpeaking(isSpeaking);
         },
-        onAgentAmplitudeChange: (amplitude: number) => {
-          setAgentAudioAmplitude(amplitude);
+        onAssistantSpeakingChange: (isSpeaking: boolean) => {
+          setAssistantSpeaking(isSpeaking);
         },
         onMuteStateChange: (muted: boolean) => {
           setIsMuted(muted);
           onMuteStateChange?.(muted);
         },
+        enableAmplitudeMonitoring,
       });
 
       if (websocketUrlOverride) {
         client._websocketUrl = websocketUrlOverride;
       }
 
+      setUserSpeaking(false);
+      setAssistantSpeaking(false);
       setIsMuted(client.isMuted);
       clientRef.current = client;
       return client;
@@ -139,6 +163,7 @@ const useLayercodeAgent = (
       onAudioInputChanged,
       websocketUrlOverride,
       audioInput,
+      enableAmplitudeMonitoring,
     ]
   );
 
@@ -234,6 +259,8 @@ const useLayercodeAgent = (
     status,
     userAudioAmplitude,
     agentAudioAmplitude,
+    userSpeaking,
+    assistantSpeaking,
     isMuted,
     conversationId: internalConversationId,
     audioInput,