localhorst/msv-webcam-backend
1
0
Fork 0
Code Issues 1 Pull Requests Packages Projects Releases Wiki Activity

copy images to tmp dir and signal

Browse Source
This commit is contained in:
Hendrik Schutter 2023-07-05 21:16:35 +02:00
parent 59e6c5048b
commit 897985a3cf
1 changed files with 16 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
msv_webcam_backend.py
View File

@ -9,13 +9,24 @@ import time
import shutil
import sys
signal_pipe_path = "/tmp/msv-webcam-signal-pipe"
signal_pipe_msg = "msv-webcam-new-images"
def copy_image(src, destination_dir_path, destination_owner):
# print("src: " + str(src))
# print("dst: " + str(destination_dir_path))
os.makedirs(os.path.dirname(destination_dir_path), exist_ok=True)
shutil.copyfile(src, destination_dir_path)
os.chmod(destination_dir_path, 0o0644)
shutil.chown(destination_dir_path, destination_owner)
def signal_new_images():
if not os.path.exists(signal_pipe_path):
os.mkfifo(signal_pipe_path)
with open(signal_pipe_path, "w") as f:
f.write(signal_pipe_msg)
f.close()
def main():
print("starting ...")
@ -42,10 +53,11 @@ def main():
if ((update_interval == -1) or (destination_dir_path == -1) or (destination_owner == -1) or (len(search_dirs) == 0)):
print("Unable to parse config!")
print("Example usage:")
print(" python msv_webcam_backend.py interval=10 search_dir=test_images/msvcamS search_dir=test_images/msvcamN destination_dir=www/ destination_owner=hendrik")
print(" python msv_webcam_backend.py interval=10 search_dir=test_images/msvcamS search_dir=test_images/msvcamN destination_dir=/tmp/msv_webcam_current destination_owner=hendrik")
sys.exit(-1)
while True:
new_images_found = False
for search_dir in search_dirs:
try:
# print("\nSearch dir: " + str(search_dir["search_dir_path"]))
@ -74,12 +86,15 @@ def main():
print("Size: " + str(search_dir["newest_file_size"]))
dst_file_tmp = os.path.join(destination_dir_path, (os.path.basename(os.path.normpath(search_dir["search_dir_path"])) + os.path.splitext(search_dir["newest_file_path"])[1]))
copy_image(search_dir["newest_file_path"], dst_file_tmp, destination_owner)
new_images_found = True
#break
else:
print("Upload not finished yet!")
except Exception as e:
print(e)
#break
if(new_images_found == True):
signal_new_images()
time.sleep(update_interval)
if __name__ == "__main__":