broadcast/broadcast/main.go

83 lines
1.9 KiB
Go

package main
import (
"os"
"time"
"crypto/tls"
"fmt"
"net"
"log"
"layeh.com/gumble/gumble"
"layeh.com/gumble/gumbleutil"
_ "layeh.com/gumble/opus"
)
type AudioListener struct {
name string
}
func (audiolistener AudioListener) OnAudioStream(e *gumble.AudioStreamEvent) {
fmt.Printf("Received AudioStreamEvent from %s\n", e.User.Name)
go ReadPacket(e.C)
}
func ReadPacket(ch <-chan *gumble.AudioPacket) {
outFile := "pcm_out.raw"
fmt.Printf("Saving out to %s", outFile) // debug
pcm_out, _ := os.OpenFile(outFile, os.O_CREATE|os.O_WRONLY|os.O_TRUNC, 0755)
defer pcm_out.Close()
for packet := range ch {
// log.Printf("Message from %s", packet.Sender.Name) // debug
buf := packet.AudioBuffer
pcm_out.Write(UnsafeCastInt16sToBytes(buf))
}
}
func main() {
config := gumble.NewConfig()
config.Username = "bon-bot"
config.Attach(gumbleutil.Listener{
TextMessage: func(e *gumble.TextMessageEvent) {
fmt.Printf("Received text message: %s\n", e.Message)
},
})
l := AudioListener{name: "Eventprinter"}
config.AttachAudio(l)
mumbleServer := os.Getenv("MUMBLE_SERVER")
if len(mumbleServer) == 0 {
mumbleServer = "mumble:64738"
log.Printf("Mumble server not defined, falling back to default value: %s", mumbleServer)
}
client, err := gumble.DialWithDialer(&net.Dialer{}, mumbleServer, config, &tls.Config{InsecureSkipVerify: true}) // TODO: fix cert or make it an option
if err != nil {
panic(err)
}
// Print available channels on the server
fmt.Printf("Channels:\n")
for idx, channel := range client.Channels {
fmt.Printf("\t%d - %s\n", idx, channel.Name)
}
channel := client.Channels.Find("Antro delle Bestemmie")
client.Self.Move(channel)
fmt.Println("Chosen Channel: ", channel.Name)
for {
time.Sleep(1 * time.Second)
if client.State() == gumble.StateDisconnected {
log.Println("Disconnected from server")
break
}
}
}