Use upsert when importing libraries.

server/controllers/apis/plex/index.js

@@ -3,6 +3,7 @@ import plexService from '../../../services/plexApi';
 
 const router = Router();
 
+// users
 router.get('/users', plexService.getUsers);
 router.get('/most-watched', plexService.getMostWatched);
 router.get('/sections', plexService.getSections);

server/models/index.js

@@ -7,7 +7,7 @@ const sequelize = new Sequelize(
   {
     dialect: 'postgres',
     host: 'localhost',
-    logging: false,
+    // logging: false,
   },
 );
 

server/models/plexLibrary.js

@@ -1,6 +1,9 @@
 const plexLibrary = (sequelize, DataTypes) => {
   const plexLibrary = sequelize.define('plex_library', {
-    title: DataTypes.STRING,
+    title: {
+      type: DataTypes.STRING,
+      unique: true,
+    },
     type: DataTypes.STRING,
     views: DataTypes.INTEGER,
     rating_key: DataTypes.INTEGER,

server/services/plexApi/importData.js

@@ -39,18 +39,25 @@ const importLibrary = async sectionId => {
 const createLibrary = libraryData => {
   console.log(libraryData[1]);
   libraryData.forEach(async data => {
-    await models.PlexLibrary.create({
-      userId: 1,
-      title: data.title,
-      type: data.type,
-      views: data.views,
-      rating_key: data.ratingKey,
-      metadata_path: data.key,
-      summary: data.summary,
-      rating: data.rating,
-      year: data.year,
-      genre: JSON.stringify(data.Genre),
-    });
+    await models.PlexLibrary.upsert(
+      {
+        userId: 1,
+        title: data.title,
+        type: data.type,
+        views: data.views,
+        rating_key: data.ratingKey,
+        metadata_path: data.key,
+        summary: data.summary,
+        rating: data.rating,
+        year: data.year,
+        genre: JSON.stringify(data.Genre),
+      },
+      {
+        where: {
+          title: data.title,
+        },
+      },
+    );
   });
 };
 

server/services/plexApi/plexApi.js

@@ -45,9 +45,10 @@ PlexApiClient.prototype.mostWatchedUrlParams = function(req) {
 };
 
 PlexApiClient.prototype.getLibraryDataBySectionUrlParams = function(req) {
+  const sectionId = req.sectionId || req.params.id;
   return {
     host: config.plex.plexServerUrl,
-    path: `/library/sections/${req.params.id}/all`,
+    path: `/library/sections/${sectionId}/all`,
     queryParams: {
       'X-Plex-Token': this.options.token || config.plex.token,
     },