Controlling program with TCP commands

[lavacode]

Hi! I'm still quite new to Python, so apologies if I'm missing something really basic..

I have this code, which has speech recognition and then sends recognized text to an API which will give a response (chatbot).
Now there are some things wrong in my flow. Where the biggest issue is that I want to remain listening to TCP commands while get_speech() is active.

As you can see in code, I'm listening to TCP-commands; with the "openMic" command you should be able to basically start the chatbot.
This will gives a welcome message from the API and then listens to your input. With the "closeMic" command I want to stop the chatbot <-- which doesn't work.

The get_speech(), function is running infinitely. The function it self runs perfect. However, I always want to be able to stop the function with the closeMic command.
It is also important that I don't want to break the program, since the user should be able to start the function again with the "openMic" command.
I've tried several things like adding booleans, passing booleans.. But I'm stuck.

Is there anyone who can help me out?
I've hidden my API and charID

import requests import json import socket import base64 import speech_recognition as sr import pyttsx3 from playsound import playsound TCP_IP = "127.0.0.1" TCP_PORT = 9999 url = "https://api.convai.com/character/getResponse" def get_speech(recognizer, microphone): with microphone as source: print("Adjusting for ambient noise...") recognizer.adjust_for_ambient_noise(source) print("Listening for your voice...") audio = recognizer.listen(source) try: print("Recognizing your speech...") return recognizer.recognize_google(audio) except sr.UnknownValueError: print("Google Speech Recognition could not understand audio") except sr.RequestError as e: print(f"Could not request results from Google Speech Recognition service; {e}") def get_response(sentence): payload = { 'userText': [sentence], 'charID': '', 'sessionID': '-1', 'voiceResponse': 'True' } headers = { 'CONVAI-API-KEY': '' } response = requests.request("POST", url, headers=headers, data=payload) data = response.json() character_response = data["text"] print("Text response: " + data["text"]) decode_string = base64.b64decode(data["audio"]) with open('audioResponse.wav', 'wb') as f: f.write(decode_string) def main(): recognizer = sr.Recognizer() microphone = sr.Microphone() server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) server_socket.bind((TCP_IP, TCP_PORT)) server_socket.listen(1) print(f"Server listening on {TCP_IP}:{TCP_PORT}") chatbotEnabled = False connected = False client_socket, addr = server_socket.accept() connected = True print(f"Client connected: {addr}") data = client_socket.recv(1024).decode().strip() while connected: if data == "openMic": chatbotEnabled = True # user_input = get_speech(recognizer, microphone, chatbotEnabled) elif data == "closeMic": chatbotEnabled = False print("chatbot disabled") get_response("Bye") playsound("audioResponse.wav") continue elif data == "stopProgram": connected = False break if chatbotEnabled: get_response("Please introduce yourself") playsound("audioResponse.wav") user_input = get_speech(recognizer, microphone) if user_input is None: continue elif user_input in ["quit", "exit", "bye"]: break elif not user_input is None: response = get_response(user_input) playsound("audioResponse.wav") if __name__ == "__main__": main()

[deanhystad]

Actually, you are not listening for TCP commands. You listen for 1 TCP command.

You'll want to put this inside the while loop.

 data = client_socket.recv(1024).decode().strip()