Merge pull request #400 from appwrite/feat-resumable-upload-node

Feat: Node resumable upload

Author: Meldiron

templates/node/lib/services/service.js.twig

@@ -50,63 +50,78 @@ class {{ service.name | caseUcfirst }} extends Service {
         const { size: size } = await promisify(fs.stat)({{ parameter.name | caseCamel | escapeKeyword }});
 
         if (size <= client.CHUNK_SIZE) {
-                payload['{{ parameter.name }}'] = fs.createReadStream({{ parameter.name | caseCamel | escapeKeyword }});
+            payload['{{ parameter.name }}'] = fs.createReadStream({{ parameter.name | caseCamel | escapeKeyword }});
 
-                return await this.client.call('{{ method.method | caseLower }}', path, {
+            return await this.client.call('{{ method.method | caseLower }}', path, {
 {% for parameter in method.parameters.header %}
                 '{{ parameter.name }}': ${{ parameter.name | caseCamel | escapeKeyword }},
 {% endfor %}
 {% for key, header in method.headers %}
                 '{{ key }}': '{{ header }}',
 {% endfor %}
-                }, payload{% if method.type == 'location' %}, 'arraybuffer'{% endif %});
+            }, payload{% if method.type == 'location' %}, 'arraybuffer'{% endif %});
         } else {
-                let id = undefined;
-                let response = undefined;
+            let id = undefined;
+            let response = undefined;
 
-                const totalCounters = Math.ceil(size / client.CHUNK_SIZE);
+            let counter = 0;
+            const totalCounters = Math.ceil(size / client.CHUNK_SIZE);
 
-                for (let counter = 0; counter < totalCounters; counter++) {
-                        const start = (counter * client.CHUNK_SIZE);
-                        const end = Math.min((((counter * client.CHUNK_SIZE) + client.CHUNK_SIZE) - 1), size);
-                        const headers = {
+            const headers = {
 {% for parameter in method.parameters.header %}
-                                '{{ parameter.name }}': ${{ parameter.name | caseCamel | escapeKeyword }},
+                '{{ parameter.name }}': ${{ parameter.name | caseCamel | escapeKeyword }},
 {% endfor %}
 {% for key, header in method.headers %}
-                                '{{ key }}': '{{ header }}',
+                '{{ key }}': '{{ header }}',
+{% endfor %}
+            };
+
+{% for parameter in method.parameters.all %}
+{% if parameter.isUploadID %}
+            if({{ parameter.name | caseCamel | escapeKeyword }} != 'unique()') {
+                try {
+                    response = await this.client.call('get', path + '/' + {{ parameter.name }}, headers);
+                    counter = response.chunksUploaded;
+                } catch(e) {
+                }
+            }
+{% endif %}
 {% endfor %}
-                                'content-range': 'bytes ' + start + '-' + end + '/' + size
-                        };
-
-                        if (id) {
-                                headers['x-{{spec.title | caseLower }}-id'] = id;
-                        }
-
-                        const stream = fs.createReadStream({{ parameter.name | caseCamel | escapeKeyword }}, {
-                                start,
-                                end
-                        });
-                        payload['{{ parameter.name }}'] = stream;
-
-                        response = await this.client.call('{{ method.method | caseLower }}', path, headers, payload{% if method.type == 'location' %}, 'arraybuffer'{% endif %});
-
-                        if (!id) {
-                                id = response['$id'];
-                        }
-                        
-                        if (onProgress !== null) {
-                                onProgress({
-                                        $id: response['$id'],
-                                        progress: Math.min((counter+1) * client.CHUNK_SIZE, size) / size * 100,
-                                        sizeUploaded: end+1,
-                                        chunksTotal: response['chunksTotal'],
-                                        chunksUploaded: response['chunksUploaded']
-                                });
-                        }
+
+            for (counter; counter < totalCounters; counter++) {
+                const start = (counter * client.CHUNK_SIZE);
+                const end = Math.min((((counter * client.CHUNK_SIZE) + client.CHUNK_SIZE) - 1), size);
+
+                headers['content-range'] = 'bytes ' + start + '-' + end + '/' + size;
+
+                if (id) {
+                    headers['x-{{spec.title | caseLower }}-id'] = id;
+                }
+
+                const stream = fs.createReadStream({{ parameter.name | caseCamel | escapeKeyword }}, {
+                    start,
+                    end
+                });
+                payload['{{ parameter.name }}'] = stream;
+
+                response = await this.client.call('{{ method.method | caseLower }}', path, headers, payload{% if method.type == 'location' %}, 'arraybuffer'{% endif %});
+
+                if (!id) {
+                    id = response['$id'];
+                }
+                
+                if (onProgress !== null) {
+                    onProgress({
+                        $id: response['$id'],
+                        progress: Math.min((counter+1) * client.CHUNK_SIZE, size) / size * 100,
+                        sizeUploaded: end+1,
+                        chunksTotal: response['chunksTotal'],
+                        chunksUploaded: response['chunksUploaded']
+                    });
                 }
+            }
 
-                return response;
+            return response;
         }
 {% endif %}
 {% endfor %}