@@ -50,78 +50,78 @@ class {{ service.name | caseUcfirst }} extends Service {
50
50
const { size: size } = await promisify(fs.stat)({{ parameter .name | caseCamel | escapeKeyword }});
51
51
52
52
if (size < = client.CHUNK_SIZE) {
53
- payload['{{ parameter .name }}'] = fs.createReadStream({{ parameter .name | caseCamel | escapeKeyword }});
53
+ payload['{{ parameter .name }}'] = fs.createReadStream({{ parameter .name | caseCamel | escapeKeyword }});
54
54
55
- return await this.client.call('{{ method .method | caseLower }}', path, {
55
+ return await this.client.call('{{ method .method | caseLower }}', path, {
56
56
{% for parameter in method .parameters .header %}
57
57
'{{ parameter .name }}': ${{ parameter .name | caseCamel | escapeKeyword }},
58
58
{% endfor %}
59
59
{% for key , header in method .headers %}
60
60
'{{ key }}': '{{ header }}',
61
61
{% endfor %}
62
- }, payload{% if method .type == ' location' %}, 'arraybuffer'{% endif %});
62
+ }, payload{% if method .type == ' location' %}, 'arraybuffer'{% endif %});
63
63
} else {
64
- let id = undefined;
65
- let response = undefined;
64
+ let id = undefined;
65
+ let response = undefined;
66
66
67
- let counter = 0;
68
- const totalCounters = Math.ceil(size / client.CHUNK_SIZE);
67
+ let counter = 0;
68
+ const totalCounters = Math.ceil(size / client.CHUNK_SIZE);
69
69
70
- const headers = {
70
+ const headers = {
71
71
{% for parameter in method .parameters .header %}
72
- '{{ parameter .name }}': ${{ parameter .name | caseCamel | escapeKeyword }},
72
+ '{{ parameter .name }}': ${{ parameter .name | caseCamel | escapeKeyword }},
73
73
{% endfor %}
74
74
{% for key , header in method .headers %}
75
- '{{ key }}': '{{ header }}',
75
+ '{{ key }}': '{{ header }}',
76
76
{% endfor %}
77
- };
77
+ };
78
78
79
79
{% for parameter in method .parameters .all %}
80
80
{% if parameter .isUploadID %}
81
- if({{ parameter .name | caseCamel | escapeKeyword }} != 'unique()') {
82
- try {
83
- response = await this.client.call('get', path + '/' + {{ parameter .name }}, headers);
84
- counter = response.chunksUploaded;
85
- } catch(e) {
86
- }
81
+ if({{ parameter .name | caseCamel | escapeKeyword }} != 'unique()') {
82
+ try {
83
+ response = await this.client.call('get', path + '/' + {{ parameter .name }}, headers);
84
+ counter = response.chunksUploaded;
85
+ } catch(e) {
87
86
}
87
+ }
88
88
{% endif %}
89
89
{% endfor %}
90
90
91
- for (counter; counter < totalCounters; counter++) {
92
- const start = (counter * client.CHUNK_SIZE);
93
- const end = Math.min((((counter * client.CHUNK_SIZE) + client.CHUNK_SIZE) - 1), size);
94
-
95
- headers['content-range'] = 'bytes ' + start + '-' + end + '/' + size;
96
-
97
- if (id) {
98
- headers['x-{{spec .title | caseLower }}-id'] = id;
99
- }
100
-
101
- const stream = fs.createReadStream({{ parameter .name | caseCamel | escapeKeyword }}, {
102
- start,
103
- end
104
- });
105
- payload['{{ parameter .name }}'] = stream;
106
-
107
- response = await this.client.call('{{ method .method | caseLower }}', path, headers, payload{% if method .type == ' location' %}, 'arraybuffer'{% endif %});
108
-
109
- if (!id) {
110
- id = response['$id'];
111
- }
112
-
113
- if (onProgress !== null) {
114
- onProgress({
115
- $id: response['$id'],
116
- progress: Math.min((counter+1) * client.CHUNK_SIZE, size) / size * 100,
117
- sizeUploaded: end+1,
118
- chunksTotal: response['chunksTotal'],
119
- chunksUploaded: response['chunksUploaded']
120
- });
121
- }
91
+ for (counter; counter < totalCounters; counter++) {
92
+ const start = (counter * client.CHUNK_SIZE);
93
+ const end = Math.min((((counter * client.CHUNK_SIZE) + client.CHUNK_SIZE) - 1), size);
94
+
95
+ headers['content-range'] = 'bytes ' + start + '-' + end + '/' + size;
96
+
97
+ if (id) {
98
+ headers['x-{{spec .title | caseLower }}-id'] = id;
99
+ }
100
+
101
+ const stream = fs.createReadStream({{ parameter .name | caseCamel | escapeKeyword }}, {
102
+ start,
103
+ end
104
+ });
105
+ payload['{{ parameter .name }}'] = stream;
106
+
107
+ response = await this.client.call('{{ method .method | caseLower }}', path, headers, payload{% if method .type == ' location' %}, 'arraybuffer'{% endif %});
108
+
109
+ if (!id) {
110
+ id = response['$id'];
111
+ }
112
+
113
+ if (onProgress !== null) {
114
+ onProgress({
115
+ $id: response['$id'],
116
+ progress: Math.min((counter+1) * client.CHUNK_SIZE, size) / size * 100,
117
+ sizeUploaded: end+1,
118
+ chunksTotal: response['chunksTotal'],
119
+ chunksUploaded: response['chunksUploaded']
120
+ });
122
121
}
122
+ }
123
123
124
- return response;
124
+ return response;
125
125
}
126
126
{% endif %}
127
127
{% endfor %}
0 commit comments