PublicMirrors/voice-changer
1
0
Fork 0
mirror of https://github.com/w-okada/voice-changer.git synced 2025-03-12 10:20:11 +03:00
Code Issues Actions Packages Projects Releases Wiki Activity

suppress broadcast

Browse Source
This commit is contained in:
wataru 2023-01-16 17:59:41 +09:00
parent 41523546e4
commit 61b27236b7
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
server/sio/MMVC_Namespace.py
View File

@ -22,17 +22,16 @@ class MMVC_Namespace(socketio.AsyncNamespace):
async def on_request_message(self, sid, msg): async def on_request_message(self, sid, msg):
timestamp = int(msg[0]) timestamp = int(msg[0])
data = msg[1] data = msg[1]
if(isinstance(data, str)): if(isinstance(data, str)):
print(type(data)) print(type(data))
print(data) print(data)
await self.emit('response', [timestamp, 0]) await self.emit('response', [timestamp, 0], to=sid)
else: else:
unpackedData = np.array(struct.unpack('<%sh' % (len(data) // struct.calcsize('<h')), data)) unpackedData = np.array(struct.unpack('<%sh' % (len(data) // struct.calcsize('<h')), data))
audio1 = self.voiceChangerManager.changeVoice(unpackedData) audio1 = self.voiceChangerManager.changeVoice(unpackedData)
# print("sio result:", len(audio1), audio1.shape) # print("sio result:", len(audio1), audio1.shape)
bin = struct.pack('<%sh' % len(audio1), *audio1) bin = struct.pack('<%sh' % len(audio1), *audio1)
await self.emit('response', [timestamp, bin]) await self.emit('response', [timestamp, bin], to=sid)
def on_disconnect(self, sid): def on_disconnect(self, sid):
# print('[{}] disconnect'.format(datetime.now().strftime('%Y-%m-%d %H:%M:%S'))) # print('[{}] disconnect'.format(datetime.now().strftime('%Y-%m-%d %H:%M:%S')))