# HG changeset patch
# User drewp@bigasterisk.com
# Date 1681763639 25200
# Node ID 9e56e86a68146d97e3ff78239efb2da280d9f881
# Parent  ff73b95fc72f95fc05d53f6a00ae232776d81728
server supports downloading into a given folder

diff -r ff73b95fc72f -r 9e56e86a6814 video.py
--- a/video.py	Mon Apr 17 13:33:05 2023 -0700
+++ b/video.py	Mon Apr 17 13:33:59 2023 -0700
@@ -43,8 +43,9 @@
 
 
 async def ingestVideoUrl(req: Request) -> Response:
+    folder = req.query_params['folder']
     url = await req.body()
-    await svc.ingestUrl(url.decode('utf8'))
+    await svc.ingestUrl(url.decode('utf8'), folder)
     return Response(status_code=202)
 
 
diff -r ff73b95fc72f -r 9e56e86a6814 video_ingest.py
--- a/video_ingest.py	Mon Apr 17 13:33:05 2023 -0700
+++ b/video_ingest.py	Mon Apr 17 13:33:59 2023 -0700
@@ -13,8 +13,9 @@
     async def addContent(self, name: str, body: Coroutine[Any, Any, bytes]):
         await self.store.save(name, iter([await body]))
 
-    async def ingestUrl(self, url: str):
-        dl_queue.queue.put({'url': url, 'outDir': str(self.store.top)})
+    async def ingestUrl(self, url: str, folder:str):
+        outDir = self.store.top / folder.lstrip('/') #danger user input
+        dl_queue.queue.put({'url': url, 'outDir': str(outDir)})
 
     async def events(self):
         prev = None