feat: fix discriminated type parsing

mobile/lib/domain/services/asset.service.dart

@@ -4,6 +4,7 @@ import 'package:immich_mobile/domain/models/exif.model.dart';
 import 'package:immich_mobile/extensions/platform_extensions.dart';
 import 'package:immich_mobile/infrastructure/repositories/local_asset.repository.dart';
 import 'package:immich_mobile/infrastructure/repositories/remote_asset.repository.dart';
+import 'package:openapi/api.dart';
 
 typedef _AssetVideoDimension = ({double? width, double? height, bool isFlipped});
 
@@ -116,4 +117,12 @@ class AssetService {
   Future<List<LocalAlbum>> getSourceAlbums(String localAssetId, {BackupSelection? backupSelection}) {
     return _localAssetRepository.getSourceAlbums(localAssetId, backupSelection: backupSelection);
   }
+
+  Future<AssetEditsDto?> getAssetEdits(String assetId) {
+    return _remoteAssetRepository.getAssetEdits(assetId);
+  }
+
+  Future<AssetEditsDto?> editAsset(String assetId, AssetEditActionListDto edits) {
+    return _remoteAssetRepository.editAsset(assetId, edits);
+  }
 }

mobile/lib/infrastructure/repositories/remote_asset.repository.dart

@@ -9,11 +9,13 @@ import 'package:immich_mobile/infrastructure/entities/remote_asset.entity.drift.
 import 'package:immich_mobile/infrastructure/entities/stack.entity.drift.dart';
 import 'package:immich_mobile/infrastructure/repositories/db.repository.dart';
 import 'package:maplibre_gl/maplibre_gl.dart';
