From 6c6c2655f2ff017b4f333e7b6395dc2a677fd73e Mon Sep 17 00:00:00 2001
From: Bradley Bickford <bradleybickford@gmail.com>
Date: Sun, 7 Jan 2024 16:23:42 -0500
Subject: [PATCH] Adding another protection to try to avoid multiple recordings
 of the same audio happening

---
 breadbot.js | 39 +++++++++++++++++++++------------------
 1 file changed, 21 insertions(+), 18 deletions(-)

diff --git a/breadbot.js b/breadbot.js
index 1ac7e34..bee8d7c 100644
--- a/breadbot.js
+++ b/breadbot.js
@@ -137,30 +137,33 @@ client.on(Events.VoiceStateUpdate, async (oldState, newState) => {
 
 				if (receiver.speaking.listenerCount("start") == 0) {
 					receiver.speaking.on("start", (user_id) => {
-						receiver.subscribe(user_id, {
-							end: {
-								behavior: EndBehaviorType.AfterSilence,
-								duration: 500
-							}
-						})
-						.pipe(new prism.opus.OggLogicalBitstream({
-							opusHead: new prism.opus.OpusHead({
-								channelCount: 2,
-								sampleRate: 48000
-							}),
-							pageSizeControl: {
-								maxPackets: 10
-							}
-						}))
-						.pipe(fs.createWriteStream(media_voice_folder + path.sep + newCallID + path.sep + `${Date.now()}-${user_id}.ogg`))
-	
+						if(!receiver.subscriptions.has(user_id)) {
+							receiver.subscribe(user_id, {
+								end: {
+									behavior: EndBehaviorType.AfterSilence,
+									duration: 500
+								}
+							})
+							.pipe(new prism.opus.OggLogicalBitstream({
+								opusHead: new prism.opus.OpusHead({
+									channelCount: 2,
+									sampleRate: 48000
+								}),
+								pageSizeControl: {
+									maxPackets: 10
+								}
+							}))
+							.pipe(fs.createWriteStream(media_voice_folder + path.sep + newCallID + path.sep + `${Date.now()}-${user_id}.ogg`))
+						} else {
+							logger.warn(`Attempted to create new user subscriber for ${user_id} even though one already exists, receiver arm if statement protected against this`)
+						}
 					})
 	
 					receiver.speaking.on("end", (user_id) => {
 						logger.info(`User ${user_id} stopped speaking`)
 					})
 				} else {
-					logger.info("Attempted to create a new start and end listener for users who are speaking for some reason, receiver armor if statement protected against this")
+					logger.warn("Attempted to create a new start and end listener for users who are speaking for some reason, receiver armor if statement protected against this")
 				}
 			} catch (error) {
 				logger.error(error)