feat: handle mediaSegmentation, define path

frankpagan · frankpagan · commit 4c8e478bf7ff · 2024-03-15T18:45:58.000-05:00
diff --git a/demo/index.html b/demo/index.html
@@ -18,7 +18,7 @@
         </form>
 
         <form>
-            <input type="file" />
+            <input type="file" path="/assets/test" />
             <button actions="upload">upload</button>
         </form>
 
diff --git a/demo/video-segmenting.html b/demo/video-segmenting.html
@@ -0,0 +1,22 @@
+<!DOCTYPE html>
+<html lang="en">
+    <head>
+        <title>Video Segmenting | CoCreateJS</title>
+
+        <!-- CoCreate Favicon -->
+        <link
+            rel="icon"
+            type="image/png"
+            sizes="32x32"
+            href="../assets/favicon.ico" />
+        <link rel="manifest" href="/manifest.webmanifest" />
+    </head>
+    <body>
+        <input id="fileInput" type="file" accept="video/mp4" />
+
+        <script src="./video-segmenting.js"></script>
+        <!-- <script src="../dist/CoCreate-file.js"></script> -->
+        <!-- <script src="../../../CoCreateJS/dist/CoCreate.js"></script> -->
+        <!-- <script src="https://CoCreate.app/dist/CoCreate.js"></script> -->
+    </body>
+</html>
diff --git a/src/client.js b/src/client.js
@@ -424,35 +424,80 @@ async function upload(element, data) {
 
         for (let input of inputs) {
             let Data = Elements.getObject(input);
-            if (Data.type) {
-                if (input.getFilter)
-                    Data.$filter = await input.getFilter()
+            let key = getAttribute('key')
+            if (Data.type === 'key')
+                Data.type = 'object'
 
-                let files = await getFiles(input)
+            Data.method = Data.type + '.update'
+            if (Data.array)
+                Data.array = 'files'
 
-                let key = getAttribute('key')
-                if (Data.type === 'key')
-                    Data.type = 'object'
+            let path = input.getAttribute('path')
+            let directory = '/'
+
+            if (path) {
+                directory = path.split('/');
+                directory = directory[directory.length - 1];
+                if (!path.endswith('/'))
+                    path += '/'
+            } else
+                path = directory = '/'
 
-                let object = input.getAttribute('object')
-                if (key) {
-                    Data[Data.type] = { _id: object, [key]: files }
-                } else {
-                    Data[Data.type] = files
+            if (input.getFilter) {
+                Data.$filter = await input.getFilter()
+                if (!Data.$filter.query)
+                    Data.$filter.query = {}
+            } else
+                Data.$filter = {
+                    query: {}
                 }
 
-                Data.method = Data.type + '.update'
-                let response = await Crud.send(Data)({
-                    array,
-                    object,
-                    upsert: true
-                });
 
-                data.push(response)
-                if (response && (!object || object !== response.object)) {
-                    Elements.setTypeValue(element, response);
+            let files = await getFiles(input)
+            let segmentSize = 10 * 1024 * 1024
+            for (let i = 0; i < files.length; i++) {
+                files[i].path = path
+                files[i].pathname = path + '/' + files[i].name
+                files[i].directory = directory
+
+
+                if (files[i].size > segmentSize) {
+                    let { streamConfig, segments } = await processFile(files[i], null, segmentSize);
+                    files[i].src = streamConfig
+                    for (let j = 0; j < segments.length; j++) {
+                        segments[j].path = path
+                        segments[j].pathname = path + '/' + segments[j].name
+                        segments[j].directory = directory
+
+                        Data.$filter.query.pathname = segments[j].pathname
+                        Crud.send({
+                            ...Data,
+                            object: segments[j],
+                            upsert: true
+                        });
+                    }
+
                 }
             }
+
+            let object = input.getAttribute('object')
+            if (key) {
+                Data[Data.type] = { _id: object, [key]: files }
+            } else {
+                Data[Data.type] = files
+            }
+
+            // Data.$filter.query.pathname = files[i].pathname
+
+            let response = await Crud.send({
+                ...Data,
+                upsert: true
+            });
+
+            data.push(response)
+            if (response && (!object || object !== response.object)) {
+                Elements.setTypeValue(element, response);
+            }
         }
 
         let queriedElements = queryElements({ element: element[i], prefix: 'upload' })
