|
|
|
@ -12,15 +12,13 @@ def five_minute_segment_from(the_time): |
|
|
|
def path_to_video_at(time_stamp): |
|
|
|
def path_to_video_at(time_stamp): |
|
|
|
return 'videos/' + str(time_stamp) + '.mkv' # mkv required for h264 encoding |
|
|
|
return 'videos/' + str(time_stamp) + '.mkv' # mkv required for h264 encoding |
|
|
|
|
|
|
|
|
|
|
|
os.environ["OPENCV_FFMPEG_CAPTURE_OPTIONS"]="hwaccel;vaapi;hw_decoders_any;vaapi,vdpau" # maybe this enables hardware accelerated ffmpeg? |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
#delay for long delay |
|
|
|
#delay for long delay |
|
|
|
long_delay = timedelta(minutes=1) |
|
|
|
long_delay = timedelta(minutes=1) |
|
|
|
|
|
|
|
|
|
|
|
last_time_stamp = five_minute_segment_from(datetime.now()) |
|
|
|
last_time_stamp = five_minute_segment_from(datetime.now()) |
|
|
|
|
|
|
|
|
|
|
|
# live webcam feed |
|
|
|
# live webcam feed |
|
|
|
camera = cv2.VideoCapture(0, cv2.CAP_FFMPEG) |
|
|
|
camera = cv2.VideoCapture(0) |
|
|
|
if not camera.isOpened(): |
|
|
|
if not camera.isOpened(): |
|
|
|
print("Cannot open camera") |
|
|
|
print("Cannot open camera") |
|
|
|
exit() |
|
|
|
exit() |
|
|
|
@ -35,7 +33,7 @@ video_writer = cv2.VideoWriter(path_to_video_at(last_time_stamp), |
|
|
|
) |
|
|
|
) |
|
|
|
|
|
|
|
|
|
|
|
# video feed from previously captured video |
|
|
|
# video feed from previously captured video |
|
|
|
old_time = cv2.VideoCapture(path_to_video_at(last_time_stamp), cv2.CAP_FFMPEG) |
|
|
|
old_time = cv2.VideoCapture(path_to_video_at(last_time_stamp)) |
|
|
|
|
|
|
|
|
|
|
|
# fullscreen window yess good |
|
|
|
# fullscreen window yess good |
|
|
|
cv2.namedWindow("mirror", cv2.WINDOW_NORMAL) |
|
|
|
cv2.namedWindow("mirror", cv2.WINDOW_NORMAL) |
|
|
|
@ -46,65 +44,66 @@ idx = 0 # current index into the frame queue |
|
|
|
short_term_delay_frames = 20 # hoow many frames back are we going in the buffer when we're on a short term delay? |
|
|
|
short_term_delay_frames = 20 # hoow many frames back are we going in the buffer when we're on a short term delay? |
|
|
|
longterm = False # are we shoowing a long term delay? (versus a sshort term delay) |
|
|
|
longterm = False # are we shoowing a long term delay? (versus a sshort term delay) |
|
|
|
|
|
|
|
|
|
|
|
with keep.presenting(): |
|
|
|
#with keep.presenting(): |
|
|
|
while(True): |
|
|
|
while(True): |
|
|
|
if last_time_stamp != five_minute_segment_from(datetime.now()): |
|
|
|
if last_time_stamp != five_minute_segment_from(datetime.now()): |
|
|
|
# find file older than our long delay |
|
|
|
# find file older than our long delay |
|
|
|
old_file = path_to_video_at(five_minute_segment_from(datetime.now() - long_delay - timedelta(minutes=1))) |
|
|
|
old_file = path_to_video_at(five_minute_segment_from(datetime.now() - long_delay - timedelta(minutes=1))) |
|
|
|
if os.path.isfile(old_file): |
|
|
|
if os.path.isfile(old_file): |
|
|
|
print(f"deleting old file {old_file}") |
|
|
|
print(f"deleting old file {old_file}") |
|
|
|
os.remove(old_file) |
|
|
|
os.remove(old_file) |
|
|
|
|
|
|
|
|
|
|
|
video_writer.release() |
|
|
|
video_writer.release() |
|
|
|
newly_recording_file = path_to_video_at(five_minute_segment_from(datetime.now())) |
|
|
|
newly_recording_file = path_to_video_at(five_minute_segment_from(datetime.now())) |
|
|
|
|
|
|
|
|
|
|
|
print(f"opening {newly_recording_file} too record this upcoming ssegment to") |
|
|
|
print(f"opening {newly_recording_file} too record this upcoming ssegment to") |
|
|
|
video_writer = cv2.VideoWriter(newly_recording_file, |
|
|
|
video_writer = cv2.VideoWriter(newly_recording_file, |
|
|
|
fourcc, |
|
|
|
fourcc, |
|
|
|
camera.get(cv2.CAP_PROP_FPS), |
|
|
|
camera.get(cv2.CAP_PROP_FPS), |
|
|
|
(int(camera.get(3)), int(camera.get(4))), |
|
|
|
(int(camera.get(3)), int(camera.get(4))), |
|
|
|
(cv2.VIDEOWRITER_PROP_HW_ACCELERATION, cv2.VIDEO_ACCELERATION_ANY) |
|
|
|
(cv2.VIDEOWRITER_PROP_HW_ACCELERATION, cv2.VIDEO_ACCELERATION_ANY) |
|
|
|
) |
|
|
|
) |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if old_time.isOpened(): |
|
|
|
if old_time.isOpened(): |
|
|
|
old_time.release() |
|
|
|
old_time.release() |
|
|
|
|
|
|
|
|
|
|
|
new_file = path_to_video_at(five_minute_segment_from(datetime.now() - long_delay)) |
|
|
|
new_file = path_to_video_at(five_minute_segment_from(datetime.now() - long_delay)) |
|
|
|
print(f"opening the previously recorded file {new_file} to read from for long mirror") |
|
|
|
print(f"opening the previously recorded file {new_file} to read from for long mirror") |
|
|
|
old_time = cv2.VideoCapture(new_file, cv2.CAP_FFMPEG) |
|
|
|
old_time = cv2.VideoCapture(new_file, cv2.CAP_FFMPEG) |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
last_time_stamp = five_minute_segment_from(datetime.now()) |
|
|
|
last_time_stamp = five_minute_segment_from(datetime.now()) |
|
|
|
|
|
|
|
|
|
|
|
ret, frame = camera.read() |
|
|
|
ret, frame = camera.read() |
|
|
|
frame = cv2.flip(frame, 1) |
|
|
|
frame = cv2.flip(frame, 1) |
|
|
|
|
|
|
|
|
|
|
|
# record the frame to the appropriate file, and also to the short term buffer |
|
|
|
# record the frame to the appropriate file, and also to the short term buffer |
|
|
|
video_writer.write(frame) |
|
|
|
video_writer.write(frame) |
|
|
|
queue[idx] = ret, frame |
|
|
|
queue[idx] = ret, frame |
|
|
|
|
|
|
|
|
|
|
|
prev_frame_valid, prev_frame = queue[(idx - short_term_delay_frames) % len(queue)] |
|
|
|
prev_frame_valid, prev_frame = queue[(idx - short_term_delay_frames) % len(queue)] |
|
|
|
old_frame_valid, old_frame = old_time.read() |
|
|
|
old_frame_valid, old_frame = old_time.read() |
|
|
|
if not longterm and prev_frame_valid: |
|
|
|
if not longterm and prev_frame_valid: |
|
|
|
cv2.imshow('mirror', prev_frame) |
|
|
|
cv2.imshow('mirror', prev_frame) |
|
|
|
elif longterm and old_frame_valid: |
|
|
|
elif longterm and old_frame_valid: |
|
|
|
cv2.imshow('mirror', old_frame) |
|
|
|
cv2.imshow('mirror', old_frame) |
|
|
|
|
|
|
|
|
|
|
|
key = cv2.waitKey(16) # listen for keyprress for 16 ms |
|
|
|
key = cv2.waitKey(16) # listen for keyprress for 16 ms |
|
|
|
if key & 0xFF == ord('q') or key == 27: # q or esc |
|
|
|
if key & 0xFF == ord('q') or key == 27: # q or esc |
|
|
|
break |
|
|
|
break |
|
|
|
if key & 0xFF == ord('a'): |
|
|
|
if key & 0xFF == ord('a'): |
|
|
|
short_term_delay_frames += 1 |
|
|
|
short_term_delay_frames += 1 |
|
|
|
if key & 0xFF == ord('d'): |
|
|
|
if key & 0xFF == ord('d'): |
|
|
|
short_term_delay_frames -= 1 |
|
|
|
short_term_delay_frames -= 1 |
|
|
|
if key & 0xFF == ord('z'): |
|
|
|
if key & 0xFF == ord('z'): |
|
|
|
longterm = not longterm |
|
|
|
longterm = not longterm |
|
|
|
|
|
|
|
|
|
|
|
idx = (idx + 1) % len(queue) |
|
|
|
idx = (idx + 1) % len(queue) |
|
|
|
|
|
|
|
|
|
|
|
# After the loop release the cap object |
|
|
|
# After the loop release the cap object |
|
|
|
camera.release() |
|
|
|
camera.release() |
|
|
|
out.release() |
|
|
|
old_time.release() |
|
|
|
|
|
|
|
video_writer.release() |
|
|
|
# Destroy all the windows |
|
|
|
# Destroy all the windows |
|
|
|
cv2.destroyAllWindows() |
|
|
|
cv2.destroyAllWindows() |
|
|
|
|
