Info lors d'un ajout d'album déjà en collection

src/middleware/Albums.js

@@ -167,6 +167,7 @@ Publié automatiquement via #musictopus`;
             genre,
             style,
             userId: collectionUserId,
+            discogsIds,
         } = this.req.query;
 
         let userId = this.req.user?._id;
@@ -216,6 +217,10 @@ Publié automatiquement via #musictopus`;
             userId = userIsSharingCollection._id;
         }
 
+        if (discogsIds) {
+            where.discogsId = { $in: discogsIds };
+        }
+
         const count = await AlbumsModel.count({
             User: userId,
             ...where,

src/routes/api/v1/search.js

@@ -3,6 +3,7 @@ import { ensureLoggedIn } from "connect-ensure-login";
 
 import { sendResponse } from "../../../libs/format";
 import { searchSong, getAlbumDetails } from "../../../helpers";
+import Albums from "../../../middleware/Albums";
 
 // eslint-disable-next-line new-cap
 const router = express.Router();
@@ -16,6 +17,30 @@ router.route("/").get(ensureLoggedIn("/connexion"), async (req, res, next) => {
             req.query.country || null
         );
 
+        const discogsIds = [];
+        const foundIds = [];
+
+        for (let i = 0; i < data.results.length; i += 1) {
+            discogsIds.push(data.results[i].id);
+        }
+
+        req.query.discogsIds = discogsIds;
+
+        const albums = new Albums(req);
+        const myAlbums = await albums.getAll();
+
+        if (myAlbums.rows) {
+            for (let i = 0; i < myAlbums.rows.length; i += 1) {
+                foundIds.push(myAlbums.rows[i].discogsId);
+            }
+        }
+
+        for (let i = 0; i < data.results.length; i += 1) {
+            data.results[i].inCollection = foundIds.includes(
+                data.results[i].id
+            );
+        }
+
         sendResponse(req, res, data);
     } catch (err) {
         next(err);