From 37f1fa6229bd65cce432ae52ad4e7a4f589b6a98 Mon Sep 17 00:00:00 2001 From: bwees Date: Fri, 22 May 2026 12:55:18 -0500 Subject: [PATCH] fix: await sync asset v2 --- mobile/lib/providers/infrastructure/action.provider.dart | 2 +- web/src/lib/managers/edit/edit-manager.svelte.ts | 2 +- web/src/lib/stores/websocket.ts | 4 ++-- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/mobile/lib/providers/infrastructure/action.provider.dart b/mobile/lib/providers/infrastructure/action.provider.dart index d73f3f1963..aa318da02d 100644 --- a/mobile/lib/providers/infrastructure/action.provider.dart +++ b/mobile/lib/providers/infrastructure/action.provider.dart @@ -536,7 +536,7 @@ class ActionNotifier extends Notifier { return ActionResult(count: ids.length, success: false, error: 'Expected single asset for applying edits'); } - final completer = ref.read(websocketProvider.notifier).waitForEvent("AssetEditReadyV1", (dynamic data) { + final completer = ref.read(websocketProvider.notifier).waitForEvent("AssetEditReadyV2", (dynamic data) { final eventAsset = SyncAssetV1.fromJson(data["asset"]); return eventAsset?.id == ids.first; }, const Duration(seconds: 10)); diff --git a/web/src/lib/managers/edit/edit-manager.svelte.ts b/web/src/lib/managers/edit/edit-manager.svelte.ts index 083a446938..dc454f854a 100644 --- a/web/src/lib/managers/edit/edit-manager.svelte.ts +++ b/web/src/lib/managers/edit/edit-manager.svelte.ts @@ -127,7 +127,7 @@ export class EditManager { try { // Setup the websocket listener before sending the edit request - const editCompleted = waitForWebsocketEvent('AssetEditReadyV1', (event) => event.asset.id === assetId, 10_000); + const editCompleted = waitForWebsocketEvent('AssetEditReadyV2', (event) => event.asset.id === assetId, 10_000); await (edits.length === 0 ? removeAssetEdits({ id: assetId }) diff --git a/web/src/lib/stores/websocket.ts b/web/src/lib/stores/websocket.ts index e5cc25bcf9..5765f85a16 100644 --- a/web/src/lib/stores/websocket.ts +++ b/web/src/lib/stores/websocket.ts @@ -5,7 +5,7 @@ import { type NotificationDto, type ServerVersionResponseDto, type SyncAssetEditV1, - type SyncAssetV1, + type SyncAssetV2, } from '@immich/sdk'; import { io, type Socket } from 'socket.io-client'; import { get, writable } from 'svelte/store'; @@ -41,7 +41,7 @@ export interface Events { AppRestartV1: (event: AppRestartEvent) => void; MaintenanceStatusV1: (event: MaintenanceStatusResponseDto) => void; - AssetEditReadyV1: (data: { asset: SyncAssetV1; edit: SyncAssetEditV1[] }) => void; + AssetEditReadyV2: (data: { asset: SyncAssetV2; edit: SyncAssetEditV1[] }) => void; } const websocket: Socket = io({