mirror of
https://github.com/migatu/conjurer.git
synced 2026-07-14 13:34:40 +00:00
Michal Tuszowski
ef6eb84921
Snapshot of the dockerisation-era bot code laid out at the repository root so it can be diffed directly against the working-copy baseline (restructure/working-copy-root) to see how the variant differed: - thin_client.py asyncio entrypoint (vs working_copy bot.py) - constants.py env-var/credential refactor, communication auth, etc. - extra gpt_interface/ service, sync.py, watch_script_params.py - conanjurer_* modules absent in this variant Docker infrastructure (docker/, docker-compose.yml, .dockerignore) intentionally omitted - this branch is for code comparison only and is not intended to be merged. Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>
68 lines
1.6 KiB
Python
68 lines
1.6 KiB
Python
# Start by making sure the `assemblyai` package is installed.
|
|
# If not, you can install it by running the following command:
|
|
# pip install -U assemblyai
|
|
#
|
|
# Then, make sure you have PyAudio installed: https://pypi.org/project/PyAudio/
|
|
#
|
|
# Note: Some macOS users might need to use `pip3` instead of `pip`.
|
|
|
|
import assemblyai as aai
|
|
import pyaudio
|
|
|
|
aai.settings.api_key = "aa9962f0088a449a9c4ab2361e96cc08"
|
|
|
|
|
|
def on_open(session_opened: aai.RealtimeSessionOpened):
|
|
"This function is called when the connection has been established."
|
|
|
|
print("Session ID:", session_opened.session_id)
|
|
|
|
|
|
def on_data(transcript: aai.RealtimeTranscript):
|
|
"This function is called when a new transcript has been received."
|
|
|
|
if not transcript.text:
|
|
return
|
|
|
|
if isinstance(transcript, aai.RealtimeFinalTranscript):
|
|
print(transcript.text, end="\r\n")
|
|
else:
|
|
print(transcript.text, end="\r")
|
|
|
|
|
|
def on_error(error: aai.RealtimeError):
|
|
"This function is called when the connection has been closed."
|
|
|
|
print("An error occured:", error)
|
|
|
|
|
|
def on_close():
|
|
"This function is called when the connection has been closed."
|
|
|
|
print("Closing Session")
|
|
|
|
|
|
transcriber = aai.RealtimeTranscriber(
|
|
on_data=on_data,
|
|
on_error=on_error,
|
|
sample_rate=44_100,
|
|
on_open=on_open, # optional
|
|
on_close=on_close, # optional
|
|
)
|
|
|
|
|
|
pa = pyaudio.PyAudio()
|
|
for i in range(pa.get_device_count()):
|
|
print(pa.get_device_info_by_index(i))
|
|
|
|
# Start the connection
|
|
# transcriber.connect()
|
|
|
|
# Open a microphone stream
|
|
# microphone_stream = aai.extras.MicrophoneStream()
|
|
|
|
# Press CTRL+C to abort
|
|
# transcriber.stream(microphone_stream)
|
|
|
|
# transcriber.close()
|