fix: tmdb series and movies not caching

Author: aleksilassila

backend/src/metadata/metadata.entity.ts

@@ -25,6 +25,36 @@ export class MovieMetadata {
   @ApiProperty({ type: 'string' })
   @UpdateDateColumn()
   updatedAt: Date;
+
+  /**
+   * Requires update before serving
+   */
+  isOutdated() {
+    const releaseDate = this.tmdbMovie?.release_date;
+
+    if (!this.tmdbMovie) return true;
+    if (!this.updatedAt) return true;
+    if (
+      releaseDate &&
+      new Date() > new Date(releaseDate) &&
+      new Date(this.updatedAt) < new Date(releaseDate)
+    )
+      return true;
+
+    return false;
+  }
+
+  /**
+   * Can be lazily updated after serving
+   */
+  isStale() {
+    if (this.isOutdated()) return true;
+
+    if (new Date().getTime() - this.updatedAt.getTime() > TMDB_CACHE_TTL)
+      return true;
+
+    return false;
+  }
 }
 
 @Entity()
@@ -45,18 +75,32 @@ export class SeriesMetadata {
   @UpdateDateColumn()
   updatedAt: Date;
 
-  isStale() {
-    if (!this.updatedAt) return true;
+  /**
+   * Requires update before serving
+   */
+  isOutdated() {
+    const nextAirDate = this.tmdbSeries?.next_episode_to_air?.air_date;
 
-    if (new Date().getTime() - this.updatedAt.getTime() > TMDB_CACHE_TTL)
+    if (!this.tmdbSeries) return true;
+    if (!this.updatedAt) return true;
+    if (
+      nextAirDate &&
+      new Date() > new Date(nextAirDate) &&
+      new Date(this.updatedAt) < new Date(nextAirDate)
+    )
       return true;
 
-    if (
-      this.tmdbSeries?.next_episode_to_air?.air_date &&
-      new Date() > new Date(this.tmdbSeries.next_episode_to_air.air_date)
-    ) {
+    return false;
+  }
+
+  /**
+   * Can be lazily updated after serving
+   */
+  isStale() {
+    if (this.isOutdated()) return true;
+
+    if (new Date().getTime() - this.updatedAt.getTime() > TMDB_CACHE_TTL)
       return true;
-    }
 
     return false;
   }

backend/src/metadata/metadata.service.ts

@@ -37,18 +37,25 @@ export class MetadataService {
       movie.tmdbId = tmdbId;
     }
 
-    if (
-      !movie.updatedAt ||
-      new Date().getTime() - movie.updatedAt.getTime() > TMDB_CACHE_TTL
-    ) {
-      const tmdbMovie = await this.tmdbService.getFullMovie(Number(tmdbId));
-      movie.tmdbMovie = tmdbMovie;
+    if (movie.isStale()) {
+      const updatedMovie = this.tmdbService
+        .getFullMovie(Number(tmdbId))
+        .then(async (tmdbMovie) => {
+          if (tmdbMovie) {
+            movie.tmdbMovie = tmdbMovie;
+            movie.updatedAt = new Date();
+          }
+
+          await this.movieRepository.upsert(movie, {
+            conflictPaths: ['tmdbId'],
+          });
+
+          return movie;
+        });
+
+      if (movie.isOutdated()) return updatedMovie;
     }
 
-    await this.movieRepository.upsert(movie, {
-      conflictPaths: ['tmdbId'],
-    });
-
     return movie;
   }
 
@@ -66,14 +73,24 @@ export class MetadataService {
 
     if (series.isStale()) {
       this.logger.debug(`Caching series ${tmdbId}`);
-      const tmdbSeries = await this.tmdbService.getFullSeries(Number(tmdbId));
-      if (tmdbSeries) series.tmdbSeries = tmdbSeries;
+      const updatedSeries = this.tmdbService
+        .getFullSeries(Number(tmdbId))
+        .then(async (tmdbSeries) => {
+          if (tmdbSeries) {
+            series.tmdbSeries = tmdbSeries;
+            series.updatedAt = new Date();
+          }
+
+          await this.seriesRepository.upsert(series, {
+            conflictPaths: ['tmdbId'],
+          });
+
+          return series;
+        });
+
+      if (series.isOutdated()) return updatedSeries;
     }
 
-    await this.seriesRepository.upsert(series, {
-      conflictPaths: ['tmdbId'],
-    });
-
     return series;
   }
 }

backend/src/user-data/library/library.controller.ts

@@ -20,7 +20,7 @@ import {
   PaginationParamsDto,
   SuccessResponseDto,
 } from 'src/common/common.dto';
-import { LibraryItemDto, LibraryItemDto2 } from './library.dto';
+import { LibraryItemDto2 } from './library.dto';
 import { LibraryService } from './library.service';
 
 @ApiTags('users')

backend/src/user-data/library/library.service.ts

@@ -1,9 +1,9 @@
 import { Inject, Injectable } from '@nestjs/common';
-import { Repository } from 'typeorm';
-import { LibraryItem } from './library.entity';
 import { MediaType, PaginationParamsDto } from 'src/common/common.dto';
-import { LibraryItemDto, LibraryItemDto2 } from './library.dto';
 import { MetadataService } from 'src/metadata/metadata.service';
+import { Repository } from 'typeorm';
+import { LibraryItemDto2 } from './library.dto';
+import { LibraryItem } from './library.entity';
 import { USER_LIBRARY_REPOSITORY } from './library.providers';
 
 @Injectable()
@@ -31,6 +31,7 @@ export class LibraryService {
             ? await this.metadataService.getMovieByTmdbId(item.tmdbId)
             : undefined;
 
+
         return LibraryItemDto2.create({
           libraryItem: item,
           seriesMetadata,