fix(mobile): save raw photo downloads that fail on android

i18n/en.json

@@ -1787,7 +1787,6 @@
   "restore_all": "Restore all",
   "restore_user": "Restore user",
   "restored_asset": "Restored asset",
-  "result": "Result",
   "resume": "Resume",
   "resume_paused_jobs": "Resume {count, plural, one {# paused job} other {# paused jobs}}",
   "review_duplicates": "Review duplicates",
@@ -2274,13 +2273,6 @@
   "workflow_info": "Workflow info",
   "workflow_json": "Workflow JSON",
   "workflow_json_help": "Edit the workflow configuration in JSON format. Changes will sync to the visual builder.",
-  "workflow_logging_completed": "Completed",
-  "workflow_logging_disable": "Disable logging",
-  "workflow_logging_disabled_description": "Logging is currently disabled for this workflow.",
-  "workflow_logging_enable": "Enable logging",
-  "workflow_logging_error_step": "Error on step #{step}",
-  "workflow_logging_halted": "Halted",
-  "workflow_logging_halted_step": "Halted on step #{step}",
   "workflow_name": "Workflow name",
   "workflow_navigation_prompt": "Are you sure you want to leave without saving your changes?",
   "workflow_summary": "Workflow summary",

i18n/fr.json

@@ -431,8 +431,8 @@
     "transcoding_realtime_description": "Permet au transcodage d'être réalisé en temps réel durant la diffusion du flux de la vidéo. Active la bascule automatique entre résolutions, mais peut entraîner une latence importante de lecture et des microcoupures en fonction des capacités du serveur.",
     "transcoding_realtime_enabled": "Activer la transcodification en temps réel",
     "transcoding_realtime_enabled_description": "Si désactivé, le serveur refusera de démarrer de nouvelles sessions de transcodifications en temps réel.",
-    "transcoding_realtime_resolutions": "Résolutions",
-    "transcoding_realtime_resolutions_description": "Les résolutions proposées pour le transcodage en temps réel. Des résolutions supérieures peuvent causer des soucis pendant la lecture si le serveur ne peut pas les transcoder suffisamment rapidement.",
+    "transcoding_realtime_resolutions": "Définitions",
+    "transcoding_realtime_resolutions_description": "Les définitions proposées pour le transcodage en temps réel. Des définitions supérieures peuvent causer des soucis pendant la lecture si le serveur ne peut pas les transcoder suffisamment rapidement.",
     "transcoding_realtime_video_codecs": "Codecs vidéo",
     "transcoding_realtime_video_codecs_description": "Les codecs vidéo proposés pour le transcodage en temps réel. Les clients choisissent la meilleure option qu'ils supportent durant la lecture. AV1 est plus efficace que HEVC, qui est plus efficace que H.264. En utilisant l'accélération matérielle, sélectionnez seulement les codecs que l'accélérateur peut encoder. En utilisant le transcodage logiciel, notez que H.264 est plus rapide que AV1, qui est plus rapide que HEVC.",
     "transcoding_reference_frames": "Trames de référence",

mobile/android/app/src/main/kotlin/app/alextran/immich/MainActivity.kt

@@ -18,6 +18,7 @@ import app.alextran.immich.images.LocalImageApi
 import app.alextran.immich.images.LocalImagesImpl
 import app.alextran.immich.images.RemoteImageApi
 import app.alextran.immich.images.RemoteImagesImpl
+import app.alextran.immich.mediasave.MediaSavePlugin
 import app.alextran.immich.permission.PermissionApi
 import app.alextran.immich.permission.PermissionApiImpl
 import app.alextran.immich.sync.NativeSyncApi
@@ -63,6 +64,7 @@ class MainActivity : FlutterFragmentActivity() {
       ConnectivityApi.setUp(messenger, ConnectivityApiImpl(ctx))
 
       flutterEngine.plugins.add(ViewIntentPlugin())
+      flutterEngine.plugins.add(MediaSavePlugin())
       flutterEngine.plugins.add(backgroundEngineLockImpl)
       flutterEngine.plugins.add(nativeSyncApiImpl)
       flutterEngine.plugins.add(permissionApiImpl)

mobile/android/app/src/main/kotlin/app/alextran/immich/mediasave/MediaSave.g.kt

@@ -0,0 +1,97 @@
+// Autogenerated from Pigeon (v26.3.4), do not edit directly.
+// See also: https://pub.dev/packages/pigeon
+@file:Suppress("UNCHECKED_CAST", "ArrayInDataClass")
+
+package app.alextran.immich.mediasave
+
+import android.util.Log
+import io.flutter.plugin.common.BasicMessageChannel
+import io.flutter.plugin.common.BinaryMessenger
+import io.flutter.plugin.common.EventChannel
+import io.flutter.plugin.common.MessageCodec
+import io.flutter.plugin.common.StandardMethodCodec
+import io.flutter.plugin.common.StandardMessageCodec
+import java.io.ByteArrayOutputStream
+import java.nio.ByteBuffer
+private object MediaSavePigeonUtils {
+
+  fun wrapResult(result: Any?): List<Any?> {
+    return listOf(result)
+  }
+
+  fun wrapError(exception: Throwable): List<Any?> {
+    return if (exception is FlutterError) {
+      listOf(
+        exception.code,
+        exception.message,
+        exception.details
+      )
+    } else {
+      listOf(
+        exception.javaClass.simpleName,
+        exception.toString(),
+        "Cause: " + exception.cause + ", Stacktrace: " + Log.getStackTraceString(exception)
+      )
+    }
+  }
+}
+
+/**
+ * Error class for passing custom error details to Flutter via a thrown PlatformException.
+ * @property code The error code.
+ * @property message The error message.
+ * @property details The error details. Must be a datatype supported by the api codec.
+ */
+class FlutterError (
+  val code: String,
+  override val message: String? = null,
+  val details: Any? = null
+) : RuntimeException()
+private open class MediaSavePigeonCodec : StandardMessageCodec() {
+  override fun readValueOfType(type: Byte, buffer: ByteBuffer): Any? {
+    return     super.readValueOfType(type, buffer)
+  }
+  override fun writeValue(stream: ByteArrayOutputStream, value: Any?)   {
+    super.writeValue(stream, value)
+  }
+}
+
+
+/** Generated interface from Pigeon that represents a handler of messages from Flutter. */
+interface MediaSaveApi {
+  fun saveToDownloads(filePath: String, title: String, relativePath: String?, callback: (Result<String?>) -> Unit)
+
+  companion object {
+    /** The codec used by MediaSaveApi. */
+    val codec: MessageCodec<Any?> by lazy {
+      MediaSavePigeonCodec()
+    }
+    /** Sets up an instance of `MediaSaveApi` to handle messages through the `binaryMessenger`. */
+    @JvmOverloads
+    fun setUp(binaryMessenger: BinaryMessenger, api: MediaSaveApi?, messageChannelSuffix: String = "") {
+      val separatedMessageChannelSuffix = if (messageChannelSuffix.isNotEmpty()) ".$messageChannelSuffix" else ""
+      run {
+        val channel = BasicMessageChannel<Any?>(binaryMessenger, "dev.flutter.pigeon.immich_mobile.MediaSaveApi.saveToDownloads$separatedMessageChannelSuffix", codec)
+        if (api != null) {
+          channel.setMessageHandler { message, reply ->
+            val args = message as List<Any?>
+            val filePathArg = args[0] as String
+            val titleArg = args[1] as String
+            val relativePathArg = args[2] as String?
+            api.saveToDownloads(filePathArg, titleArg, relativePathArg) { result: Result<String?> ->
+              val error = result.exceptionOrNull()
+              if (error != null) {
+                reply.reply(MediaSavePigeonUtils.wrapError(error))
+              } else {
+                val data = result.getOrNull()
+                reply.reply(MediaSavePigeonUtils.wrapResult(data))
+              }
+            }
+          }
+        } else {
+          channel.setMessageHandler(null)
+        }
+      }
+    }
+  }
+}

mobile/android/app/src/main/kotlin/app/alextran/immich/mediasave/MediaSavePlugin.kt

@@ -0,0 +1,102 @@
+package app.alextran.immich.mediasave
+
+import android.content.ContentValues
+import android.content.Context
+import android.os.Build
+import android.os.Environment
+import android.provider.MediaStore
+import io.flutter.embedding.engine.plugins.FlutterPlugin
+import java.io.File
+import kotlinx.coroutines.CoroutineScope
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.SupervisorJob
+import kotlinx.coroutines.cancel
+import kotlinx.coroutines.launch
+
+class MediaSavePlugin : FlutterPlugin, MediaSaveApi {
+  private var context: Context? = null
+  private val ioScope = CoroutineScope(SupervisorJob() + Dispatchers.IO)
+
+  override fun onAttachedToEngine(binding: FlutterPlugin.FlutterPluginBinding) {
+    context = binding.applicationContext
+    MediaSaveApi.setUp(binding.binaryMessenger, this)
+  }
+
+  override fun onDetachedFromEngine(binding: FlutterPlugin.FlutterPluginBinding) {
+    MediaSaveApi.setUp(binding.binaryMessenger, null)
+    ioScope.cancel()
+    context = null
+  }
+
+  override fun saveToDownloads(
+    filePath: String,
+    title: String,
+    relativePath: String?,
+    callback: (Result<String?>) -> Unit,
+  ) {
+    val context = context ?: run {
+      callback(Result.success(null))
+      return
+    }
+
+    ioScope.launch {
+      try {
+        callback(Result.success(insertIntoFiles(context, filePath, title, relativePath)))
+      } catch (e: Exception) {
+        callback(Result.failure(e))
+      }
+    }
+  }
+
+  // Uses the Files collection, not Images: Images only accepts MIME types the
+  // platform knows and rejects raw formats like CR3, while Files accepts any
+  // type. The file lands under [relativePath] (Download/Immich), not the gallery.
+  private fun insertIntoFiles(
+    context: Context,
+    filePath: String,
+    title: String,
+    relativePath: String?,
+  ): String? {
+    val resolver = context.contentResolver
+    val collection = MediaStore.Files.getContentUri("external")
+    val source = File(filePath)
+    // Anything reaching this fallback is a format the platform can't type, so
+    // store it as a generic binary. The file saves and stays openable.
+    val mimeType = "application/octet-stream"
+
+    if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.Q) {
+      val values = ContentValues().apply {
+        put(MediaStore.MediaColumns.DISPLAY_NAME, title)
+        put(MediaStore.MediaColumns.MIME_TYPE, mimeType)
+        relativePath?.let { put(MediaStore.MediaColumns.RELATIVE_PATH, it) }
+        put(MediaStore.MediaColumns.IS_PENDING, 1)
+      }
+      val uri = resolver.insert(collection, values) ?: return null
+
+      try {
+        val out = resolver.openOutputStream(uri)
+        if (out == null) {
+          resolver.delete(uri, null, null)
+          return null
+        }
+        out.use { source.inputStream().use { input -> input.copyTo(it) } }
+        resolver.update(uri, ContentValues().apply { put(MediaStore.MediaColumns.IS_PENDING, 0) }, null, null)
+        return uri.lastPathSegment
+      } catch (e: Exception) {
+        resolver.delete(uri, null, null)
+        throw e
+      }
+    }
+
+    val dir = File(Environment.getExternalStorageDirectory(), relativePath ?: Environment.DIRECTORY_DCIM).apply { mkdirs() }
+    val target = File(dir, title)
+    source.inputStream().use { input -> target.outputStream().use { input.copyTo(it) } }
+    val values = ContentValues().apply {
+      put(MediaStore.MediaColumns.DISPLAY_NAME, title)
+      put(MediaStore.MediaColumns.MIME_TYPE, mimeType)
+      @Suppress("DEPRECATION")
+      put(MediaStore.MediaColumns.DATA, target.absolutePath)
+    }
+    return resolver.insert(collection, values)?.lastPathSegment
+  }
+}

mobile/lib/platform/media_save_api.g.dart

