random/mumble-bot/bot.py

import pymumble_py3 as pymumble
import subprocess as sp
import time
import sys
import os
import fcntl
import audioop

pwd = ""  # password
server = "mumble.esiliati.org"  # server address
nick = "TubiaBot"
channel = "radiospore"
port = 64738  # port number

# Spin up a client and connect to mumble server
mumble = pymumble.Mumble(server, nick, password=pwd, port=port)
# set up callback called when PCS event occurs
mumble.set_receive_sound(1)  # Enable receiving sound from mumble server
mumble.start()
mumble.is_ready()  # Wait for client is ready
mumble.channels.find_by_name(channel).move_in()
mumble.users.myself.mute()

BUFFER = 0.1
BITRATE = 48000
RESOLUTION = 10 # in ms
FLOAT_RESOLUTION = float(RESOLUTION) / 1000
MONO_CHUNK_SIZE = BITRATE * 2 * RESOLUTION / 1000
STEREO_CHUNK_SIZE = MONO_CHUNK_SIZE * 2 
silent = b"\x00" * int(STEREO_CHUNK_SIZE)
cursor_time = None
cursor_time = time.time() - BUFFER

while mumble.is_alive():
    if cursor_time < time.time() - BUFFER: 
        base_sound = None

        try:
            for user in mumble.users.values():  # check the audio queue of each user                
                if user.sound.is_sound():
                    # available sound is to be treated now and not later
                    sound = user.sound.get_sound(FLOAT_RESOLUTION)
                    stereo_pcm = audioop.tostereo(sound.pcm, 2, 1, 1)
                    if base_sound == None:
                        base_sound = stereo_pcm
                    else:
                        base_sound = audioop.add(base_sound, stereo_pcm, 2)
        except RuntimeError:
            eprint("ignored exception in stderr...")
            
        if base_sound:
            sys.stdout.buffer.write(base_sound)
        else:
            sys.stdout.buffer.write(silent)                        

        cursor_time += FLOAT_RESOLUTION
    else:
        time.sleep(FLOAT_RESOLUTION)