mirror of
https://github.com/overleaf/overleaf.git
synced 2024-11-21 20:47:08 -05:00
e0d91eaa26
Downgrade all INFO logs to DEBUG GitOrigin-RevId: 05ed582ef0721fcada059f0ad158565f50feca27
119 lines
3.6 KiB
JavaScript
119 lines
3.6 KiB
JavaScript
/* eslint-disable
|
|
camelcase,
|
|
no-unused-vars,
|
|
*/
|
|
// TODO: This file was created by bulk-decaffeinate.
|
|
// Fix any style issues and re-enable lint.
|
|
/*
|
|
* decaffeinate suggestions:
|
|
* DS102: Remove unnecessary code created because of implicit returns
|
|
* DS207: Consider shorter variations of null checks
|
|
* Full docs: https://github.com/decaffeinate/decaffeinate/blob/master/docs/suggestions.md
|
|
*/
|
|
let DocumentUpdaterManager
|
|
const request = require('request')
|
|
const logger = require('@overleaf/logger')
|
|
const Settings = require('@overleaf/settings')
|
|
|
|
module.exports = DocumentUpdaterManager = {
|
|
_requestDocument(project_id, doc_id, url, callback) {
|
|
if (callback == null) {
|
|
callback = function () {}
|
|
}
|
|
|
|
logger.debug({ project_id, doc_id }, 'getting doc from document updater')
|
|
return request.get(url, function (error, res, body) {
|
|
if (error != null) {
|
|
return callback(error)
|
|
}
|
|
if (res.statusCode >= 200 && res.statusCode < 300) {
|
|
try {
|
|
body = JSON.parse(body)
|
|
} catch (error1) {
|
|
error = error1
|
|
return callback(error)
|
|
}
|
|
logger.debug(
|
|
{ project_id, doc_id, version: body.version },
|
|
'got doc from document updater'
|
|
)
|
|
return callback(null, body.lines.join('\n'), body.version)
|
|
} else {
|
|
error = new Error(
|
|
`doc updater returned a non-success status code: ${res.statusCode}`
|
|
)
|
|
logger.error(
|
|
{ err: error, project_id, doc_id, url },
|
|
'error accessing doc updater'
|
|
)
|
|
return callback(error)
|
|
}
|
|
})
|
|
},
|
|
|
|
getDocument(project_id, doc_id, callback) {
|
|
const url = `${Settings.apis.documentupdater.url}/project/${project_id}/doc/${doc_id}`
|
|
DocumentUpdaterManager._requestDocument(project_id, doc_id, url, callback)
|
|
},
|
|
|
|
peekDocument(project_id, doc_id, callback) {
|
|
const url = `${Settings.apis.documentupdater.url}/project/${project_id}/doc/${doc_id}/peek`
|
|
DocumentUpdaterManager._requestDocument(project_id, doc_id, url, callback)
|
|
},
|
|
|
|
setDocument(project_id, doc_id, content, user_id, callback) {
|
|
if (callback == null) {
|
|
callback = function () {}
|
|
}
|
|
const url = `${Settings.apis.documentupdater.url}/project/${project_id}/doc/${doc_id}`
|
|
logger.debug({ project_id, doc_id }, 'setting doc in document updater')
|
|
return request.post(
|
|
{
|
|
url,
|
|
json: {
|
|
lines: content.split('\n'),
|
|
source: 'restore',
|
|
user_id,
|
|
undoing: true,
|
|
},
|
|
},
|
|
function (error, res, body) {
|
|
if (error != null) {
|
|
return callback(error)
|
|
}
|
|
if (res.statusCode >= 200 && res.statusCode < 300) {
|
|
return callback(null)
|
|
} else {
|
|
error = new Error(
|
|
`doc updater returned a non-success status code: ${res.statusCode}`
|
|
)
|
|
logger.error(
|
|
{ err: error, project_id, doc_id, url },
|
|
'error accessing doc updater'
|
|
)
|
|
return callback(error)
|
|
}
|
|
}
|
|
)
|
|
},
|
|
}
|
|
|
|
module.exports.promises = {
|
|
// peekDocument returns two arguments so we can't use util.promisify, which only handles a single argument, we need
|
|
// to treat this it as a special case.
|
|
peekDocument: (project_id, doc_id) => {
|
|
return new Promise((resolve, reject) => {
|
|
DocumentUpdaterManager.peekDocument(
|
|
project_id,
|
|
doc_id,
|
|
(err, content, version) => {
|
|
if (err) {
|
|
reject(err)
|
|
} else {
|
|
resolve([content, version])
|
|
}
|
|
}
|
|
)
|
|
})
|
|
},
|
|
}
|