fix: Use correct files to discard after local consumption

lib/features/document_upload/cubit/document_upload_cubit.dart

@@ -44,6 +44,7 @@ class DocumentUploadCubit extends Cubit<DocumentUploadState> {
     Iterable<int> tags = const [],
     DateTime? createdAt,
     int? asn,
+    void Function(double)? onProgressChanged,
   }) async {
     final taskId = await _documentApi.create(
       bytes,
@@ -54,6 +55,7 @@ class DocumentUploadCubit extends Cubit<DocumentUploadState> {
       tags: tags,
       createdAt: createdAt,
       asn: asn,
+      onProgressChanged: onProgressChanged,
     );
     if (taskId != null) {
       _tasksNotifier.listenToTaskChanges(taskId);

lib/features/sharing/cubit/receive_share_cubit.dart

@@ -23,27 +23,28 @@ class ConsumptionChangeNotifier extends ChangeNotifier {
   }
 
   /// Creates a local copy of all shared files and reloads all files
-  /// from the user's consumption directory.
+  /// from the user's consumption directory. Returns the newly added files copied to the consumption directory.
-  Future<void> addFiles({
+  Future<List<File>> addFiles({
     required List<File> files,
     required String userId,
   }) async {
     if (files.isEmpty) {
-      return;
+      return [];
     }
     final consumptionDirectory =
         await FileService.getConsumptionDirectory(userId: userId);
+    final List<File> localFiles = [];
     for (final file in files) {
-      File localFile;
+      if (!file.path.startsWith(consumptionDirectory.path)) {
-      if (file.path.startsWith(consumptionDirectory.path)) {
+        final localFile = await file
-        localFile = file;
+            .copy(p.join(consumptionDirectory.path, p.basename(file.path)));
+        localFiles.add(localFile);
       } else {
-        final fileName = p.basename(file.path);
+        localFiles.add(file);
-        localFile = File(p.join(consumptionDirectory.path, fileName));
-        await file.copy(localFile.path);
       }
     }
-    return loadFromConsumptionDirectory(userId: userId);
+    await loadFromConsumptionDirectory(userId: userId);
+    return localFiles;
   }
 
   /// Marks a file as processed by removing it from the queue and deleting the local copy of the file.

lib/features/sharing/view/widgets/event_listener_shell.dart

@@ -141,13 +141,13 @@ class _EventListenerShellState extends State<EventListenerShell>
     if (files.isNotEmpty) {
       final userId = context.read<LocalUserAccount>().id;
       final notifier = context.read<ConsumptionChangeNotifier>();
-      await notifier.addFiles(
+      final addedLocalFiles = await notifier.addFiles(
         files: files,
         userId: userId,
       );
       consumeLocalFiles(
         context,
-        files: files,
+        files: addedLocalFiles,
         userId: userId,
         exitAppAfterConsumed: true,
       );

packages/paperless_api/lib/src/modules/documents_api/paperless_documents_api.dart

@@ -14,6 +14,7 @@ abstract class PaperlessDocumentsApi {
     int? correspondent,
     Iterable<int> tags = const [],
     int? asn,
+    void Function(double progress)? onProgressChanged,
   });
   Future<DocumentModel> update(DocumentModel doc);
   Future<int> findNextAsn();