fix: new schemaformfield has value of the same type

web/src/lib/components/workflows/SchemaFormFields.svelte

@@ -1,5 +1,5 @@
 <script lang="ts">
-  import { getComponentDefaultValue, getComponentFromSchema } from '$lib/utils/workflow';
+  import { getComponentFromSchema, type ComponentConfig } from '$lib/utils/workflow';
   import { Field, Input, MultiSelect, Select, Switch, Text } from '@immich/ui';
   import WorkflowPickerField from './WorkflowPickerField.svelte';
 
@@ -25,6 +25,24 @@
     config = configKey ? { ...config, [configKey]: { ...actualConfig, ...updates } } : { ...config, ...updates };
   };
 
+  // Helper to determine default value for a component based on its type
+  const getDefaultValue = (component: ComponentConfig): unknown => {
+    if (component.defaultValue !== undefined) {
+      return component.defaultValue;
+    }
+
+    // Initialize with appropriate empty value based on component type
+    if (component.type === 'multiselect' || (component.type === 'text' && component.subType === 'people-picker')) {
+      return [];
+    }
+
+    if (component.type === 'switch') {
+      return false;
+    }
+
+    return '';
+  };
+
   // Derive which keys need initialization (missing from actualConfig)
   const uninitializedKeys = $derived.by(() => {
     if (!components) {
@@ -33,7 +51,7 @@
 
     return Object.entries(components)
       .filter(([key]) => actualConfig[key] === undefined)
-      .map(([key, component]) => ({ key, component, defaultValue: getComponentDefaultValue(component) }));
+      .map(([key, component]) => ({ key, component, defaultValue: getDefaultValue(component) }));
   });
 
   // Derive the batch updates needed

web/src/lib/services/workflow.service.ts

@@ -57,6 +57,10 @@ export const getActionsByContext = (
   return availableActions.filter((action) => action.supportedContexts.includes(context));
 };
 
+/**
+ * Remap configs when items are reordered (drag-drop)
+ * Moves config from old index to new index position
+ */
 export const remapConfigsOnReorder = (
   configs: Record<string, unknown>,
   prefix: 'filter' | 'action',
@@ -107,19 +111,30 @@ export const remapConfigsOnRemove = (
   return newConfigs;
 };
 
-export const initializeConfigs = (
-  type: 'action' | 'filter',
-  workflow: WorkflowResponseDto,
-): Record<string, unknown> => {
+/**
+ * Initialize filter configurations from existing workflow
+ * Uses index-based keys to support multiple filters of the same type
+ */
+export const initializeFilterConfigs = (workflow: WorkflowResponseDto): Record<string, unknown> => {
   const configs: Record<string, unknown> = {};
 
-  if (workflow.filters && type == 'filter') {
+  if (workflow.filters) {
     for (const [index, workflowFilter] of workflow.filters.entries()) {
       configs[`filter_${index}`] = workflowFilter.filterConfig ?? {};
     }
   }
 
-  if (workflow.actions && type == 'action') {
+  return configs;
+};
+
+/**
+ * Initialize action configurations from existing workflow
+ * Uses index-based keys to support multiple actions of the same type
+ */
+export const initializeActionConfigs = (workflow: WorkflowResponseDto): Record<string, unknown> => {
+  const configs: Record<string, unknown> = {};
+
+  if (workflow.actions) {
     for (const [index, workflowAction] of workflow.actions.entries()) {
       configs[`action_${index}`] = workflowAction.actionConfig ?? {};
     }
@@ -160,6 +175,9 @@ export const buildWorkflowPayload = (
   };
 };
 
+/**
+ * Parse JSON workflow and update state
+ */
 export const parseWorkflowJson = (
   jsonString: string,
   availableTriggers: PluginTriggerResponseDto[],
@@ -182,8 +200,10 @@ export const parseWorkflowJson = (
   try {
     const parsed = JSON.parse(jsonString);
 
+    // Find trigger
     const trigger = availableTriggers.find((t) => t.type === parsed.triggerType);
 
+    // Parse filters (using index-based keys to support multiple of same type)
     const filters: PluginFilterResponseDto[] = [];
     const filterConfigs: Record<string, unknown> = {};
     if (Array.isArray(parsed.filters)) {
@@ -197,6 +217,7 @@ export const parseWorkflowJson = (
       }
     }
 
+    // Parse actions (using index-based keys to support multiple of same type)
     const actions: PluginActionResponseDto[] = [];
     const actionConfigs: Record<string, unknown> = {};
     if (Array.isArray(parsed.actions)) {
@@ -231,6 +252,9 @@ export const parseWorkflowJson = (
   }
 };
 
+/**
+ * Check if workflow has changes compared to previous version
+ */
 export const hasWorkflowChanged = (
   previousWorkflow: WorkflowResponseDto,
   enabled: boolean,
@@ -242,30 +266,36 @@ export const hasWorkflowChanged = (
   filterConfigs: Record<string, unknown>,
   actionConfigs: Record<string, unknown>,
 ): boolean => {
+  // Check enabled state
   if (enabled !== previousWorkflow.enabled) {
     return true;
   }
 
+  // Check name or description
   if (name !== (previousWorkflow.name ?? '') || description !== (previousWorkflow.description ?? '')) {
     return true;
   }
 
+  // Check trigger
   if (triggerType !== previousWorkflow.triggerType) {
     return true;
   }
 
+  // Check filters order/items
   const previousFilterIds = previousWorkflow.filters?.map((f) => f.pluginFilterId) ?? [];
   const currentFilterIds = orderedFilters.map((f) => f.id);
   if (JSON.stringify(previousFilterIds) !== JSON.stringify(currentFilterIds)) {
     return true;
   }
 
+  // Check actions order/items
   const previousActionIds = previousWorkflow.actions?.map((a) => a.pluginActionId) ?? [];
   const currentActionIds = orderedActions.map((a) => a.id);
   if (JSON.stringify(previousActionIds) !== JSON.stringify(currentActionIds)) {
     return true;
   }
 
+  // Check filter configs (using index-based keys)
   const previousFilterConfigs: Record<string, unknown> = {};
   for (const [index, wf] of (previousWorkflow.filters ?? []).entries()) {
     previousFilterConfigs[`filter_${index}`] = wf.filterConfig ?? {};
@@ -274,6 +304,7 @@ export const hasWorkflowChanged = (
     return true;
   }
 
+  // Check action configs (using index-based keys)
   const previousActionConfigs: Record<string, unknown> = {};
   for (const [index, wa] of (previousWorkflow.actions ?? []).entries()) {
     previousActionConfigs[`action_${index}`] = wa.actionConfig ?? {};
@@ -285,6 +316,9 @@ export const hasWorkflowChanged = (
   return false;
 };
 
+/**
+ * Update a workflow via API
+ */
 export const handleUpdateWorkflow = async (
   workflowId: string,
   name: string,

web/src/lib/utils/workflow.ts

@@ -28,22 +28,6 @@ interface JSONSchema {
   required?: string[];
 }
 
-export const getComponentDefaultValue = (component: ComponentConfig): unknown => {
-  if (component.defaultValue !== undefined) {
-    return component.defaultValue;
-  }
-
-  if (component.type === 'multiselect' || (component.type === 'text' && component.subType === 'people-picker')) {
-    return [];
-  }
-
-  if (component.type === 'switch') {
-    return false;
-  }
-
-  return '';
-};
-
 export const getComponentFromSchema = (schema: object | null): Record<string, ComponentConfig> | null => {
   if (!schema || !isJSONSchema(schema) || !schema.properties) {
     return null;

web/src/routes/(user)/utilities/workflows/[workflowId]/+page.svelte

@@ -15,7 +15,8 @@
     getFiltersByContext,
     handleUpdateWorkflow,
     hasWorkflowChanged,
-    initializeConfigs,
+    initializeActionConfigs,
+    initializeFilterConfigs,
     parseWorkflowJson,
     remapConfigsOnRemove,
     remapConfigsOnReorder,
@@ -94,8 +95,8 @@
     ),
   );
 
-  let filterConfigs: Record<string, unknown> = $derived(initializeConfigs('filter', editWorkflow));
-  let actionConfigs: Record<string, unknown> = $derived(initializeConfigs('action', editWorkflow));
+  let filterConfigs: Record<string, unknown> = $derived(initializeFilterConfigs(editWorkflow));
+  let actionConfigs: Record<string, unknown> = $derived(initializeActionConfigs(editWorkflow));
 
   $effect(() => {
     editWorkflow.triggerType = triggerType;
@@ -128,6 +129,7 @@
         actionConfigs,
       );
 
+      // Update the previous workflow state to the new values
       previousWorkflow = updated;
       editWorkflow = updated;
 
@@ -198,6 +200,7 @@
     ),
   );
 
+  // Drag and drop handlers
   let draggedFilterIndex: number | null = $state(null);
   let draggedActionIndex: number | null = $state(null);
   let dragOverFilterIndex: number | null = $state(null);
@@ -249,6 +252,7 @@
       return;
     }
 
+    // Remap configs to follow the new order
     actionConfigs = remapConfigsOnReorder(actionConfigs, 'action', draggedActionIndex, index, selectedActions.length);
 
     const newActions = [...selectedActions];
@@ -262,12 +266,12 @@
     dragOverActionIndex = null;
   };
 
-  const handleAddStep = async (type: 'action' | 'filter') => {
-    const result = await modalManager.show(AddWorkflowStepModal, {
+  const handleAddStep = async (type?: 'action' | 'filter') => {
+    const result = (await modalManager.show(AddWorkflowStepModal, {
       filters: supportFilters,
       actions: supportActions,
       type,
-    });
+    })) as { type: 'filter' | 'action'; item: PluginFilterResponseDto | PluginActionResponseDto } | undefined;
 
     if (result) {
       if (result.type === 'filter') {
@@ -279,11 +283,13 @@
   };
 
   const handleRemoveFilter = (index: number) => {
+    // Remap configs to account for the removed item
     filterConfigs = remapConfigsOnRemove(filterConfigs, 'filter', index, selectedFilters.length);
     selectedFilters = selectedFilters.filter((_, i) => i !== index);
   };
 
   const handleRemoveAction = (index: number) => {
+    // Remap configs to account for the removed item
     actionConfigs = remapConfigsOnRemove(actionConfigs, 'action', index, selectedActions.length);
     selectedActions = selectedActions.filter((_, i) => i !== index);
   };