overleaf/services/document-updater/test/unit/js/ProjectHistoryRedisManager/ProjectHistoryRedisManagerTests.js

const sinon = require('sinon')
const { expect } = require('chai')
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.rclient = {}
    this.source = 'editor'
    tk.freeze(new Date())

    this.Limits = {
      docIsTooLarge: sinon.stub().returns(false),
    }

    this.ProjectHistoryRedisManager = SandboxedModule.require(modulePath, {
      requires: {
        '@overleaf/settings': (this.settings = {
          max_doc_length: 123,
          redis: {
            project_history: {
              key_schema: {
                projectHistoryOps({ project_id: projectId }) {
                  return `ProjectHistory:Ops:${projectId}`
                },
                projectHistoryFirstOpTimestamp({ project_id: projectId }) {
                  return `ProjectHistory:FirstOpTimestamp:${projectId}`
                },
              },
            },
          },
        }),
        '@overleaf/redis-wrapper': {
          createClient: () => this.rclient,
        },
        './Metrics': (this.metrics = { summary: sinon.stub() }),
        './Limits': this.Limits,
      },
    })
  })

  afterEach(function () {
    tk.reset()
  })

  describe('queueOps', function () {
    beforeEach(async function () {
      this.ops = ['mock-op-1', 'mock-op-2']
      this.multi = { exec: sinon.stub().resolves([1]) }
      this.multi.rpush = sinon.stub()
      this.multi.setnx = sinon.stub()
      this.rclient.multi = () => this.multi
      await this.ProjectHistoryRedisManager.promises.queueOps(
        this.project_id,
        ...this.ops
      )
    })

    it('should queue an update', function () {
      this.multi.rpush
        .calledWithExactly(
          `ProjectHistory:Ops:${this.project_id}`,
          this.ops[0],
          this.ops[1]
        )
        .should.equal(true)
    })

    it('should set the queue timestamp if not present', function () {
      this.multi.setnx
        .calledWithExactly(
          `ProjectHistory:FirstOpTimestamp:${this.project_id}`,
          Date.now()
        )
        .should.equal(true)
    })
  })

  describe('queueRenameEntity', function () {
    beforeEach(async function () {
      this.file_id = 1234

      this.rawUpdate = {
        pathname: (this.pathname = '/old'),
        newPathname: (this.newPathname = '/new'),
        version: (this.version = 2),
      }

      this.ProjectHistoryRedisManager.promises.queueOps = sinon
        .stub()
        .resolves()
      await this.ProjectHistoryRedisManager.promises.queueRenameEntity(
        this.project_id,
        this.projectHistoryId,
        'file',
        this.file_id,
        this.user_id,
        this.rawUpdate,
        this.source
      )
    })

    it('should queue an update', function () {
      const update = {
        pathname: this.pathname,
        new_pathname: this.newPathname,
        meta: {
          user_id: this.user_id,
          ts: new Date(),
          source: this.source,
        },
        version: this.version,
        projectHistoryId: this.projectHistoryId,
        file: this.file_id,
      }

      this.ProjectHistoryRedisManager.promises.queueOps
        .calledWithExactly(this.project_id, JSON.stringify(update))
        .should.equal(true)
    })
  })

  describe('queueAddEntity', function () {
    beforeEach(function () {
      this.doc_id = 1234

      this.rawUpdate = {
        pathname: (this.pathname = '/old'),
        docLines: (this.docLines = 'a\nb'),
        version: (this.version = 2),
      }

      this.ProjectHistoryRedisManager.promises.queueOps = sinon
        .stub()
        .resolves()
    })

    it('should queue an update', async function () {
      this.rawUpdate.url = this.url = 'filestore.example.com'
      await this.ProjectHistoryRedisManager.promises.queueAddEntity(
        this.project_id,
        this.projectHistoryId,
        'doc',
        this.doc_id,
        this.user_id,
        this.rawUpdate,
        this.source
      )

      const update = {
        pathname: this.pathname,
        docLines: this.docLines,
        url: this.url,
        meta: {
          user_id: this.user_id,
          ts: new Date(),
          source: this.source,
        },
        version: this.version,
        projectHistoryId: this.projectHistoryId,
        doc: this.doc_id,
      }

      this.ProjectHistoryRedisManager.promises.queueOps
        .calledWithExactly(this.project_id, JSON.stringify(update))
        .should.equal(true)
    })

    it('should forward history compatible ranges if history ranges support is enabled', async function () {
      this.rawUpdate.historyRangesSupport = true
      this.docLines = 'the quick fox jumps over the lazy dog'

      const ranges = {
        changes: [
          {
            op: { p: 4, i: 'quick' },
            metadata: { ts: '2024-01-01T00:00:00.000Z', user_id: 'user-1' },
          },
          {
            op: { p: 9, d: ' brown' },
            metadata: { ts: '2024-02-01T00:00:00.000Z', user_id: 'user-1' },
          },
          {
            op: { p: 14, i: 'jumps' },
            metadata: { ts: '2024-02-01T00:00:00.000Z', user_id: 'user-1' },
          },
        ],
        comments: [
          {
            op: { p: 29, c: 'lazy', t: 'comment-1' },
            metadata: { resolved: false },
          },
        ],
      }
      this.rawUpdate.ranges = ranges
      this.rawUpdate.docLines = this.docLines

      await this.ProjectHistoryRedisManager.promises.queueAddEntity(
        this.project_id,
        this.projectHistoryId,
        'doc',
        this.doc_id,
        this.user_id,
        this.rawUpdate,
        this.source
      )

      const historyCompatibleRanges = {
        comments: [
          {
            op: { p: 29, c: 'lazy', t: 'comment-1', hpos: 35 },
            metadata: { resolved: false },
          },
        ],
        changes: [
          {
            op: { p: 4, i: 'quick' },
            metadata: { ts: '2024-01-01T00:00:00.000Z', user_id: 'user-1' },
          },
          {
            op: { p: 9, d: ' brown' },
            metadata: { ts: '2024-02-01T00:00:00.000Z', user_id: 'user-1' },
          },
          {
            op: { p: 14, i: 'jumps', hpos: 20 },
            metadata: { ts: '2024-02-01T00:00:00.000Z', user_id: 'user-1' },
          },
        ],
      }

      const update = {
        pathname: this.pathname,
        docLines: 'the quick brown fox jumps over the lazy dog',
        meta: {
          user_id: this.user_id,
          ts: new Date(),
          source: this.source,
        },
        version: this.version,
        projectHistoryId: this.projectHistoryId,
        ranges: historyCompatibleRanges,
        doc: this.doc_id,
      }

      expect(
        this.ProjectHistoryRedisManager.promises.queueOps
      ).to.have.been.calledWithExactly(this.project_id, JSON.stringify(update))
    })

    it('should not forward ranges if history ranges support is disabled', async function () {
      this.rawUpdate.historyRangesSupport = false

      const ranges = {
        changes: [
          {
            op: { p: 0, i: 'foo' },
            metadata: { ts: '2024-01-01T00:00:00.000Z', user_id: 'user-1' },
          },
          {
            op: { p: 7, d: ' baz' },
            metadata: { ts: '2024-02-01T00:00:00.000Z', user_id: 'user-1' },
          },
        ],
        comments: [
          {
            op: { p: 4, c: 'bar', t: 'comment-1' },
            metadata: { resolved: false },
          },
        ],
      }
      this.rawUpdate.ranges = ranges

      await this.ProjectHistoryRedisManager.promises.queueAddEntity(
        this.project_id,
        this.projectHistoryId,
        'doc',
        this.doc_id,
        this.user_id,
        this.rawUpdate,
        this.source
      )

      const update = {
        pathname: this.pathname,
        docLines: this.docLines,
        meta: {
          user_id: this.user_id,
          ts: new Date(),
          source: this.source,
        },
        version: this.version,
        projectHistoryId: this.projectHistoryId,
        doc: this.doc_id,
      }

      this.ProjectHistoryRedisManager.promises.queueOps
        .calledWithExactly(this.project_id, JSON.stringify(update))
        .should.equal(true)
    })

    it('should not forward ranges if history ranges support is undefined', async function () {
      this.rawUpdate.historyRangesSupport = false

      const ranges = {
        changes: [
          {
            op: { p: 0, i: 'foo' },
            metadata: { ts: '2024-01-01T00:00:00.000Z', user_id: 'user-1' },
          },
          {
            op: { p: 7, d: ' baz' },
            metadata: { ts: '2024-02-01T00:00:00.000Z', user_id: 'user-1' },
          },
        ],
        comments: [
          {
            op: { p: 4, c: 'bar', t: 'comment-1' },
            metadata: { resolved: false },
          },
        ],
      }
      this.rawUpdate.ranges = ranges

      await this.ProjectHistoryRedisManager.promises.queueAddEntity(
        this.project_id,
        this.projectHistoryId,
        'doc',
        this.doc_id,
        this.user_id,
        this.rawUpdate,
        this.source
      )

      const update = {
        pathname: this.pathname,
        docLines: this.docLines,
        meta: {
          user_id: this.user_id,
          ts: new Date(),
          source: this.source,
        },
        version: this.version,
        projectHistoryId: this.projectHistoryId,
        doc: this.doc_id,
      }

      this.ProjectHistoryRedisManager.promises.queueOps
        .calledWithExactly(this.project_id, JSON.stringify(update))
        .should.equal(true)
    })
  })

  describe('queueResyncProjectStructure', function () {
    it('should queue an update', function () {})
  })

  describe('queueResyncDocContent', function () {
    beforeEach(function () {
      this.doc_id = 1234
      this.lines = ['one', 'two']
      this.ranges = {
        changes: [{ op: { i: 'ne', p: 1 } }, { op: { d: 'deleted', p: 3 } }],
      }
      this.resolvedCommentIds = ['comment-1']
      this.version = 2
      this.pathname = '/path'

      this.ProjectHistoryRedisManager.promises.queueOps = sinon
        .stub()
        .resolves()
    })

    describe('with a good doc', function () {
      beforeEach(async function () {
        this.update = {
          resyncDocContent: {
            content: 'one\ntwo',
            version: this.version,
          },
          projectHistoryId: this.projectHistoryId,
          path: this.pathname,
          doc: this.doc_id,
          meta: { ts: new Date() },
        }

        await this.ProjectHistoryRedisManager.promises.queueResyncDocContent(
          this.project_id,
          this.projectHistoryId,
          this.doc_id,
          this.lines,
          this.ranges,
          this.resolvedCommentIds,
          this.version,
          this.pathname,
          false
        )
      })

      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.promises.queueOps
          .calledWithExactly(this.project_id, JSON.stringify(this.update))
          .should.equal(true)
      })
    })

    describe('with a doc that is too large', function () {
      beforeEach(async function () {
        this.Limits.docIsTooLarge.returns(true)
        await expect(
          this.ProjectHistoryRedisManager.promises.queueResyncDocContent(
            this.project_id,
            this.projectHistoryId,
            this.doc_id,
            this.lines,
            this.ranges,
            this.resolvedCommentIds,
            this.version,
            this.pathname,
            false
          )
        ).to.be.rejected
      })

      it('should not queue an update if the doc is too large', function () {
        this.ProjectHistoryRedisManager.promises.queueOps.called.should.equal(
          false
        )
      })
    })

    describe('when history ranges support is enabled', function () {
      beforeEach(async function () {
        this.update = {
          resyncDocContent: {
            content: 'onedeleted\ntwo',
            version: this.version,
            ranges: this.ranges,
            resolvedCommentIds: this.resolvedCommentIds,
          },
          projectHistoryId: this.projectHistoryId,
          path: this.pathname,
          doc: this.doc_id,
          meta: { ts: new Date() },
        }

        await this.ProjectHistoryRedisManager.promises.queueResyncDocContent(
          this.project_id,
          this.projectHistoryId,
          this.doc_id,
          this.lines,
          this.ranges,
          this.resolvedCommentIds,
          this.version,
          this.pathname,
          true
        )
      })

      it('should include tracked deletes in the update', function () {
        this.ProjectHistoryRedisManager.promises.queueOps.should.have.been.calledWithExactly(
          this.project_id,
          JSON.stringify(this.update)
        )
      })

      it('should check the doc length without tracked deletes', function () {
        this.Limits.docIsTooLarge.should.have.been.calledWith(
          JSON.stringify(this.update).length,
          this.lines,
          this.settings.max_doc_length
        )
      })

      it('should queue an update', function () {
        this.ProjectHistoryRedisManager.promises.queueOps
          .calledWithExactly(this.project_id, JSON.stringify(this.update))
          .should.equal(true)
      })
    })
  })
})