mirror of
https://github.com/overleaf/overleaf.git
synced 2024-12-12 05:05:44 -05:00
4f32ddc4cb
Do size check on doc before queuing resyncDocContent GitOrigin-RevId: 315b849375fd17a2936adacaad4a93ccf283d853
274 lines
7.5 KiB
JavaScript
274 lines
7.5 KiB
JavaScript
/* eslint-disable
|
|
camelcase,
|
|
no-return-assign,
|
|
no-unused-vars,
|
|
*/
|
|
// TODO: This file was created by bulk-decaffeinate.
|
|
// Fix any style issues and re-enable lint.
|
|
/*
|
|
* decaffeinate suggestions:
|
|
* DS101: Remove unnecessary use of Array.from
|
|
* DS102: Remove unnecessary code created because of implicit returns
|
|
* Full docs: https://github.com/decaffeinate/decaffeinate/blob/master/docs/suggestions.md
|
|
*/
|
|
const sinon = require('sinon')
|
|
const modulePath = '../../../../app/js/ProjectHistoryRedisManager.js'
|
|
const SandboxedModule = require('sandboxed-module')
|
|
const tk = require('timekeeper')
|
|
|
|
describe('ProjectHistoryRedisManager', function () {
|
|
beforeEach(function () {
|
|
this.project_id = 'project-id-123'
|
|
this.projectHistoryId = 'history-id-123'
|
|
this.user_id = 'user-id-123'
|
|
this.callback = sinon.stub()
|
|
this.rclient = {}
|
|
tk.freeze(new Date())
|
|
|
|
this.Limits = {
|
|
docIsTooLarge: sinon.stub().returns(false),
|
|
}
|
|
|
|
return (this.ProjectHistoryRedisManager = SandboxedModule.require(
|
|
modulePath,
|
|
{
|
|
requires: {
|
|
'@overleaf/settings': (this.settings = {
|
|
max_doc_length: 123,
|
|
redis: {
|
|
project_history: {
|
|
key_schema: {
|
|
projectHistoryOps({ project_id }) {
|
|
return `ProjectHistory:Ops:${project_id}`
|
|
},
|
|
projectHistoryFirstOpTimestamp({ project_id }) {
|
|
return `ProjectHistory:FirstOpTimestamp:${project_id}`
|
|
},
|
|
},
|
|
},
|
|
},
|
|
}),
|
|
'@overleaf/redis-wrapper': {
|
|
createClient: () => this.rclient,
|
|
},
|
|
'./Metrics': (this.metrics = { summary: sinon.stub() }),
|
|
'./Limits': this.Limits,
|
|
},
|
|
}
|
|
))
|
|
})
|
|
|
|
afterEach(function () {
|
|
return tk.reset()
|
|
})
|
|
|
|
describe('queueOps', function () {
|
|
beforeEach(function () {
|
|
this.ops = ['mock-op-1', 'mock-op-2']
|
|
this.multi = { exec: sinon.stub() }
|
|
this.multi.rpush = sinon.stub()
|
|
this.multi.setnx = sinon.stub()
|
|
this.rclient.multi = () => this.multi
|
|
// @rclient = multi: () => @multi
|
|
return this.ProjectHistoryRedisManager.queueOps(
|
|
this.project_id,
|
|
...Array.from(this.ops),
|
|
this.callback
|
|
)
|
|
})
|
|
|
|
it('should queue an update', function () {
|
|
return this.multi.rpush
|
|
.calledWithExactly(
|
|
`ProjectHistory:Ops:${this.project_id}`,
|
|
this.ops[0],
|
|
this.ops[1]
|
|
)
|
|
.should.equal(true)
|
|
})
|
|
|
|
return it('should set the queue timestamp if not present', function () {
|
|
return this.multi.setnx
|
|
.calledWithExactly(
|
|
`ProjectHistory:FirstOpTimestamp:${this.project_id}`,
|
|
Date.now()
|
|
)
|
|
.should.equal(true)
|
|
})
|
|
})
|
|
|
|
describe('queueRenameEntity', function () {
|
|
beforeEach(function () {
|
|
this.file_id = 1234
|
|
|
|
this.rawUpdate = {
|
|
pathname: (this.pathname = '/old'),
|
|
newPathname: (this.newPathname = '/new'),
|
|
version: (this.version = 2),
|
|
}
|
|
|
|
this.ProjectHistoryRedisManager.queueOps = sinon.stub()
|
|
return this.ProjectHistoryRedisManager.queueRenameEntity(
|
|
this.project_id,
|
|
this.projectHistoryId,
|
|
'file',
|
|
this.file_id,
|
|
this.user_id,
|
|
this.rawUpdate,
|
|
this.callback
|
|
)
|
|
})
|
|
|
|
return it('should queue an update', function () {
|
|
const update = {
|
|
pathname: this.pathname,
|
|
new_pathname: this.newPathname,
|
|
meta: {
|
|
user_id: this.user_id,
|
|
ts: new Date(),
|
|
},
|
|
version: this.version,
|
|
projectHistoryId: this.projectHistoryId,
|
|
file: this.file_id,
|
|
}
|
|
|
|
return this.ProjectHistoryRedisManager.queueOps
|
|
.calledWithExactly(
|
|
this.project_id,
|
|
JSON.stringify(update),
|
|
this.callback
|
|
)
|
|
.should.equal(true)
|
|
})
|
|
})
|
|
|
|
return describe('queueAddEntity', function () {
|
|
beforeEach(function () {
|
|
this.rclient.rpush = sinon.stub().yields()
|
|
this.doc_id = 1234
|
|
|
|
this.rawUpdate = {
|
|
pathname: (this.pathname = '/old'),
|
|
docLines: (this.docLines = 'a\nb'),
|
|
version: (this.version = 2),
|
|
url: (this.url = 'filestore.example.com'),
|
|
}
|
|
|
|
this.ProjectHistoryRedisManager.queueOps = sinon.stub()
|
|
return this.ProjectHistoryRedisManager.queueAddEntity(
|
|
this.project_id,
|
|
this.projectHistoryId,
|
|
'doc',
|
|
this.doc_id,
|
|
this.user_id,
|
|
this.rawUpdate,
|
|
this.callback
|
|
)
|
|
})
|
|
|
|
it('should queue an update', function () {
|
|
const update = {
|
|
pathname: this.pathname,
|
|
docLines: this.docLines,
|
|
url: this.url,
|
|
meta: {
|
|
user_id: this.user_id,
|
|
ts: new Date(),
|
|
},
|
|
version: this.version,
|
|
projectHistoryId: this.projectHistoryId,
|
|
doc: this.doc_id,
|
|
}
|
|
|
|
return this.ProjectHistoryRedisManager.queueOps
|
|
.calledWithExactly(
|
|
this.project_id,
|
|
JSON.stringify(update),
|
|
this.callback
|
|
)
|
|
.should.equal(true)
|
|
})
|
|
|
|
describe('queueResyncProjectStructure', function () {
|
|
return it('should queue an update', function () {})
|
|
})
|
|
|
|
describe('queueResyncDocContent', function () {
|
|
beforeEach(function () {
|
|
this.doc_id = 1234
|
|
this.lines = ['one', 'two']
|
|
this.version = 2
|
|
this.pathname = '/path'
|
|
|
|
this.update = {
|
|
resyncDocContent: {
|
|
content: this.lines.join('\n'),
|
|
version: this.version,
|
|
},
|
|
projectHistoryId: this.projectHistoryId,
|
|
path: this.pathname,
|
|
doc: this.doc_id,
|
|
meta: {
|
|
ts: new Date(),
|
|
},
|
|
}
|
|
|
|
this.ProjectHistoryRedisManager.queueOps = sinon.stub()
|
|
})
|
|
|
|
describe('with a good doc', function () {
|
|
beforeEach(function () {
|
|
this.ProjectHistoryRedisManager.queueResyncDocContent(
|
|
this.project_id,
|
|
this.projectHistoryId,
|
|
this.doc_id,
|
|
this.lines,
|
|
this.version,
|
|
this.pathname,
|
|
this.callback
|
|
)
|
|
})
|
|
it('should check if the doc is too large', function () {
|
|
this.Limits.docIsTooLarge
|
|
.calledWith(
|
|
JSON.stringify(this.update).length,
|
|
this.lines,
|
|
this.settings.max_doc_length
|
|
)
|
|
.should.equal(true)
|
|
})
|
|
|
|
it('should queue an update', function () {
|
|
this.ProjectHistoryRedisManager.queueOps
|
|
.calledWithExactly(
|
|
this.project_id,
|
|
JSON.stringify(this.update),
|
|
this.callback
|
|
)
|
|
.should.equal(true)
|
|
})
|
|
})
|
|
|
|
describe('with a doc that is too large', function () {
|
|
beforeEach(function () {
|
|
this.Limits.docIsTooLarge.returns(true)
|
|
this.ProjectHistoryRedisManager.queueResyncDocContent(
|
|
this.project_id,
|
|
this.projectHistoryId,
|
|
this.doc_id,
|
|
this.lines,
|
|
this.version,
|
|
this.pathname,
|
|
this.callback
|
|
)
|
|
})
|
|
it('should not queue an update if the doc is too large', function () {
|
|
this.ProjectHistoryRedisManager.queueOps.called.should.equal(false)
|
|
this.callback
|
|
.calledWith(sinon.match.instanceOf(Error))
|
|
.should.equal(true)
|
|
})
|
|
})
|
|
})
|
|
})
|
|
})
|