Skip to content

Commit dbaf3d0

Browse files
authored
fix(release): release worker dies (#417)
* fix(release): check that file.content is not empty * fix(release): delete inside of the Promise.all
1 parent a6499c5 commit dbaf3d0

1 file changed

Lines changed: 12 additions & 2 deletions

File tree

workers/release/src/index.ts

Lines changed: 12 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -179,17 +179,23 @@ export default class ReleaseWorker extends Worker {
179179
const fileInfo = await this.saveFile(map);
180180

181181
/**
182-
* Remove 'content' and save id of saved file instead
182+
* Save id of saved file instead
183183
*/
184184
map._id = fileInfo._id;
185-
delete map.content;
186185

187186
return map;
188187
} catch (error) {
189188
this.logger.error(`Map ${map.mapFileName} was not saved: ${error}`);
190189
}
191190
}));
192191

192+
/**
193+
* Delete file content after it is saved to the GridFS
194+
*/
195+
savedFiles.forEach(file => {
196+
delete file.content;
197+
})
198+
193199
/**
194200
* Filter unsaved maps
195201
*/
@@ -282,6 +288,10 @@ export default class ReleaseWorker extends Worker {
282288
*/
283289
private saveFile(file: SourceMapDataExtended): Promise<SourceMapFileChunk> {
284290
return new Promise((resolve, reject) => {
291+
if (!file.content) {
292+
return reject(new Error('Source map content is empty'));
293+
}
294+
285295
const readable = Readable.from([ file.content ]);
286296
const writeStream = this.db.getBucket().openUploadStream(file.mapFileName);
287297

0 commit comments

Comments
 (0)