| 1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069 |
- const { setTimeout } = require('timers/promises')
- const sinon = require('sinon')
- const { expect } = require('chai')
- const SandboxedModule = require('sandboxed-module')
- const tk = require('timekeeper')
- const { RequestFailedError } = require('@overleaf/fetch-utils')
- const FILESTORE_URL = 'http://filestore.example.com'
- const CLSI_HOST = 'clsi.example.com'
- const MODULE_PATH = '../../../../app/src/Features/Compile/ClsiManager.js'
- const GLOBAL_BLOB_HASH = 'aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa'
- describe('ClsiManager', function () {
- beforeEach(function () {
- tk.freeze(Date.now())
- this.user_id = 'user-id'
- this.project = {
- _id: 'project-id',
- compiler: 'latex',
- rootDoc_id: 'mock-doc-id-1',
- imageName: 'mock-image-name',
- overleaf: { history: { id: 42 } },
- }
- this.docs = {
- '/main.tex': {
- name: 'main.tex',
- _id: 'mock-doc-id-1',
- lines: ['Hello', 'world'],
- },
- '/chapters/chapter1.tex': {
- name: 'chapter1.tex',
- _id: 'mock-doc-id-2',
- lines: ['Chapter 1'],
- },
- }
- this.files = {
- '/images/frog.png': {
- name: 'frog.png',
- _id: 'mock-file-id-1',
- created: new Date(),
- hash: GLOBAL_BLOB_HASH,
- },
- '/images/image.png': {
- name: 'image.png',
- _id: 'mock-file-id-2',
- created: new Date(),
- hash: 'bbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbb',
- },
- '/images/no-hash.png': {
- name: 'no-hash.png',
- _id: 'mock-file-id-3',
- created: new Date(),
- },
- }
- this.clsiCookieKey = 'clsiserver'
- this.clsiServerId = 'clsi-server-id'
- this.newClsiServerId = 'newserver'
- this.rawOutputFiles = {}
- this.responseBody = {
- compile: { status: 'success' },
- }
- this.response = {
- ok: true,
- status: 200,
- headers: {
- raw: sinon.stub().returns({
- 'set-cookie': [`${this.clsiCookieKey}=${this.newClsiServerId}`],
- }),
- },
- }
- this.FetchUtils = {
- fetchString: sinon
- .stub()
- .callsFake(() => Promise.resolve(JSON.stringify(this.responseBody))),
- fetchStringWithResponse: sinon.stub().callsFake(() =>
- Promise.resolve({
- body: JSON.stringify(this.responseBody),
- response: this.response,
- })
- ),
- fetchStream: sinon.stub(),
- RequestFailedError,
- }
- this.ClsiCookieManager = {
- promises: {
- clearServerId: sinon.stub().resolves(),
- getServerId: sinon.stub().resolves('clsi-server-id'),
- setServerId: sinon.stub().resolves(),
- },
- }
- this.ClsiStateManager = {
- computeHash: sinon.stub().returns('01234567890abcdef'),
- }
- this.ClsiFormatChecker = {
- promises: {
- checkRecoursesForProblems: sinon.stub().resolves(),
- },
- }
- this.Project = {}
- this.ProjectEntityHandler = {
- getAllDocPathsFromProject: sinon.stub(),
- promises: {
- getAllDocs: sinon.stub().resolves(this.docs),
- getAllFiles: sinon.stub().resolves(this.files),
- },
- }
- this.ProjectGetter = {
- promises: {
- findById: sinon.stub().resolves(this.project),
- getProject: sinon.stub().resolves(this.project),
- },
- }
- this.DocumentUpdaterHandler = {
- promises: {
- clearProjectState: sinon.stub().resolves(),
- flushProjectToMongo: sinon.stub().resolves(),
- getProjectDocsIfMatch: sinon.stub().resolves(),
- },
- }
- this.Metrics = {
- Timer: class Metrics {
- constructor() {
- this.done = sinon.stub()
- }
- },
- inc: sinon.stub(),
- count: sinon.stub(),
- }
- this.Settings = {
- apis: {
- filestore: {
- url: FILESTORE_URL,
- secret: 'secret',
- },
- clsi: {
- url: `http://${CLSI_HOST}`,
- submissionBackendClass: 'n2d',
- },
- clsi_priority: {
- url: 'https://clsipremium.example.com',
- },
- },
- enablePdfCaching: true,
- clsiCookie: { key: 'clsiserver' },
- }
- this.ClsiCacheHandler = {
- clearCache: sinon.stub().resolves(),
- }
- this.Features = {
- hasFeature: sinon.stub().withArgs('project-history-blobs').returns(true),
- }
- this.HistoryManager = {
- getFilestoreBlobURL: sinon.stub().callsFake((historyId, hash) => {
- if (hash === GLOBAL_BLOB_HASH) {
- return `${FILESTORE_URL}/history/global/hash/${hash}`
- }
- return `${FILESTORE_URL}/history/project/${historyId}/hash/${hash}`
- }),
- }
- this.ClsiManager = SandboxedModule.require(MODULE_PATH, {
- requires: {
- '@overleaf/settings': this.Settings,
- '../../models/Project': {
- Project: this.Project,
- },
- '../../infrastructure/Features': this.Features,
- '../Project/ProjectEntityHandler': this.ProjectEntityHandler,
- '../Project/ProjectGetter': this.ProjectGetter,
- '../DocumentUpdater/DocumentUpdaterHandler':
- this.DocumentUpdaterHandler,
- './ClsiCookieManager': () => this.ClsiCookieManager,
- './ClsiStateManager': this.ClsiStateManager,
- './ClsiCacheHandler': this.ClsiCacheHandler,
- '@overleaf/fetch-utils': this.FetchUtils,
- './ClsiFormatChecker': this.ClsiFormatChecker,
- '@overleaf/metrics': this.Metrics,
- '../History/HistoryManager': this.HistoryManager,
- },
- })
- })
- after(function () {
- tk.reset()
- })
- describe('sendRequest', function () {
- describe('with a successful compile', function () {
- const buildId = '18fbe9e7564-30dcb2f71250c690'
- beforeEach(async function () {
- this.outputFiles = [
- {
- url: `/project/${this.project_id}/user/${this.user_id}/build/1234/output/output.pdf`,
- path: 'output.pdf',
- type: 'pdf',
- build: buildId,
- },
- {
- url: `/project/${this.project_id}/user/${this.user_id}/build/1234/output/output.log`,
- path: 'output.log',
- type: 'log',
- build: buildId,
- },
- ]
- this.responseBody.compile.outputFiles = this.outputFiles.map(
- outputFile => ({
- ...outputFile,
- url: `http://${CLSI_HOST}${outputFile.url}`,
- })
- )
- this.responseBody.compile.buildId = buildId
- this.timeout = 100
- this.result = await this.ClsiManager.promises.sendRequest(
- this.project._id,
- this.user_id,
- {
- compileBackendClass: 'e2',
- compileGroup: 'standard',
- timeout: this.timeout,
- }
- )
- })
- it('should send the request to the CLSI', function () {
- this.FetchUtils.fetchStringWithResponse.should.have.been.calledWith(
- sinon.match(
- url =>
- url.host === CLSI_HOST &&
- url.pathname ===
- `/project/${this.project._id}/user/${this.user_id}/compile` &&
- url.searchParams.get('compileBackendClass') === 'e2' &&
- url.searchParams.get('compileGroup') === 'standard'
- ),
- {
- method: 'POST',
- json: sinon.match({
- compile: {
- options: {
- compiler: this.project.compiler,
- imageName: this.project.imageName,
- timeout: this.timeout,
- draft: false,
- compileGroup: 'standard',
- metricsMethod: 'standard',
- stopOnFirstError: false,
- syncType: undefined,
- },
- rootResourcePath: 'main.tex',
- resources: _makeResources(this.project, this.docs, this.files),
- },
- }),
- headers: {
- Accept: 'application/json',
- 'Content-Type': 'application/json',
- Cookie: `${this.clsiCookieKey}=${this.clsiServerId}`,
- },
- signal: sinon.match.instanceOf(AbortSignal),
- }
- )
- })
- it('should get the project with the required fields', function () {
- this.ProjectGetter.promises.getProject.should.have.been.calledWith(
- this.project._id,
- {
- compiler: 1,
- rootDoc_id: 1,
- imageName: 1,
- rootFolder: 1,
- 'overleaf.history.id': 1,
- }
- )
- })
- it('should flush the project to the database', function () {
- this.DocumentUpdaterHandler.promises.flushProjectToMongo.should.have.been.calledWith(
- this.project._id
- )
- })
- it('should get all the docs', function () {
- this.ProjectEntityHandler.promises.getAllDocs.should.have.been.calledWith(
- this.project._id
- )
- })
- it('should get all the files', function () {
- this.ProjectEntityHandler.promises.getAllFiles.should.have.been.calledWith(
- this.project._id
- )
- })
- it('should return the status and output files', function () {
- expect(this.result.status).to.equal('success')
- expect(this.result.outputFiles.map(f => f.path)).to.have.members(
- this.outputFiles.map(f => f.path)
- )
- })
- it('should return the buildId', function () {
- expect(this.result.buildId).to.equal(buildId)
- })
- it('should persist the cookie from the response', function () {
- expect(
- this.ClsiCookieManager.promises.setServerId
- ).to.have.been.calledWith(
- this.project._id,
- this.user_id,
- 'standard',
- 'e2',
- this.newClsiServerId
- )
- })
- })
- describe('with ranges on the pdf and stats/timings details', function () {
- beforeEach(async function () {
- this.ranges = [{ start: 1, end: 42, hash: 'foo' }]
- this.startXRefTable = 123
- this.size = 456
- this.contentId = '123-321'
- this.outputFiles = [
- {
- url: `/project/${this.project._id}/user/${this.user_id}/build/1234/output/output.pdf`,
- path: 'output.pdf',
- type: 'pdf',
- build: 1234,
- contentId: this.contentId,
- ranges: this.ranges,
- startXRefTable: this.startXRefTable,
- size: this.size,
- },
- {
- url: `/project/${this.project._id}/user/${this.user_id}/build/1234/output/output.log`,
- path: 'output.log',
- type: 'log',
- build: 1234,
- },
- ]
- this.stats = { fooStat: 1 }
- this.timings = { barTiming: 2 }
- this.responseBody.compile.outputFiles = this.outputFiles.map(
- outputFile => ({
- ...outputFile,
- url: `http://${CLSI_HOST}${outputFile.url}`,
- })
- )
- this.responseBody.compile.stats = this.stats
- this.responseBody.compile.timings = this.timings
- this.result = await this.ClsiManager.promises.sendRequest(
- this.project._id,
- this.user_id,
- { compileBackendClass: 'e2', compileGroup: 'standard' }
- )
- })
- it('should emit the caching details and stats/timings', function () {
- expect(this.result.status).to.equal('success')
- expect(this.result.clsiServerId).to.equal(this.newClsiServerId)
- expect(this.result.validationError).to.be.undefined
- expect(this.result.stats).to.deep.equal(this.stats)
- expect(this.result.timings).to.deep.equal(this.timings)
- const outputPdf = this.result.outputFiles.find(
- f => f.path === 'output.pdf'
- )
- expect(outputPdf.ranges).to.deep.equal(this.ranges)
- expect(outputPdf.startXRefTable).to.equal(this.startXRefTable)
- expect(outputPdf.contentId).to.equal(this.contentId)
- expect(outputPdf.size).to.equal(this.size)
- })
- })
- describe('with the incremental compile option', function () {
- beforeEach(async function () {
- const doc = this.docs['/main.tex']
- this.DocumentUpdaterHandler.promises.getProjectDocsIfMatch.resolves([
- { _id: doc._id, lines: doc.lines, v: 123 },
- ])
- this.ProjectEntityHandler.getAllDocPathsFromProject.returns({
- 'mock-doc-id-1': 'main.tex',
- })
- this.result = await this.ClsiManager.promises.sendRequest(
- this.project._id,
- this.user_id,
- {
- timeout: 100,
- incrementalCompilesEnabled: true,
- compileBackendClass: 'e2',
- compileGroup: 'priority',
- compileFromClsiCache: true,
- populateClsiCache: true,
- enablePdfCaching: true,
- pdfCachingMinChunkSize: 1337,
- }
- )
- })
- it('should get the project with the required fields', function () {
- this.ProjectGetter.promises.getProject.should.have.been.calledWith(
- this.project._id,
- {
- compiler: 1,
- rootDoc_id: 1,
- imageName: 1,
- rootFolder: 1,
- 'overleaf.history.id': 1,
- }
- )
- })
- it('should not explicitly flush the project to the database', function () {
- this.DocumentUpdaterHandler.promises.flushProjectToMongo.should.not.have.been.calledWith(
- this.project._id
- )
- })
- it('should get only the live docs from the docupdater with a background flush in docupdater', function () {
- this.DocumentUpdaterHandler.promises.getProjectDocsIfMatch.should.have.been.calledWith(
- this.project._id
- )
- })
- it('should not get any of the files', function () {
- this.ProjectEntityHandler.promises.getAllFiles.should.not.have.been
- .called
- })
- it('should build up the CLSI request', function () {
- this.FetchUtils.fetchStringWithResponse.should.have.been.calledWith(
- sinon.match(
- url =>
- url.hostname === CLSI_HOST &&
- url.pathname ===
- `/project/${this.project._id}/user/${this.user_id}/compile` &&
- url.searchParams.get('compileBackendClass') === 'e2' &&
- url.searchParams.get('compileGroup') === 'priority'
- ),
- {
- method: 'POST',
- json: sinon.match({
- compile: {
- options: {
- compiler: this.project.compiler,
- timeout: 100,
- imageName: this.project.imageName,
- draft: false,
- syncType: 'incremental',
- syncState: '01234567890abcdef',
- compileGroup: 'priority',
- compileFromClsiCache: true,
- populateClsiCache: true,
- enablePdfCaching: true,
- pdfCachingMinChunkSize: 1337,
- metricsMethod: 'priority',
- stopOnFirstError: false,
- },
- rootResourcePath: 'main.tex',
- resources: [
- {
- path: 'main.tex',
- content: this.docs['/main.tex'].lines.join('\n'),
- },
- ],
- },
- }),
- headers: {
- Accept: 'application/json',
- 'Content-Type': 'application/json',
- Cookie: `${this.clsiCookieKey}=${this.clsiServerId}`,
- },
- signal: sinon.match.instanceOf(AbortSignal),
- }
- )
- })
- })
- describe('when the root doc is set and not in the docupdater', function () {
- beforeEach(async function () {
- const doc = this.docs['/main.tex']
- this.DocumentUpdaterHandler.promises.getProjectDocsIfMatch.resolves([
- { _id: doc._id, lines: doc.lines, v: 123 },
- ])
- this.ProjectEntityHandler.getAllDocPathsFromProject.returns({
- 'mock-doc-id-1': 'main.tex',
- 'mock-doc-id-2': '/chapters/chapter1.tex',
- })
- await this.ClsiManager.promises.sendRequest(
- this.project._id,
- this.user_id,
- {
- timeout: 100,
- incrementalCompilesEnabled: true,
- rootDoc_id: 'mock-doc-id-2',
- }
- )
- })
- it('should still change the root path', function () {
- this.FetchUtils.fetchStringWithResponse.should.have.been.calledWith(
- sinon.match.any,
- sinon.match({
- json: { compile: { rootResourcePath: 'chapters/chapter1.tex' } },
- })
- )
- })
- })
- describe('when root doc override is valid', function () {
- beforeEach(async function () {
- await this.ClsiManager.promises.sendRequest(
- this.project._id,
- this.user_id,
- { rootDoc_id: 'mock-doc-id-2' }
- )
- })
- it('should change root path', function () {
- this.FetchUtils.fetchStringWithResponse.should.have.been.calledWith(
- sinon.match.any,
- sinon.match({
- json: { compile: { rootResourcePath: 'chapters/chapter1.tex' } },
- })
- )
- })
- })
- describe('when root doc override is invalid', function () {
- beforeEach(async function () {
- await this.ClsiManager.promises.sendRequest(
- this.project._id,
- this.user_id,
- { rootDoc_id: 'invalid-id' }
- )
- })
- it('should fallback to default root doc', function () {
- this.FetchUtils.fetchStringWithResponse.should.have.been.calledWith(
- sinon.match.any,
- sinon.match({
- json: { compile: { rootResourcePath: 'main.tex' } },
- })
- )
- })
- })
- describe('when the project has an invalid compiler', function () {
- beforeEach(async function () {
- this.project.compiler = 'context'
- await this.ClsiManager.promises.sendRequest(
- this.project._id,
- this.user_id,
- {}
- )
- })
- it('should set the compiler to pdflatex', function () {
- expect(this.FetchUtils.fetchStringWithResponse).to.have.been.calledWith(
- sinon.match.any,
- sinon.match({
- json: { compile: { options: { compiler: 'pdflatex' } } },
- })
- )
- })
- })
- describe('when there is no valid root document', function () {
- beforeEach(async function () {
- this.project.rootDoc_id = 'not-valid'
- await this.ClsiManager.promises.sendRequest(
- this.project._id,
- this.user_id,
- {}
- )
- })
- it('should set to main.tex', function () {
- expect(this.FetchUtils.fetchStringWithResponse).to.have.been.calledWith(
- sinon.match.any,
- sinon.match({
- json: { compile: { rootResourcePath: 'main.tex' } },
- })
- )
- })
- })
- describe('when there is no valid root document and no main.tex document', function () {
- beforeEach(async function () {
- this.project.rootDoc_id = 'not-valid'
- this.docs = {
- '/other.tex': {
- name: 'other.tex',
- _id: 'mock-doc-id-1',
- lines: ['Hello', 'world'],
- },
- '/chapters/chapter1.tex': {
- name: 'chapter1.tex',
- _id: 'mock-doc-id-2',
- lines: ['Chapter 1'],
- },
- }
- this.ProjectEntityHandler.promises.getAllDocs.resolves(this.docs)
- this.result = await this.ClsiManager.promises.sendRequest(
- this.project._id,
- this.user_id,
- {}
- )
- })
- it('should report a validation problem', function () {
- expect(this.result.status).to.equal('validation-problems')
- })
- })
- describe('when there is no valid root document and a single document which is not main.tex', function () {
- beforeEach(async function () {
- this.project.rootDoc_id = 'not-valid'
- this.docs = {
- '/other.tex': {
- name: 'other.tex',
- _id: 'mock-doc-id-1',
- lines: ['Hello', 'world'],
- },
- }
- this.ProjectEntityHandler.promises.getAllDocs.resolves(this.docs)
- await this.ClsiManager.promises.sendRequest(
- this.project._id,
- this.user_id,
- {}
- )
- })
- it('should set io to the only file', function () {
- expect(this.FetchUtils.fetchStringWithResponse).to.have.been.calledWith(
- sinon.match.any,
- sinon.match({
- json: { compile: { rootResourcePath: 'other.tex' } },
- })
- )
- })
- })
- describe('with the draft option', function () {
- beforeEach(async function () {
- await this.ClsiManager.promises.sendRequest(
- this.project._id,
- this.user_id,
- {
- timeout: 100,
- draft: true,
- }
- )
- })
- it('should add the draft option into the request', function () {
- expect(this.FetchUtils.fetchStringWithResponse).to.have.been.calledWith(
- sinon.match.any,
- sinon.match({
- json: { compile: { options: { draft: true } } },
- })
- )
- })
- })
- describe('with a failed compile', function () {
- beforeEach(async function () {
- this.responseBody.compile.status = 'failure'
- this.result = await this.ClsiManager.promises.sendRequest(
- this.project._id,
- this.user_id,
- {}
- )
- })
- it('should return a failure status', function () {
- expect(this.result.status).to.equal('failure')
- })
- })
- describe('with a sync conflict', function () {
- beforeEach(async function () {
- const conflictResponseBody = { compile: { status: 'conflict' } }
- this.FetchUtils.fetchStringWithResponse
- .withArgs(
- sinon.match.any,
- sinon.match({
- json: sinon.match(
- json => json.compile.options.syncType !== 'full'
- ),
- })
- )
- .resolves({
- body: JSON.stringify(conflictResponseBody),
- response: this.response,
- })
- this.result = await this.ClsiManager.promises.sendRequest(
- this.project._id,
- this.user_id,
- {}
- )
- })
- it('should send two requests to CLSI', function () {
- this.FetchUtils.fetchStringWithResponse.should.have.been.calledTwice
- })
- it('should call the CLSI first without syncType:full', function () {
- const compileOptions =
- this.FetchUtils.fetchStringWithResponse.getCall(0).args[1].json
- .compile.options
- expect(compileOptions.syncType).to.be.undefined
- })
- it('should call the CLSI a second time with syncType:full', function () {
- const compileOptions =
- this.FetchUtils.fetchStringWithResponse.getCall(1).args[1].json
- .compile.options
- expect(compileOptions.syncType).to.equal('full')
- })
- it('should return a success status', function () {
- this.result.status.should.equal('success')
- })
- })
- describe('with an unavailable response', function () {
- beforeEach(async function () {
- this.FetchUtils.fetchStringWithResponse.onCall(0).resolves({
- body: JSON.stringify({ compile: { status: 'unavailable' } }),
- response: this.response,
- })
- this.result = await this.ClsiManager.promises.sendRequest(
- this.project._id,
- this.user_id,
- {}
- )
- })
- it('should send two requests to CLSI', function () {
- this.FetchUtils.fetchStringWithResponse.should.have.been.calledTwice
- })
- it('should call the CLSI first without syncType:full', function () {
- const compileOptions =
- this.FetchUtils.fetchStringWithResponse.getCall(0).args[1].json
- .compile.options
- expect(compileOptions.syncType).to.be.undefined
- })
- it('should call the CLSI a second time with syncType:full', function () {
- const compileOptions =
- this.FetchUtils.fetchStringWithResponse.getCall(1).args[1].json
- .compile.options
- expect(compileOptions.syncType).to.equal('full')
- })
- it('should clear the CLSI server id cookie', function () {
- expect(
- this.ClsiCookieManager.promises.clearServerId
- ).to.have.been.calledWith(this.project._id, this.user_id)
- })
- it('should return a success status', function () {
- expect(this.result.status).to.equal('success')
- })
- })
- describe('when the resources fail the precompile check', function () {
- beforeEach(function () {
- this.ClsiFormatChecker.promises.checkRecoursesForProblems.rejects(
- new Error('failed')
- )
- })
- it('should throw an error', async function () {
- await expect(
- this.ClsiManager.promises.sendRequest(
- this.project._id,
- this.user_id,
- {}
- )
- ).to.be.rejected
- })
- })
- describe('when a new backend is configured', function () {
- beforeEach(async function () {
- this.Settings.apis.clsi_new = { url: 'https://compiles.somewhere.test' }
- await this.ClsiManager.promises.sendRequest(
- this.project._id,
- this.user_id,
- {
- compileBackendClass: 'e2',
- compileGroup: 'standard',
- }
- )
- // wait for the background task to finish
- await setTimeout(0)
- })
- it('makes a request to the new backend', function () {
- expect(this.FetchUtils.fetchStringWithResponse).to.have.been.calledTwice
- expect(this.FetchUtils.fetchStringWithResponse).to.have.been.calledWith(
- sinon.match(
- url =>
- url.host === CLSI_HOST &&
- url.pathname ===
- `/project/${this.project._id}/user/${this.user_id}/compile` &&
- url.searchParams.get('compileBackendClass') === 'e2' &&
- url.searchParams.get('compileGroup') === 'standard'
- )
- )
- expect(this.FetchUtils.fetchStringWithResponse).to.have.been.calledWith(
- sinon.match(
- url =>
- url.toString() ===
- `${this.Settings.apis.clsi_new.url}/project/${this.project._id}/user/${this.user_id}/compile?compileBackendClass=e2&compileGroup=standard`
- )
- )
- })
- })
- })
- describe('sendExternalRequest', function () {
- beforeEach(function () {
- this.submissionId = 'submission-id'
- this.clsiRequest = 'mock-request'
- })
- describe('with a successful compile', function () {
- beforeEach(async function () {
- this.outputFiles = [
- {
- url: `/project/${this.submissionId}/build/1234/output/output.pdf`,
- path: 'output.pdf',
- type: 'pdf',
- build: 1234,
- },
- {
- url: `/project/${this.submissionId}/build/1234/output/output.log`,
- path: 'output.log',
- type: 'log',
- build: 1234,
- },
- ]
- this.responseBody.compile.outputFiles = this.outputFiles.map(
- outputFile => ({
- ...outputFile,
- url: `http://${CLSI_HOST}${outputFile.url}`,
- })
- )
- this.result = await this.ClsiManager.promises.sendExternalRequest(
- this.submissionId,
- this.clsiRequest,
- { compileBackendClass: 'e2', compileGroup: 'standard' }
- )
- })
- it('should send the request to the CLSI', function () {
- this.FetchUtils.fetchStringWithResponse.should.have.been.calledWith(
- sinon.match(
- url =>
- url.host === CLSI_HOST &&
- url.pathname === `/project/${this.submissionId}/compile` &&
- url.searchParams.get('compileBackendClass') === 'e2' &&
- url.searchParams.get('compileGroup') === 'standard'
- ),
- {
- method: 'POST',
- json: this.clsiRequest,
- headers: {
- Accept: 'application/json',
- 'Content-Type': 'application/json',
- Cookie: `${this.clsiCookieKey}=${this.clsiServerId}`,
- },
- signal: sinon.match.instanceOf(AbortSignal),
- }
- )
- })
- it('should return the status and output files', function () {
- expect(this.result.status).to.equal('success')
- expect(this.result.outputFiles.map(f => f.path)).to.have.members(
- this.outputFiles.map(f => f.path)
- )
- })
- })
- describe('with a failed compile', function () {
- beforeEach(async function () {
- this.responseBody.compile.status = 'failure'
- this.result = await this.ClsiManager.promises.sendExternalRequest(
- this.submissionId,
- this.clsiRequest,
- {}
- )
- })
- it('should return a failure status', function () {
- expect(this.result.status).to.equal('failure')
- })
- })
- describe('when the resources fail the precompile check', function () {
- beforeEach(async function () {
- this.ClsiFormatChecker.promises.checkRecoursesForProblems.rejects(
- new Error('failed')
- )
- this.responseBody.compile.status = 'failure'
- })
- it('should throw an error', async function () {
- await expect(
- this.ClsiManager.promises.sendExternalRequest(
- this.submissionId,
- this.clsiRequest,
- {}
- )
- ).to.be.rejected
- })
- })
- })
- describe('deleteAuxFiles', function () {
- describe('with the standard compileGroup', function () {
- beforeEach(async function () {
- await this.ClsiManager.promises.deleteAuxFiles(
- this.project._id,
- this.user_id,
- { compileBackendClass: 'e2', compileGroup: 'standard' },
- 'node-1'
- )
- })
- it('should call the delete method in the standard CLSI', function () {
- this.FetchUtils.fetchString.should.have.been.calledWith(
- sinon.match(
- url =>
- url.host === CLSI_HOST &&
- url.pathname ===
- `/project/${this.project._id}/user/${this.user_id}` &&
- url.searchParams.get('compileBackendClass') === 'e2' &&
- url.searchParams.get('compileGroup') === 'standard' &&
- url.searchParams.get('clsiserverid') === 'node-1'
- ),
- { method: 'DELETE' }
- )
- })
- it('should clear the output.tar.gz files in clsi-cache', function () {
- this.ClsiCacheHandler.clearCache
- .calledWith(this.project._id, this.user_id)
- .should.equal(true)
- })
- it('should clear the project state from the docupdater', function () {
- this.DocumentUpdaterHandler.promises.clearProjectState
- .calledWith(this.project._id)
- .should.equal(true)
- })
- it('should clear the clsi persistance', function () {
- this.ClsiCookieManager.promises.clearServerId
- .calledWith(this.project._id, this.user_id)
- .should.equal(true)
- })
- it('should not persist a cookie on response', function () {
- expect(this.ClsiCookieManager.promises.setServerId).not.to.have.been
- .called
- })
- })
- })
- describe('wordCount', function () {
- describe('with root file', function () {
- beforeEach(async function () {
- await this.ClsiManager.promises.wordCount(
- this.project._id,
- this.user_id,
- false,
- { compileBackendClass: 'e2', compileGroup: 'standard' },
- 'node-1'
- )
- })
- it('should call wordCount with root file', function () {
- expect(this.FetchUtils.fetchString).to.have.been.calledWith(
- sinon.match(
- url =>
- url.toString() ===
- `http://clsi.example.com/project/${this.project._id}/user/${this.user_id}/wordcount?compileBackendClass=e2&compileGroup=standard&file=main.tex&image=mock-image-name&clsiserverid=node-1`
- )
- )
- })
- it('should not persist a cookie on response', function () {
- expect(this.ClsiCookieManager.promises.setServerId).not.to.have.been
- .called
- })
- })
- describe('with param file', function () {
- beforeEach(async function () {
- await this.ClsiManager.promises.wordCount(
- this.project._id,
- this.user_id,
- 'other.tex',
- { compileBackendClass: 'e2', compileGroup: 'standard' },
- 'node-2'
- )
- })
- it('should call wordCount with param file', function () {
- expect(this.FetchUtils.fetchString).to.have.been.calledWith(
- sinon.match(
- url =>
- url.host === CLSI_HOST &&
- url.pathname ===
- `/project/${this.project._id}/user/${this.user_id}/wordcount` &&
- url.searchParams.get('compileBackendClass') === 'e2' &&
- url.searchParams.get('compileGroup') === 'standard' &&
- url.searchParams.get('clsiserverid') === 'node-2' &&
- url.searchParams.get('file') === 'other.tex' &&
- url.searchParams.get('image') === 'mock-image-name'
- )
- )
- })
- it('should not persist a cookie on response', function () {
- expect(this.ClsiCookieManager.promises.setServerId).not.to.have.been
- .called
- })
- })
- })
- })
- function _makeResources(project, docs, files) {
- const resources = []
- for (const [path, doc] of Object.entries(docs)) {
- resources.push({
- path: path.replace(/^\//, ''),
- content: doc.lines.join('\n'),
- })
- }
- for (const [path, file] of Object.entries(files)) {
- let url, fallbackURL
- if (file.hash === GLOBAL_BLOB_HASH) {
- url = `${FILESTORE_URL}/history/global/hash/${file.hash}`
- fallbackURL = `${FILESTORE_URL}/project/${project._id}/file/${file._id}`
- } else if (file.hash) {
- url = `${FILESTORE_URL}/history/project/${project.overleaf.history.id}/hash/${file.hash}`
- fallbackURL = `${FILESTORE_URL}/project/${project._id}/file/${file._id}`
- } else {
- url = `${FILESTORE_URL}/project/${project._id}/file/${file._id}`
- }
- resources.push({
- path: path.replace(/^\//, ''),
- url,
- fallbackURL,
- modified: file.created.getTime(),
- })
- }
- return resources
- }
|