overleaf/services/project-history/app/js/Router.js

228 lines
5.5 KiB
JavaScript
Raw Normal View History

import OError from '@overleaf/o-error'
import * as HttpController from './HttpController.js'
import { Joi, validate } from './Validation.js'
export function initialize(app) {
app.use(
validate({
params: Joi.object({
project_id: Joi.string().regex(/^[0-9a-f]{24}$/),
user_id: Joi.string().regex(/^[0-9a-f]{24}$/),
label_id: Joi.string().regex(/^[0-9a-f]{24}$/),
version: Joi.number().integer(),
}),
})
)
// use an extended timeout on all endpoints, to allow for long requests to history-v1
app.use(longerTimeout)
app.post('/project', HttpController.initializeProject)
app.delete('/project/:project_id', HttpController.deleteProject)
app.get(
'/project/:project_id/diff',
validate({
query: {
pathname: Joi.string().required(),
from: Joi.number().integer().required(),
to: Joi.number().integer().required(),
},
}),
HttpController.getDiff
)
app.get(
'/project/:project_id/filetree/diff',
validate({
query: {
from: Joi.number().integer().required(),
to: Joi.number().integer().required(),
},
}),
HttpController.getFileTreeDiff
)
app.get(
'/project/:project_id/updates',
validate({
query: {
before: Joi.number().integer(),
min_count: Joi.number().integer(),
},
}),
HttpController.getUpdates
)
app.get('/project/:project_id/version', HttpController.latestVersion)
app.post(
'/project/:project_id/flush',
validate({
query: {
debug: Joi.boolean().default(false),
bisect: Joi.boolean().default(false),
},
}),
HttpController.flushProject
)
app.post(
'/project/:project_id/resync',
validate({
query: {
force: Joi.boolean().default(false),
},
body: {
force: Joi.boolean().default(false),
origin: Joi.object({
kind: Joi.string().required(),
}),
historyRangesMigration: Joi.string()
.optional()
.valid('forwards', 'backwards'),
},
}),
HttpController.resyncProject
)
app.get(
'/project/:project_id/dump',
validate({
query: {
count: Joi.number().integer(),
},
}),
HttpController.dumpProject
)
app.get('/project/:project_id/labels', HttpController.getLabels)
app.post(
'/project/:project_id/user/:user_id/labels',
validate({
body: {
version: Joi.number().integer().required(),
comment: Joi.string().required(),
created_at: Joi.string(),
validate_exists: Joi.boolean().default(true),
},
}),
HttpController.createLabel
)
app.delete(
'/project/:project_id/user/:user_id/labels/:label_id',
validate({
params: Joi.object({
project_id: Joi.string().regex(/^[0-9a-f]{24}$/),
user_id: Joi.string().regex(/^[0-9a-f]{24}$/),
label_id: Joi.string().regex(/^[0-9a-f]{24}$/),
}),
}),
HttpController.deleteLabelForUser
)
app.delete(
'/project/:project_id/labels/:label_id',
validate({
params: Joi.object({
project_id: Joi.string().regex(/^[0-9a-f]{24}$/),
label_id: Joi.string().regex(/^[0-9a-f]{24}$/),
}),
}),
HttpController.deleteLabel
)
app.post(
'/user/:from_user/labels/transfer/:to_user',
HttpController.transferLabels
)
app.get(
'/project/:project_id/version/:version/:pathname',
HttpController.getFileSnapshot
)
app.get(
'/project/:project_id/ranges/version/:version/:pathname',
HttpController.getRangesSnapshot
)
app.get(
'/project/:project_id/version/:version',
HttpController.getProjectSnapshot
)
app.post(
'/project/:project_id/force',
validate({
query: {
clear: Joi.boolean().default(false),
},
}),
HttpController.forceDebugProject
)
app.get('/project/:project_id/blob/:hash', HttpController.getProjectBlob)
app.get('/status/failures', HttpController.getFailures)
app.get('/status/queue', HttpController.getQueueCounts)
app.post(
'/retry/failures',
validate({
query: {
failureType: Joi.string().valid('soft', 'hard'),
// bail out after this time limit
timeout: Joi.number().integer().default(300),
// maximum number of projects to check
limit: Joi.number().integer().default(100),
callbackUrl: Joi.string(),
},
}),
HttpController.retryFailures
)
app.post(
'/flush/old',
validate({
query: {
// flush projects with queued ops older than this
maxAge: Joi.number()
.integer()
.default(6 * 3600),
// pause this amount of time between checking queues
queueDelay: Joi.number().integer().default(100),
// maximum number of queues to check
limit: Joi.number().integer().default(1000),
// maximum amount of time allowed
timeout: Joi.number()
.integer()
.default(60 * 1000),
// whether to run in the background
background: Joi.boolean().falsy('0').truthy('1').default(false),
},
}),
HttpController.flushOld
)
app.get('/status', (req, res, next) => res.send('project-history is up'))
app.get('/oops', function (req, res, next) {
throw new OError('dummy test error')
})
app.get('/check_lock', HttpController.checkLock)
app.get('/health_check', HttpController.healthCheck)
}
function longerTimeout(req, res, next) {
res.setTimeout(6 * 60 * 1000)
next()
}