fix(updated): Update completedChallenges and progressTimestamps without duplicates (#17226)

Closes #17200

common/models/user.js

@@ -46,24 +46,20 @@ function destroyAll(id, Model) {
 function buildCompletedChallengesUpdate(completedChallenges, project) {
   const key = Object.keys(project)[0];
   const solutions = project[key];
+  const solutionKeys = Object.keys(solutions);
   const currentCompletedChallenges = [ ...completedChallenges ];
   const currentCompletedProjects = currentCompletedChallenges
-    .filter(({id}) => Object.keys(solutions).includes(id));
+    .filter(({id}) => solutionKeys.includes(id));
   const now = Date.now();
-  const update = Object.keys(solutions).reduce((update, currentId) => {
+  const update = solutionKeys.reduce((update, currentId) => {
     const indexOfCurrentId = _.findIndex(
-      currentCompletedProjects,
+      update,
       ({id}) => id === currentId
     );
     const isCurrentlyCompleted = indexOfCurrentId !== -1;
-    if (
+    if (isCurrentlyCompleted) {
-      isCurrentlyCompleted &&
-      currentCompletedProjects[
-        indexOfCurrentId
-      ].solution !== solutions[currentId]
-    ) {
       update[indexOfCurrentId] = {
-        ...update[indexOfCurrentId],
+        ..._.find(update, ({id}) => id === currentId).__data,
         solution: solutions[currentId]
       };
     }
@@ -87,7 +83,11 @@ function buildCompletedChallengesUpdate(completedChallenges, project) {
     ],
     'id'
   );
-  return updatedExisting;
+  return {
+    updated: updatedExisting,
+    isNewCompletionCount:
+      updatedExisting.length - completedChallenges.length
+  };
 }
 
 function isTheSame(val1, val2) {
@@ -735,13 +735,26 @@ module.exports = function(User) {
     };
 
   User.prototype.updateMyProjects = function updateMyProjects(project) {
-    const updateData = {};
+    const updateData = { $set: {} };
     return this.getCompletedChallenges$()
-      .flatMap(completedChallenges => {
+      .flatMap(() => {
-        updateData.completedChallenges = buildCompletedChallengesUpdate(
+        const {
-          completedChallenges,
+          updated,
+          isNewCompletionCount
+        } = buildCompletedChallengesUpdate(
+          this.completedChallenges,
           project
         );
+        updateData.$set.completedChallenges = updated;
+        if (isNewCompletionCount) {
+          let points = [];
+          // give points a length of isNewCompletionCount
+          points[isNewCompletionCount - 1] = true;
+          updateData.$push = {};
+          updateData.$push.progressTimestamps = {
+            $each: points.map(() => Date.now())
+          };
+        }
         return this.update$(updateData);
       })
       .do(() => Object.assign(this, updateData))

server/boot/challenge.js

@@ -20,7 +20,7 @@ function buildUserUpdate(
   timezone
 ) {
   let finalChallenge;
-  const updateData = { $push: {} };
+  const updateData = {};
   const { timezone: userTimezone, completedChallenges = [] } = user;
 
   const oldChallenge = _.find(
@@ -44,9 +44,11 @@ function buildUserUpdate(
     };
   }
 
-  updateData.$push = {
+  updateData.$set = {
-    ...updateData.$push,
+    completedChallenges: _.uniqBy(
-    completedChallenges: finalChallenge
+      [finalChallenge, ...completedChallenges],
+      'id'
+    )
   };
 
   if (