120 lines
4.6 KiB
Python
120 lines
4.6 KiB
Python
import pyaudio, numpy, keyboard, time
|
|
import scipy.io.wavfile as wav
|
|
from sys import getsizeof
|
|
|
|
RATE=48000
|
|
RECORD_SECONDS = 20
|
|
CHUNKSIZE = 1024*4
|
|
|
|
SourcesToRecord = ["VoiceMeeter VAIO3 Output", "CABLE"]
|
|
print("Searching for audio sources")
|
|
Sources = []
|
|
AudioChannels = []
|
|
Frames = []
|
|
p = pyaudio.PyAudio()
|
|
info = p.get_host_api_info_by_index(0)
|
|
numdevices = info.get('deviceCount')
|
|
|
|
for i in range(0, numdevices):
|
|
if (p.get_device_info_by_host_api_device_index(0, i).get('maxInputChannels')) > 0:
|
|
i2 = 0
|
|
while(i2 < len(SourcesToRecord)):
|
|
if(SourcesToRecord[i2] in p.get_device_info_by_host_api_device_index(0, i).get('name')):
|
|
print("Using " + p.get_device_info_by_host_api_device_index(0, i).get('name') + " for '" + SourcesToRecord[i2] + "' ID: " + str(i))
|
|
Sources.append(i)
|
|
AudioChannels.append(p.open(format=pyaudio.paInt16, channels=1, rate=RATE, input=True, frames_per_buffer=CHUNKSIZE, input_device_index=i))
|
|
i2+=1
|
|
|
|
#streamLocal = p.open(format=pyaudio.paInt16, channels=1, rate=RATE, input=True, frames_per_buffer=CHUNKSIZE, input_device_index=localAudioChan)
|
|
#if("VoiceMeeter VAIO3 Output" in p.get_device_info_by_host_api_device_index(0, i).get('name')):
|
|
# localAudioChan = i
|
|
# print("Using " + p.get_device_info_by_host_api_device_index(0, i).get('name') + " for local stream " + str(i))
|
|
#if("CABLE" in p.get_device_info_by_host_api_device_index(0, i).get('name')):
|
|
# incomingAudioChan = i
|
|
# print("Using " + p.get_device_info_by_host_api_device_index(0, i).get('name') + " for Discord stream " + str(i))
|
|
|
|
## Populate frame buffer
|
|
i = 0
|
|
while(i <= len(SourcesToRecord)):
|
|
Frames.append([])
|
|
i += 1
|
|
|
|
|
|
samplesI = 0
|
|
saves = 0
|
|
|
|
def on_triggered(): #define your function to be executed on hot-key press
|
|
global cb, saves
|
|
print("Saving replay..", end = "")
|
|
cutUpBuffers = []
|
|
i = 0
|
|
name = time.strftime("%Y-%m-%d_%H-%M-%S-out-")
|
|
while(i < len(Frames) - 1):
|
|
# cutUpBuffers.append(numpy.hstack(Frames[i][-320:]))
|
|
wav.write(name + str(saves) + str(i) + '.wav',RATE,numpy.hstack(Frames[i][-320:]))
|
|
i += 1
|
|
saves+=1
|
|
print("[DONE]")
|
|
# wav.write(name + str(saves) + '-local.wav',RATE,numpydata2)
|
|
#write_to_textfield(text_to_print) #<-- your function
|
|
|
|
shortcut = 'alt+1'
|
|
keyboard.add_hotkey(shortcut, on_triggered)
|
|
|
|
# initialize portaudio
|
|
cleanUp = False
|
|
|
|
incomingAudioChan = -1
|
|
localAudioChan = -1
|
|
deviceWithId = {}
|
|
#for i in range(0, numdevices):
|
|
# if (p.get_device_info_by_host_api_device_index(0, i).get('maxInputChannels')) > 0:
|
|
# print("Using " + p.get_device_info_by_host_api_device_index(0, i).get('name') + " for " + str(i))
|
|
#for i in range(0, numdevices):
|
|
# if (p.get_device_info_by_host_api_device_index(0, i).get('maxInputChannels')) > 0:
|
|
# deviceWithId[i] = p.get_device_info_by_host_api_device_index(0, i).get('name')
|
|
# # print("id ", i, " - ", p.get_device_info_by_host_api_device_index(0, i).get('name'))
|
|
# if("VoiceMeeter VAIO3 Output" in p.get_device_info_by_host_api_device_index(0, i).get('name')):
|
|
# localAudioChan = i
|
|
# print("Using " + p.get_device_info_by_host_api_device_index(0, i).get('name') + " for local stream " + str(i))
|
|
# if("CABLE" in p.get_device_info_by_host_api_device_index(0, i).get('name')):
|
|
# incomingAudioChan = i
|
|
# print("Using " + p.get_device_info_by_host_api_device_index(0, i).get('name') + " for Discord stream " + str(i))
|
|
#if(incomingAudioChan == -1 or localAudioChan == -1):
|
|
# print("FAILURE")
|
|
# exit
|
|
|
|
print(" There are " + str(len(SourcesToRecord)) + " SourcesToRecord. Frames: " + str(len(Frames)))
|
|
|
|
print("Running!")
|
|
try:
|
|
while True:
|
|
i = 0
|
|
while(i < len(SourcesToRecord)):
|
|
data = AudioChannels[i].read(CHUNKSIZE)
|
|
# print(i)
|
|
Frames[i].append(numpy.fromstring(data, dtype=numpy.int16))
|
|
i += 1
|
|
|
|
samplesI+=1
|
|
if(len(Frames[i]) >= 900):
|
|
cleanUp = True
|
|
|
|
if(len(Frames[i]) <= 700):
|
|
cleanUp = False
|
|
|
|
if(cleanUp):
|
|
while(i < len(SourcesToRecord)):
|
|
Frames[i] = Frames[i].pop(0)
|
|
i += 1
|
|
|
|
except KeyboardInterrupt:
|
|
i = 0
|
|
while(i < len(AudioChannels)):
|
|
AudioChannels[i].stop_stream()
|
|
AudioChannels[i].close()
|
|
i += 1
|
|
p.terminate()
|
|
print("Quiting system, saved frame over lifetime: ", end="")
|
|
print(samplesI)
|