agw/overleaf-cep
1
0
Fork 0
mirror of https://github.com/yu-i-i/overleaf-cep.git synced 2026-06-04 06:39:02 +02:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #13537 from overleaf/em-promisify-clsi-manager-2

Browse Source 
Promisify ClsiManager

GitOrigin-RevId: e785cdb1989b433f7baa1a4d974b09ba3a93fcbd
This commit is contained in:
Eric Mc Sween
2023-07-06 07:17:03 -04:00
committed by Copybot
parent 06d77871c6
commit 9346d1fa14
12 changed files with 1125 additions and 1273 deletions
Download Patch File Download Diff File Expand all files Collapse all files
services/web/app/src/Features/LinkedFiles/ProjectOutputFileAgent.js
+28 -52
View File
@@ -7,8 +7,8 @@ const {
CompileFailedError,
BadDataError,
AccessDeniedError,
OutputFileFetchFailedError,
} = require('./LinkedFilesErrors')
const { OutputFileFetchFailedError } = require('../Errors/Errors')
const LinkedFilesHandler = require('./LinkedFilesHandler')
function _prepare(projectId, linkedFileData, userId, callback) {
@@ -46,31 +46,20 @@ function createLinkedFile(
if (err) {
return callback(err)
}
readStream.on('error', callback)
readStream.on('response', response => {
if (response.statusCode >= 200 && response.statusCode < 300) {
LinkedFilesHandler.importFromStream(
projectId,
readStream,
linkedFileData,
name,
parentFolderId,
userId,
(err, file) => {
if (err) {
return callback(err)
}
callback(null, file._id)
}
) // Created
} else {
err = new OutputFileFetchFailedError(
`Output file fetch failed: ${linkedFileData.build_id}, ${linkedFileData.source_output_file_path}`
)
err.statusCode = response.statusCode
callback(err)
LinkedFilesHandler.importFromStream(
projectId,
readStream,
linkedFileData,
name,
parentFolderId,
userId,
(err, file) => {
if (err) {
return callback(err)
}
callback(null, file._id)
}
})
)
})
})
}
@@ -94,32 +83,21 @@ function refreshLinkedFile(
if (err) {
return callback(err)
}
readStream.on('error', callback)
readStream.on('response', response => {
if (response.statusCode >= 200 && response.statusCode < 300) {
linkedFileData.build_id = newBuildId
LinkedFilesHandler.importFromStream(
projectId,
readStream,
linkedFileData,
name,
parentFolderId,
userId,
(err, file) => {
if (err) {
return callback(err)
}
callback(null, file._id)
}
) // Created
} else {
err = new OutputFileFetchFailedError(
`Output file fetch failed: ${linkedFileData.build_id}, ${linkedFileData.source_output_file_path}`
)
err.statusCode = response.statusCode
callback(err)
linkedFileData.build_id = newBuildId
LinkedFilesHandler.importFromStream(
projectId,
readStream,
linkedFileData,
name,
parentFolderId,
userId,
(err, file) => {
if (err) {
return callback(err)
}
callback(null, file._id)
}
})
)
}
)
})
@@ -193,7 +171,6 @@ function _getFileStream(linkedFileData, userId, callback) {
if (err) {
return callback(err)
}
readStream.pause()
callback(null, readStream)
}
)
@@ -239,7 +216,6 @@ function _compileAndGetFileStream(linkedFileData, userId, callback) {
if (err) {
return callback(err)
}
readStream.pause()
callback(null, readStream, buildId)
}
)