You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
82 lines
1.9 KiB
82 lines
1.9 KiB
import subprocess
|
|
import shlex
|
|
from threading import Thread
|
|
from time import sleep
|
|
import pyaudio #pip3 install pyaudio
|
|
import wave
|
|
|
|
# set desired values
|
|
start = 1
|
|
length = 3
|
|
|
|
# open wave file
|
|
wave_file = wave.open('door.wav', 'rb')
|
|
|
|
# initialize audio
|
|
py_audio = pyaudio.PyAudio()
|
|
stream = py_audio.open(format=py_audio.get_format_from_width(wave_file.getsampwidth()),
|
|
channels=wave_file.getnchannels(),
|
|
rate=wave_file.getframerate(),
|
|
output=True)
|
|
|
|
# skip unwanted frames
|
|
n_frames = int(start * wave_file.getframerate())
|
|
wave_file.setpos(n_frames)
|
|
|
|
# write desired frames to audio buffer
|
|
n_frames = int(length * wave_file.getframerate())
|
|
frames = wave_file.readframes(n_frames)
|
|
|
|
|
|
|
|
def run_command(command):
|
|
process = subprocess.Popen(shlex.split(command), stdout=subprocess.PIPE)
|
|
while True:
|
|
output = process.stdout.readline().decode()
|
|
if output == '' and process.poll() is not None:
|
|
break
|
|
if output:
|
|
output = output.strip()
|
|
return int(output[20:])
|
|
rc = process.poll()
|
|
return rc
|
|
|
|
|
|
class Worker(Thread):
|
|
def __init__(self, custom_handler):
|
|
|
|
self.handler = custom_handler
|
|
|
|
def run(self):
|
|
|
|
currentValue = 0 #store values to check if ambient light is increasing or decreasing, dont do anything if no change, play from position based on scale(0-100k is mapped to 0-100% of song)
|
|
previousValue = 0
|
|
while(True):
|
|
sleep(0.05)
|
|
#sleep(0.05)
|
|
currentValue = run_command("./lmutracker3")
|
|
if currentValue > previousValue:
|
|
print("light is increasing")
|
|
stream.write(frames)
|
|
|
|
# close and terminate everything properly
|
|
#stream.close()
|
|
#py_audio.terminate()
|
|
#wave_file.close()
|
|
elif currentValue < previousValue:
|
|
print("light is decreasing")
|
|
else:
|
|
print("light remains the same")
|
|
previousValue = currentValue
|
|
#print(testval)
|
|
#check handler
|
|
if self.handler:
|
|
#do something
|
|
pass
|
|
handler = {}
|
|
worker = Worker(handler)
|
|
|
|
#start thread
|
|
worker.run()
|
|
|
|
|
|
|