feat: AssetUploadReadyV1 event (#19858)

Author: jrasm91

server/src/repositories/event.repository.ts

@@ -16,6 +16,7 @@ import { AssetResponseDto } from 'src/dtos/asset-response.dto';
 import { AuthDto } from 'src/dtos/auth.dto';
 import { NotificationDto } from 'src/dtos/notification.dto';
 import { ReleaseNotification, ServerVersionResponseDto } from 'src/dtos/server.dto';
+import { SyncAssetExifV1, SyncAssetV1 } from 'src/dtos/sync.dto';
 import { ImmichWorker, MetadataKey, QueueName } from 'src/enum';
 import { ConfigRepository } from 'src/repositories/config.repository';
 import { LoggingRepository } from 'src/repositories/logging.repository';
@@ -109,6 +110,8 @@ export interface ClientEventMap {
   on_new_release: [ReleaseNotification];
   on_notification: [NotificationDto];
   on_session_delete: [string];
+
+  AssetUploadReadyV1: [{ asset: SyncAssetV1; exif: SyncAssetExifV1 }];
 }
 
 export type EventItem<T extends EmitEvent> = {

server/src/services/job.service.ts

@@ -19,6 +19,7 @@ import {
 import { ArgOf, ArgsOf } from 'src/repositories/event.repository';
 import { BaseService } from 'src/services/base.service';
 import { ConcurrentQueueName, JobItem } from 'src/types';
+import { hexOrBufferToBase64 } from 'src/utils/bytes';
 
 const asJobItem = (dto: JobCreateDto): JobItem => {
   switch (dto.name) {
@@ -304,6 +305,54 @@ export class JobService extends BaseService {
         await this.jobRepository.queueAll(jobs);
         if (asset.visibility === AssetVisibility.TIMELINE || asset.visibility === AssetVisibility.ARCHIVE) {
           this.eventRepository.clientSend('on_upload_success', asset.ownerId, mapAsset(asset));
+          if (asset.exifInfo) {
+            const exif = asset.exifInfo;
+            this.eventRepository.clientSend('AssetUploadReadyV1', asset.ownerId, {
+              // TODO remove `on_upload_success` and then modify the query to select only the required fields)
+              asset: {
+                id: asset.id,
+                ownerId: asset.ownerId,
+                originalFileName: asset.originalFileName,
+                thumbhash: asset.thumbhash ? hexOrBufferToBase64(asset.thumbhash) : null,
+                checksum: hexOrBufferToBase64(asset.checksum),
+                fileCreatedAt: asset.fileCreatedAt,
+                fileModifiedAt: asset.fileModifiedAt,
+                localDateTime: asset.localDateTime,
+                duration: asset.duration,
+                type: asset.type,
+                deletedAt: asset.deletedAt,
+                isFavorite: asset.isFavorite,
+                visibility: asset.visibility,
+              },
+              exif: {
+                assetId: exif.assetId,
+                description: exif.description,
+                exifImageWidth: exif.exifImageWidth,
+                exifImageHeight: exif.exifImageHeight,
+                fileSizeInByte: exif.fileSizeInByte,
+                orientation: exif.orientation,
+                dateTimeOriginal: exif.dateTimeOriginal,
+                modifyDate: exif.modifyDate,
+                timeZone: exif.timeZone,
+                latitude: exif.latitude,
+                longitude: exif.longitude,
+                projectionType: exif.projectionType,
+                city: exif.city,
+                state: exif.state,
+                country: exif.country,
+                make: exif.make,
+                model: exif.model,
+                lensModel: exif.lensModel,
+                fNumber: exif.fNumber,
+                focalLength: exif.focalLength,
+                iso: exif.iso,
+                exposureTime: exif.exposureTime,
+                profileDescription: exif.profileDescription,
+                rating: exif.rating,
+                fps: exif.fps,
+              },
+            });
+          }
         }
 
         break;