+import 'package:openapi/api.dart' hide AssetVisibility;
 
 class RemoteAssetRepository extends DriftDatabaseRepository {
   final Drift _db;
+  final AssetsApi _api;
 
-  const RemoteAssetRepository(this._db) : super(_db);
+  const RemoteAssetRepository(this._db, this._api) : super(_db);
 
   /// For testing purposes
   Future<List<RemoteAsset>> getSome(String userId) {
@@ -258,4 +260,12 @@ class RemoteAssetRepository extends DriftDatabaseRepository {
   Future<int> getCount() {
     return _db.managers.remoteAssetEntity.count();
   }
+
+  Future<AssetEditsDto?> getAssetEdits(String assetId) async {
+    return _api.getAssetEdits(assetId);
+  }
+
+  Future<AssetEditsDto?> editAsset(String assetId, AssetEditActionListDto edits) {
+    return _api.editAsset(assetId, edits);
+  }
 }

mobile/lib/presentation/pages/editing/drift_edit.page.dart

@@ -11,6 +11,7 @@ import 'package:immich_mobile/domain/models/asset/base_asset.model.dart';
 import 'package:immich_mobile/entities/asset.entity.dart';
 import 'package:immich_mobile/extensions/build_context_extensions.dart';
 import 'package:immich_mobile/providers/background_sync.provider.dart';
+import 'package:immich_mobile/providers/infrastructure/asset.provider.dart';
 import 'package:immich_mobile/repositories/file_media.repository.dart';
 import 'package:immich_mobile/routing/router.dart';
 import 'package:immich_mobile/services/foreground_upload.service.dart';
@@ -91,6 +92,8 @@ class DriftEditImagePage extends ConsumerWidget {
 
   @override
   Widget build(BuildContext context, WidgetRef ref) {
+    final edits = ref.read(assetServiceProvider).getAssetEdits(asset.remoteId!);
+
     return Scaffold(
       appBar: AppBar(
         title: Text("edit".tr()),
@@ -139,6 +142,12 @@ class DriftEditImagePage extends ConsumerWidget {
         child: Row(
           mainAxisAlignment: MainAxisAlignment.spaceEvenly,
           children: <Widget>[
+            FutureBuilder(
+              future: edits,
+              builder: (ctx, data) {
+                return Text(data.hasData ? data.data?.edits.length.toString() ?? "" : "...");
+              },
+            ),
             Column(
               mainAxisAlignment: MainAxisAlignment.center,
               children: <Widget>[

mobile/lib/presentation/widgets/images/thumbnail_tile.widget.dart

@@ -6,7 +6,6 @@ import 'package:immich_mobile/domain/models/setting.model.dart';
 import 'package:immich_mobile/extensions/build_context_extensions.dart';
 import 'package:immich_mobile/extensions/duration_extensions.dart';
 import 'package:immich_mobile/extensions/theme_extensions.dart';
-import 'package:immich_mobile/presentation/widgets/asset_viewer/asset_viewer.state.dart';
 import 'package:immich_mobile/presentation/widgets/images/thumbnail.widget.dart';
 import 'package:immich_mobile/presentation/widgets/timeline/constants.dart';
 import 'package:immich_mobile/providers/backup/asset_upload_progress.provider.dart';
@@ -48,7 +47,6 @@ class _ThumbnailTileState extends ConsumerState<ThumbnailTile> {
   Widget build(BuildContext context) {
     final asset = widget.asset;
     final heroIndex = widget.heroOffset ?? TabsRouterScope.of(context)?.controller.activeIndex ?? 0;
-    final isCurrentAsset = ref.watch(assetViewerProvider.select((current) => current.currentAsset == asset));
 
     final assetContainerColor = context.isDarkTheme
         ? context.primaryColor.darken(amount: 0.4)
@@ -61,10 +59,6 @@ class _ThumbnailTileState extends ConsumerState<ThumbnailTile> {
     final bool storageIndicator =
         ref.watch(settingsProvider.select((s) => s.get(Setting.showStorageIndicator))) && widget.showStorageIndicator;
 
-    if (!isCurrentAsset) {
-      _hideIndicators = false;
-    }
-
     if (isSelected) {
       _showSelectionContainer = true;
     }
@@ -102,11 +96,7 @@ class _ThumbnailTileState extends ConsumerState<ThumbnailTile> {
               children: [
                 Positioned.fill(
                   child: Hero(
-                    // This key resets the hero animation when the asset is changed in the asset viewer.
-                    // It doesn't seem like the best solution, and only works to reset the hero, not prime the hero of the new active asset for animation,
-                    // but other solutions have failed thus far.
-                    key: ValueKey(isCurrentAsset),
-                    tag: '${asset?.heroTag}_$heroIndex',
+                    tag: '${asset?.heroTag ?? ''}_$heroIndex',
                     child: Thumbnail.fromAsset(asset: asset, size: widget.size),
                     // Placeholderbuilder used to hide indicators on first hero animation, since flightShuttleBuilder isn't called until both source and destination hero exist in widget tree.
                     placeholderBuilder: (context, heroSize, child) {

mobile/lib/providers/infrastructure/asset.provider.dart

@@ -3,6 +3,7 @@ import 'package:immich_mobile/domain/services/asset.service.dart';
 import 'package:immich_mobile/infrastructure/repositories/local_asset.repository.dart';
 import 'package:immich_mobile/infrastructure/repositories/remote_asset.repository.dart';
 import 'package:immich_mobile/infrastructure/repositories/trashed_local_asset.repository.dart';
+import 'package:immich_mobile/providers/api.provider.dart';
 import 'package:immich_mobile/providers/infrastructure/db.provider.dart';
 import 'package:immich_mobile/providers/user.provider.dart';
 
@@ -11,7 +12,7 @@ final localAssetRepository = Provider<DriftLocalAssetRepository>(
 );
 
 final remoteAssetRepositoryProvider = Provider<RemoteAssetRepository>(
-  (ref) => RemoteAssetRepository(ref.watch(driftProvider)),
+  (ref) => RemoteAssetRepository(ref.watch(driftProvider), ref.watch(apiServiceProvider).assetsApi),
 );
 
 final trashedLocalAssetRepository = Provider<DriftTrashedLocalAssetRepository>(

mobile/openapi/lib/model/asset_edit_action_list_dto_edits_inner.dart

@@ -19,7 +19,7 @@ class AssetEditActionListDtoEditsInner {
 
   AssetEditAction action;
 
-  MirrorParameters parameters;
+  Map<String, dynamic> parameters;
 
   @override
   bool operator ==(Object other) => identical(this, other) || other is AssetEditActionListDtoEditsInner &&
@@ -52,7 +52,7 @@ class AssetEditActionListDtoEditsInner {
 
       return AssetEditActionListDtoEditsInner(
         action: AssetEditAction.fromJson(json[r'action'])!,
-        parameters: MirrorParameters.fromJson(json[r'parameters'])!,
+        parameters: json[r'parameters'],
       );
     }
     return null;

open-api/bin/generate-open-api.sh

@@ -21,6 +21,7 @@ function dart {
   patch --no-backup-if-mismatch -u ../mobile/openapi/lib/api_client.dart <./patch/api_client.dart.patch
   patch --no-backup-if-mismatch -u ../mobile/openapi/lib/api.dart <./patch/api.dart.patch
   patch --no-backup-if-mismatch -u ../mobile/openapi/pubspec.yaml <./patch/pubspec_immich_mobile.yaml.patch
+  patch --no-backup-if-mismatch -u ../mobile/openapi/lib/model/asset_edit_action_list_dto_edits_inner.dart <./patch/asset_edit_action_list_dto_edits_inner.dart.patch
   # Don't include analysis_options.yaml for the generated openapi files
   # so that language servers can properly exclude the mobile/openapi directory
   rm ../mobile/openapi/analysis_options.yaml

open-api/patch/asset_edit_action_list_dto_edits_inner.dart.patch

@@ -0,0 +1,20 @@
+--- /tmp/asset_edit_orig.dart	2026-01-20 10:38:05
++++ /tmp/asset_edit_final.dart	2026-01-20 10:40:33
+@@ -19,7 +19,7 @@
+ 
+   AssetEditAction action;
+ 
+-  MirrorParameters parameters;
++  Map<String, dynamic> parameters;
+ 
+   @override
+   bool operator ==(Object other) => identical(this, other) || other is AssetEditActionListDtoEditsInner &&
+@@ -62,7 +62,7 @@
+ 
+       return AssetEditActionListDtoEditsInner(
+         action: AssetEditAction.fromJson(json[r'action'])!,
+-        parameters: MirrorParameters.fromJson(json[r'parameters'])!,
++        parameters: json[r'parameters'],
+       );
+     }
+     return null;

plugins/manifest.json

@@ -1,6 +1,6 @@
 {
   "name": "immich-core",
-  "version": "2.4.1",
+  "version": "2.0.1",
   "title": "Immich Core",
   "description": "Core workflow capabilities for Immich",
   "author": "Immich Team",
@@ -12,7 +12,9 @@
       "methodName": "filterFileName",
       "title": "Filter by filename",
       "description": "Filter assets by filename pattern using text matching or regular expressions",
-      "supportedContexts": ["asset"],
+      "supportedContexts": [
+        "asset"
+      ],
       "schema": {
         "type": "object",
         "properties": {
@@ -24,7 +26,11 @@
           "matchType": {
             "type": "string",
             "title": "Match type",
-            "enum": ["contains", "regex", "exact"],
+            "enum": [
+              "contains",
+              "regex",
+              "exact"
+            ],
             "default": "contains",
             "description": "Type of pattern matching to perform"
           },
@@ -34,14 +40,18 @@
             "description": "Whether matching should be case-sensitive"
           }
         },
-        "required": ["pattern"]
+        "required": [
+          "pattern"
+        ]
       }
     },
     {
       "methodName": "filterFileType",
       "title": "Filter by file type",
       "description": "Filter assets by file type",
-      "supportedContexts": ["asset"],
+      "supportedContexts": [
+        "asset"
+      ],
       "schema": {
         "type": "object",
         "properties": {
@@ -50,19 +60,26 @@
             "title": "File types",
             "items": {
               "type": "string",
-              "enum": ["image", "video"]
+              "enum": [
+                "image",
+                "video"
+              ]
             },
             "description": "Allowed file types"
           }
         },
-        "required": ["fileTypes"]
+        "required": [
+          "fileTypes"
+        ]
       }
     },
     {
       "methodName": "filterPerson",
       "title": "Filter by person",
-      "description": "Filter assets by detected people in the photo",
-      "supportedContexts": ["person"],
+      "description": "Filter by detected person",
+      "supportedContexts": [
+        "person"
+      ],
       "schema": {
         "type": "object",
         "properties": {
@@ -75,14 +92,15 @@
             "description": "List of person to match",
             "subType": "people-picker"
           },
-          "matchMode": {
-            "type": "string",
-            "title": "Match mode",
-            "enum": ["any", "all", "exact"],
-            "default": "any"
+          "matchAny": {
+            "type": "boolean",
+            "default": true,
+            "description": "Match any name (true) or require all names (false)"
           }
         },
-        "required": ["personIds"]
+        "required": [
+          "personIds"
+        ]
       }
     }
   ],
@@ -91,14 +109,18 @@
       "methodName": "actionArchive",
       "title": "Archive",
       "description": "Move the asset to archive",
-      "supportedContexts": ["asset"],
+      "supportedContexts": [
+        "asset"
+      ],
       "schema": {}
     },
     {
       "methodName": "actionFavorite",
       "title": "Favorite",
       "description": "Mark the asset as favorite or unfavorite",
-      "supportedContexts": ["asset"],
+      "supportedContexts": [
+        "asset"
+      ],
       "schema": {
         "type": "object",
         "properties": {
@@ -114,7 +136,10 @@
       "methodName": "actionAddToAlbum",
       "title": "Add to Album",
       "description": "Add the item to a specified album",
-      "supportedContexts": ["asset", "person"],
+      "supportedContexts": [
+        "asset",
+        "person"
+      ],
       "schema": {
         "type": "object",
         "properties": {
@@ -125,7 +150,9 @@
             "subType": "album-picker"
           }
         },
-        "required": ["albumId"]
+        "required": [
+          "albumId"
+        ]
       }
     }
   ]

plugins/src/index.d.ts

@@ -1,6 +1,5 @@
 declare module 'main' {
   export function filterFileName(): I32;
-  export function filterPerson(): I32;
   export function actionAddToAlbum(): I32;
   export function actionArchive(): I32;
 }
@@ -9,6 +8,5 @@ declare module 'extism:host' {
   interface user {
     updateAsset(ptr: PTR): I32;
     addAssetToAlbum(ptr: PTR): I32;
-    getFacesForAsset(ptr: PTR): PTR;
   }
 }

plugins/src/index.ts

@@ -1,4 +1,4 @@
-const { updateAsset, addAssetToAlbum, getFacesForAsset } = Host.getFunctions();
+const { updateAsset, addAssetToAlbum } = Host.getFunctions();
 
 function parseInput() {
   return JSON.parse(Host.inputString());
@@ -9,64 +9,6 @@ function returnOutput(output: any) {
   return 0;
 }
 
-/**
- * Filter by person - checks if the recognized person matches the configured person IDs.
- *
- * For PersonRecognized trigger:
- * - data.personId contains the ID of the person that was just recognized
- * - Checks if personId is in the configured list
- *
- * matchMode options:
- * - 'any': passes if the triggering person is in the list
- * - 'all': passes if all configured persons are present in the asset
- * - 'exact': passes if the asset contains exactly the configured persons
- */
-export function filterPerson() {
-  const input = parseInput();
-  const { authToken, data, config } = input;
-  const { personIds, matchMode = 'any' } = config;
-
-  if (!personIds || personIds.length === 0) {
-    return returnOutput({ passed: true });
-  }
-
-  const triggerPersonId = data.personId;
-
-  if (matchMode === 'any') {
-    const passed = triggerPersonId && personIds.includes(triggerPersonId);
-    return returnOutput({ passed });
-  }
-
-  const payload = Memory.fromJsonObject({
-    authToken,
-    assetId: data.asset.id,
-  });
-
-  const resultPtr = getFacesForAsset(payload.offset);
-  payload.free();
-
-  const faces = JSON.parse(Memory.find(resultPtr).readJsonObject());
-
-  const assetPersonIds: string[] = faces
-    .filter((face: { personId: string | null }) => face.personId !== null)
-    .map((face: { personId: string }) => face.personId);
-
-  let passed = false;
-
-  if (matchMode === 'all') {
-    passed = personIds.every((id: string) => assetPersonIds.includes(id));
-  } else if (matchMode === 'exact') {
-    const uniquePersonIds = new Set(personIds);
-    const uniqueAssetPersonIds = new Set(assetPersonIds);
-
-    passed =
-      uniquePersonIds.size === uniqueAssetPersonIds.size &&
-      personIds.every((id: string) => uniqueAssetPersonIds.has(id));
-  }
-
-  return returnOutput({ passed });
-}
-
 export function filterFileName() {
   const input = parseInput();
   const { data, config } = input;
@@ -102,7 +44,7 @@ export function actionAddToAlbum() {
       authToken,
       assetId: data.asset.id,
       albumId: albumId,
-    }),
+    })
   );
 
   addAssetToAlbum(ptr.offset);
@@ -119,7 +61,7 @@ export function actionArchive() {
       authToken,
       id: data.asset.id,
       visibility: 'archive',
-    }),
+    })
   );
 
   updateAsset(ptr.offset);

server/src/queries/person.repository.sql

@@ -122,7 +122,6 @@ select
   "asset_face"."id",
   "asset_face"."personId",
   "asset_face"."sourceType",
-  "asset_face"."assetId",
   (
     select
       to_json(obj)

server/src/repositories/album.repository.ts

@@ -318,7 +318,6 @@ export class AlbumRepository {
     await db
       .insertInto('album_asset')
       .values(assetIds.map((assetId) => ({ albumId, assetId })))
-      .onConflict((oc) => oc.columns(['albumId', 'assetId']).doNothing())
       .execute();
   }
 
@@ -327,11 +326,7 @@ export class AlbumRepository {
     if (values.length === 0) {
       return;
     }
-    await this.db
-      .insertInto('album_asset')
-      .values(values)
-      .onConflict((oc) => oc.columns(['albumId', 'assetId']).doNothing())
-      .execute();
+    await this.db.insertInto('album_asset').values(values).execute();
   }
 
   /**

server/src/repositories/event.repository.ts

@@ -44,7 +44,6 @@ type EventMap = {
 
   // asset events
   AssetCreate: [{ asset: Asset }];
-  PersonRecognized: [{ assetId: string; ownerId: string; personId: string }];
   AssetTag: [{ assetId: string }];
   AssetUntag: [{ assetId: string }];
   AssetHide: [{ assetId: string; userId: string }];

server/src/repositories/person.repository.ts

@@ -248,7 +248,7 @@ export class PersonRepository {
   getFaceForFacialRecognitionJob(id: string) {
     return this.db
       .selectFrom('asset_face')
-      .select(['asset_face.id', 'asset_face.personId', 'asset_face.sourceType', 'asset_face.assetId'])
+      .select(['asset_face.id', 'asset_face.personId', 'asset_face.sourceType'])
       .select((eb) =>
         jsonObjectFrom(
           eb

server/src/services/person.service.ts

@@ -540,12 +540,6 @@ export class PersonService extends BaseService {
     if (personId) {
       this.logger.debug(`Assigning face ${id} to person ${personId}`);
       await this.personRepository.reassignFaces({ faceIds: [id], newPersonId: personId });
-
-      await this.eventRepository.emit('PersonRecognized', {
-        assetId: face.assetId,
-        ownerId: face.asset.ownerId,
-        personId,
-      });
     }
 
     return JobStatus.Success;

server/src/services/plugin-host.functions.ts

@@ -7,7 +7,6 @@ import { AlbumRepository } from 'src/repositories/album.repository';
 import { AssetRepository } from 'src/repositories/asset.repository';
 import { CryptoRepository } from 'src/repositories/crypto.repository';
 import { LoggingRepository } from 'src/repositories/logging.repository';
-import { PersonRepository } from 'src/repositories/person.repository';
 import { AssetTable } from 'src/schema/tables/asset.table';
 import { requireAccess } from 'src/utils/access';
 
@@ -21,7 +20,6 @@ export class PluginHostFunctions {
     private albumRepository: AlbumRepository,
     private accessRepository: AccessRepository,
     private cryptoRepository: CryptoRepository,
-    private personRepository: PersonRepository,
     private logger: LoggingRepository,
     private pluginJwtSecret: string,
   ) {}
@@ -35,7 +33,6 @@ export class PluginHostFunctions {
       'extism:host/user': {
         updateAsset: (cp: CurrentPlugin, offs: bigint) => this.handleUpdateAsset(cp, offs),
         addAssetToAlbum: (cp: CurrentPlugin, offs: bigint) => this.handleAddAssetToAlbum(cp, offs),
-        getFacesForAsset: (cp: CurrentPlugin, offs: bigint) => this.handleGetFacesForAsset(cp, offs),
       },
     };
   }
@@ -120,28 +117,4 @@ export class PluginHostFunctions {
     await this.albumRepository.addAssetIds(albumId, [assetId]);
     return 0;
   }
-
-  /**
-   * Host function wrapper for getFacesForAsset.
-   * Reads the input from the plugin, parses it, and returns faces data.
-   */
-  private async handleGetFacesForAsset(cp: CurrentPlugin, offs: bigint) {
-    const input = JSON.parse(cp.read(offs)!.text());
-    const result = await this.getFacesForAsset(input);
-    return cp.store(JSON.stringify(result));
-  }
-
-  async getFacesForAsset(input: { authToken: string; assetId: string }) {
-    const { authToken, assetId } = input;
-
-    const auth = this.validateToken(authToken);
-
-    await requireAccess(this.accessRepository, {
-      auth: { user: { id: auth.userId } } as any,
-      permission: Permission.AssetRead,
-      ids: [assetId],
-    });
-
-    return this.personRepository.getFaces(assetId);
-  }
 }

server/src/services/plugin.service.ts

@@ -17,7 +17,6 @@ import { IWorkflowJob, JobItem, JobOf, WorkflowData } from 'src/types';
 interface WorkflowContext {
   authToken: string;
   asset: Asset;
-  personId?: string;
 }
 
 interface PluginInput<T = unknown> {
@@ -25,7 +24,6 @@ interface PluginInput<T = unknown> {
   config: T;
   data: {
     asset: Asset;
-    personId?: string;
   };
 }
 
@@ -46,7 +44,6 @@ export class PluginService extends BaseService {
       this.albumRepository,
       this.accessRepository,
       this.cryptoRepository,
-      this.personRepository,
       this.logger,
       this.pluginJwtSecret,
     );
@@ -120,9 +117,7 @@ export class PluginService extends BaseService {
 
   private async loadPluginToDatabase(manifest: PluginManifestDto, basePath: string): Promise<void> {
     const currentPlugin = await this.pluginRepository.getPluginByName(manifest.name);
-    const isDev = this.configRepository.isDev();
-
-    if (currentPlugin != null && currentPlugin.version === manifest.version && !isDev) {
+    if (currentPlugin != null && currentPlugin.version === manifest.version) {
       this.logger.log(`Plugin ${manifest.name} is up to date (version ${manifest.version}). Skipping`);
       return;
     }
@@ -183,14 +178,6 @@ export class PluginService extends BaseService {
     });
   }
 
-  @OnEvent({ name: 'PersonRecognized' })
-  async handlePersonRecognized({ assetId, ownerId, personId }: ArgOf<'PersonRecognized'>) {
-    await this.handleTrigger(PluginTriggerType.PersonRecognized, {
-      ownerId,
-      event: { userId: ownerId, assetId, personId },
-    });
-  }
-
   private async handleTrigger<T extends PluginTriggerType>(
     triggerType: T,
     params: { ownerId: string; event: WorkflowData[T] },
@@ -232,7 +219,7 @@ export class PluginService extends BaseService {
 
           const authToken = this.cryptoRepository.signJwt({ userId: data.userId }, this.pluginJwtSecret);
 
-          const context: WorkflowContext = {
+          const context = {
             authToken,
             asset,
           };
@@ -243,35 +230,13 @@ export class PluginService extends BaseService {
           }
 
           await this.executeActions(workflowActions, context);
-          this.logger.debug(`Workflow ${workflowId} executed successfully for AssetCreate`);
+          this.logger.debug(`Workflow ${workflowId} executed successfully`);
           return JobStatus.Success;
         }
 
         case PluginTriggerType.PersonRecognized: {
-          const data = event as WorkflowData[PluginTriggerType.PersonRecognized];
-
-          const asset = await this.assetRepository.getById(data.assetId);
-          if (!asset) {
-            this.logger.error(`Asset ${data.assetId} not found for workflow ${workflowId}`);
-            return JobStatus.Failed;
-          }
-
-          const authToken = this.cryptoRepository.signJwt({ userId: data.userId }, this.pluginJwtSecret);
-
-          const context: WorkflowContext = {
-            authToken,
-            asset,
-            personId: data.personId,
-          };
-
-          const filtersPassed = await this.executeFilters(workflowFilters, context);
-          if (!filtersPassed) {
-            return JobStatus.Skipped;
-          }
-
-          await this.executeActions(workflowActions, context);
-          this.logger.debug(`Workflow ${workflowId} executed successfully for PersonRecognized`);
-          return JobStatus.Success;
+          this.logger.error('unimplemented');
+          return JobStatus.Skipped;
         }
 
         default: {
@@ -304,7 +269,6 @@ export class PluginService extends BaseService {
         config: workflowFilter.filterConfig,
         data: {
           asset: context.asset,
-          personId: context.personId,
         },
       };
 
@@ -347,7 +311,6 @@ export class PluginService extends BaseService {
         config: workflowAction.actionConfig,
         data: {
           asset: context.asset,
-          personId: context.personId,
         },
       };
 

server/src/types.ts

@@ -259,9 +259,8 @@ export interface WorkflowData {
     asset: Asset;
   };
   [PluginTriggerType.PersonRecognized]: {
-    userId: string;
-    assetId: string;
     personId: string;
+    assetId: string;
   };
 }