selfhostyourtech/reflector
2
0
Fork 0
mirror of https://github.com/Monadical-SAS/reflector.git synced 2025-12-20 20:29:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

update log info

Browse Source
This commit is contained in:
Gokul Mohanarangan
2023-07-11 18:51:17 +05:30
parent 71eb277fd7
commit 34f2795fa9
2 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
server_executor_cleaned.py
View File

@@ -39,6 +39,7 @@ def channel_send(channel, message):
def get_transcription(frames): def get_transcription(frames):
print("Transcribing..")
out_file = io.BytesIO() out_file = io.BytesIO()
wf = wave.open(out_file, "wb") wf = wave.open(out_file, "wb")
wf.setnchannels(CHANNELS) wf.setnchannels(CHANNELS)
@@ -93,7 +94,7 @@ async def offer(request):
def log_info(msg, *args): def log_info(msg, *args):
logger.info(pc_id + " " + msg, *args) logger.info(pc_id + " " + msg, *args)
log_info("Created for %s", request.remote) log_info("Created for " + request.remote)
@pc.on("datachannel") @pc.on("datachannel")
def on_datachannel(channel): def on_datachannel(channel):
@@ -110,14 +111,14 @@ async def offer(request):
@pc.on("connectionstatechange") @pc.on("connectionstatechange")
async def on_connectionstatechange(): async def on_connectionstatechange():
log_info("Connection state is %s", pc.connectionState) log_info("Connection state is " + pc.connectionState)
if pc.connectionState == "failed": if pc.connectionState == "failed":
await pc.close() await pc.close()
pcs.discard(pc) pcs.discard(pc)
@pc.on("track") @pc.on("track")
def on_track(track): def on_track(track):
log_info("Track %s received", track.kind) log_info("Track " + track.kind + " received")
pc.addTrack(AudioStreamTrack(relay.subscribe(track))) pc.addTrack(AudioStreamTrack(relay.subscribe(track)))
await pc.setRemoteDescription(offer) await pc.setRemoteDescription(offer)

0
utils/test.py
View File