mirror of
https://github.com/overleaf/overleaf.git
synced 2024-12-27 10:52:01 +00:00
297 lines
11 KiB
CoffeeScript
297 lines
11 KiB
CoffeeScript
should = require('chai').should()
|
|
spies = require('chai-spies')
|
|
chai = require('chai').use(spies)
|
|
sinon = require("sinon")
|
|
SandboxedModule = require('sandboxed-module')
|
|
assert = require('chai').assert
|
|
path = require 'path'
|
|
_ = require 'underscore'
|
|
modulePath = path.join __dirname, '../../../../app/js/Features/DocumentUpdater/DocumentUpdaterHandler'
|
|
|
|
describe 'DocumentUpdaterHandler - Flushing documents :', ->
|
|
|
|
beforeEach ->
|
|
@project_id = "project-id-923"
|
|
@doc_id = "doc-id-394"
|
|
@lines = ["one", "two", "three"]
|
|
@version = 42
|
|
@user_id = "mock-user-id-123"
|
|
@project =
|
|
_id: @project_id
|
|
|
|
@request = {}
|
|
@projectEntityHandler = {}
|
|
@rclient = {auth:->}
|
|
@settings =
|
|
apis : documentupdater: url : "http://something.com"
|
|
redis:{web:{}}
|
|
@handler = SandboxedModule.require modulePath, requires:
|
|
'request': defaults:=> return @request
|
|
'settings-sharelatex':@settings
|
|
'logger-sharelatex':{log:(->), error:(->)}
|
|
'../Project/ProjectEntityHandler':@projectEntityHandler
|
|
"../../models/Project": Project: @Project={}
|
|
'../../Features/Project/ProjectLocator':{}
|
|
'redis-sharelatex' : createClient: () => @rclient
|
|
"../../infrastructure/Metrics":
|
|
Timer:->
|
|
done:->
|
|
|
|
describe 'queueChange', ->
|
|
beforeEach ->
|
|
@change = {
|
|
"action":"removeText",
|
|
"range":{"start":{"row":2,"column":2},"end":{"row":2,"column":3}},
|
|
"text":"e"
|
|
}
|
|
@rclient.multi = sinon.stub().returns @rclient
|
|
@rclient.exec = sinon.stub().callsArg(0)
|
|
@rclient.rpush = sinon.stub()
|
|
@rclient.sadd = sinon.stub()
|
|
@callback = sinon.stub()
|
|
|
|
describe "successfully", ->
|
|
beforeEach ->
|
|
@handler.queueChange(@project_id, @doc_id, @change, @callback)
|
|
|
|
it "should push the change", ->
|
|
@rclient.rpush
|
|
.calledWith("PendingUpdates:#{@doc_id}", JSON.stringify(@change))
|
|
.should.equal true
|
|
|
|
it "should notify the doc updater of the change via the pending-updates-list queue", ->
|
|
@rclient.rpush
|
|
.calledWith("pending-updates-list", "#{@project_id}:#{@doc_id}")
|
|
.should.equal true
|
|
|
|
it "should push the doc id into the pending updates set", ->
|
|
@rclient.sadd
|
|
.calledWith("DocsWithPendingUpdates", "#{@project_id}:#{@doc_id}")
|
|
.should.equal true
|
|
|
|
describe "with error connecting to redis during exec", ->
|
|
beforeEach ->
|
|
@rclient.exec = sinon.stub().callsArgWith(0, new Error("something went wrong"))
|
|
@handler.queueChange(@project_id, @doc_id, @change, @callback)
|
|
|
|
it "should return an error", ->
|
|
@callback.calledWithExactly(sinon.match(Error)).should.equal true
|
|
|
|
|
|
describe 'flushProjectToMongo', ->
|
|
beforeEach ->
|
|
@callback = sinon.stub()
|
|
|
|
describe "successfully", ->
|
|
beforeEach ->
|
|
@request.post = sinon.stub().callsArgWith(1, null, {statusCode: 204}, "")
|
|
@handler.flushProjectToMongo @project_id, @callback
|
|
|
|
it 'should flush the document from the document updater', ->
|
|
url = "#{@settings.apis.documentupdater.url}/project/#{@project_id}/flush"
|
|
@request.post.calledWith(url).should.equal true
|
|
|
|
it "should call the callback with no error", ->
|
|
@callback.calledWith(null).should.equal true
|
|
|
|
describe "when the document updater API returns an error", ->
|
|
beforeEach ->
|
|
@request.post = sinon.stub().callsArgWith(1, @error = new Error("something went wrong"), null, null)
|
|
@handler.flushProjectToMongo @project_id, @callback
|
|
|
|
it "should return an error to the callback", ->
|
|
@callback.calledWith(@error).should.equal true
|
|
|
|
describe "when the document updater returns a failure error code", ->
|
|
beforeEach ->
|
|
@request.post = sinon.stub().callsArgWith(1, null, { statusCode: 500 }, "")
|
|
@handler.flushProjectToMongo @project_id, @callback
|
|
|
|
it "should return the callback with an error", ->
|
|
@callback
|
|
.calledWith(new Error("doc updater returned failure status code: 500"))
|
|
.should.equal true
|
|
|
|
describe 'flushProjectToMongoAndDelete', ->
|
|
beforeEach ->
|
|
@callback = sinon.stub()
|
|
|
|
describe "successfully", ->
|
|
beforeEach ->
|
|
@request.del = sinon.stub().callsArgWith(1, null, {statusCode: 204}, "")
|
|
@handler.flushProjectToMongoAndDelete @project_id, @callback
|
|
|
|
it 'should delete the project from the document updater', ->
|
|
url = "#{@settings.apis.documentupdater.url}/project/#{@project_id}"
|
|
@request.del.calledWith(url).should.equal true
|
|
|
|
it "should call the callback with no error", ->
|
|
@callback.calledWith(null).should.equal true
|
|
|
|
describe "when the document updater API returns an error", ->
|
|
beforeEach ->
|
|
@request.del = sinon.stub().callsArgWith(1, @error = new Error("something went wrong"), null, null)
|
|
@handler.flushProjectToMongoAndDelete @project_id, @callback
|
|
|
|
it "should return an error to the callback", ->
|
|
@callback.calledWith(@error).should.equal true
|
|
|
|
describe "when the document updater returns a failure error code", ->
|
|
beforeEach ->
|
|
@request.del = sinon.stub().callsArgWith(1, null, { statusCode: 500 }, "")
|
|
@handler.flushProjectToMongoAndDelete @project_id, @callback
|
|
|
|
it "should return the callback with an error", ->
|
|
@callback
|
|
.calledWith(new Error("doc updater returned failure status code: 500"))
|
|
.should.equal true
|
|
|
|
describe 'flushDocToMongo', ->
|
|
beforeEach ->
|
|
@callback = sinon.stub()
|
|
|
|
describe "successfully", ->
|
|
beforeEach ->
|
|
@request.post = sinon.stub().callsArgWith(1, null, {statusCode: 204}, "")
|
|
@handler.flushDocToMongo @project_id, @doc_id, @callback
|
|
|
|
it 'should flush the document from the document updater', ->
|
|
url = "#{@settings.apis.documentupdater.url}/project/#{@project_id}/doc/#{@doc_id}/flush"
|
|
@request.post.calledWith(url).should.equal true
|
|
|
|
it "should call the callback with no error", ->
|
|
@callback.calledWith(null).should.equal true
|
|
|
|
describe "when the document updater API returns an error", ->
|
|
beforeEach ->
|
|
@request.post = sinon.stub().callsArgWith(1, @error = new Error("something went wrong"), null, null)
|
|
@handler.flushDocToMongo @project_id, @doc_id, @callback
|
|
|
|
it "should return an error to the callback", ->
|
|
@callback.calledWith(@error).should.equal true
|
|
|
|
describe "when the document updater returns a failure error code", ->
|
|
beforeEach ->
|
|
@request.post = sinon.stub().callsArgWith(1, null, { statusCode: 500 }, "")
|
|
@handler.flushDocToMongo @project_id, @doc_id, @callback
|
|
|
|
it "should return the callback with an error", ->
|
|
@callback
|
|
.calledWith(new Error("doc updater returned failure status code: 500"))
|
|
.should.equal true
|
|
|
|
describe "deleteDoc", ->
|
|
beforeEach ->
|
|
@callback = sinon.stub()
|
|
|
|
describe "successfully", ->
|
|
beforeEach ->
|
|
@request.del = sinon.stub().callsArgWith(1, null, {statusCode: 204}, "")
|
|
@handler.deleteDoc @project_id, @doc_id, @callback
|
|
|
|
it 'should delete the document from the document updater', ->
|
|
url = "#{@settings.apis.documentupdater.url}/project/#{@project_id}/doc/#{@doc_id}"
|
|
@request.del.calledWith(url).should.equal true
|
|
|
|
it "should call the callback with no error", ->
|
|
@callback.calledWith(null).should.equal true
|
|
|
|
describe "when the document updater API returns an error", ->
|
|
beforeEach ->
|
|
@request.del = sinon.stub().callsArgWith(1, @error = new Error("something went wrong"), null, null)
|
|
@handler.deleteDoc @project_id, @doc_id, @callback
|
|
|
|
it "should return an error to the callback", ->
|
|
@callback.calledWith(@error).should.equal true
|
|
|
|
describe "when the document updater returns a failure error code", ->
|
|
beforeEach ->
|
|
@request.del = sinon.stub().callsArgWith(1, null, { statusCode: 500 }, "")
|
|
@handler.deleteDoc @project_id, @doc_id, @callback
|
|
|
|
it "should return the callback with an error", ->
|
|
@callback
|
|
.calledWith(new Error("doc updater returned failure status code: 500"))
|
|
.should.equal true
|
|
|
|
describe "setDocument", ->
|
|
beforeEach ->
|
|
@callback = sinon.stub()
|
|
@source = "dropbox"
|
|
|
|
describe "successfully", ->
|
|
beforeEach ->
|
|
@request.post = sinon.stub().callsArgWith(1, null, {statusCode: 204}, "")
|
|
@handler.setDocument @project_id, @doc_id, @user_id, @lines, @source, @callback
|
|
|
|
it 'should set the document in the document updater', ->
|
|
url = "#{@settings.apis.documentupdater.url}/project/#{@project_id}/doc/#{@doc_id}"
|
|
@request.post
|
|
.calledWith({
|
|
url: url
|
|
json:
|
|
lines: @lines
|
|
source: @source
|
|
user_id: @user_id
|
|
})
|
|
.should.equal true
|
|
|
|
it "should call the callback with no error", ->
|
|
@callback.calledWith(null).should.equal true
|
|
|
|
describe "when the document updater API returns an error", ->
|
|
beforeEach ->
|
|
@request.post = sinon.stub().callsArgWith(1, @error = new Error("something went wrong"), null, null)
|
|
@handler.setDocument @project_id, @doc_id, @user_id, @lines, @source, @callback
|
|
|
|
it "should return an error to the callback", ->
|
|
@callback.calledWith(@error).should.equal true
|
|
|
|
describe "when the document updater returns a failure error code", ->
|
|
beforeEach ->
|
|
@request.post = sinon.stub().callsArgWith(1, null, { statusCode: 500 }, "")
|
|
@handler.setDocument @project_id, @doc_id, @user_id, @lines, @source, @callback
|
|
|
|
it "should return the callback with an error", ->
|
|
@callback
|
|
.calledWith(new Error("doc updater returned failure status code: 500"))
|
|
.should.equal true
|
|
|
|
describe "getDocument", ->
|
|
beforeEach ->
|
|
@callback = sinon.stub()
|
|
|
|
describe "successfully", ->
|
|
beforeEach ->
|
|
@body = JSON.stringify
|
|
lines: @lines
|
|
version: @version
|
|
ops: @ops = ["mock-op-1", "mock-op-2"]
|
|
@fromVersion = 2
|
|
@request.get = sinon.stub().callsArgWith(1, null, {statusCode: 200}, @body)
|
|
@handler.getDocument @project_id, @doc_id, @fromVersion, @callback
|
|
|
|
it 'should get the document from the document updater', ->
|
|
url = "#{@settings.apis.documentupdater.url}/project/#{@project_id}/doc/#{@doc_id}?fromVersion=#{@fromVersion}"
|
|
@request.get.calledWith(url).should.equal true
|
|
|
|
it "should call the callback with the lines and version", ->
|
|
@callback.calledWith(null, @lines, @version, @ops).should.equal true
|
|
|
|
describe "when the document updater API returns an error", ->
|
|
beforeEach ->
|
|
@request.get = sinon.stub().callsArgWith(1, @error = new Error("something went wrong"), null, null)
|
|
@handler.getDocument @project_id, @doc_id, @fromVersion, @callback
|
|
|
|
it "should return an error to the callback", ->
|
|
@callback.calledWith(@error).should.equal true
|
|
|
|
describe "when the document updater returns a failure error code", ->
|
|
beforeEach ->
|
|
@request.get = sinon.stub().callsArgWith(1, null, { statusCode: 500 }, "")
|
|
@handler.getDocument @project_id, @doc_id, @fromVersion, @callback
|
|
|
|
it "should return the callback with an error", ->
|
|
@callback
|
|
.calledWith(new Error("doc updater returned failure status code: 500"))
|
|
.should.equal true
|