fix(api): 🐛 games are not duplicated for a given release or tag (#492)

Include local dev data.

✅ Closes: #491

.data/games/agerating.metadata.json

@@ -1 +1 @@
-{"indexes":[{"v":{"$numberInt":"2"},"key":{"_id":{"$numberInt":"1"}},"name":"_id_"}],"uuid":"4910f19cfe5e497cba8135106061fbf2","collectionName":"agerating","type":"collection"}
+{"indexes":[{"v":{"$numberInt":"2"},"key":{"_id":{"$numberInt":"1"}},"name":"_id_"}],"uuid":"36e900b16aa94018bf9c744eab3fe290","collectionName":"agerating","type":"collection"}

.data/games/assets.metadata.json

@@ -1 +1 @@
-{"indexes":[{"v":{"$numberInt":"2"},"key":{"_id":{"$numberInt":"1"}},"name":"_id_"}],"uuid":"49864dfc319b4456880df0075f64a6f7","collectionName":"assets","type":"collection"}
+{"indexes":[{"v":{"$numberInt":"2"},"key":{"_id":{"$numberInt":"1"}},"name":"_id_"}],"uuid":"8a19cf814cc34ac4928df8f9f9b53b94","collectionName":"assets","type":"collection"}

.data/games/company.metadata.json

@@ -1 +1 @@
-{"indexes":[{"v":{"$numberInt":"2"},"key":{"_id":{"$numberInt":"1"}},"name":"_id_"}],"uuid":"cd8542959d9b41ccae0a197fad38585d","collectionName":"company","type":"collection"}
+{"indexes":[{"v":{"$numberInt":"2"},"key":{"_id":{"$numberInt":"1"}},"name":"_id_"}],"uuid":"4a6e5e537167467e958726f77af9339f","collectionName":"company","type":"collection"}

.data/games/completionstatus.metadata.json

@@ -1 +1 @@
-{"indexes":[{"v":{"$numberInt":"2"},"key":{"_id":{"$numberInt":"1"}},"name":"_id_"}],"uuid":"25e892ab0e204d7099b87c6f7b3fa3be","collectionName":"completionstatus","type":"collection"}
+{"indexes":[{"v":{"$numberInt":"2"},"key":{"_id":{"$numberInt":"1"}},"name":"_id_"}],"uuid":"1e0c3290b51e4988bf5e40d63cd04d8e","collectionName":"completionstatus","type":"collection"}

.data/games/consolidated-games.metadata.json

@@ -1 +1 @@
-{"indexes":[{"v":{"$numberInt":"2"},"key":{"_id":{"$numberInt":"1"}},"name":"_id_"}],"uuid":"eeba5ef3253046debdf955836b0e23e5","collectionName":"consolidated-games","type":"collection"}
+{"indexes":[{"v":{"$numberInt":"2"},"key":{"_id":{"$numberInt":"1"}},"name":"_id_"}],"uuid":"c813d5dccc764cdd9f53fc92cd885228","collectionName":"consolidated-games","type":"collection"}

.data/games/game.metadata.json

@@ -1 +1 @@
-{"indexes":[{"v":{"$numberInt":"2"},"key":{"_id":{"$numberInt":"1"}},"name":"_id_"}],"uuid":"6afdb1473dae413da5cbc3fa0298d90b","collectionName":"game","type":"collection"}
+{"indexes":[{"v":{"$numberInt":"2"},"key":{"_id":{"$numberInt":"1"}},"name":"_id_"}],"uuid":"14e3e4eb1ff5466eb6a65c7517e2ac58","collectionName":"game","type":"collection"}

.data/games/gamefeature.metadata.json

@@ -1 +1 @@
-{"indexes":[{"v":{"$numberInt":"2"},"key":{"_id":{"$numberInt":"1"}},"name":"_id_"}],"uuid":"422377182dcf4de49ace4ed224015e24","collectionName":"gamefeature","type":"collection"}
+{"indexes":[{"v":{"$numberInt":"2"},"key":{"_id":{"$numberInt":"1"}},"name":"_id_"}],"uuid":"9ef6bf04d2684510a3519cd240fe18a0","collectionName":"gamefeature","type":"collection"}

.data/games/gamesource.metadata.json

@@ -1 +1 @@
-{"indexes":[{"v":{"$numberInt":"2"},"key":{"_id":{"$numberInt":"1"}},"name":"_id_"}],"uuid":"c9efdc97c44a432f9f5bdd5718aae120","collectionName":"gamesource","type":"collection"}
+{"indexes":[{"v":{"$numberInt":"2"},"key":{"_id":{"$numberInt":"1"}},"name":"_id_"}],"uuid":"170e9232130e4c2fbc08e1c495d31136","collectionName":"gamesource","type":"collection"}

.data/games/genre.metadata.json

@@ -1 +1 @@
-{"indexes":[{"v":{"$numberInt":"2"},"key":{"_id":{"$numberInt":"1"}},"name":"_id_"}],"uuid":"ca53ece8f111420b89e6bd582b45a916","collectionName":"genre","type":"collection"}
+{"indexes":[{"v":{"$numberInt":"2"},"key":{"_id":{"$numberInt":"1"}},"name":"_id_"}],"uuid":"0ea04227a82b40efaab7be21ddabc4c1","collectionName":"genre","type":"collection"}

.data/games/platform.metadata.json

@@ -1 +1 @@
-{"indexes":[{"v":{"$numberInt":"2"},"key":{"_id":{"$numberInt":"1"}},"name":"_id_"}],"uuid":"0ed6d6cbbd934a5f95aa41427812beb8","collectionName":"platform","type":"collection"}
+{"indexes":[{"v":{"$numberInt":"2"},"key":{"_id":{"$numberInt":"1"}},"name":"_id_"}],"uuid":"b0699a5c85a9408c978d7bf58d60dfd5","collectionName":"platform","type":"collection"}

.data/games/region.metadata.json

@@ -1 +1 @@
-{"indexes":[{"v":{"$numberInt":"2"},"key":{"_id":{"$numberInt":"1"}},"name":"_id_"}],"uuid":"67920823e8914dfaab3f06efc74bae2a","collectionName":"region","type":"collection"}
+{"indexes":[{"v":{"$numberInt":"2"},"key":{"_id":{"$numberInt":"1"}},"name":"_id_"}],"uuid":"7d7c69f8238f4a42ae76e18b744d3f08","collectionName":"region","type":"collection"}

.data/games/series.metadata.json

@@ -1 +1 @@
-{"indexes":[{"v":{"$numberInt":"2"},"key":{"_id":{"$numberInt":"1"}},"name":"_id_"}],"uuid":"e0d726cb9c5549849c279cba90d33143","collectionName":"series","type":"collection"}
+{"indexes":[{"v":{"$numberInt":"2"},"key":{"_id":{"$numberInt":"1"}},"name":"_id_"}],"uuid":"2d7c4ceb0cc84e9983d0a7578cd0fbec","collectionName":"series","type":"collection"}

.data/games/tag.metadata.json

@@ -1 +1 @@
-{"indexes":[{"v":{"$numberInt":"2"},"key":{"_id":{"$numberInt":"1"}},"name":"_id_"}],"uuid":"7e824dacb8874e308b24b6fb7022119c","collectionName":"tag","type":"collection"}
+{"indexes":[{"v":{"$numberInt":"2"},"key":{"_id":{"$numberInt":"1"}},"name":"_id_"}],"uuid":"5b24eaae57914aa880ba55721dd20f2e","collectionName":"tag","type":"collection"}

apps/game-db-updater/src/handlers/persistGameEntities.ts

@@ -4,7 +4,7 @@ import { v6 as guid } from 'uuid'
 import type { IHandlePublishedTopics } from '../IHandlePublishedTopics'
 import { getDbClient } from '../dbClient'
 
-const { isEmpty } = _
+const { isEmpty, uniq } = _
 
 const debug = createDebugger(
   'playnite-web/game-db-updater/handler/persistGameEntities',
@@ -53,60 +53,79 @@ const handler: IHandlePublishedTopics = async (topic, payload) => {
 
       if (isEmpty(consolidatedGames)) {
         const id = guid()
+        await client.db('games').collection('consolidated-games').insertOne({
+          id,
+          name: entity.name,
+          releases: [],
+          description: entity.description,
+          playlists: [],
+        })
+      }
+
+      const releaseCursor = await client
+        .db('games')
+        .collection<{ name: string; releases: string[] }>('consolidated-games')
+        .aggregate([
+          {
+            $match: { name: entity.name },
+          },
+          {
+            $project: {
+              releases: {
+                $concatArrays: ['$releases', [entityId]],
+              },
+            },
+          },
+        ])
+      for await (const doc of releaseCursor) {
         await client
           .db('games')
-          .collection('consolidated-games')
-          .insertOne({
-            id,
-            name: entity.name,
-            releases: [entityId],
-            description: entity.description,
-            playlists:
-              entity?.tags
-                ?.filter((tag) => isPlaylistTag.test(tag.name))
-                ?.map((tag) => tag.id) ?? [],
-          })
-      } else {
-        await client
-          .db('games')
-          .collection<{ releases: string[] }>('consolidated-games')
-          .updateOne({ name: entity.name }, { $push: { releases: entityId } })
-        const cursor = await client
-          .db('games')
-          .collection<{ name: string; releases: string[] }>(
+          .collection<{ name: string; releases: Array<string> }>(
             'consolidated-games',
           )
-          .aggregate([
+          .updateOne(
+            { name: entity.name },
             {
-              $match: { name: entity.name },
-            },
-            {
-              $project: {
-                playlists: {
-                  $concatArrays:
-                    entity?.tags
-                      ?.filter((tag) => isPlaylistTag.test(tag.name))
-                      ?.map((tag) => tag.id) ?? [],
-                },
+              $set: {
+                releases: uniq(doc.releases ?? []),
               },
             },
-          ])
+          )
+      }
 
-        for await (const doc of cursor) {
-          await client
-            .db('games')
-            .collection<{ name: string; playlists: Array<string> }>(
-              'consolidated-games',
-            )
-            .updateOne(
-              { name: entity.name },
-              {
-                $set: {
-                  playlists: doc.playlists ?? [],
-                },
+      const playlists =
+        entity?.tags
+          ?.filter((tag) => isPlaylistTag.test(tag.name))
+          ?.map((tag) => tag.id) ?? []
+      const cursor = await client
+        .db('games')
+        .collection<{ name: string; releases: string[] }>('consolidated-games')
+        .aggregate([
+          {
+            $match: { name: entity.name },
+          },
+          {
+            $project: {
+              playlists: {
+                $concatArrays: ['$playlists', playlists],
               },
-            )
-        }
+            },
+          },
+        ])
+      for await (const doc of cursor) {
+        await client
+          .db('games')
+          .collection<{ name: string; playlists: Array<string> }>(
+            'consolidated-games',
+          )
+          .updateOne(
+            { name: entity.name },
+            {
+              $set: {
+                playlists: uniq(doc.playlists ?? []),
+              },
+            },
+          )
       }
     }
   } catch (e) {

apps/playnite-web/cypress/e2e/homepage.cy.ts

@@ -11,10 +11,10 @@ describe('Homepage', () => {
     cy.viewport(1366, 1080)
     cy.visit('/')
     cy.contains('h4', 'On Deck').parents('[data-test="playlist"]')
-    cy.get('[data-test="GameFigure"]').should('have.length', 8)
+    cy.get('[data-test="GameFigure"]').should('have.length', 9)
     cy.get('[data-test="GameFigure"]')
       .eq(0)
-      .should('have.text', 'Black Myth: Wukong')
+      .should('have.text', 'Star Ocean: The Second Story R')
 
     cy.get('[data-test="playlist"] ul').compareSnapshot({
       name: 'homepage-playing-playlist',
@@ -37,9 +37,13 @@ describe('Homepage', () => {
     cy.get('[data-test="GameFigure"] span').eq(0).click({ force: true })
     cy.get('[data-test="GameDetails"] h4').should(
       'have.text',
-      'Black Myth: Wukong',
+      'Star Ocean: The Second Story R',
     )
-    const description = `Black Myth: Wukong is an action RPG rooted in Chinese mythology. The story is based on Journey to the West, one of the Four Great Classical Novels of Chinese literature. You shall set out as the Destined One to venture into the challenges and marvels ahead, to uncover the obscured truth beneath the veil of a glorious legend from the past.`
+    const description = `Two worlds, one fateful encounter.
+
+In an endless sea of stars, at the edge of the universe, two people who live in different worlds go on a journey to save planet Expel.
+
+Choose your path and witness an awakened destiny.`
     cy.get('[data-test="GameDetails"]').should('contain.text', description)
     cy.get('[name="close-drawer"]').click()
     cy.get('[data-test="GameDetails"]').should('not.exist')

apps/playnite-web/project.json

@@ -28,7 +28,7 @@
       "executor": "nx:run-commands",
       "options": {
         "cwd": "{projectRoot}",
-        "command": "yarn cross-env NODE_ENV=development DEBUG='playnite-web/*' yarn node --experimental-json-modules scripts/utils/startDevServer.js"
+        "command": "yarn cross-env NODE_ENV=development yarn node --experimental-json-modules scripts/utils/startDevServer.js"
       }
     },
     "test/unit": {