@@ -0,0 +1,81 @@
+// Autogenerated from Pigeon (v26.3.4), do not edit directly.
+// See also: https://pub.dev/packages/pigeon
+// ignore_for_file: unused_import, unused_shown_name
+// ignore_for_file: type=lint
+
+import 'dart:async';
+import 'dart:typed_data' show Float64List, Int32List, Int64List;
+
+import 'package:flutter/services.dart';
+import 'package:meta/meta.dart' show immutable, protected, visibleForTesting;
+
+Object? _extractReplyValueOrThrow(List<Object?>? replyList, String channelName, {required bool isNullValid}) {
+  if (replyList == null) {
+    throw PlatformException(
+      code: 'channel-error',
+      message: 'Unable to establish connection on channel: "$channelName".',
+    );
+  } else if (replyList.length > 1) {
+    throw PlatformException(code: replyList[0]! as String, message: replyList[1] as String?, details: replyList[2]);
+  } else if (!isNullValid && (replyList.isNotEmpty && replyList[0] == null)) {
+    throw PlatformException(
+      code: 'null-error',
+      message: 'Host platform returned null value for non-null return value.',
+    );
+  }
+  return replyList.firstOrNull;
+}
+
+class _PigeonCodec extends StandardMessageCodec {
+  const _PigeonCodec();
+  @override
+  void writeValue(WriteBuffer buffer, Object? value) {
+    if (value is int) {
+      buffer.putUint8(4);
+      buffer.putInt64(value);
+    } else {
+      super.writeValue(buffer, value);
+    }
+  }
+
+  @override
+  Object? readValueOfType(int type, ReadBuffer buffer) {
+    switch (type) {
+      default:
+        return super.readValueOfType(type, buffer);
+    }
+  }
+}
+
+class MediaSaveApi {
+  /// Constructor for [MediaSaveApi].  The [binaryMessenger] named argument is
+  /// available for dependency injection.  If it is left null, the default
+  /// BinaryMessenger will be used which routes to the host platform.
+  MediaSaveApi({BinaryMessenger? binaryMessenger, String messageChannelSuffix = ''})
+    : pigeonVar_binaryMessenger = binaryMessenger,
+      pigeonVar_messageChannelSuffix = messageChannelSuffix.isNotEmpty ? '.$messageChannelSuffix' : '';
+  final BinaryMessenger? pigeonVar_binaryMessenger;
+
+  static const MessageCodec<Object?> pigeonChannelCodec = _PigeonCodec();
+
+  final String pigeonVar_messageChannelSuffix;
+
+  Future<String?> saveToDownloads(String filePath, String title, String? relativePath) async {
+    final pigeonVar_channelName =
+        'dev.flutter.pigeon.immich_mobile.MediaSaveApi.saveToDownloads$pigeonVar_messageChannelSuffix';
+    final pigeonVar_channel = BasicMessageChannel<Object?>(
+      pigeonVar_channelName,
+      pigeonChannelCodec,
+      binaryMessenger: pigeonVar_binaryMessenger,
+    );
+    final Future<Object?> pigeonVar_sendFuture = pigeonVar_channel.send(<Object?>[filePath, title, relativePath]);
+    final pigeonVar_replyList = await pigeonVar_sendFuture as List<Object?>?;
+
+    final Object? pigeonVar_replyValue = _extractReplyValueOrThrow(
+      pigeonVar_replyList,
+      pigeonVar_channelName,
+      isNullValid: true,
+    );
+    return pigeonVar_replyValue as String?;
+  }
+}

mobile/lib/repositories/file_media.repository.dart

@@ -1,10 +1,16 @@
 import 'dart:io';
 
-import 'package:flutter/foundation.dart';
+import 'package:flutter/services.dart';
 import 'package:hooks_riverpod/hooks_riverpod.dart';
 import 'package:immich_mobile/domain/models/asset/base_asset.model.dart';
+import 'package:immich_mobile/extensions/platform_extensions.dart';
+import 'package:immich_mobile/platform/media_save_api.g.dart';
+import 'package:immich_mobile/utils/mime.utils.dart';
+import 'package:path/path.dart' as p;
 import 'package:photo_manager/photo_manager.dart' hide AssetType;
 
