python-codecs: add timestamps

koush · Apr 25, 2023 · e984452 · e984452
1 parent 0609fc8
commit e984452
Show file tree

Hide file tree

Showing 5 changed files with 8 additions and 5 deletions.
diff --git a/plugins/python-codecs/package-lock.json b/plugins/python-codecs/package-lock.json
diff --git a/plugins/python-codecs/package.json b/plugins/python-codecs/package.json
@@ -1,6 +1,6 @@
 {
    "name": "@scrypted/python-codecs",
-   "version": "0.1.42",
+   "version": "0.1.46",
    "description": "Python Codecs for Scrypted",
    "keywords": [
       "scrypted",

diff --git a/plugins/python-codecs/src/gst_generator.py b/plugins/python-codecs/src/gst_generator.py
@@ -46,7 +46,6 @@ def finish():
         nonlocal hasFinished
         hasFinished = True
         yieldQueue.put(None)
-        sampleQueue.put_nowait(None)
         asyncio.run_coroutine_threadsafe(sampleQueue.put(None), loop = loop)
         if not finished.done():
             finished.set_result(None)
@@ -73,8 +72,8 @@ async def gen():
                 finally:
                     yieldQueue.put(None)
         finally:
-            finish()
             print('gstreamer finished')
+            finish()
 
 
     def on_new_sample(sink, preroll):

diff --git a/plugins/python-codecs/src/pilimage.py b/plugins/python-codecs/src/pilimage.py
@@ -2,6 +2,7 @@
 from typing import Any
 from thread import to_thread
 import io
+import time
 
 try:
     from PIL import Image
@@ -81,6 +82,7 @@ def toPILImage(pilImageWrapper: PILImage, options: scrypted_sdk.ImageOptions = N
 
 async def createPILMediaObject(image: PILImage):
     ret = await scrypted_sdk.mediaManager.createMediaObject(image, scrypted_sdk.ScryptedMimeTypes.Image.value, {
+        'timestamp': time.time() * 1000,
         'format': None,
         'width': image.width,
         'height': image.height,

diff --git a/plugins/python-codecs/src/vipsimage.py b/plugins/python-codecs/src/vipsimage.py
@@ -7,6 +7,7 @@
     Image = None
     pyvips = None
 from thread import to_thread
+import time
 
 class VipsImage(scrypted_sdk.VideoFrame):
     def __init__(self, vipsImage: Image) -> None:
@@ -90,6 +91,7 @@ def toVipsImage(vipsImageWrapper: VipsImage, options: scrypted_sdk.ImageOptions
 
 async def createVipsMediaObject(image: VipsImage):
     ret = await scrypted_sdk.mediaManager.createMediaObject(image, scrypted_sdk.ScryptedMimeTypes.Image.value, {
+        'timestamp': time.time() * 1000,
         'format': None,
         'width': image.width,
         'height': image.height,