# HG changeset patch
# User drewp@bigasterisk.com
# Date 1681717285 25200
# Node ID 1b388ee5dd09b7644f60fd35596f050d0ae55919
# Parent 071943adf0006c70a287f9c316b0e11dee5134b3
reformat
diff -r 071943adf000 -r 1b388ee5dd09 src/ingest/IngestDrop.ts
--- a/src/ingest/IngestDrop.ts Sun Apr 16 03:19:33 2023 -0700
+++ b/src/ingest/IngestDrop.ts Mon Apr 17 00:41:25 2023 -0700
@@ -17,6 +17,7 @@
}
`,
];
+
render() {
return html`
Drop video url here
`;
}
diff -r 071943adf000 -r 1b388ee5dd09 video.py
--- a/video.py Sun Apr 16 03:19:33 2023 -0700
+++ b/video.py Mon Apr 17 00:41:25 2023 -0700
@@ -14,6 +14,7 @@
from video_file_store import VideoFileStore
from video_ingest import VideoIngest
import dl_queue
+
logging.basicConfig(level=logging.DEBUG)
log = logging.getLogger()
logging.getLogger('sse_starlette').setLevel(logging.WARNING)
@@ -50,15 +51,18 @@
async def ingestQueue(req: Request) -> EventSourceResponse:
+
async def g():
async for ev in svc.events():
yield json.dumps(ev)
+
return EventSourceResponse(g())
store = VideoFileStore(top=Path('/data'))
svc = VideoIngest(store)
+
def main():
app = Starlette(
@@ -78,7 +82,7 @@
app.add_middleware(PrometheusMiddleware, app_name='video_api')
app.add_route("/metrics", handle_metrics)
-
+
app.state.processTask = asyncio.create_task(dl_queue.process())
return app
diff -r 071943adf000 -r 1b388ee5dd09 vite.config.ts
--- a/vite.config.ts Sun Apr 16 03:19:33 2023 -0700
+++ b/vite.config.ts Mon Apr 17 00:41:25 2023 -0700
@@ -18,7 +18,6 @@
formats: ["es"],
},
},
-
define: {
global: {},
},