+final _mediaSaveApi = MediaSaveApi();
+
 final fileMediaRepositoryProvider = Provider((ref) => const FileMediaRepository());
 
 class FileMediaRepository {
@@ -25,8 +31,19 @@ class FileMediaRepository {
   }
 
   Future<AssetEntity?> saveImageWithFile(String filePath, {String? title, String? relativePath}) async {
-    final entity = await PhotoManager.editor.saveImageWithPath(filePath, title: title, relativePath: relativePath);
-    return entity;
+    try {
+      return await PhotoManager.editor.saveImageWithPath(filePath, title: title, relativePath: relativePath);
+    } on PlatformException catch (e) {
+      // Some formats (e.g. raw like CR3) have no MIME the platform recognises, so
+      // photo_manager falls back to `image/*` and MediaStore rejects the save.
+      // Save those to Downloads ourselves, where the Files collection takes any
+      // type. Anything else isn't ours to handle.
+      if (!CurrentPlatform.isAndroid || !isUnsupportedMimeError(e)) {
+        rethrow;
+      }
+      final id = await _mediaSaveApi.saveToDownloads(filePath, title ?? p.basename(filePath), 'Download/Immich');
+      return id == null ? null : AssetEntity(id: id, typeInt: 1, width: 0, height: 0);
+    }
   }
 
   Future<AssetEntity?> saveLivePhoto({required File image, required File video, required String title}) async {

mobile/lib/utils/mime.utils.dart

@@ -0,0 +1,12 @@
+import 'package:flutter/services.dart';
+
+// True when a gallery save failed because MediaStore rejected the file's MIME.
+// Android raises `Unsupported MIME type` for formats it can't type (e.g. raw
+// like CR3), where photo_manager falls back to `image/*`. Matched on the detail
+// string (case-insensitive) because photo_manager surfaces no distinct error
+// code for it. Keeps `mime type` in the match so it doesn't catch unrelated
+// `Unsupported*` errors (e.g. UnsupportedOperationException).
+bool isUnsupportedMimeError(PlatformException e) {
+  final details = e.details;
+  return details is String && details.toLowerCase().contains('unsupported mime type');
+}

mobile/lib/utils/openapi_patching.dart

@@ -41,7 +41,6 @@ final Map<String, Map<String, Object?>> openApiPatches = {
   'SyncAssetV1': {'isEdited': false},
   'ServerFeaturesDto': {'ocr': false, 'realtimeTranscoding': false},
   'MemoriesResponse': {'duration': 5},
-  'WorkflowResponseDto': {'logging': false},
 };
 
 void upgradeDto(dynamic value, String targetType) {

mobile/openapi/README.md

@@ -341,7 +341,6 @@ Class | Method | HTTP request | Description
 *WorkflowsApi* | [**deleteWorkflow**](doc//WorkflowsApi.md#deleteworkflow) | **DELETE** /workflows/{id} | Delete a workflow
 *WorkflowsApi* | [**getWorkflow**](doc//WorkflowsApi.md#getworkflow) | **GET** /workflows/{id} | Retrieve a workflow
 *WorkflowsApi* | [**getWorkflowForShare**](doc//WorkflowsApi.md#getworkflowforshare) | **GET** /workflows/{id}/share | Retrieve a workflow
-*WorkflowsApi* | [**getWorkflowLogs**](doc//WorkflowsApi.md#getworkflowlogs) | **GET** /workflows/{id}/logs | Retrieve a workflow
 *WorkflowsApi* | [**getWorkflowTriggers**](doc//WorkflowsApi.md#getworkflowtriggers) | **GET** /workflows/triggers | List all workflow triggers
 *WorkflowsApi* | [**searchWorkflows**](doc//WorkflowsApi.md#searchworkflows) | **GET** /workflows | List all workflows
 *WorkflowsApi* | [**updateWorkflow**](doc//WorkflowsApi.md#updateworkflow) | **PUT** /workflows/{id} | Update a workflow
@@ -712,10 +711,7 @@ Class | Method | HTTP request | Description
  - [VideoCodec](doc//VideoCodec.md)
  - [VideoContainer](doc//VideoContainer.md)
  - [WorkflowCreateDto](doc//WorkflowCreateDto.md)
- - [WorkflowLogEntryDto](doc//WorkflowLogEntryDto.md)
- - [WorkflowLogEntryDtoLastStep](doc//WorkflowLogEntryDtoLastStep.md)
  - [WorkflowResponseDto](doc//WorkflowResponseDto.md)
- - [WorkflowResult](doc//WorkflowResult.md)
  - [WorkflowShareResponseDto](doc//WorkflowShareResponseDto.md)
  - [WorkflowShareStepDto](doc//WorkflowShareStepDto.md)
  - [WorkflowStepDto](doc//WorkflowStepDto.md)

mobile/openapi/lib/api.dart

@@ -432,10 +432,7 @@ part 'model/version_check_state_response_dto.dart';
 part 'model/video_codec.dart';
 part 'model/video_container.dart';
 part 'model/workflow_create_dto.dart';
-part 'model/workflow_log_entry_dto.dart';
-part 'model/workflow_log_entry_dto_last_step.dart';
 part 'model/workflow_response_dto.dart';
-part 'model/workflow_result.dart';
 part 'model/workflow_share_response_dto.dart';
 part 'model/workflow_share_step_dto.dart';
 part 'model/workflow_step_dto.dart';

mobile/openapi/lib/api/workflows_api.dart

@@ -239,95 +239,6 @@ class WorkflowsApi {
     return null;
   }
 
-  /// Retrieve a workflow
-  ///
-  /// Retrieve a workflow details without ids, default values, etc.
-  ///
-  /// Note: This method returns the HTTP [Response].
-  ///
-  /// Parameters:
-  ///
-  /// * [String] id (required):
-  ///
-  /// * [DateTime] before:
-  ///   Filter by runs before a date/time
-  ///
-  /// * [int] limit:
-  ///   Maximum number of logs
-  ///
-  /// * [WorkflowResult] result:
-  ///   Filter by run result
-  Future<Response> getWorkflowLogsWithHttpInfo(String id, { DateTime? before, int? limit, WorkflowResult? result, Future<void>? abortTrigger, }) async {
-    // ignore: prefer_const_declarations
-    final apiPath = r'/workflows/{id}/logs'
-      .replaceAll('{id}', id);
-
-    // ignore: prefer_final_locals
-    Object? postBody;
-
-    final queryParams = <QueryParam>[];
-    final headerParams = <String, String>{};
-    final formParams = <String, String>{};
-
-    if (before != null) {
-      queryParams.addAll(_queryParams('', 'before', before));
-    }
-    if (limit != null) {
-      queryParams.addAll(_queryParams('', 'limit', limit));
-    }
-    if (result != null) {
-      queryParams.addAll(_queryParams('', 'result', result));
-    }
-
-    const contentTypes = <String>[];
-
-
-    return apiClient.invokeAPI(
-      apiPath,
-      'GET',
-      queryParams,
-      postBody,
-      headerParams,
-      formParams,
-      contentTypes.isEmpty ? null : contentTypes.first,
-      abortTrigger: abortTrigger,
-    );
-  }
-
-  /// Retrieve a workflow
-  ///
-  /// Retrieve a workflow details without ids, default values, etc.
-  ///
-  /// Parameters:
-  ///
-  /// * [String] id (required):
-  ///
-  /// * [DateTime] before:
-  ///   Filter by runs before a date/time
-  ///
-  /// * [int] limit:
-  ///   Maximum number of logs
-  ///
-  /// * [WorkflowResult] result:
-  ///   Filter by run result
-  Future<List<WorkflowLogEntryDto>?> getWorkflowLogs(String id, { DateTime? before, int? limit, WorkflowResult? result, Future<void>? abortTrigger, }) async {
-    final response = await getWorkflowLogsWithHttpInfo(id, before: before, limit: limit, result: result, abortTrigger: abortTrigger,);
-    if (response.statusCode >= HttpStatus.badRequest) {
-      throw ApiException(response.statusCode, await _decodeBodyBytes(response));
-    }
-    // When a remote server returns no body with a status of 204, we shall not decode it.
-    // At the time of writing this, `dart:convert` will throw an "Unexpected end of input"
-    // FormatException when trying to decode an empty string.
-    if (response.body.isNotEmpty && response.statusCode != HttpStatus.noContent) {
-      final responseBody = await _decodeBodyBytes(response);
-      return (await apiClient.deserializeAsync(responseBody, 'List<WorkflowLogEntryDto>') as List)
-        .cast<WorkflowLogEntryDto>()
-        .toList(growable: false);
-
-    }
-    return null;
-  }
-
   /// List all workflow triggers
   ///
   /// Retrieve a list of all available workflow triggers.
@@ -397,15 +308,12 @@ class WorkflowsApi {
   /// * [String] id:
   ///   Workflow ID
   ///
-  /// * [bool] logging:
-  ///   Workflow logs run results
-  ///
   /// * [String] name:
   ///   Workflow name
   ///
   /// * [WorkflowTrigger] trigger:
   ///   Workflow trigger type
-  Future<Response> searchWorkflowsWithHttpInfo({ String? description, bool? enabled, String? id, bool? logging, String? name, WorkflowTrigger? trigger, Future<void>? abortTrigger, }) async {
+  Future<Response> searchWorkflowsWithHttpInfo({ String? description, bool? enabled, String? id, String? name, WorkflowTrigger? trigger, Future<void>? abortTrigger, }) async {
     // ignore: prefer_const_declarations
     final apiPath = r'/workflows';
 
@@ -425,9 +333,6 @@ class WorkflowsApi {
     if (id != null) {
       queryParams.addAll(_queryParams('', 'id', id));
     }
-    if (logging != null) {
-      queryParams.addAll(_queryParams('', 'logging', logging));
-    }
     if (name != null) {
       queryParams.addAll(_queryParams('', 'name', name));
     }
@@ -465,16 +370,13 @@ class WorkflowsApi {
   /// * [String] id:
   ///   Workflow ID
   ///
-  /// * [bool] logging:
-  ///   Workflow logs run results
-  ///
   /// * [String] name:
   ///   Workflow name
   ///
   /// * [WorkflowTrigger] trigger:
   ///   Workflow trigger type
-  Future<List<WorkflowResponseDto>?> searchWorkflows({ String? description, bool? enabled, String? id, bool? logging, String? name, WorkflowTrigger? trigger, Future<void>? abortTrigger, }) async {
-    final response = await searchWorkflowsWithHttpInfo(description: description, enabled: enabled, id: id, logging: logging, name: name, trigger: trigger, abortTrigger: abortTrigger,);
+  Future<List<WorkflowResponseDto>?> searchWorkflows({ String? description, bool? enabled, String? id, String? name, WorkflowTrigger? trigger, Future<void>? abortTrigger, }) async {
+    final response = await searchWorkflowsWithHttpInfo(description: description, enabled: enabled, id: id, name: name, trigger: trigger, abortTrigger: abortTrigger,);
     if (response.statusCode >= HttpStatus.badRequest) {
       throw ApiException(response.statusCode, await _decodeBodyBytes(response));
     }

mobile/openapi/lib/api_client.dart

@@ -909,14 +909,8 @@ class ApiClient {
           return VideoContainerTypeTransformer().decode(value);
         case 'WorkflowCreateDto':
           return WorkflowCreateDto.fromJson(value);
-        case 'WorkflowLogEntryDto':
-          return WorkflowLogEntryDto.fromJson(value);
-        case 'WorkflowLogEntryDtoLastStep':
-          return WorkflowLogEntryDtoLastStep.fromJson(value);
         case 'WorkflowResponseDto':
           return WorkflowResponseDto.fromJson(value);
-        case 'WorkflowResult':
-          return WorkflowResultTypeTransformer().decode(value);
         case 'WorkflowShareResponseDto':
           return WorkflowShareResponseDto.fromJson(value);
         case 'WorkflowShareStepDto':

mobile/openapi/lib/api_helper.dart

@@ -214,9 +214,6 @@ String parameterToString(dynamic value) {
   if (value is VideoContainer) {
     return VideoContainerTypeTransformer().encode(value).toString();
   }
-  if (value is WorkflowResult) {
-    return WorkflowResultTypeTransformer().encode(value).toString();
-  }
   if (value is WorkflowTrigger) {
     return WorkflowTriggerTypeTransformer().encode(value).toString();
   }

mobile/openapi/lib/model/permission.dart

@@ -172,7 +172,6 @@ class Permission {
   static const workflowPeriodRead = Permission._(r'workflow.read');
   static const workflowPeriodUpdate = Permission._(r'workflow.update');
   static const workflowPeriodDelete = Permission._(r'workflow.delete');
-  static const workflowPeriodLogs = Permission._(r'workflow.logs');
   static const adminUserPeriodCreate = Permission._(r'adminUser.create');
   static const adminUserPeriodRead = Permission._(r'adminUser.read');
   static const adminUserPeriodUpdate = Permission._(r'adminUser.update');
@@ -331,7 +330,6 @@ class Permission {
     workflowPeriodRead,
     workflowPeriodUpdate,
     workflowPeriodDelete,
-    workflowPeriodLogs,
     adminUserPeriodCreate,
     adminUserPeriodRead,
     adminUserPeriodUpdate,
@@ -525,7 +523,6 @@ class PermissionTypeTransformer {
         case r'workflow.read': return Permission.workflowPeriodRead;
         case r'workflow.update': return Permission.workflowPeriodUpdate;
         case r'workflow.delete': return Permission.workflowPeriodDelete;
-        case r'workflow.logs': return Permission.workflowPeriodLogs;
         case r'adminUser.create': return Permission.adminUserPeriodCreate;
         case r'adminUser.read': return Permission.adminUserPeriodRead;
         case r'adminUser.update': return Permission.adminUserPeriodUpdate;

mobile/openapi/lib/model/workflow_create_dto.dart

@@ -15,7 +15,6 @@ class WorkflowCreateDto {
   WorkflowCreateDto({
     this.description = const Optional.absent(),
     this.enabled = const Optional.absent(),
-    this.logging = const Optional.absent(),
     this.name = const Optional.absent(),
     this.steps = const Optional.present(const []),
     required this.trigger,
@@ -33,15 +32,6 @@ class WorkflowCreateDto {
   ///
   Optional<bool?> enabled;
 
-  /// Workflow logs run results
-  ///
-  /// Please note: This property should have been non-nullable! Since the specification file
-  /// does not include a default value (using the "default:" property), however, the generated
-  /// source code must fall back to having a nullable type.
-  /// Consider adding a "default:" property in the specification file to hide this note.
-  ///
-  Optional<bool?> logging;
-
   /// Workflow name
   Optional<String?> name;
 
@@ -53,7 +43,6 @@ class WorkflowCreateDto {
   bool operator ==(Object other) => identical(this, other) || other is WorkflowCreateDto &&
     other.description == description &&
     other.enabled == enabled &&
-    other.logging == logging &&
     other.name == name &&
     _deepEquality.equals(other.steps, steps) &&
     other.trigger == trigger;
@@ -63,13 +52,12 @@ class WorkflowCreateDto {
     // ignore: unnecessary_parenthesis
     (description == null ? 0 : description!.hashCode) +
     (enabled == null ? 0 : enabled!.hashCode) +
-    (logging == null ? 0 : logging!.hashCode) +
     (name == null ? 0 : name!.hashCode) +
     (steps.hashCode) +
     (trigger.hashCode);
 
   @override
-  String toString() => 'WorkflowCreateDto[description=$description, enabled=$enabled, logging=$logging, name=$name, steps=$steps, trigger=$trigger]';
+  String toString() => 'WorkflowCreateDto[description=$description, enabled=$enabled, name=$name, steps=$steps, trigger=$trigger]';
 
   Map<String, dynamic> toJson() {
     final json = <String, dynamic>{};
@@ -81,10 +69,6 @@ class WorkflowCreateDto {
       final value = this.enabled.value;
       json[r'enabled'] = value;
     }
-    if (this.logging.isPresent) {
-      final value = this.logging.value;
-      json[r'logging'] = value;
-    }
     if (this.name.isPresent) {
       final value = this.name.value;
       json[r'name'] = value;
@@ -108,7 +92,6 @@ class WorkflowCreateDto {
       return WorkflowCreateDto(
         description: json.containsKey(r'description') ? Optional.present(mapValueOfType<String>(json, r'description')) : const Optional.absent(),
         enabled: json.containsKey(r'enabled') ? Optional.present(mapValueOfType<bool>(json, r'enabled')) : const Optional.absent(),
-        logging: json.containsKey(r'logging') ? Optional.present(mapValueOfType<bool>(json, r'logging')) : const Optional.absent(),
         name: json.containsKey(r'name') ? Optional.present(mapValueOfType<String>(json, r'name')) : const Optional.absent(),
         steps: json.containsKey(r'steps') ? Optional.present(WorkflowStepDto.listFromJson(json[r'steps'])) : const Optional.absent(),
         trigger: WorkflowTrigger.fromJson(json[r'trigger'])!,

mobile/openapi/lib/model/workflow_log_entry_dto.dart

@@ -1,150 +0,0 @@
-//
-// AUTO-GENERATED FILE, DO NOT MODIFY!
-//
-// @dart=2.18
-
-// ignore_for_file: unused_element, unused_import
-// ignore_for_file: always_put_required_named_parameters_first
-// ignore_for_file: constant_identifier_names
-// ignore_for_file: lines_longer_than_80_chars
-
-part of openapi.api;
-
-class WorkflowLogEntryDto {
-  /// Returns a new [WorkflowLogEntryDto] instance.
-  WorkflowLogEntryDto({
-    required this.at,
-    required this.id,
-    this.lastStep = const Optional.absent(),
-    required this.result,
-    this.triggerDataId = const Optional.absent(),
-  });
-
-  /// Workflow run date/time
-  String at;
-
-  /// Workflow log entry ID
-  String id;
-
-  ///
-  /// Please note: This property should have been non-nullable! Since the specification file
-  /// does not include a default value (using the "default:" property), however, the generated
-  /// source code must fall back to having a nullable type.
-  /// Consider adding a "default:" property in the specification file to hide this note.
-  ///
-  Optional<WorkflowLogEntryDtoLastStep?> lastStep;
-
-  WorkflowResult result;
-
-  /// Workflow trigger data ID
-  ///
-  /// Please note: This property should have been non-nullable! Since the specification file
-  /// does not include a default value (using the "default:" property), however, the generated
-  /// source code must fall back to having a nullable type.
-  /// Consider adding a "default:" property in the specification file to hide this note.
-  ///
-  Optional<String?> triggerDataId;
-
-  @override
-  bool operator ==(Object other) => identical(this, other) || other is WorkflowLogEntryDto &&
-    other.at == at &&
-    other.id == id &&
-    other.lastStep == lastStep &&
-    other.result == result &&
-    other.triggerDataId == triggerDataId;
-
-  @override
-  int get hashCode =>
-    // ignore: unnecessary_parenthesis
-    (at.hashCode) +
-    (id.hashCode) +
-    (lastStep == null ? 0 : lastStep!.hashCode) +
-    (result.hashCode) +
-    (triggerDataId == null ? 0 : triggerDataId!.hashCode);
-
-  @override
-  String toString() => 'WorkflowLogEntryDto[at=$at, id=$id, lastStep=$lastStep, result=$result, triggerDataId=$triggerDataId]';
-
-  Map<String, dynamic> toJson() {
-    final json = <String, dynamic>{};
-      json[r'at'] = this.at;
-      json[r'id'] = this.id;
-    if (this.lastStep.isPresent) {
-      final value = this.lastStep.value;
-      json[r'lastStep'] = value;
-    }
-      json[r'result'] = this.result;
-    if (this.triggerDataId.isPresent) {
-      final value = this.triggerDataId.value;
-      json[r'triggerDataId'] = value;
-    }
-    return json;
-  }
-
-  /// Returns a new [WorkflowLogEntryDto] instance and imports its values from
-  /// [value] if it's a [Map], null otherwise.
-  // ignore: prefer_constructors_over_static_methods
-  static WorkflowLogEntryDto? fromJson(dynamic value) {
-    upgradeDto(value, "WorkflowLogEntryDto");
-    if (value is Map) {
-      final json = value.cast<String, dynamic>();
-
-      return WorkflowLogEntryDto(
-        at: mapValueOfType<String>(json, r'at')!,
-        id: mapValueOfType<String>(json, r'id')!,
-        lastStep: json.containsKey(r'lastStep') ? Optional.present(WorkflowLogEntryDtoLastStep.fromJson(json[r'lastStep'])) : const Optional.absent(),
-        result: WorkflowResult.fromJson(json[r'result'])!,
-        triggerDataId: json.containsKey(r'triggerDataId') ? Optional.present(mapValueOfType<String>(json, r'triggerDataId')) : const Optional.absent(),
-      );
-    }
-    return null;
-  }
-
-  static List<WorkflowLogEntryDto> listFromJson(dynamic json, {bool growable = false,}) {
-    final result = <WorkflowLogEntryDto>[];
-    if (json is List && json.isNotEmpty) {
-      for (final row in json) {
-        final value = WorkflowLogEntryDto.fromJson(row);
-        if (value != null) {
-          result.add(value);
-        }
-      }
-    }
-    return result.toList(growable: growable);
-  }
-
-  static Map<String, WorkflowLogEntryDto> mapFromJson(dynamic json) {
-    final map = <String, WorkflowLogEntryDto>{};
-    if (json is Map && json.isNotEmpty) {
-      json = json.cast<String, dynamic>(); // ignore: parameter_assignments
-      for (final entry in json.entries) {
-        final value = WorkflowLogEntryDto.fromJson(entry.value);
-        if (value != null) {
-          map[entry.key] = value;
-        }
-      }
-    }
-    return map;
-  }
-
-  // maps a json object with a list of WorkflowLogEntryDto-objects as value to a dart map
-  static Map<String, List<WorkflowLogEntryDto>> mapListFromJson(dynamic json, {bool growable = false,}) {
-    final map = <String, List<WorkflowLogEntryDto>>{};
-    if (json is Map && json.isNotEmpty) {
-      // ignore: parameter_assignments
-      json = json.cast<String, dynamic>();
-      for (final entry in json.entries) {
-        map[entry.key] = WorkflowLogEntryDto.listFromJson(entry.value, growable: growable,);
-      }
-    }
-    return map;
-  }
-
-  /// The list of required keys that must be present in a JSON.
-  static const requiredKeys = <String>{
-    'at',
-    'id',
-    'result',
-  };
-}
-

mobile/openapi/lib/model/workflow_log_entry_dto_last_step.dart

@@ -1,112 +0,0 @@
-//
-// AUTO-GENERATED FILE, DO NOT MODIFY!
-//
-// @dart=2.18
-
-// ignore_for_file: unused_element, unused_import
-// ignore_for_file: always_put_required_named_parameters_first
-// ignore_for_file: constant_identifier_names
-// ignore_for_file: lines_longer_than_80_chars
-
-part of openapi.api;
-
-class WorkflowLogEntryDtoLastStep {
-  /// Returns a new [WorkflowLogEntryDtoLastStep] instance.
-  WorkflowLogEntryDtoLastStep({
-    required this.index,
-    required this.method,
-  });
-
-  /// Index of the step in the workflow
-  ///
-  /// Minimum value: 0
-  /// Maximum value: 9007199254740991
-  int index;
-
-  /// Method of the step
-  String method;
-
-  @override
-  bool operator ==(Object other) => identical(this, other) || other is WorkflowLogEntryDtoLastStep &&
-    other.index == index &&
-    other.method == method;
-
-  @override
-  int get hashCode =>
-    // ignore: unnecessary_parenthesis
-    (index.hashCode) +
-    (method.hashCode);
-
-  @override
-  String toString() => 'WorkflowLogEntryDtoLastStep[index=$index, method=$method]';
-
-  Map<String, dynamic> toJson() {
-    final json = <String, dynamic>{};
-      json[r'index'] = this.index;
-      json[r'method'] = this.method;
-    return json;
-  }
-
-  /// Returns a new [WorkflowLogEntryDtoLastStep] instance and imports its values from
-  /// [value] if it's a [Map], null otherwise.
-  // ignore: prefer_constructors_over_static_methods
-  static WorkflowLogEntryDtoLastStep? fromJson(dynamic value) {
-    upgradeDto(value, "WorkflowLogEntryDtoLastStep");
-    if (value is Map) {
-      final json = value.cast<String, dynamic>();
-
-      return WorkflowLogEntryDtoLastStep(
-        index: mapValueOfType<int>(json, r'index')!,
-        method: mapValueOfType<String>(json, r'method')!,
-      );
-    }
-    return null;
-  }
-
-  static List<WorkflowLogEntryDtoLastStep> listFromJson(dynamic json, {bool growable = false,}) {
-    final result = <WorkflowLogEntryDtoLastStep>[];
-    if (json is List && json.isNotEmpty) {
-      for (final row in json) {
-        final value = WorkflowLogEntryDtoLastStep.fromJson(row);
-        if (value != null) {
-          result.add(value);
-        }
-      }
-    }
-    return result.toList(growable: growable);
-  }
-
-  static Map<String, WorkflowLogEntryDtoLastStep> mapFromJson(dynamic json) {
-    final map = <String, WorkflowLogEntryDtoLastStep>{};
-    if (json is Map && json.isNotEmpty) {
-      json = json.cast<String, dynamic>(); // ignore: parameter_assignments
-      for (final entry in json.entries) {
-        final value = WorkflowLogEntryDtoLastStep.fromJson(entry.value);
-        if (value != null) {
-          map[entry.key] = value;
-        }
-      }
-    }
-    return map;
-  }
-
-  // maps a json object with a list of WorkflowLogEntryDtoLastStep-objects as value to a dart map
-  static Map<String, List<WorkflowLogEntryDtoLastStep>> mapListFromJson(dynamic json, {bool growable = false,}) {
-    final map = <String, List<WorkflowLogEntryDtoLastStep>>{};
-    if (json is Map && json.isNotEmpty) {
-      // ignore: parameter_assignments
-      json = json.cast<String, dynamic>();
-      for (final entry in json.entries) {
-        map[entry.key] = WorkflowLogEntryDtoLastStep.listFromJson(entry.value, growable: growable,);
-      }
-    }
-    return map;
-  }
-
-  /// The list of required keys that must be present in a JSON.
-  static const requiredKeys = <String>{
-    'index',
-    'method',
-  };
-}
-

mobile/openapi/lib/model/workflow_response_dto.dart

@@ -17,7 +17,6 @@ class WorkflowResponseDto {
     required this.description,
     required this.enabled,
     required this.id,
-    required this.logging,
     required this.name,
     this.steps = const [],
     required this.trigger,
@@ -36,9 +35,6 @@ class WorkflowResponseDto {
   /// Workflow ID
   String id;
 
-  /// Workflow logs run results
-  bool logging;
-
   /// Workflow name
   String? name;
 
@@ -56,7 +52,6 @@ class WorkflowResponseDto {
     other.description == description &&
     other.enabled == enabled &&
     other.id == id &&
-    other.logging == logging &&
     other.name == name &&
     _deepEquality.equals(other.steps, steps) &&
     other.trigger == trigger &&
@@ -69,14 +64,13 @@ class WorkflowResponseDto {
     (description == null ? 0 : description!.hashCode) +
     (enabled.hashCode) +
     (id.hashCode) +
-    (logging.hashCode) +
     (name == null ? 0 : name!.hashCode) +
     (steps.hashCode) +
     (trigger.hashCode) +
     (updatedAt.hashCode);
 
   @override
-  String toString() => 'WorkflowResponseDto[createdAt=$createdAt, description=$description, enabled=$enabled, id=$id, logging=$logging, name=$name, steps=$steps, trigger=$trigger, updatedAt=$updatedAt]';
+  String toString() => 'WorkflowResponseDto[createdAt=$createdAt, description=$description, enabled=$enabled, id=$id, name=$name, steps=$steps, trigger=$trigger, updatedAt=$updatedAt]';
 
   Map<String, dynamic> toJson() {
     final json = <String, dynamic>{};
@@ -88,7 +82,6 @@ class WorkflowResponseDto {
     }
       json[r'enabled'] = this.enabled;
       json[r'id'] = this.id;
-      json[r'logging'] = this.logging;
     if (this.name != null) {
       json[r'name'] = this.name;
     } else {
@@ -113,7 +106,6 @@ class WorkflowResponseDto {
         description: mapValueOfType<String>(json, r'description'),
         enabled: mapValueOfType<bool>(json, r'enabled')!,
         id: mapValueOfType<String>(json, r'id')!,
-        logging: mapValueOfType<bool>(json, r'logging')!,
         name: mapValueOfType<String>(json, r'name'),
         steps: WorkflowStepDto.listFromJson(json[r'steps']),
         trigger: WorkflowTrigger.fromJson(json[r'trigger'])!,
@@ -169,7 +161,6 @@ class WorkflowResponseDto {
     'description',
     'enabled',
     'id',
-    'logging',
     'name',
     'steps',
     'trigger',

mobile/openapi/lib/model/workflow_result.dart

@@ -1,88 +0,0 @@
-//
-// AUTO-GENERATED FILE, DO NOT MODIFY!
-//
-// @dart=2.18
-
-// ignore_for_file: unused_element, unused_import
-// ignore_for_file: always_put_required_named_parameters_first
-// ignore_for_file: constant_identifier_names
-// ignore_for_file: lines_longer_than_80_chars
-
-part of openapi.api;
-
-/// Workflow run result
-class WorkflowResult {
-  /// Instantiate a new enum with the provided [value].
-  const WorkflowResult._(this.value);
-
-  /// The underlying value of this enum member.
-  final String value;
-
-  @override
-  String toString() => value;
-
-  String toJson() => value;
-
-  static const completed = WorkflowResult._(r'completed');
-  static const halted = WorkflowResult._(r'halted');
-  static const error = WorkflowResult._(r'error');
-
-  /// List of all possible values in this [enum][WorkflowResult].
-  static const values = <WorkflowResult>[
-    completed,
-    halted,
-    error,
-  ];
-
-  static WorkflowResult? fromJson(dynamic value) => WorkflowResultTypeTransformer().decode(value);
-
-  static List<WorkflowResult> listFromJson(dynamic json, {bool growable = false,}) {
-    final result = <WorkflowResult>[];
-    if (json is List && json.isNotEmpty) {
-      for (final row in json) {
-        final value = WorkflowResult.fromJson(row);
-        if (value != null) {
-          result.add(value);
-        }
-      }
-    }
-    return result.toList(growable: growable);
-  }
-}
-
-/// Transformation class that can [encode] an instance of [WorkflowResult] to String,
-/// and [decode] dynamic data back to [WorkflowResult].
-class WorkflowResultTypeTransformer {
-  factory WorkflowResultTypeTransformer() => _instance ??= const WorkflowResultTypeTransformer._();
-
-  const WorkflowResultTypeTransformer._();
-
-  String encode(WorkflowResult data) => data.value;
-
-  /// Decodes a [dynamic value][data] to a WorkflowResult.
-  ///
-  /// If [allowNull] is true and the [dynamic value][data] cannot be decoded successfully,
-  /// then null is returned. However, if [allowNull] is false and the [dynamic value][data]
-  /// cannot be decoded successfully, then an [UnimplementedError] is thrown.
-  ///
-  /// The [allowNull] is very handy when an API changes and a new enum value is added or removed,
-  /// and users are still using an old app with the old code.
-  WorkflowResult? decode(dynamic data, {bool allowNull = true}) {
-    if (data != null) {
-      switch (data) {
-        case r'completed': return WorkflowResult.completed;
-        case r'halted': return WorkflowResult.halted;
-        case r'error': return WorkflowResult.error;
-        default:
-          if (!allowNull) {
-            throw ArgumentError('Unknown enum value to decode: $data');
-          }
-      }
-    }
-    return null;
-  }
-
-  /// Singleton [WorkflowResultTypeTransformer] instance.
-  static WorkflowResultTypeTransformer? _instance;
-}
-

mobile/openapi/lib/model/workflow_update_dto.dart

@@ -15,7 +15,6 @@ class WorkflowUpdateDto {
   WorkflowUpdateDto({
     this.description = const Optional.absent(),
     this.enabled = const Optional.absent(),
-    this.logging = const Optional.absent(),
     this.name = const Optional.absent(),
     this.steps = const Optional.present(const []),
     this.trigger = const Optional.absent(),
@@ -33,15 +32,6 @@ class WorkflowUpdateDto {
   ///
   Optional<bool?> enabled;
 
-  /// Workflow logs run results
-  ///
-  /// Please note: This property should have been non-nullable! Since the specification file
-  /// does not include a default value (using the "default:" property), however, the generated
-  /// source code must fall back to having a nullable type.
-  /// Consider adding a "default:" property in the specification file to hide this note.
-  ///
-  Optional<bool?> logging;
-
   /// Workflow name
   Optional<String?> name;
 
@@ -59,7 +49,6 @@ class WorkflowUpdateDto {
   bool operator ==(Object other) => identical(this, other) || other is WorkflowUpdateDto &&
     other.description == description &&
     other.enabled == enabled &&
-    other.logging == logging &&
     other.name == name &&
     _deepEquality.equals(other.steps, steps) &&
     other.trigger == trigger;
@@ -69,13 +58,12 @@ class WorkflowUpdateDto {
     // ignore: unnecessary_parenthesis
     (description == null ? 0 : description!.hashCode) +
     (enabled == null ? 0 : enabled!.hashCode) +
-    (logging == null ? 0 : logging!.hashCode) +
     (name == null ? 0 : name!.hashCode) +
     (steps.hashCode) +
     (trigger == null ? 0 : trigger!.hashCode);
 
   @override
-  String toString() => 'WorkflowUpdateDto[description=$description, enabled=$enabled, logging=$logging, name=$name, steps=$steps, trigger=$trigger]';
+  String toString() => 'WorkflowUpdateDto[description=$description, enabled=$enabled, name=$name, steps=$steps, trigger=$trigger]';
 
   Map<String, dynamic> toJson() {
     final json = <String, dynamic>{};
@@ -87,10 +75,6 @@ class WorkflowUpdateDto {
       final value = this.enabled.value;
       json[r'enabled'] = value;
     }
-    if (this.logging.isPresent) {
-      final value = this.logging.value;
-      json[r'logging'] = value;
-    }
     if (this.name.isPresent) {
       final value = this.name.value;
       json[r'name'] = value;
@@ -117,7 +101,6 @@ class WorkflowUpdateDto {
       return WorkflowUpdateDto(
         description: json.containsKey(r'description') ? Optional.present(mapValueOfType<String>(json, r'description')) : const Optional.absent(),
         enabled: json.containsKey(r'enabled') ? Optional.present(mapValueOfType<bool>(json, r'enabled')) : const Optional.absent(),
-        logging: json.containsKey(r'logging') ? Optional.present(mapValueOfType<bool>(json, r'logging')) : const Optional.absent(),
         name: json.containsKey(r'name') ? Optional.present(mapValueOfType<String>(json, r'name')) : const Optional.absent(),
         steps: json.containsKey(r'steps') ? Optional.present(WorkflowStepDto.listFromJson(json[r'steps'])) : const Optional.absent(),
         trigger: json.containsKey(r'trigger') ? Optional.present(WorkflowTrigger.fromJson(json[r'trigger'])) : const Optional.absent(),

mobile/pigeon/media_save_api.dart

@@ -0,0 +1,21 @@
+import 'package:pigeon/pigeon.dart';
+
+@ConfigurePigeon(
+  PigeonOptions(
+    dartOut: 'lib/platform/media_save_api.g.dart',
+    kotlinOut: 'android/app/src/main/kotlin/app/alextran/immich/mediasave/MediaSave.g.kt',
+    kotlinOptions: KotlinOptions(package: 'app.alextran.immich.mediasave'),
+    dartOptions: DartOptions(),
+    dartPackageName: 'immich_mobile',
+  ),
+)
+@HostApi()
+abstract class MediaSaveApi {
+  // Saves a file to a MediaStore Files-collection entry under [relativePath]
+  // (e.g. Download/Immich). Fallback for when photo_manager can't save a file
+  // because the platform has no MIME for it (e.g. raw like CR3) and MediaStore
+  // rejects the `image/*` it falls back to; the Files collection accepts any
+  // type. Returns the new media id, or null on failure.
+  @async
+  String? saveToDownloads(String filePath, String title, String? relativePath);
+}

mobile/test/utils/mime_utils_test.dart

@@ -0,0 +1,27 @@
+import 'package:flutter/services.dart';
+import 'package:flutter_test/flutter_test.dart';
+import 'package:immich_mobile/utils/mime.utils.dart';
+
+void main() {
+  group('isUnsupportedMimeError', () {
+    PlatformException err(Object? details) => PlatformException(code: 'saveImageWithPath', details: details);
+
+    test('detects the MediaStore unsupported-mime failure', () {
+      expect(isUnsupportedMimeError(err('java.lang.IllegalArgumentException: Unsupported MIME type image/*')), isTrue);
+    });
+
+    test('is case-insensitive', () {
+      expect(isUnsupportedMimeError(err('unsupported mime type foo')), isTrue);
+    });
+
+    test('ignores other Unsupported* errors', () {
+      expect(isUnsupportedMimeError(err('java.lang.UnsupportedOperationException')), isFalse);
+    });
+
+    test('ignores unrelated failures and non-string details', () {
+      expect(isUnsupportedMimeError(err('Permission denied')), isFalse);
+      expect(isUnsupportedMimeError(err(null)), isFalse);
+      expect(isUnsupportedMimeError(err(42)), isFalse);
+    });
+  });
+}

open-api/immich-openapi-specs.json

@@ -15854,15 +15854,6 @@
               "type": "string"
             }
           },
-          {
-            "name": "logging",
-            "required": false,
-            "in": "query",
-            "description": "Workflow logs run results",
-            "schema": {
-              "type": "boolean"
-            }
-          },
           {
             "name": "name",
             "required": false,
@@ -16176,95 +16167,6 @@
         "x-immich-state": "Deprecated"
       }
     },
-    "/workflows/{id}/logs": {
-      "get": {
-        "description": "Retrieve a workflow details without ids, default values, etc.",
-        "operationId": "getWorkflowLogs",
-        "parameters": [
-          {
-            "name": "before",
-            "required": false,
-            "in": "query",
-            "description": "Filter by runs before a date/time",
-            "schema": {
-              "format": "date-time",
-              "pattern": "^(?:(?:\\d\\d[2468][048]|\\d\\d[13579][26]|\\d\\d0[48]|[02468][048]00|[13579][26]00)-02-29|\\d{4}-(?:(?:0[13578]|1[02])-(?:0[1-9]|[12]\\d|3[01])|(?:0[469]|11)-(?:0[1-9]|[12]\\d|30)|(?:02)-(?:0[1-9]|1\\d|2[0-8])))T(?:(?:[01]\\d|2[0-3]):[0-5]\\d(?::[0-5]\\d(?:\\.\\d+)?)?(?:Z|([+-](?:[01]\\d|2[0-3]):[0-5]\\d)))$",
-              "example": "2024-01-01T00:00:00.000Z",
-              "type": "string"
-            }
-          },
-          {
-            "name": "id",
-            "required": true,
-            "in": "path",
-            "schema": {
-              "format": "uuid",
-              "pattern": "^([0-9a-fA-F]{8}-[0-9a-fA-F]{4}-4[0-9a-fA-F]{3}-[89abAB][0-9a-fA-F]{3}-[0-9a-fA-F]{12})$",
-              "type": "string"
-            }
-          },
-          {
-            "name": "limit",
-            "required": false,
-            "in": "query",
-            "description": "Maximum number of logs",
-            "schema": {
-              "maximum": 9007199254740991,
-              "exclusiveMinimum": true,
-              "default": 50,
-              "type": "integer",
-              "minimum": 0
-            }
-          },
-          {
-            "name": "result",
-            "required": false,
-            "in": "query",
-            "description": "Filter by run result",
-            "schema": {
-              "$ref": "#/components/schemas/WorkflowResult"
-            }
-          }
-        ],
-        "responses": {
-          "200": {
-            "content": {
-              "application/json": {
-                "schema": {
-                  "items": {
-                    "$ref": "#/components/schemas/WorkflowLogEntryDto"
-                  },
-                  "type": "array"
-                }
-              }
-            },
-            "description": ""
-          }
-        },
-        "security": [
-          {
-            "bearer": []
-          },
-          {
-            "cookie": []
-          },
-          {
-            "api_key": []
-          }
-        ],
-        "summary": "Retrieve a workflow",
-        "tags": [
-          "Workflows"
-        ],
-        "x-immich-history": [
-          {
-            "version": "v3.0.0",
-            "state": "Added"
-          }
-        ],
-        "x-immich-permission": "workflow.logs"
-      }
-    },
     "/workflows/{id}/share": {
       "get": {
         "description": "Retrieve a workflow details without ids, default values, etc.",
@@ -21113,7 +21015,6 @@
           "workflow.read",
           "workflow.update",
           "workflow.delete",
-          "workflow.logs",
           "adminUser.create",
           "adminUser.read",
           "adminUser.update",
@@ -27954,10 +27855,6 @@
             "description": "Workflow enabled",
             "type": "boolean"
           },
-          "logging": {
-            "description": "Workflow logs run results",
-            "type": "boolean"
-          },
           "name": {
             "description": "Workflow name",
             "nullable": true,
@@ -27979,56 +27876,6 @@
         ],
         "type": "object"
       },
-      "WorkflowLogEntryDto": {
-        "properties": {
-          "at": {
-            "description": "Workflow run date/time",
-            "type": "string"
-          },
-          "id": {
-            "description": "Workflow log entry ID",
-            "format": "uuid",
-            "pattern": "^([0-9a-fA-F]{8}-[0-9a-fA-F]{4}-4[0-9a-fA-F]{3}-[89abAB][0-9a-fA-F]{3}-[0-9a-fA-F]{12})$",
-            "type": "string"
-          },
-          "lastStep": {
-            "description": "Last step ran, if the workflow ended early",
-            "properties": {
-              "index": {
-                "description": "Index of the step in the workflow",
-                "exclusiveMinimum": true,
-                "maximum": 9007199254740991,
-                "minimum": 0,
-                "type": "integer"
-              },
-              "method": {
-                "description": "Method of the step",
-                "type": "string"
-              }
-            },
-            "required": [
-              "method",
-              "index"
-            ],
-            "type": "object"
-          },
-          "result": {
-            "$ref": "#/components/schemas/WorkflowResult"
-          },
-          "triggerDataId": {
-            "description": "Workflow trigger data ID",
-            "format": "uuid",
-            "pattern": "^([0-9a-fA-F]{8}-[0-9a-fA-F]{4}-[1-8][0-9a-fA-F]{3}-[89abAB][0-9a-fA-F]{3}-[0-9a-fA-F]{12}|00000000-0000-0000-0000-000000000000|ffffffff-ffff-ffff-ffff-ffffffffffff)$",
-            "type": "string"
-          }
-        },
-        "required": [
-          "at",
-          "id",
-          "result"
-        ],
-        "type": "object"
-      },
       "WorkflowResponseDto": {
         "properties": {
           "createdAt": {
@@ -28050,10 +27897,6 @@
             "pattern": "^([0-9a-fA-F]{8}-[0-9a-fA-F]{4}-4[0-9a-fA-F]{3}-[89abAB][0-9a-fA-F]{3}-[0-9a-fA-F]{12})$",
             "type": "string"
           },
-          "logging": {
-            "description": "Workflow logs run results",
-            "type": "boolean"
-          },
           "name": {
             "description": "Workflow name",
             "nullable": true,
@@ -28080,7 +27923,6 @@
           "description",
           "enabled",
           "id",
-          "logging",
           "name",
           "steps",
           "trigger",
@@ -28088,15 +27930,6 @@
         ],
         "type": "object"
       },
-      "WorkflowResult": {
-        "description": "Workflow run result",
-        "enum": [
-          "completed",
-          "halted",
-          "error"
-        ],
-        "type": "string"
-      },
       "WorkflowShareResponseDto": {
         "properties": {
           "description": {
@@ -28221,10 +28054,6 @@
             "description": "Workflow enabled",
             "type": "boolean"
           },
-          "logging": {
-            "description": "Workflow logs run results",
-            "type": "boolean"
-          },
           "name": {
             "description": "Workflow name",
             "nullable": true,

packages/sdk/src/fetch-client.ts

@@ -2791,8 +2791,6 @@ export type WorkflowResponseDto = {
     enabled: boolean;
     /** Workflow ID */
     id: string;
-    /** Workflow logs run results */
-    logging: boolean;
     /** Workflow name */
     name: string | null;
     /** Workflow steps */
@@ -2807,8 +2805,6 @@ export type WorkflowCreateDto = {
     description?: string | null;
     /** Workflow enabled */
     enabled?: boolean;
-    /** Workflow logs run results */
-    logging?: boolean;
     /** Workflow name */
     name?: string | null;
     steps?: WorkflowStepDto[];
@@ -2826,30 +2822,12 @@ export type WorkflowUpdateDto = {
     description?: string | null;
     /** Workflow enabled */
     enabled?: boolean;
-    /** Workflow logs run results */
-    logging?: boolean;
     /** Workflow name */
     name?: string | null;
     steps?: WorkflowStepDto[];
     /** Workflow trigger type */
     trigger?: WorkflowTrigger;
 };
-export type WorkflowLogEntryDto = {
-    /** Workflow run date/time */
-    at: string;
-    /** Workflow log entry ID */
-    id: string;
-    /** Last step ran, if the workflow ended early */
-    lastStep?: {
-        /** Index of the step in the workflow */
-        index: number;
-        /** Method of the step */
-        method: string;
-    };
-    result: WorkflowResult;
-    /** Workflow trigger data ID */
-    triggerDataId?: string;
-};
 export type WorkflowShareStepDto = {
     /** Step configuration */
     config: {
@@ -6999,11 +6977,10 @@ export function getUniqueOriginalPaths(opts?: Oazapfts.RequestOpts) {
 /**
  * List all workflows
  */
-export function searchWorkflows({ description, enabled, id, logging, name, trigger }: {
+export function searchWorkflows({ description, enabled, id, name, trigger }: {
     description?: string;
     enabled?: boolean;
     id?: string;
-    logging?: boolean;
     name?: string;
     trigger?: WorkflowTrigger;
 }, opts?: Oazapfts.RequestOpts) {
@@ -7014,7 +6991,6 @@ export function searchWorkflows({ description, enabled, id, logging, name, trigg
         description,
         enabled,
         id,
-        logging,
         name,
         trigger
     }))}`, {
@@ -7087,26 +7063,6 @@ export function updateWorkflow({ id, workflowUpdateDto }: {
         body: workflowUpdateDto
     })));
 }
-/**
- * Retrieve a workflow
- */
-export function getWorkflowLogs({ before, id, limit, result }: {
-    before?: string;
-    id: string;
-    limit?: number;
-    result?: WorkflowResult;
-}, opts?: Oazapfts.RequestOpts) {
-    return oazapfts.ok(oazapfts.fetchJson<{
-        status: 200;
-        data: WorkflowLogEntryDto[];
-    }>(`/workflows/${encodeURIComponent(id)}/logs${QS.query(QS.explode({
-        before,
-        limit,
-        result
-    }))}`, {
-        ...opts
-    }));
-}
 /**
  * Retrieve a workflow
  */
@@ -7354,7 +7310,6 @@ export enum Permission {
     WorkflowRead = "workflow.read",
     WorkflowUpdate = "workflow.update",
     WorkflowDelete = "workflow.delete",
-    WorkflowLogs = "workflow.logs",
     AdminUserCreate = "adminUser.create",
     AdminUserRead = "adminUser.read",
     AdminUserUpdate = "adminUser.update",
@@ -7731,11 +7686,6 @@ export enum AssetOrderBy {
     TakenAt = "takenAt",
     CreatedAt = "createdAt"
 }
-export enum WorkflowResult {
-    Completed = "completed",
-    Halted = "halted",
-    Error = "error"
-}
 export enum ReleaseType {
     Major = "major",
     Premajor = "premajor",

server/src/controllers/workflow.controller.ts

@@ -4,8 +4,6 @@ import { Endpoint, HistoryBuilder } from 'src/decorators';
 import { AuthDto } from 'src/dtos/auth.dto';
 import {
   WorkflowCreateDto,
-  WorkflowGetLogsDto,
-  WorkflowLogEntryDto,
   WorkflowResponseDto,
   WorkflowSearchDto,
   WorkflowShareResponseDto,
@@ -115,19 +113,4 @@ export class WorkflowController {
   deleteWorkflow(@Auth() auth: AuthDto, @Param() { id }: UUIDParamDto): Promise<void> {
     return this.service.delete(auth, id);
   }
-
-  @Get(':id/logs')
-  @Authenticated({ permission: Permission.WorkflowLogs })
-  @Endpoint({
-    summary: 'Retrieve a workflow',
-    description: 'Retrieve a workflow details without ids, default values, etc.',
-    history: HistoryBuilder.v3(),
-  })
-  getWorkflowLogs(
-    @Auth() auth: AuthDto,
-    @Param() { id }: UUIDParamDto,
-    @Query() dto: WorkflowGetLogsDto,
-  ): Promise<WorkflowLogEntryDto[]> {
-    return this.service.getLogs(auth, id, dto);
-  }
 }

server/src/dtos/workflow.dto.ts

@@ -1,7 +1,6 @@
 import type { WorkflowStepConfig, WorkflowTrigger } from '@immich/plugin-sdk';
 import { createZodDto } from 'nestjs-zod';
-import { WorkflowResultSchema, WorkflowTriggerSchema, WorkflowTypeSchema } from 'src/enum';
-import { isoDatetimeToDate } from 'src/validation';
+import { WorkflowTriggerSchema, WorkflowTypeSchema } from 'src/enum';
 import z from 'zod';
 
 const WorkflowTriggerResponseSchema = z
@@ -18,7 +17,6 @@ const WorkflowSearchSchema = z
     name: z.string().optional().describe('Workflow name'),
     description: z.string().optional().describe('Workflow description'),
     enabled: z.boolean().optional().describe('Workflow enabled'),
-    logging: z.boolean().optional().describe('Workflow logs run results'),
   })
   .meta({ id: 'WorkflowSearchDto' });
 
@@ -44,7 +42,6 @@ const WorkflowCreateSchema = z
     name: z.string().nullable().optional().describe('Workflow name'),
     description: z.string().nullable().optional().describe('Workflow description'),
     enabled: z.boolean().optional().describe('Workflow enabled'),
-    logging: z.boolean().optional().describe('Workflow logs run results'),
     steps: z.array(WorkflowStepSchema).optional(),
   })
   .meta({ id: 'WorkflowCreateDto' });
@@ -55,7 +52,6 @@ const WorkflowUpdateSchema = z
     name: z.string().nullable().optional().describe('Workflow name'),
     description: z.string().nullable().optional().describe('Workflow description'),
     enabled: z.boolean().optional().describe('Workflow enabled'),
-    logging: z.boolean().optional().describe('Workflow logs run results'),
     steps: z.array(WorkflowStepSchema).optional(),
   })
   .meta({ id: 'WorkflowUpdateDto' });
@@ -69,7 +65,6 @@ const WorkflowResponseSchema = z
     createdAt: z.string().describe('Creation date'),
     updatedAt: z.string().describe('Update date'),
     enabled: z.boolean().describe('Workflow enabled'),
-    logging: z.boolean().describe('Workflow logs run results'),
     steps: z.array(WorkflowStepSchema).describe('Workflow steps'),
   })
   .meta({ id: 'WorkflowResponseDto' });
@@ -83,36 +78,12 @@ const WorkflowShareResponseSchema = z
   })
   .meta({ id: 'WorkflowShareResponseDto' });
 
-const WorkflowLogEntrySchema = z
-  .object({
-    id: z.uuidv4().describe('Workflow log entry ID'),
-    at: z.string().describe('Workflow run date/time'),
-    result: WorkflowResultSchema.describe('Workflow run result'),
-    triggerDataId: z.uuid().optional().describe('Workflow trigger data ID'),
-    lastStep: z
-      .object({
-        method: z.string().describe('Method of the step'),
-        index: z.int().positive().describe('Index of the step in the workflow'),
-      })
-      .optional()
-      .describe('Last step ran, if the workflow ended early'),
-  })
-  .meta({ id: 'WorkflowLogEntryDto' });
-
-const WorkflowGetLogsSchema = z.object({
-  result: WorkflowResultSchema.optional().describe('Filter by run result'),
-  before: isoDatetimeToDate.optional().describe('Filter by runs before a date/time'),
-  limit: z.coerce.number().int().positive().default(50).describe('Maximum number of logs'),
-});
-
 export class WorkflowTriggerResponseDto extends createZodDto(WorkflowTriggerResponseSchema) {}
 export class WorkflowSearchDto extends createZodDto(WorkflowSearchSchema) {}
 export class WorkflowCreateDto extends createZodDto(WorkflowCreateSchema) {}
 export class WorkflowUpdateDto extends createZodDto(WorkflowUpdateSchema) {}
 export class WorkflowResponseDto extends createZodDto(WorkflowResponseSchema) {}
 export class WorkflowShareResponseDto extends createZodDto(WorkflowShareResponseSchema) {}
-export class WorkflowLogEntryDto extends createZodDto(WorkflowLogEntrySchema) {}
-export class WorkflowGetLogsDto extends createZodDto(WorkflowGetLogsSchema) {}
 
 type Workflow = {
   id: string;
@@ -122,7 +93,6 @@ type Workflow = {
   name: string | null;
   description: string | null;
   enabled: boolean;
-  logging: boolean;
 };
 
 type WorkflowStep = {
@@ -137,7 +107,6 @@ export const mapWorkflow = (workflow: Workflow & { steps: WorkflowStep[] }): Wor
     id: workflow.id,
     enabled: workflow.enabled,
     trigger: workflow.trigger,
-    logging: workflow.logging,
     name: workflow.name,
     description: workflow.description,
     createdAt: workflow.createdAt.toISOString(),

server/src/enum.ts

@@ -298,7 +298,6 @@ export enum Permission {
   WorkflowRead = 'workflow.read',
   WorkflowUpdate = 'workflow.update',
   WorkflowDelete = 'workflow.delete',
-  WorkflowLogs = 'workflow.logs',
 
   AdminUserCreate = 'adminUser.create',
   AdminUserRead = 'adminUser.read',
@@ -1235,14 +1234,3 @@ export enum CalendarHeatmapType {
   Upload = 'Upload',
   Taken = 'Taken',
 }
-
-export enum WorkflowResult {
-  Completed = 'completed',
-  Halted = 'halted',
-  Error = 'error',
-}
-
-export const WorkflowResultSchema = z
-  .enum(WorkflowResult)
-  .describe('Workflow run result')
-  .meta({ id: 'WorkflowResult' });

server/src/queries/workflow.repository.sql

@@ -9,7 +9,6 @@ select
   "workflow"."enabled",
   "workflow"."createdAt",
   "workflow"."updatedAt",
-  "workflow"."logging",
   (
     select
       coalesce(json_agg(agg), '[]')
@@ -42,7 +41,6 @@ select
   "workflow"."enabled",
   "workflow"."createdAt",
   "workflow"."updatedAt",
-  "workflow"."logging",
   (
     select
       coalesce(json_agg(agg), '[]')
@@ -71,7 +69,6 @@ select
   "workflow"."id",
   "workflow"."name",
   "workflow"."trigger",
-  "workflow"."logging",
   (
     select
       coalesce(json_agg(agg), '[]')
@@ -99,40 +96,6 @@ where
   "id" = $2
   and "enabled" = $3
 
--- WorkflowRepository.getLogs
-select
-  "workflow_log"."id",
-  "workflow_log"."createdAt",
-  "workflow_log"."halted",
-  "workflow_log"."error",
-  "workflow_log"."workflowId",
-  "workflow_log"."workflowStepId",
-  "workflow_log"."triggerDataId",
-  (
-    select
-      to_json(obj)
-    from
-      (
-        select
-          "plugin_method"."pluginId",
-          "plugin_method"."name" as "methodName",
-          "workflow_step"."order"
-        from
-          "workflow_step"
-          inner join "plugin_method" on "plugin_method"."id" = "workflow_step"."pluginMethodId"
-        where
-          "workflow_step"."id" = "workflow_log"."workflowStepId"
-      ) as obj
-  ) as "step"
-from
-  "workflow_log"
-where
-  "workflow_log"."workflowId" = $1
-order by
-  "workflow_log"."createdAt" desc
-limit
-  $2
-
 -- WorkflowRepository.delete
 delete from "workflow"
 where

server/src/repositories/workflow.repository.ts

@@ -4,10 +4,8 @@ import { jsonArrayFrom, jsonObjectFrom } from 'kysely/helpers/postgres';
 import { InjectKysely } from 'nestjs-kysely';
 import { columns } from 'src/database';
 import { DummyValue, GenerateSql } from 'src/decorators';
-import { WorkflowGetLogsDto, WorkflowSearchDto } from 'src/dtos/workflow.dto';
-import { WorkflowResult } from 'src/enum';
+import { WorkflowSearchDto } from 'src/dtos/workflow.dto';
 import { DB } from 'src/schema';
-import { WorkflowLogTable } from 'src/schema/tables/workflow-log.table';
 import { WorkflowStepTable } from 'src/schema/tables/workflow-step.table';
 import { WorkflowTable } from 'src/schema/tables/workflow.table';
 
@@ -28,7 +26,6 @@ export class WorkflowRepository {
         'workflow.enabled',
         'workflow.createdAt',
         'workflow.updatedAt',
-        'workflow.logging',
       ])
       .select((eb) => [
         jsonArrayFrom(
@@ -67,7 +64,7 @@ export class WorkflowRepository {
   getForWorkflowRun(id: string) {
     return this.db
       .selectFrom('workflow')
-      .select(['workflow.id', 'workflow.name', 'workflow.trigger', 'workflow.logging'])
+      .select(['workflow.id', 'workflow.name', 'workflow.trigger'])
       .select((eb) => [
         jsonArrayFrom(
           eb
@@ -100,9 +97,6 @@ export class WorkflowRepository {
 
   update(id: string, dto: Updateable<WorkflowTable>, steps?: WorkflowStepUpsert[]) {
     return this.db.transaction().execute(async (tx) => {
-      if (dto.logging === false) {
-        await tx.deleteFrom('workflow_log').where('workflowId', '=', id).execute();
-      }
       if (Object.values(dto).some((prop) => prop !== undefined)) {
         await tx.updateTable('workflow').set(dto).where('id', '=', id).executeTakeFirstOrThrow();
       }
@@ -110,44 +104,6 @@ export class WorkflowRepository {
     });
   }
 
-  @GenerateSql({ params: [DummyValue.UUID, { result: undefined }] })
-  getLogs(id: string, dto: WorkflowGetLogsDto) {
-    return this.db
-      .selectFrom('workflow_log')
-      .select([
-        'workflow_log.id',
-        'workflow_log.createdAt',
-        'workflow_log.halted',
-        'workflow_log.error',
-        'workflow_log.workflowId',
-        'workflow_log.workflowStepId',
-        'workflow_log.triggerDataId',
-      ])
-      .where('workflow_log.workflowId', '=', id)
-      .select((eb) => [
-        jsonObjectFrom(
-          eb
-            .selectFrom('workflow_step')
-            .whereRef('workflow_step.id', '=', 'workflow_log.workflowStepId')
-            .innerJoin('plugin_method', 'plugin_method.id', 'workflow_step.pluginMethodId')
-            .select(['plugin_method.pluginId', 'plugin_method.name as methodName', 'workflow_step.order']),
-        ).as('step'),
-      ])
-      .$if(dto.result === WorkflowResult.Error, (qb) => qb.where('workflow_log.error', '=', true))
-      .$if(dto.result === WorkflowResult.Halted, (qb) => qb.where('workflow_log.halted', '=', true))
-      .$if(dto.result === WorkflowResult.Completed, (qb) =>
-        qb.where('workflow_log.halted', '=', false).where('workflow_log.error', '=', false),
-      )
-      .$if(dto.before !== undefined, (qb) => qb.where('workflow_log.createdAt', '<', dto.before!))
-      .orderBy('workflow_log.createdAt', 'desc')
-      .limit(dto.limit)
-      .execute();
-  }
-
-  log(dto: Insertable<WorkflowLogTable>) {
-    return this.db.insertInto('workflow_log').values(dto).execute();
-  }
-
   async updateStep(id: string, dto: Updateable<WorkflowStepTable>) {
     await this.db.updateTable('workflow_step').where('workflow_step.id', '=', id).set(dto).execute();
   }

server/src/schema/index.ts

@@ -86,7 +86,6 @@ import {
   VideoStreamSessionTable,
   VideoStreamVariantTable,
 } from 'src/schema/tables/video-stream.table';
-import { WorkflowLogTable } from 'src/schema/tables/workflow-log.table';
 import { WorkflowStepTable } from 'src/schema/tables/workflow-step.table';
 import { WorkflowTable } from 'src/schema/tables/workflow.table';
 
@@ -278,5 +277,4 @@ export interface DB {
 
   workflow: WorkflowTable;
   workflow_step: WorkflowStepTable;
-  workflow_log: WorkflowLogTable;
 }

server/src/schema/migrations/1783930557118-AddWorkflowLogsTable.ts

@@ -1,24 +0,0 @@
-import { Kysely, sql } from 'kysely';
-
-export async function up(db: Kysely<any>): Promise<void> {
-  await sql`ALTER TABLE "workflow" ADD "logging" boolean NOT NULL DEFAULT false;`.execute(db);
-  await sql`CREATE TABLE "workflow_log" (
-  "id" uuid NOT NULL DEFAULT uuid_generate_v4(),
-  "createdAt" timestamp with time zone NOT NULL DEFAULT now(),
-  "workflowId" uuid NOT NULL,
-  "error" boolean NOT NULL,
-  "halted" boolean NOT NULL,
-  "workflowStepId" uuid,
-  "triggerDataId" uuid,
-  CONSTRAINT "workflow_log_workflowId_fkey" FOREIGN KEY ("workflowId") REFERENCES "workflow" ("id") ON UPDATE CASCADE ON DELETE CASCADE,
-  CONSTRAINT "workflow_log_workflowStepId_fkey" FOREIGN KEY ("workflowStepId") REFERENCES "workflow_step" ("id") ON UPDATE CASCADE ON DELETE SET NULL,
-  CONSTRAINT "workflow_log_pkey" PRIMARY KEY ("id")
-);`.execute(db);
-  await sql`CREATE INDEX "workflow_log_workflowId_idx" ON "workflow_log" ("workflowId");`.execute(db);
-  await sql`CREATE INDEX "workflow_log_workflowStepId_idx" ON "workflow_log" ("workflowStepId");`.execute(db);
-}
-
-export async function down(db: Kysely<any>): Promise<void> {
-  await sql`ALTER TABLE "workflow" DROP COLUMN "logging";`.execute(db);
-  await sql`DROP TABLE "workflow_log";`.execute(db);
-}

server/src/schema/tables/workflow-log.table.ts

@@ -1,35 +0,0 @@
-import {
-  Column,
-  CreateDateColumn,
-  ForeignKeyColumn,
-  Generated,
-  PrimaryGeneratedColumn,
-  Table,
-  Timestamp,
-} from '@immich/sql-tools';
-import { WorkflowStepTable } from 'src/schema/tables/workflow-step.table';
-import { WorkflowTable } from 'src/schema/tables/workflow.table';
-
-@Table('workflow_log')
-export class WorkflowLogTable {
-  @PrimaryGeneratedColumn()
-  id!: Generated<string>;
-
-  @CreateDateColumn()
-  createdAt!: Generated<Timestamp>;
-
-  @ForeignKeyColumn(() => WorkflowTable, { onUpdate: 'CASCADE', onDelete: 'CASCADE', index: true })
-  workflowId!: string;
-
-  @Column({ type: 'boolean' })
-  error!: boolean;
-
-  @Column({ type: 'boolean' })
-  halted!: boolean;
-
-  @ForeignKeyColumn(() => WorkflowStepTable, { onDelete: 'SET NULL', onUpdate: 'CASCADE', nullable: true })
-  workflowStepId!: string | null;
-
-  @Column({ type: 'uuid', nullable: true })
-  triggerDataId!: string | null;
-}

server/src/schema/tables/workflow.table.ts

@@ -41,7 +41,4 @@ export class WorkflowTable {
 
   @Column({ type: 'boolean', default: true })
   enabled!: Generated<boolean>;
-
-  @Column({ type: 'boolean', default: false })
-  logging!: Generated<boolean>;
 }

server/src/services/workflow-execution.service.ts

@@ -36,7 +36,7 @@ const dummy = () => {
 };
 
 type ExecuteOptions<T extends WorkflowType> = {
-  read: (type: T) => Promise<{ authUserId: string; data: WorkflowEventData<T>; entityId?: string }>;
+  read: (type: T) => Promise<{ authUserId: string; data: WorkflowEventData<T> }>;
   write: (auth: AuthDto, changes: WorkflowChanges<T>) => Promise<void>;
 };
 
@@ -331,7 +331,6 @@ export class WorkflowExecutionService extends BaseService {
               return {
                 data: { asset } as any,
                 authUserId: asset.ownerId,
-                entityId: asset.id,
               };
             },
             write: async (auth, changes) => {
@@ -399,12 +398,11 @@ export class WorkflowExecutionService extends BaseService {
       return;
     }
 
-    const { read, write } = handler;
-    const readResult = await read(type);
-    let data = readResult.data;
-
-    for (const step of workflow.steps) {
-      try {
+    try {
+      const { read, write } = handler;
+      const readResult = await read(type);
+      let data = readResult.data;
+      for (const step of workflow.steps) {
         const payload: WorkflowEventPayload<typeof type> = {
           trigger: workflow.trigger,
           type,
@@ -455,45 +453,14 @@ export class WorkflowExecutionService extends BaseService {
 
         const shouldContinue = result?.workflow?.continue ?? true;
         if (!shouldContinue) {
-          if (workflow.logging) {
-            await this.workflowRepository.log({
-              workflowId,
-              error: false,
-              halted: true,
-              workflowStepId: step.id,
-              triggerDataId: readResult.entityId,
-            });
-          }
-
-          this.logger.debug(`Workflow ${workflowId} stopped on step ${step.id}`);
-          return;
+          break;
         }
-      } catch (error) {
-        this.logger.error(`Error executing workflow ${workflowId}:`, error);
-
-        if (workflow.logging) {
-          await this.workflowRepository.log({
-            workflowId,
-            error: true,
-            halted: false,
-            workflowStepId: step.id,
-            triggerDataId: readResult.entityId,
-          });
-        }
-
-        return JobStatus.Failed;
       }
-    }
 
-    if (workflow.logging) {
-      await this.workflowRepository.log({
-        workflowId,
-        error: false,
-        halted: false,
-        triggerDataId: readResult.entityId,
-      });
+      this.logger.debug(`Workflow ${workflowId} executed successfully`);
+    } catch (error) {
+      this.logger.error(`Error executing workflow ${workflowId}:`, error);
+      return JobStatus.Failed;
     }
-
-    this.logger.debug(`Workflow ${workflowId} executed successfully`);
   }
 }

server/src/services/workflow.service.ts

@@ -5,15 +5,13 @@ import {
   mapWorkflow,
   mapWorkflowShare,
   WorkflowCreateDto,
-  WorkflowGetLogsDto,
-  WorkflowLogEntryDto,
   WorkflowResponseDto,
   WorkflowSearchDto,
   WorkflowShareResponseDto,
   WorkflowTriggerResponseDto,
   WorkflowUpdateDto,
 } from 'src/dtos/workflow.dto';
-import { Permission, WorkflowResult } from 'src/enum';
+import { Permission } from 'src/enum';
 import { PluginMethodSearchResponse } from 'src/repositories/plugin.repository';
 import { BaseService } from 'src/services/base.service';
 import { getWorkflowTriggers, isMethodCompatible, resolveMethod } from 'src/utils/workflow';
@@ -84,23 +82,6 @@ export class WorkflowService extends BaseService {
     await this.workflowRepository.delete(id);
   }
 
-  async getLogs(auth: AuthDto, id: string, dto: WorkflowGetLogsDto): Promise<WorkflowLogEntryDto[]> {
-    await this.requireAccess({ auth, permission: Permission.WorkflowLogs, ids: [id] });
-    const logs = await this.workflowRepository.getLogs(id, dto);
-    return logs.map((entry) => ({
-      id: entry.id,
-      at: entry.createdAt.toISOString(),
-      result: entry.error ? WorkflowResult.Error : entry.halted ? WorkflowResult.Halted : WorkflowResult.Completed,
-      triggerDataId: entry.triggerDataId ?? undefined,
-      lastStep: entry.step
-        ? {
-            index: entry.step.order,
-            method: `${entry.step.pluginId}#${entry.step.methodName}`,
-          }
-        : undefined,
-    }));
-  }
-
   private async resolveAndValidateSteps<T extends { method: string }>(steps: T[], trigger: WorkflowTrigger) {
     const methods = await this.pluginRepository.getForValidation();
     const results: Array<T & { pluginMethod: PluginMethodSearchResponse }> = [];

server/src/utils/access.ts

@@ -324,8 +324,7 @@ const checkOtherAccess = async (access: AccessRepository, request: OtherAccessRe
 
     case Permission.WorkflowRead:
     case Permission.WorkflowUpdate:
-    case Permission.WorkflowDelete:
-    case Permission.WorkflowLogs: {
+    case Permission.WorkflowDelete: {
       return access.workflow.checkOwnerAccess(auth.user.id, ids);
     }
 

web/src/lib/modals/WorkflowLogsModal.svelte

@@ -1,169 +0,0 @@
-<script lang="ts">
-  import { type WorkflowLogEntryDto, type WorkflowResponseDto, WorkflowResult, getWorkflowLogs } from '@immich/sdk';
-  import {
-    Modal,
-    ModalBody,
-    Table,
-    TableHeader,
-    TableHeading,
-    TableBody,
-    TableRow,
-    TableCell,
-    HStack,
-    Icon,
-    VStack,
-    Button,
-    Select,
-    type SelectOption,
-  } from '@immich/ui';
-  import { mdiHistory, mdiOpenInNew } from '@mdi/js';
-  import { t } from 'svelte-i18n';
-  import { locale } from '$lib/stores/preferences.store';
-  import { DateTime } from 'luxon';
-  import { Route } from '$lib/route';
-  import { handleUpdateWorkflow } from '$lib/services/workflow.service';
-
-  type Props = {
-    workflow: WorkflowResponseDto;
-    onClose: () => void;
-  };
-
-  let { workflow, onClose }: Props = $props();
-
-  let entries: WorkflowLogEntryDto[] = $state([]);
-  let placeholder: HTMLElement | undefined = $state();
-  let filter: WorkflowResult | undefined = $state();
-  let before: string | undefined = $state();
-  let hasNext = $state(true);
-  let loading = $state(false);
-
-  const setLogging = (logging: boolean) =>
-    handleUpdateWorkflow(workflow.id, { logging }).then((success) => {
-      if (success) {
-        workflow = { ...workflow, logging };
-        reset();
-      }
-    });
-
-  const reset = () => {
-    entries = [];
-    hasNext = true;
-    before = undefined;
-  };
-
-  const setFilter = (option: SelectOption<WorkflowResult>) => {
-    reset();
-    filter = option.value;
-    void getLogs();
-  };
-
-  const getLogs = async () => {
-    if (!hasNext || loading) {
-      return;
-    }
-
-    loading = true;
-    const limit = 50;
-    const results = await getWorkflowLogs({ id: workflow.id, result: filter, before, limit });
-    entries.push(...results);
-    if (results.length < limit) {
-      hasNext = false;
-    } else {
-      before = results.at(-1)?.at;
-    }
-    loading = false;
-  };
-
-  const observer = new IntersectionObserver((entries) => {
-    const entry = entries.find((entry) => entry.target === placeholder);
-    if (entry?.isIntersecting) {
-      void getLogs();
-    }
-  });
-
-  $effect(() => {
-    if (placeholder) {
-      observer.disconnect();
-      observer.observe(placeholder);
-    }
-  });
-</script>
-
-<Modal title={$t('logs')} icon={mdiHistory} {onClose} size="medium">
-  <ModalBody>
-    {#if workflow.logging}
-      <Table striped>
-        <TableHeader>
-          <TableHeading>{$t('date')}</TableHeading>
-          <TableHeading>{$t('result')}</TableHeading>
-        </TableHeader>
-        <TableBody class="max-h-100">
-          {#each entries as entry (entry.id)}
-            <TableRow>
-              <TableCell>
-                <HStack class="justify-center">
-                  <p>
-                    {DateTime.fromISO(entry.at).toLocaleString(DateTime.DATETIME_MED, {
-                      locale: $locale,
-                    })}
-                  </p>
-                  {#if entry.triggerDataId}
-                    <a href={Route.viewAsset({ id: entry.triggerDataId })} target="_blank">
-                      <Icon icon={mdiOpenInNew} size="20" class="text-primary" />
-                    </a>
-                  {/if}
-                </HStack>
-              </TableCell>
-              <TableCell>
-                <HStack class="justify-center">
-                  {#if entry.result === WorkflowResult.Completed}
-                    <p class="rounded-full bg-green-700 px-3 py-1 text-xs text-white">
-                      {$t('workflow_logging_completed')}
-                    </p>
-                  {:else if entry.result === WorkflowResult.Halted}
-                    <p class="rounded-full bg-gray-600 px-3 py-1 text-xs text-white">
-                      {#if entry.lastStep}
-                        {$t('workflow_logging_halted_step', { values: { step: entry.lastStep.index + 1 } })}
-                      {:else}
-                        {$t('workflow_logging_halted')}
-                      {/if}
-                    </p>
-                  {:else}
-                    <p class="rounded-full bg-red-500 px-3 py-1 text-xs text-white">
-                      {#if entry.lastStep}
-                        {$t('workflow_logging_error_step', { values: { step: entry.lastStep.index + 1 } })}
-                      {:else}
-                        {$t('error')}
-                      {/if}
-                    </p>
-                  {/if}
-                </HStack>
-              </TableCell>
-            </TableRow>
-          {/each}
-          {#if hasNext}
-            <TableRow><TableCell><div bind:this={placeholder}>...</div></TableCell></TableRow>
-          {/if}
-        </TableBody>
-      </Table>
-      <div class="mt-5 flex gap-5">
-        <Select
-          onSelect={setFilter}
-          class="flex-1"
-          placeholder={$t('filter')}
-          options={[
-            { value: WorkflowResult.Completed, label: $t('workflow_logging_completed') },
-            { value: WorkflowResult.Halted, label: $t('workflow_logging_halted') },
-            { value: WorkflowResult.Error, label: $t('error') },
-          ]}
-        />
-        <Button class="flex-1" onclick={() => setLogging(false)}>{$t('workflow_logging_disable')}</Button>
-      </div>
-    {:else}
-      <VStack class="gap-5 py-5">
-        <p class="text-md text-center">{$t('workflow_logging_disabled_description')}</p>
-        <Button onclick={() => setLogging(true)}>{$t('workflow_logging_enable')}</Button>
-      </VStack>
-    {/if}
-  </ModalBody>
-</Modal>

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

@@ -17,7 +17,6 @@ import {
   mdiDeleteOutline,
   mdiDownload,
   mdiFileDocumentMultipleOutline,
-  mdiHistory,
   mdiPause,
   mdiPencil,
   mdiPlay,
@@ -27,7 +26,6 @@ import type { MessageFormatter } from 'svelte-i18n';
 import { goto } from '$app/navigation';
 import { eventManager } from '$lib/managers/event-manager.svelte';
 import WorkflowDuplicateModal from '$lib/modals/WorkflowDuplicateModal.svelte';
-import WorkflowLogsModal from '$lib/modals/WorkflowLogsModal.svelte';
 import WorkflowTemplatePickerModal from '$lib/modals/WorkflowTemplatePickerModal.svelte';
 import { Route } from '$lib/route';
 import { copyToClipboard, downloadJson } from '$lib/utils';
@@ -119,13 +117,7 @@ export const getWorkflowActions = ($t: MessageFormatter, workflow: WorkflowRespo
     onAction: () => handleDeleteWorkflow(workflow),
   };
 
-  const Logs: ActionItem = {
-    title: $t('check_logs'),
-    icon: mdiHistory,
-    onAction: () => modalManager.show(WorkflowLogsModal, { workflow }),
-  };
-
-  return { CopyJson, Download, Duplicate, ToggleEnabled, Edit, Delete, Logs };
+  return { CopyJson, Download, Duplicate, ToggleEnabled, Edit, Delete };
 };
 
 export const getWorkflowShowSchemaAction = (

web/src/routes/(user)/workflows/+page.svelte

@@ -75,7 +75,7 @@
       {:else}
         <div class="my-6 flex flex-col gap-3">
           {#each workflows as workflow (workflow.id)}
-            {@const { ToggleEnabled, Duplicate, Logs, Edit, Delete } = getWorkflowActions($t, workflow)}
+            {@const { ToggleEnabled, Duplicate, Edit, Delete } = getWorkflowActions($t, workflow)}
 
             <Card class="group shadow-none transition-colors hover:border-primary">
               <CardHeader>
@@ -120,7 +120,6 @@
                       ToggleEnabled,
                       Edit,
                       Duplicate,
-                      Logs,
                       getWorkflowShowSchemaAction($t, expandedIds.has(workflow.id), () => onToggleExpand(workflow.id)),
                       MenuItemType.Divider,
                       Delete,

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

@@ -261,7 +261,7 @@
 
   $effect(() => console.log(steps));
 
-  const { Download, Duplicate, CopyJson, Delete, Logs } = $derived(
+  const { Download, Duplicate, CopyJson, Delete } = $derived(
     getWorkflowActions($t, { ...savedWorkflow, name, description, enabled, trigger, steps }),
   );
 </script>
@@ -276,7 +276,7 @@
       {onClose}
       translations={{ close: $t('back') }}
       closeIcon={mdiArrowLeft}
-      actions={[Logs, Duplicate, CopyJson, Download, Delete].map((item) => ({ ...item, color: undefined }))}
+      actions={[Duplicate, CopyJson, Download, Delete].map((item) => ({ ...item, color: undefined }))}
     >
       <ControlBarHeader>
         <ControlBarTitle>{data.workflow.name}</ControlBarTitle>