From ff0945b8819dbcf41b7744a38359c732fdf03bfe Mon Sep 17 00:00:00 2001
From: Mitchell <mgerb42@gmail.com>
Date: Sun, 7 Oct 2018 20:09:03 -0500
Subject: [PATCH] fix(audio clipping): save separated audio streams

---
 server/bothandlers/sounds.go | 31 ++++++++++++++++---------------
 1 file changed, 16 insertions(+), 15 deletions(-)

diff --git a/server/bothandlers/sounds.go b/server/bothandlers/sounds.go
index c2cb118..b376702 100644
--- a/server/bothandlers/sounds.go
+++ b/server/bothandlers/sounds.go
@@ -356,37 +356,38 @@ func writePacketsToFile(username string, packets chan *discordgo.Packet) {
 		os.Mkdir(config.Config.ClipsPath, os.ModePerm)
 	}
 
-	// construct filename
-	timestamp := time.Now().UTC().Format("2006-01-02") + "-" + strconv.Itoa(int(time.Now().Unix()))
-	filename := config.Config.ClipsPath + "/" + timestamp + "-" + username + ".wav"
-
 	// grab everything from the voice packet channel and dump it to the file
 	// close when there is nothing left
-	pcmOut := make([]int16, 0)
+	// split audio into specific voice streams
+	pcmOut := map[uint32][]int16{}
 
 loop:
 	for {
 		select {
 		case p := <-packets:
-			for _, pcm := range p.PCM {
-				pcmOut = append(pcmOut, pcm)
-			}
+			pcmOut[p.SSRC] = append(pcmOut[p.SSRC], p.PCM...)
 		default:
 			break loop
 		}
 	}
 
-	cmd := exec.Command("ffmpeg", "-f", "s16le", "-ar", strconv.Itoa(sampleRate), "-ac", strconv.Itoa(channels), "-i", "pipe:0", filename)
+	for key, pcmData := range pcmOut {
+		// construct filename
+		timestamp := time.Now().UTC().Format("2006-01-02") + "-" + strconv.Itoa(int(time.Now().Unix()))
+		filename := config.Config.ClipsPath + "/" + timestamp + "-" + strconv.Itoa(int(key)) + "-" + username + ".wav"
 
-	output := new(bytes.Buffer)
+		cmd := exec.Command("ffmpeg", "-f", "s16le", "-ar", strconv.Itoa(sampleRate), "-ac", strconv.Itoa(channels), "-i", "pipe:0", filename)
 
-	binary.Write(output, binary.LittleEndian, pcmOut)
-	cmd.Stdin = bytes.NewReader(output.Bytes())
+		output := new(bytes.Buffer)
 
-	err := cmd.Run()
+		binary.Write(output, binary.LittleEndian, pcmData)
+		cmd.Stdin = bytes.NewReader(output.Bytes())
 
-	if err != nil {
-		log.Error(err)
+		err := cmd.Run()
+
+		if err != nil {
+			log.Error(err)
+		}
 	}
 }