mirror of
https://github.com/overleaf/overleaf.git
synced 2024-09-16 02:52:31 -04:00
124 lines
4.3 KiB
CoffeeScript
124 lines
4.3 KiB
CoffeeScript
logger = require("logger-sharelatex")
|
|
request = require("request")
|
|
settings = require("settings-sharelatex")
|
|
ProjectLocator = require("../Project/ProjectLocator")
|
|
U = require('underscore')
|
|
Async = require('async')
|
|
Project = require("../../models/Project").Project
|
|
UserGetter = require "../User/UserGetter"
|
|
|
|
oneMinInMs = 60 * 1000
|
|
fiveMinsInMs = oneMinInMs * 5
|
|
|
|
|
|
module.exports = ReferencesSearchHandler =
|
|
|
|
_findBibDocIds: (project) ->
|
|
ids = []
|
|
|
|
_process = (folder) ->
|
|
folder.docs.forEach (doc) ->
|
|
if doc?.name?.match(/^.*\.bib$/)
|
|
ids.push(doc._id)
|
|
folder.folders.forEach (folder) ->
|
|
_process(folder)
|
|
|
|
project.rootFolder.forEach (rootFolder) ->
|
|
_process(rootFolder)
|
|
|
|
return ids
|
|
|
|
_isFullIndex: (project, callback = (err, result) ->) ->
|
|
owner = project.owner_ref
|
|
callback(null, owner.features.references == true)
|
|
|
|
# projectId: String, docIds: List[String]|Null
|
|
index: (projectId, docIds, callback=(err, data)->) ->
|
|
Project.findPopulatedById projectId, (err, project) ->
|
|
if err
|
|
logger.err {err, projectId}, "error finding project"
|
|
return callback(err)
|
|
if docIds == "ALL"
|
|
logger.log {projectId}, "indexing all bib files in project"
|
|
docIds = ReferencesSearchHandler._findBibDocIds(project)
|
|
ReferencesSearchHandler._isFullIndex project, (err, isFullIndex) ->
|
|
if err
|
|
logger.err {err, projectId}, "error checking whether to do full index"
|
|
return callback(err)
|
|
bibDocUrls = docIds.map (docId) ->
|
|
ReferencesSearchHandler._buildDocUrl projectId, docId
|
|
logger.log {projectId, isFullIndex, docIds}, "sending request to references service"
|
|
request.post {
|
|
url: "#{settings.apis.references.url}/project/#{projectId}/index"
|
|
json:
|
|
docUrls: bibDocUrls
|
|
fullIndex: isFullIndex
|
|
}, (err, res, data) ->
|
|
if err
|
|
logger.err {err, projectId}, "error communicating with references api"
|
|
return callback(err)
|
|
if 200 <= res.statusCode < 300
|
|
logger.log {projectId}, "got keys from references api"
|
|
return callback(null, data)
|
|
else
|
|
err = new Error("references api responded with non-success code: #{res.statusCode}")
|
|
logger.log {err, projectId}, "error updating references"
|
|
return callback(err)
|
|
|
|
## ## ## ##
|
|
|
|
indexProjectReferences: (project, callback = (err) ->) ->
|
|
logger.log {projectId: project._id}, "try indexing references from project"
|
|
ids = ReferencesSearchHandler._findBibDocIds(project)
|
|
logger.log {projectId: project._id, count: ids.length}, "found bib files in project"
|
|
Async.eachSeries(
|
|
ids,
|
|
(docId, next) ->
|
|
ReferencesSearchHandler.indexFile project._id, docId, (err) ->
|
|
next(err)
|
|
, (err) ->
|
|
logger.log {projectId: project._id, count: ids.length}, "done index bib files in project"
|
|
callback(err)
|
|
)
|
|
|
|
indexFile: (projectId, fileId, callback = (err)->) ->
|
|
target_url = "#{settings.apis.references.url}/project/#{projectId}"
|
|
fileUrl = ReferencesSearchHandler._buildDocUrl projectId, fileId
|
|
logger.log {projectId, fileId}, "checking if file should be fully indexed"
|
|
ReferencesSearchHandler._isFullIndex projectId, (err, isFullIndex) ->
|
|
if err
|
|
logger.err {projectId, fileId, err}, "error checking if file should be fully indexed"
|
|
return callback(err)
|
|
logger.log {projectId, fileId, isFullIndex}, "sending index request to references api"
|
|
request.post {
|
|
url: target_url
|
|
json:
|
|
referencesUrl: fileUrl
|
|
}, (err, res, result) ->
|
|
if err
|
|
return callback(err)
|
|
if 200 <= res.statusCode < 300
|
|
return callback(null)
|
|
else
|
|
err = new Error("references api responded with non-success code: #{res.statusCode}")
|
|
logger.log {err, projectId, fileUrl}, "error updating references"
|
|
return callback(err)
|
|
|
|
getKeys: (projectId, callback = (err, result)->) ->
|
|
logger.log {projectId}, "getting keys from remote references api"
|
|
url = "#{settings.apis.references.url}/project/#{projectId}/keys"
|
|
request.get {
|
|
url: url
|
|
json: true
|
|
}, (err, res, result) ->
|
|
if err
|
|
return callback(err)
|
|
if 200 <= res.statusCode < 300
|
|
return callback(null, result)
|
|
else
|
|
err = new Error("references api responded with non-success code: #{res.statusCode}")
|
|
logger.log {err, projectId}, "error getting references keys"
|
|
return callback(err)
|
|
|
|
_buildDocUrl: (projectId, docId) ->
|
|
"#{settings.apis.web.url}/project/#{projectId}/doc/#{docId}"
|