From deca6f1f93e0f21e1a7be09d163aea6932ba1952 Mon Sep 17 00:00:00 2001
From: Thomas <thomas-@users.noreply.github.com>
Date: Thu, 26 Aug 2021 14:45:14 +0200
Subject: [PATCH] Add script to upgrade v1 project histories (if created after
 full project history enabled) (#4712)

GitOrigin-RevId: b329b83ae4167c3c58b947936d6a460f6f2b4327
---
 ...conversion_if_created_after_fph_enabled.js | 142 ++++++++++++++++++
 1 file changed, 142 insertions(+)
 create mode 100644 services/web/scripts/history/upgrade_v1_without_conversion_if_created_after_fph_enabled.js

diff --git a/services/web/scripts/history/upgrade_v1_without_conversion_if_created_after_fph_enabled.js b/services/web/scripts/history/upgrade_v1_without_conversion_if_created_after_fph_enabled.js
new file mode 100644
index 0000000000..b047f28421
--- /dev/null
+++ b/services/web/scripts/history/upgrade_v1_without_conversion_if_created_after_fph_enabled.js
@@ -0,0 +1,142 @@
+const SCRIPT_VERSION = 1
+const VERBOSE_LOGGING = process.env.VERBOSE_LOGGING === 'true'
+const WRITE_CONCURRENCY = parseInt(process.env.WRITE_CONCURRENCY, 10) || 10
+const BATCH_SIZE = parseInt(process.env.BATCH_SIZE, 10) || 100
+const DRY_RUN = process.env.DRY_RUN !== 'false'
+// persist fallback in order to keep batchedUpdate in-sync
+process.env.BATCH_SIZE = BATCH_SIZE
+
+const { ReadPreference, ObjectId } = require('mongodb')
+const { db } = require('../../app/src/infrastructure/mongodb')
+const { promiseMapWithLimit } = require('../../app/src/util/promises')
+const { batchedUpdate } = require('../helpers/batchedUpdate')
+
+console.log({ DRY_RUN, VERBOSE_LOGGING, WRITE_CONCURRENCY, BATCH_SIZE })
+
+const RESULT = {
+  DRY_RUN,
+  projectsUpgraded: 0,
+}
+
+const ID_WHEN_FULL_PROJECT_HISTORY_ENABLED = '5a8d8a370000000000000000'
+const OBJECT_ID_WHEN_FULL_PROJECT_HISTORY_ENABLED = new ObjectId(
+  ID_WHEN_FULL_PROJECT_HISTORY_ENABLED
+)
+const DATETIME_WHEN_FULL_PROJECT_HISTORY_ENABLED = OBJECT_ID_WHEN_FULL_PROJECT_HISTORY_ENABLED.getTimestamp()
+
+// set a default BATCH_LAST_ID at our cutoff point if none set
+// we still check against this cut off point later, even if
+// BATCH_LAST_ID is set to something problematic
+if (!process.env.BATCH_LAST_ID) {
+  process.env.BATCH_LAST_ID = ID_WHEN_FULL_PROJECT_HISTORY_ENABLED
+}
+
+async function processBatch(_, projects) {
+  await promiseMapWithLimit(WRITE_CONCURRENCY, projects, processProject)
+  console.log(RESULT)
+}
+
+async function processProject(project) {
+  // safety check
+  if (!projectCreatedAfterFullProjectHistoryEnabled(project)) {
+    return
+  }
+  // if they have SL history, continue to send to both history systems (for now)
+  const anyDocHistory = await anyDocHistoryExists(project)
+  if (anyDocHistory) {
+    return await doUpgradeForV1WithoutConversion(project, true)
+  }
+  const anyDocHistoryIndex = await anyDocHistoryIndexExists(project)
+  if (anyDocHistoryIndex) {
+    return await doUpgradeForV1WithoutConversion(project, true)
+  }
+  // or if no sl history, nothing to 'downgrade' to
+  return await doUpgradeForV1WithoutConversion(project, false)
+}
+
+function projectCreatedAfterFullProjectHistoryEnabled(project) {
+  return (
+    project._id.getTimestamp() >= DATETIME_WHEN_FULL_PROJECT_HISTORY_ENABLED
+  )
+}
+
+async function doUpgradeForV1WithoutConversion(project, allowDowngrade) {
+  const setProperties = {
+    'overleaf.history.display': true,
+    'overleaf.history.upgradedAt': new Date(),
+    'overleaf.history.upgradeReason': `v1-after-fph/${SCRIPT_VERSION}`,
+  }
+  if (allowDowngrade) {
+    setProperties['overleaf.history.allowDowngrade'] = true
+  }
+  if (!DRY_RUN) {
+    db.projects.updateOne(
+      { _id: project._id },
+      {
+        $set: setProperties,
+      }
+    )
+  }
+  if (VERBOSE_LOGGING) {
+    console.log(
+      `project ${project._id} converted to full project history${
+        allowDowngrade ? ', with allowDowngrade' : ''
+      }`
+    )
+  }
+  RESULT.projectsUpgraded += 1
+}
+
+async function anyDocHistoryExists(project) {
+  return await db.docHistory.findOne(
+    { project_id: { $eq: project._id } },
+    {
+      projection: { _id: 1 },
+      readPreference: ReadPreference.SECONDARY,
+    }
+  )
+}
+
+async function anyDocHistoryIndexExists(project) {
+  return await db.docHistoryIndex.findOne(
+    { project_id: { $eq: project._id } },
+    {
+      projection: { _id: 1 },
+      readPreference: ReadPreference.SECONDARY,
+    }
+  )
+}
+
+async function main() {
+  const projection = {
+    _id: 1,
+    overleaf: 1,
+  }
+  const options = {
+    hint: { _id: 1 },
+  }
+  await batchedUpdate(
+    'projects',
+    {
+      $and: [
+        { 'overleaf.history.display': { $ne: true } },
+        { 'overleaf.history.id': { $exists: true } },
+      ],
+    },
+    processBatch,
+    projection,
+    options
+  )
+  console.log('Final')
+  console.log(RESULT)
+}
+
+main()
+  .then(() => {
+    console.error('Done.')
+    process.exit(0)
+  })
+  .catch(error => {
+    console.error({ error })
+    process.exit(1)
+  })