GettingUpdatesTests.coffee 2.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116
  1. sinon = require "sinon"
  2. chai = require("chai")
  3. chai.should()
  4. expect = chai.expect
  5. mongojs = require "../../../app/js/mongojs"
  6. db = mongojs.db
  7. ObjectId = mongojs.ObjectId
  8. Settings = require "settings-sharelatex"
  9. TrackChangesClient = require "./helpers/TrackChangesClient"
  10. MockWebApi = require "./helpers/MockWebApi"
  11. describe "Getting updates", ->
  12. before (done) ->
  13. @now = Date.now()
  14. @to = @now
  15. @user_id = ObjectId().toString()
  16. @doc_id = ObjectId().toString()
  17. @project_id = ObjectId().toString()
  18. @minutes = 60 * 1000
  19. @days = 24 * 60 * @minutes
  20. MockWebApi.users[@user_id] = @user =
  21. email: "user@sharelatex.com"
  22. first_name: "Leo"
  23. last_name: "Lion"
  24. id: @user_id
  25. sinon.spy MockWebApi, "getUser"
  26. @updates = []
  27. for i in [0..9]
  28. @updates.push {
  29. op: [{ i: "a", p: 0 }]
  30. meta: { ts: @now - (9 - i) * @days - 2 * @minutes, user_id: @user_id }
  31. v: 2 * i + 1
  32. }
  33. @updates.push {
  34. op: [{ i: "b", p: 0 }]
  35. meta: { ts: @now - (9 - i) * @days, user_id: @user_id }
  36. v: 2 * i + 2
  37. }
  38. TrackChangesClient.pushRawUpdates @project_id, @doc_id, @updates, (error) =>
  39. throw error if error?
  40. done()
  41. after: () ->
  42. MockWebApi.getUser.restore()
  43. describe "getting updates up to the limit", ->
  44. before (done) ->
  45. TrackChangesClient.getUpdates @project_id, { before: @to + 1, min_count: 3 }, (error, body) =>
  46. throw error if error?
  47. @updates = body.updates
  48. done()
  49. it "should fetch the user details from the web api", ->
  50. MockWebApi.getUser
  51. .calledWith(@user_id)
  52. .should.equal true
  53. it "should return at least the min_count number of summarized updates", ->
  54. docs1 = {}
  55. docs1[@doc_id] = toV: 20, fromV: 19
  56. docs2 = {}
  57. docs2[@doc_id] = toV: 18, fromV: 17
  58. docs3 = {}
  59. docs3[@doc_id] = toV: 16, fromV: 15
  60. expect(@updates.slice(0,3)).to.deep.equal [{
  61. docs: docs1
  62. meta:
  63. start_ts: @to - 2 * @minutes
  64. end_ts: @to
  65. users: [@user]
  66. }, {
  67. docs: docs2
  68. meta:
  69. start_ts: @to - 1 * @days - 2 * @minutes
  70. end_ts: @to - 1 * @days
  71. users: [@user]
  72. }, {
  73. docs: docs3
  74. meta:
  75. start_ts: @to - 2 * @days - 2 * @minutes
  76. end_ts: @to - 2 * @days
  77. users: [@user]
  78. }]
  79. describe "getting updates beyond the end of the database", ->
  80. before (done) ->
  81. TrackChangesClient.getUpdates @project_id, { before: @to - 8 * @days + 1, min_count: 30 }, (error, body) =>
  82. throw error if error?
  83. @updates = body.updates
  84. done()
  85. it "should return as many updates as it can", ->
  86. docs1 = {}
  87. docs1[@doc_id] = toV: 4, fromV: 3
  88. docs2 = {}
  89. docs2[@doc_id] = toV: 2, fromV: 1
  90. expect(@updates).to.deep.equal [{
  91. docs: docs1
  92. meta:
  93. start_ts: @to - 8 * @days - 2 * @minutes
  94. end_ts: @to - 8 * @days
  95. users: [@user]
  96. }, {
  97. docs: docs2
  98. meta:
  99. start_ts: @to - 9 * @days - 2 * @minutes
  100. end_ts: @to - 9 * @days
  101. users: [@user]
  102. }]