Adding Spotify: If Duplicate, update current instead of creating enw

Author: mangledbottles

src/controller/Spotify.controller.ts

@@ -122,6 +122,27 @@ exports.storeSpotifyCredentials = ({ email, display_name, product, country, spot
   })
 }
 
+exports.updateSpotifyCredentials = (providerId: string, { email, display_name, product, country, spotifyId,
+  expires_in, access_token, refresh_token }, userId) => {
+  return new Promise(async (resolve, reject) => {
+    try {
+      const connection = await connect();
+      const repo = connection.getRepository(MusicProviders);
+
+      const additional = { product, country, spotifyId, email, display_name };
+      const response = await repo.save({
+        providerId, userId,
+        country, expiresIn: expires_in, accessToken: access_token, refreshToken: refresh_token, additional, displayName: display_name
+      })
+
+      resolve(response);
+
+    } catch (error) {
+      reject(error);
+    }
+  });
+}
+
 /**
  * Spotify Search for song
  *

src/routes/Callback.route.ts

@@ -5,22 +5,29 @@ const NAMESPACE = 'Callback';
 
 /** Import dependecies */
 const Spotify = require('../controller/Spotify.controller');
- 
+
 
 router.get('/spotify', async (req: Request, res: Response) => {
     try {
-        globalThis.Logger.log('info', `[${NAMESPACE}] Authenticating from Spotify `, { ...globalThis.LoggingParams})
+        globalThis.Logger.log('info', `[${NAMESPACE}] Authenticating from Spotify `, { ...globalThis.LoggingParams })
 
         const { code, state } = req.query;
         const [userId, device] = state.toString().split("+");
         const { email, display_name, product, country, spotifyId,
             expires_in, access_token, refresh_token } = await Spotify.authorizeUser(code);
 
-        await Spotify.storeSpotifyCredentials({
-            email, display_name, product, country, spotifyId,
-            expires_in, access_token, refresh_token
-        }, userId);
         const { isDuplicate, providerId } = await Spotify.checkIfSpotifyAccountDuplicate(userId, spotifyId);
+        if (isDuplicate) {
+            await Spotify.updateSpotifyCredentials(providerId, {
+                email, display_name, product, country, spotifyId,
+                expires_in, access_token, refresh_token
+            }, userId);
+        } else {
+            await Spotify.storeSpotifyCredentials({
+                email, display_name, product, country, spotifyId,
+                expires_in, access_token, refresh_token
+            }, userId);
+        }
 
         /** Requirement for Hosts only
         if(product != "premium") res.status().json({
@@ -32,11 +39,11 @@ router.get('/spotify', async (req: Request, res: Response) => {
         } else if (device == 'Android') {
             res.redirect("https://fonzmusic.com/spotify");
         } else {
-            res.status(400).send({ message: "Invalid device"});
+            res.status(400).send({ message: "Invalid device" });
         }
     } catch (error) {
         globalThis.Logger.log('error', `[${NAMESPACE}] Could not Authenticate from Spotify `, { ...globalThis.LoggingParams, error },)
-    
+
         res.status(error.status || 500).send(error);
     }
 });