wip

Author: etnoy

server/src/queries/asset.repository.sql

@@ -263,6 +263,9 @@ with
     where
       "assets"."deletedAt" is null
       and "assets"."isVisible" = $2
+      and "assets"."fileCreatedAt" is not null
+      and "assets"."fileModifiedAt" is not null
+      and "assets"."localDateTime" is not null
   )
 select
   "timeBucket",

server/src/queries/library.repository.sql

@@ -132,7 +132,10 @@ from
   inner join "assets" on "assets"."libraryId" = "libraries"."id"
   left join "exif" on "exif"."assetId" = "assets"."id"
 where
-  "libraries"."id" = $6
+  "assets"."fileCreatedAt" is not null
+  and "assets"."fileModifiedAt" is not null
+  and "assets"."localDateTime" is not null
+  and "libraries"."id" = $6
 group by
   "libraries"."id"
 select

server/src/repositories/asset.repository.ts

@@ -138,9 +138,6 @@ export class AssetRepository implements IAssetRepository {
           )
           .innerJoin('exif', 'a.id', 'exif.assetId')
           .selectAll('a')
-          .$narrowType<{ fileCreatedAt: NotNull }>()
-          .$narrowType<{ fileModifiedAt: NotNull }>()
-          .$narrowType<{ localDateTime: NotNull }>()
           .select((eb) => eb.fn.toJson(eb.table('exif')).as('exifInfo')),
       )
       .selectFrom('res')

server/src/repositories/library.repository.ts

@@ -100,6 +100,9 @@ export class LibraryRepository implements ILibraryRepository {
     const stats = await this.db
       .selectFrom('libraries')
       .innerJoin('assets', 'assets.libraryId', 'libraries.id')
+      .where('assets.fileCreatedAt', 'is not', null)
+      .where('assets.fileModifiedAt', 'is not', null)
+      .where('assets.localDateTime', 'is not', null)
       .leftJoin('exif', 'exif.assetId', 'assets.id')
       .select((eb) =>
         eb.fn

server/src/services/library.service.ts

@@ -574,9 +574,14 @@ export class LibraryService extends BaseService {
     }
 
     const mtime = stat.mtime;
-    const isTimeUpdated = !asset.fileModifiedAt || mtime.toISOString() !== asset.fileModifiedAt.toISOString();
 
-    if (isTimeUpdated) {
+    if (!asset.fileModifiedAt || !asset.fileCreatedAt || !asset.localDateTime) {
+      this.logger.verbose(`Asset ${asset.originalPath} needs metadata extraction in library ${libraryId}`);
+
+      return AssetSyncResult.UPDATE;
+    }
+
+    if (mtime.toISOString() !== asset.fileModifiedAt.toISOString()) {
       this.logger.verbose(
         `Asset ${asset.originalPath} modification time changed from ${asset.fileModifiedAt?.toISOString()} to ${mtime.toISOString()}, queuing re-import in library ${libraryId}`,
       );