input.py

import pyaudio
import wave
import time
import sys
import strip_worker
import sounddevice as sd
import numpy as np
import collections
from scipy import signal

SAMPLES_PER_WINDOW = 1024
FS = 44100

device = [d['name'] == 'pulse' for d in list(sd.query_devices())].index(True)


# How much latency to update the lightstrip
latency_comp = 0.02
frame_delay = round(latency_comp*FS/SAMPLES_PER_WINDOW)
print(frame_delay)
windows = collections.deque(np.zeros((frame_delay, SAMPLES_PER_WINDOW, 2)))

# Create strip thread
worker = strip_worker.NewStripWorker(SAMPLES_PER_WINDOW, FS, "New Light Strip Worker")

worker.start()

print(sd.query_devices())
print(sd.query_devices(device, 'input'))


def input_sound(indata, outdata, frames, sd_time, status):
  global windows
  #windows.append(indata)
  #outdata[:,:2] = windows.popleft()[:,:2]
  #print(sd_time.inputBufferAdcTime)
  worker.addWindow(indata[:,0].flatten())

def output_sound(outdata, frames, time, status):
  pass

with sd.Stream(callback=input_sound, samplerate=FS, device=device, blocksize=SAMPLES_PER_WINDOW, latency=0.001):
  while True:
    sd.sleep(100)


# stop thread
worker.stop()
worker.join()