Update .mypy-baseline.txt

Modified is always going to be set
Update test_websockets.py
2026-02-24 20:36:25 +00:00 · 2026-02-22 16:15:06 -08:00 · 2026-02-22 16:15:06 -08:00 · 2026-02-22 16:15:06 -08:00 · 2026-02-22 16:15:06 -08:00 · 2026-02-22 16:15:06 -08:00
32 changed files with 739 additions and 1005 deletions
--- a/.github/workflows/ci-backend.yml
+++ b/.github/workflows/ci-backend.yml
@@ -129,7 +129,6 @@ jobs:
        run: |
          uv pip list
      - name: Check typing (pyrefly)
-        continue-on-error: true
        run: |
          uv run pyrefly \
            check \
@@ -144,7 +143,6 @@ jobs:
            ${{ runner.os }}-mypy-py${{ env.DEFAULT_PYTHON }}-
            ${{ runner.os }}-mypy-
      - name: Check typing (mypy)
-        continue-on-error: true
        run: |
          uv run mypy \
            --show-error-codes \
--- a/.mypy-baseline.txt
+++ b/.mypy-baseline.txt
@@ -450,9 +450,6 @@ src/documents/permissions.py:0: error: Item "list[str]" of "Any | list[str] | Qu
 src/documents/permissions.py:0: error: Item "list[str]" of "Any | list[str] | QuerySet[User, User]" has no attribute "exists"  [union-attr]
 src/documents/permissions.py:0: error: Missing type parameters for generic type "QuerySet"  [type-arg]
 src/documents/permissions.py:0: error: Missing type parameters for generic type "dict"  [type-arg]
-src/documents/plugins/helpers.py:0: error: "Collection[str]" has no attribute "update"  [attr-defined]
-src/documents/plugins/helpers.py:0: error: Argument 1 to "send" of "BaseStatusManager" has incompatible type "dict[str, Collection[str]]"; expected "dict[str, str | int | None]"  [arg-type]
-src/documents/plugins/helpers.py:0: error: Argument 1 to "send" of "BaseStatusManager" has incompatible type "dict[str, Collection[str]]"; expected "dict[str, str | int | None]"  [arg-type]
 src/documents/plugins/helpers.py:0: error: Function is missing a type annotation  [no-untyped-def]
 src/documents/plugins/helpers.py:0: error: Function is missing a type annotation  [no-untyped-def]
 src/documents/plugins/helpers.py:0: error: Skipping analyzing "channels_redis.pubsub": module is installed, but missing library stubs or py.typed marker  [import-untyped]
@@ -676,7 +673,6 @@ src/documents/signals/handlers.py:0: error: Argument 3 to "validate_move" has in
 src/documents/signals/handlers.py:0: error: Argument 5 to "_suggestion_printer" has incompatible type "Any | None"; expected "MatchingModel"  [arg-type]
 src/documents/signals/handlers.py:0: error: Argument 5 to "_suggestion_printer" has incompatible type "Any | None"; expected "MatchingModel"  [arg-type]
 src/documents/signals/handlers.py:0: error: Argument 5 to "_suggestion_printer" has incompatible type "Any | None"; expected "MatchingModel"  [arg-type]
-src/documents/signals/handlers.py:0: error: Function is missing a return type annotation  [no-untyped-def]
 src/documents/signals/handlers.py:0: error: Function is missing a type annotation  [no-untyped-def]
 src/documents/signals/handlers.py:0: error: Function is missing a type annotation  [no-untyped-def]
 src/documents/signals/handlers.py:0: error: Function is missing a type annotation for one or more arguments  [no-untyped-def]
@@ -700,11 +696,15 @@ src/documents/signals/handlers.py:0: error: Function is missing a type annotatio
 src/documents/signals/handlers.py:0: error: Function is missing a type annotation for one or more arguments  [no-untyped-def]
 src/documents/signals/handlers.py:0: error: Function is missing a type annotation for one or more arguments  [no-untyped-def]
 src/documents/signals/handlers.py:0: error: Function is missing a type annotation for one or more arguments  [no-untyped-def]
+src/documents/signals/handlers.py:0: error: Function is missing a type annotation for one or more arguments  [no-untyped-def]
+src/documents/signals/handlers.py:0: error: Incompatible return value type (got "tuple[DocumentMetadataOverrides | None, str]", expected "tuple[DocumentMetadataOverrides, str] | None")  [return-value]
 src/documents/signals/handlers.py:0: error: Incompatible types in assignment (expression has type "list[Tag]", variable has type "set[Tag]")  [assignment]
 src/documents/signals/handlers.py:0: error: Incompatible types in assignment (expression has type "tuple[Any, Any, Any]", variable has type "tuple[Any, Any]")  [assignment]
+src/documents/signals/handlers.py:0: error: Item "ConsumableDocument" of "Document | ConsumableDocument" has no attribute "refresh_from_db"  [union-attr]
 src/documents/signals/handlers.py:0: error: Item "ConsumableDocument" of "Document | ConsumableDocument" has no attribute "save"  [union-attr]
 src/documents/signals/handlers.py:0: error: Item "ConsumableDocument" of "Document | ConsumableDocument" has no attribute "source_path"  [union-attr]
 src/documents/signals/handlers.py:0: error: Item "ConsumableDocument" of "Document | ConsumableDocument" has no attribute "tags"  [union-attr]
+src/documents/signals/handlers.py:0: error: Item "ConsumableDocument" of "Document | ConsumableDocument" has no attribute "tags"  [union-attr]
 src/documents/signals/handlers.py:0: error: Item "ConsumableDocument" of "Document | ConsumableDocument" has no attribute "title"  [union-attr]
 src/documents/signals/handlers.py:0: error: Item "None" of "Any | None" has no attribute "get"  [union-attr]
 src/documents/signals/handlers.py:0: error: Item "None" of "Any | None" has no attribute "get"  [union-attr]
@@ -1941,6 +1941,7 @@ src/paperless/tests/test_websockets.py:0: error: Item "None" of "BaseChannelLaye
 src/paperless/tests/test_websockets.py:0: error: Item "None" of "BaseChannelLayer | None" has no attribute "group_send"  [union-attr]
 src/paperless/tests/test_websockets.py:0: error: Item "None" of "BaseChannelLayer | None" has no attribute "group_send"  [union-attr]
 src/paperless/tests/test_websockets.py:0: error: Item "None" of "BaseChannelLayer | None" has no attribute "group_send"  [union-attr]
+src/paperless/tests/test_websockets.py:0: error: Item "None" of "BaseChannelLayer | None" has no attribute "group_send"  [union-attr]
 src/paperless/tests/test_websockets.py:0: error: TypedDict "_WebsocketTestScope" has no key "user"  [typeddict-item]
 src/paperless/tests/test_websockets.py:0: error: TypedDict "_WebsocketTestScope" has no key "user"  [typeddict-item]
 src/paperless/tests/test_websockets.py:0: error: TypedDict "_WebsocketTestScope" has no key "user"  [typeddict-item]
--- a/docs/usage.md
+++ b/docs/usage.md
@@ -564,18 +564,6 @@ For security reasons, webhooks can be limited to specific ports and disallowed f
 [configuration settings](configuration.md#workflow-webhooks) to change this behavior. If you are allowing non-admins to create workflows,
 you may want to adjust these settings to prevent abuse.

-##### Move to Trash {#workflow-action-move-to-trash}
-
-"Move to Trash" actions move the document to the trash. The document can be restored
-from the trash until the trash is emptied (after the configured delay or manually).
-
-The "Move to Trash" action will always be executed at the end of the workflow run,
-regardless of its position in the action list. After a "Move to Trash" action is executed
-no other workflow will be executed on the document.
-
-If a "Move to Trash" action is executed in a consume pipeline, the consumption
-will be aborted and the file will be deleted.
-
 #### Workflow placeholders

 Titles and webhook payloads can be generated by workflows using [Jinja templates](https://jinja.palletsprojects.com/en/3.1.x/templates/).
--- a/src-ui/messages.xlf
+++ b/src-ui/messages.xlf
@@ -5355,13 +5355,6 @@
          <context context-type="linenumber">445</context>
        </context-group>
      </trans-unit>
-      <trans-unit id="7902569198692046993" datatype="html">
-        <source>The document will be moved to the trash at the end of the workflow run.</source>
-        <context-group purpose="location">
-          <context context-type="sourcefile">src/app/components/common/edit-dialog/workflow-edit-dialog/workflow-edit-dialog.component.html</context>
-          <context context-type="linenumber">454</context>
-        </context-group>
-      </trans-unit>
      <trans-unit id="4626030417479279989" datatype="html">
        <source>Consume Folder</source>
        <context-group purpose="location">
@@ -5464,124 +5457,109 @@
          <context context-type="linenumber">144</context>
        </context-group>
      </trans-unit>
-      <trans-unit id="2048798344356757326" datatype="html">
-        <source>Move to trash</source>
-        <context-group purpose="location">
-          <context context-type="sourcefile">src/app/components/common/edit-dialog/workflow-edit-dialog/workflow-edit-dialog.component.ts</context>
-          <context context-type="linenumber">148</context>
-        </context-group>
-        <context-group purpose="location">
-          <context context-type="sourcefile">src/app/components/document-detail/document-detail.component.ts</context>
-          <context context-type="linenumber">1087</context>
-        </context-group>
-        <context-group purpose="location">
-          <context context-type="sourcefile">src/app/components/document-list/bulk-editor/bulk-editor.component.ts</context>
-          <context context-type="linenumber">760</context>
-        </context-group>
-      </trans-unit>
      <trans-unit id="4522609911791833187" datatype="html">
        <source>Has any of these tags</source>
        <context-group purpose="location">
          <context context-type="sourcefile">src/app/components/common/edit-dialog/workflow-edit-dialog/workflow-edit-dialog.component.ts</context>
-          <context context-type="linenumber">217</context>
+          <context context-type="linenumber">213</context>
        </context-group>
      </trans-unit>
      <trans-unit id="4166903555074156852" datatype="html">
        <source>Has all of these tags</source>
        <context-group purpose="location">
          <context context-type="sourcefile">src/app/components/common/edit-dialog/workflow-edit-dialog/workflow-edit-dialog.component.ts</context>
-          <context context-type="linenumber">224</context>
+          <context context-type="linenumber">220</context>
        </context-group>
      </trans-unit>
      <trans-unit id="6624363795312783141" datatype="html">
        <source>Does not have these tags</source>
        <context-group purpose="location">
          <context context-type="sourcefile">src/app/components/common/edit-dialog/workflow-edit-dialog/workflow-edit-dialog.component.ts</context>
-          <context context-type="linenumber">231</context>
+          <context context-type="linenumber">227</context>
        </context-group>
      </trans-unit>
      <trans-unit id="7168528512669831184" datatype="html">
        <source>Has any of these correspondents</source>
        <context-group purpose="location">
          <context context-type="sourcefile">src/app/components/common/edit-dialog/workflow-edit-dialog/workflow-edit-dialog.component.ts</context>
-          <context context-type="linenumber">238</context>
+          <context context-type="linenumber">234</context>
        </context-group>
      </trans-unit>
      <trans-unit id="5281365940563983618" datatype="html">
        <source>Has correspondent</source>
        <context-group purpose="location">
          <context context-type="sourcefile">src/app/components/common/edit-dialog/workflow-edit-dialog/workflow-edit-dialog.component.ts</context>
-          <context context-type="linenumber">246</context>
+          <context context-type="linenumber">242</context>
        </context-group>
      </trans-unit>
      <trans-unit id="6884498632428600393" datatype="html">
        <source>Does not have correspondents</source>
        <context-group purpose="location">
          <context context-type="sourcefile">src/app/components/common/edit-dialog/workflow-edit-dialog/workflow-edit-dialog.component.ts</context>
-          <context context-type="linenumber">254</context>
+          <context context-type="linenumber">250</context>
        </context-group>
      </trans-unit>
      <trans-unit id="4806713133917046341" datatype="html">
        <source>Has document type</source>
        <context-group purpose="location">
          <context context-type="sourcefile">src/app/components/common/edit-dialog/workflow-edit-dialog/workflow-edit-dialog.component.ts</context>
-          <context context-type="linenumber">262</context>
+          <context context-type="linenumber">258</context>
        </context-group>
      </trans-unit>
      <trans-unit id="8801397520369995032" datatype="html">
        <source>Has any of these document types</source>
        <context-group purpose="location">
          <context context-type="sourcefile">src/app/components/common/edit-dialog/workflow-edit-dialog/workflow-edit-dialog.component.ts</context>
-          <context context-type="linenumber">270</context>
+          <context context-type="linenumber">266</context>
        </context-group>
      </trans-unit>
      <trans-unit id="1507843981661822403" datatype="html">
        <source>Does not have document types</source>
        <context-group purpose="location">
          <context context-type="sourcefile">src/app/components/common/edit-dialog/workflow-edit-dialog/workflow-edit-dialog.component.ts</context>
-          <context context-type="linenumber">278</context>
+          <context context-type="linenumber">274</context>
        </context-group>
      </trans-unit>
      <trans-unit id="4277260190522078330" datatype="html">
        <source>Has storage path</source>
        <context-group purpose="location">
          <context context-type="sourcefile">src/app/components/common/edit-dialog/workflow-edit-dialog/workflow-edit-dialog.component.ts</context>
-          <context context-type="linenumber">286</context>
+          <context context-type="linenumber">282</context>
        </context-group>
      </trans-unit>
      <trans-unit id="8858580062214623097" datatype="html">
        <source>Has any of these storage paths</source>
        <context-group purpose="location">
          <context context-type="sourcefile">src/app/components/common/edit-dialog/workflow-edit-dialog/workflow-edit-dialog.component.ts</context>
-          <context context-type="linenumber">294</context>
+          <context context-type="linenumber">290</context>
        </context-group>
      </trans-unit>
      <trans-unit id="6070943364927280151" datatype="html">
        <source>Does not have storage paths</source>
        <context-group purpose="location">
          <context context-type="sourcefile">src/app/components/common/edit-dialog/workflow-edit-dialog/workflow-edit-dialog.component.ts</context>
-          <context context-type="linenumber">302</context>
+          <context context-type="linenumber">298</context>
        </context-group>
      </trans-unit>
      <trans-unit id="6250799006816371860" datatype="html">
        <source>Matches custom field query</source>
        <context-group purpose="location">
          <context context-type="sourcefile">src/app/components/common/edit-dialog/workflow-edit-dialog/workflow-edit-dialog.component.ts</context>
-          <context context-type="linenumber">310</context>
+          <context context-type="linenumber">306</context>
        </context-group>
      </trans-unit>
      <trans-unit id="3138206142174978019" datatype="html">
        <source>Create new workflow</source>
        <context-group purpose="location">
          <context context-type="sourcefile">src/app/components/common/edit-dialog/workflow-edit-dialog/workflow-edit-dialog.component.ts</context>
-          <context context-type="linenumber">539</context>
+          <context context-type="linenumber">535</context>
        </context-group>
      </trans-unit>
      <trans-unit id="5996779210524133604" datatype="html">
        <source>Edit workflow</source>
        <context-group purpose="location">
          <context context-type="sourcefile">src/app/components/common/edit-dialog/workflow-edit-dialog/workflow-edit-dialog.component.ts</context>
-          <context context-type="linenumber">543</context>
+          <context context-type="linenumber">539</context>
        </context-group>
      </trans-unit>
      <trans-unit id="5457837313196342910" datatype="html">
@@ -7795,6 +7773,17 @@
          <context context-type="linenumber">758</context>
        </context-group>
      </trans-unit>
+      <trans-unit id="2048798344356757326" datatype="html">
+        <source>Move to trash</source>
+        <context-group purpose="location">
+          <context context-type="sourcefile">src/app/components/document-detail/document-detail.component.ts</context>
+          <context context-type="linenumber">1087</context>
+        </context-group>
+        <context-group purpose="location">
+          <context context-type="sourcefile">src/app/components/document-list/bulk-editor/bulk-editor.component.ts</context>
+          <context context-type="linenumber">760</context>
+        </context-group>
+      </trans-unit>
      <trans-unit id="7295637485862454066" datatype="html">
        <source>Error deleting document</source>
        <context-group purpose="location">
--- a/src-ui/src/app/components/common/edit-dialog/workflow-edit-dialog/workflow-edit-dialog.component.html
+++ b/src-ui/src/app/components/common/edit-dialog/workflow-edit-dialog/workflow-edit-dialog.component.html
@@ -448,13 +448,6 @@
          </div>
        </div>
      }
-      @case (WorkflowActionType.MoveToTrash) {
-        <div class="row">
-          <div class="col">
-            <p class="text-muted small" i18n>The document will be moved to the trash at the end of the workflow run.</p>
-          </div>
-        </div>
-      }
    }
  </div>
 </ng-template>
--- a/src-ui/src/app/components/common/edit-dialog/workflow-edit-dialog/workflow-edit-dialog.component.ts
+++ b/src-ui/src/app/components/common/edit-dialog/workflow-edit-dialog/workflow-edit-dialog.component.ts
@@ -143,10 +143,6 @@ export const WORKFLOW_ACTION_OPTIONS = [
    id: WorkflowActionType.PasswordRemoval,
    name: $localize`Password removal`,
  },
-  {
-    id: WorkflowActionType.MoveToTrash,
-    name: $localize`Move to trash`,
-  },
 ]

 export enum TriggerFilterType {
--- a/src-ui/src/app/components/document-detail/document-detail.component.html
+++ b/src-ui/src/app/components/document-detail/document-detail.component.html
@@ -95,7 +95,6 @@
  <div class="col-md-6 col-xl-5 mb-4">

    <form [formGroup]='documentForm' (ngSubmit)="save()">
-
      <div class="btn-toolbar mb-1 border-bottom">
        <div class="btn-group pb-3">
          <button type="button" class="btn btn-sm btn-outline-secondary" i18n-title title="Close" (click)="close()">
--- a/src-ui/src/app/components/document-detail/document-detail.component.spec.ts
+++ b/src-ui/src/app/components/document-detail/document-detail.component.spec.ts
@@ -65,6 +65,7 @@ import { TagService } from 'src/app/services/rest/tag.service'
 import { UserService } from 'src/app/services/rest/user.service'
 import { SettingsService } from 'src/app/services/settings.service'
 import { ToastService } from 'src/app/services/toast.service'
+import { WebsocketStatusService } from 'src/app/services/websocket-status.service'
 import { environment } from 'src/environments/environment'
 import { ConfirmDialogComponent } from '../common/confirm-dialog/confirm-dialog.component'
 import { PasswordRemovalConfirmDialogComponent } from '../common/confirm-dialog/password-removal-confirm-dialog/password-removal-confirm-dialog.component'
@@ -83,9 +84,9 @@ const doc: Document = {
  storage_path: 31,
  tags: [41, 42, 43],
  content: 'text content',
-  added: new Date('May 4, 2014 03:24:00'),
-  created: new Date('May 4, 2014 03:24:00'),
-  modified: new Date('May 4, 2014 03:24:00'),
+  added: new Date('May 4, 2014 03:24:00').toISOString(),
+  created: new Date('May 4, 2014 03:24:00').toISOString(),
+  modified: new Date('May 4, 2014 03:24:00').toISOString(),
  archive_serial_number: null,
  original_file_name: 'file.pdf',
  owner: null,
@@ -306,6 +307,29 @@ describe('DocumentDetailComponent', () => {
    expect(component.activeNavID).toEqual(component.DocumentDetailNavIDs.Notes)
  })

+  it('should switch from preview to details when pdf preview enters the DOM', fakeAsync(() => {
+    component.nav = {
+      activeId: component.DocumentDetailNavIDs.Preview,
+      select: jest.fn(),
+    } as any
+    ;(component as any).pdfPreview = {
+      nativeElement: { offsetParent: {} },
+    }
+
+    tick()
+    expect(component.nav.select).toHaveBeenCalledWith(
+      component.DocumentDetailNavIDs.Details
+    )
+  }))
+
+  it('should forward title key up value to titleSubject', () => {
+    const subjectSpy = jest.spyOn(component.titleSubject, 'next')
+
+    component.titleKeyUp({ target: { value: 'Updated title' } })
+
+    expect(subjectSpy).toHaveBeenCalledWith('Updated title')
+  })
+
  it('should change url on tab switch', () => {
    initNormally()
    const navigateSpy = jest.spyOn(router, 'navigate')
@@ -392,7 +416,7 @@ describe('DocumentDetailComponent', () => {
    jest.spyOn(documentService, 'get').mockReturnValue(
      of({
        ...doc,
-        modified: new Date('2024-01-02T00:00:00Z'),
+        modified: '2024-01-02T00:00:00Z',
        duplicate_documents: updatedDuplicates,
      })
    )
@@ -1205,17 +1229,21 @@ describe('DocumentDetailComponent', () => {
    expect(errorSpy).toHaveBeenCalled()
  })

-  it('should warn when open document does not match doc retrieved from backend on init', () => {
+  it('should show incoming update modal when open local draft is older than backend on init', () => {
    let openModal: NgbModalRef
    modalService.activeInstances.subscribe((modals) => (openModal = modals[0]))
    const modalSpy = jest.spyOn(modalService, 'open')
-    const openDoc = Object.assign({}, doc)
+    const openDoc = Object.assign({}, doc, {
+      __changedFields: ['title'],
+    })
    // simulate a document being modified elsewhere and db updated
-    doc.modified = new Date()
+    const remoteDoc = Object.assign({}, doc, {
+      modified: new Date(new Date(doc.modified).getTime() + 1000).toISOString(),
+    })
    jest
      .spyOn(activatedRoute, 'paramMap', 'get')
      .mockReturnValue(of(convertToParamMap({ id: 3, section: 'details' })))
-    jest.spyOn(documentService, 'get').mockReturnValueOnce(of(doc))
+    jest.spyOn(documentService, 'get').mockReturnValueOnce(of(remoteDoc))
    jest.spyOn(openDocumentsService, 'getOpenDocument').mockReturnValue(openDoc)
    jest.spyOn(customFieldsService, 'listAll').mockReturnValue(
      of({
@@ -1225,11 +1253,185 @@ describe('DocumentDetailComponent', () => {
      })
    )
    fixture.detectChanges() // calls ngOnInit
-    expect(modalSpy).toHaveBeenCalledWith(ConfirmDialogComponent)
-    const closeSpy = jest.spyOn(openModal, 'close')
+    expect(modalSpy).toHaveBeenCalledWith(ConfirmDialogComponent, {
+      backdrop: 'static',
+    })
    const confirmDialog = openModal.componentInstance as ConfirmDialogComponent
-    confirmDialog.confirmClicked.next(confirmDialog)
-    expect(closeSpy).toHaveBeenCalled()
+    expect(confirmDialog.messageBold).toContain('Document was updated at')
+  })
+
+  it('should react to websocket document updated notifications', () => {
+    initNormally()
+    const updateMessage = {
+      document_id: component.documentId,
+      modified: '2026-02-17T00:00:00Z',
+      owner_id: 1,
+    }
+    const handleSpy = jest
+      .spyOn(component as any, 'handleIncomingDocumentUpdated')
+      .mockImplementation(() => {})
+    const websocketStatusService = TestBed.inject(WebsocketStatusService)
+
+    websocketStatusService.handleDocumentUpdated(updateMessage)
+
+    expect(handleSpy).toHaveBeenCalledWith(updateMessage)
+  })
+
+  it('should queue incoming update while network is active and flush after', () => {
+    initNormally()
+    const loadSpy = jest.spyOn(component as any, 'loadDocument')
+    const toastSpy = jest.spyOn(toastService, 'showInfo')
+
+    component.networkActive = true
+    ;(component as any).handleIncomingDocumentUpdated({
+      document_id: component.documentId,
+      modified: '2026-02-17T00:00:00Z',
+    })
+
+    expect(loadSpy).not.toHaveBeenCalled()
+
+    component.networkActive = false
+    ;(component as any).flushPendingIncomingUpdate()
+
+    expect(loadSpy).toHaveBeenCalledWith(component.documentId, true)
+    expect(toastSpy).toHaveBeenCalledWith(
+      'Document reloaded with latest changes.'
+    )
+  })
+
+  it('should ignore queued incoming update matching local save modified', () => {
+    initNormally()
+    const loadSpy = jest.spyOn(component as any, 'loadDocument')
+    const toastSpy = jest.spyOn(toastService, 'showInfo')
+
+    component.networkActive = true
+    ;(component as any).lastLocalSaveModified = '2026-02-17T00:00:00+00:00'
+    ;(component as any).handleIncomingDocumentUpdated({
+      document_id: component.documentId,
+      modified: '2026-02-17T00:00:00+00:00',
+    })
+
+    component.networkActive = false
+    ;(component as any).flushPendingIncomingUpdate()
+
+    expect(loadSpy).not.toHaveBeenCalled()
+    expect(toastSpy).not.toHaveBeenCalled()
+  })
+
+  it('should clear pdf source if preview URL is empty', () => {
+    component.pdfSource = { url: '/preview', password: 'secret' } as any
+    component.previewUrl = null
+    ;(component as any).updatePdfSource()
+
+    expect(component.pdfSource).toBeUndefined()
+  })
+
+  it('should close incoming update modal if one is open', () => {
+    const modalRef = { close: jest.fn() } as unknown as NgbModalRef
+    ;(component as any).incomingUpdateModal = modalRef
+    ;(component as any).closeIncomingUpdateModal()
+
+    expect(modalRef.close).toHaveBeenCalled()
+    expect((component as any).incomingUpdateModal).toBeNull()
+  })
+
+  it('should reload remote version when incoming update modal is confirmed', async () => {
+    let openModal: NgbModalRef
+    modalService.activeInstances.subscribe((modals) => (openModal = modals[0]))
+    const reloadSpy = jest
+      .spyOn(component as any, 'reloadRemoteVersion')
+      .mockImplementation(() => {})
+
+    ;(component as any).showIncomingUpdateModal('2026-02-17T00:00:00Z')
+
+    const dialog = openModal.componentInstance as ConfirmDialogComponent
+    dialog.confirmClicked.next()
+    await openModal.result
+
+    expect(dialog.buttonsEnabled).toBe(false)
+    expect(reloadSpy).toHaveBeenCalled()
+    expect((component as any).incomingUpdateModal).toBeNull()
+  })
+
+  it('should overwrite open document state when loading remote version with force', () => {
+    const openDoc = Object.assign({}, doc, {
+      title: 'Locally edited title',
+      __changedFields: ['title'],
+    })
+    const remoteDoc = Object.assign({}, doc, {
+      title: 'Remote title',
+      modified: '2026-02-17T00:00:00Z',
+    })
+    jest.spyOn(documentService, 'get').mockReturnValue(of(remoteDoc))
+    jest.spyOn(documentService, 'getMetadata').mockReturnValue(
+      of({
+        has_archive_version: false,
+        original_mime_type: 'application/pdf',
+      })
+    )
+    jest.spyOn(documentService, 'getSuggestions').mockReturnValue(
+      of({
+        suggested_tags: [],
+        suggested_document_types: [],
+        suggested_correspondents: [],
+      })
+    )
+    jest.spyOn(openDocumentsService, 'getOpenDocument').mockReturnValue(openDoc)
+    const setDirtySpy = jest.spyOn(openDocumentsService, 'setDirty')
+    const saveSpy = jest.spyOn(openDocumentsService, 'save')
+
+    ;(component as any).loadDocument(doc.id, true)
+
+    expect(openDoc.title).toEqual('Remote title')
+    expect(openDoc.__changedFields).toEqual([])
+    expect(setDirtySpy).toHaveBeenCalledWith(openDoc, false)
+    expect(saveSpy).toHaveBeenCalled()
+  })
+
+  it('should ignore incoming update for a different document id', () => {
+    initNormally()
+    const loadSpy = jest.spyOn(component as any, 'loadDocument')
+
+    ;(component as any).handleIncomingDocumentUpdated({
+      document_id: component.documentId + 1,
+      modified: '2026-02-17T00:00:00Z',
+    })
+
+    expect(loadSpy).not.toHaveBeenCalled()
+  })
+
+  it('should show incoming update modal when local document has unsaved edits', () => {
+    initNormally()
+    jest.spyOn(openDocumentsService, 'isDirty').mockReturnValue(true)
+    const modalSpy = jest
+      .spyOn(component as any, 'showIncomingUpdateModal')
+      .mockImplementation(() => {})
+
+    ;(component as any).handleIncomingDocumentUpdated({
+      document_id: component.documentId,
+      modified: '2026-02-17T00:00:00Z',
+    })
+
+    expect(modalSpy).toHaveBeenCalledWith('2026-02-17T00:00:00Z')
+  })
+
+  it('should reload current document and show toast when reloading remote version', () => {
+    component.documentId = doc.id
+    const closeModalSpy = jest
+      .spyOn(component as any, 'closeIncomingUpdateModal')
+      .mockImplementation(() => {})
+    const loadSpy = jest
+      .spyOn(component as any, 'loadDocument')
+      .mockImplementation(() => {})
+    const notifySpy = jest.spyOn(component.docChangeNotifier, 'next')
+    const toastSpy = jest.spyOn(toastService, 'showInfo')
+
+    ;(component as any).reloadRemoteVersion()
+
+    expect(closeModalSpy).toHaveBeenCalled()
+    expect(notifySpy).toHaveBeenCalledWith(doc.id)
+    expect(loadSpy).toHaveBeenCalledWith(doc.id, true)
+    expect(toastSpy).toHaveBeenCalledWith('Document reloaded.')
  })

  it('should change preview element by render type', () => {
@@ -1478,6 +1680,14 @@ describe('DocumentDetailComponent', () => {
    expect(component.createDisabled(DataType.Tag)).toBeFalsy()
  })

+  it('should expose add permission via userCanAdd getter', () => {
+    currentUserCan = true
+    expect(component.userCanAdd).toBeTruthy()
+
+    currentUserCan = false
+    expect(component.userCanAdd).toBeFalsy()
+  })
+
  it('should call tryRenderTiff when no archive and file is tiff', () => {
    initNormally()
    const tiffRenderSpy = jest.spyOn(
--- a/src-ui/src/app/components/document-detail/document-detail.component.ts
+++ b/src-ui/src/app/components/document-detail/document-detail.component.ts
@@ -13,6 +13,7 @@ import {
  NgbDateStruct,
  NgbDropdownModule,
  NgbModal,
+  NgbModalRef,
  NgbNav,
  NgbNavChangeEvent,
  NgbNavModule,
@@ -80,6 +81,7 @@ import { TagService } from 'src/app/services/rest/tag.service'
 import { UserService } from 'src/app/services/rest/user.service'
 import { SettingsService } from 'src/app/services/settings.service'
 import { ToastService } from 'src/app/services/toast.service'
+import { WebsocketStatusService } from 'src/app/services/websocket-status.service'
 import { getFilenameFromContentDisposition } from 'src/app/utils/http'
 import { ISODateAdapter } from 'src/app/utils/ngb-iso-date-adapter'
 import * as UTIF from 'utif'
@@ -142,6 +144,11 @@ enum ContentRenderType {
  TIFF = 'tiff',
 }

+interface IncomingDocumentUpdate {
+  document_id: number
+  modified: string
+}
+
@Component({
  selector: 'pngx-document-detail',
  templateUrl: './document-detail.component.html',
@@ -205,6 +212,7 @@ export class DocumentDetailComponent
  private componentRouterService = inject(ComponentRouterService)
  private deviceDetectorService = inject(DeviceDetectorService)
  private savedViewService = inject(SavedViewService)
+  private readonly websocketStatusService = inject(WebsocketStatusService)

  @ViewChild('inputTitle')
  titleInput: TextComponent
@@ -261,6 +269,9 @@ export class DocumentDetailComponent
  isDirty$: Observable<boolean>
  unsubscribeNotifier: Subject<any> = new Subject()
  docChangeNotifier: Subject<any> = new Subject()
+  private incomingUpdateModal: NgbModalRef
+  private pendingIncomingUpdate: IncomingDocumentUpdate
+  private lastLocalSaveModified: string | null = null

  requiresPassword: boolean = false
  password: string
@@ -432,7 +443,58 @@ export class DocumentDetailComponent
      )
  }

-  private loadDocument(documentId: number): void {
+  private hasLocalEdits(doc: Document): boolean {
+    return (
+      this.openDocumentService.isDirty(doc) || !!doc.__changedFields?.length
+    )
+  }
+
+  private showIncomingUpdateModal(modified: string): void {
+    if (this.incomingUpdateModal) return
+
+    const modal = this.modalService.open(ConfirmDialogComponent, {
+      backdrop: 'static',
+    })
+    this.incomingUpdateModal = modal
+
+    let formattedModified = null
+    const parsed = new Date(modified)
+    formattedModified = parsed.toLocaleString()
+
+    modal.componentInstance.title = $localize`Document was updated`
+    modal.componentInstance.messageBold = $localize`Document was updated at ${formattedModified}.`
+    modal.componentInstance.message = $localize`Reload to discard your local unsaved edits and load the latest remote version.`
+    modal.componentInstance.btnClass = 'btn-warning'
+    modal.componentInstance.btnCaption = $localize`Reload`
+    modal.componentInstance.cancelBtnCaption = $localize`Dismiss`
+
+    modal.componentInstance.confirmClicked.pipe(first()).subscribe(() => {
+      modal.componentInstance.buttonsEnabled = false
+      modal.close()
+      this.reloadRemoteVersion()
+    })
+    modal.result.finally(() => {
+      this.incomingUpdateModal = null
+    })
+  }
+
+  private closeIncomingUpdateModal() {
+    if (!this.incomingUpdateModal) return
+    this.incomingUpdateModal.close()
+    this.incomingUpdateModal = null
+  }
+
+  private flushPendingIncomingUpdate() {
+    if (!this.pendingIncomingUpdate || this.networkActive) return
+    const pendingUpdate = this.pendingIncomingUpdate
+    this.pendingIncomingUpdate = null
+    this.handleIncomingDocumentUpdated(pendingUpdate)
+  }
+
+  private loadDocument(documentId: number, forceRemote: boolean = false): void {
+    this.closeIncomingUpdateModal()
+    this.pendingIncomingUpdate = null
+    this.lastLocalSaveModified = null
    this.previewUrl = this.documentsService.getPreviewUrl(documentId)
    this.updatePdfSource()
    this.http
@@ -477,21 +539,25 @@ export class DocumentDetailComponent
            openDocument.duplicate_documents = doc.duplicate_documents
            this.openDocumentService.save()
          }
-          const useDoc = openDocument || doc
-          if (openDocument) {
-            if (
-              new Date(doc.modified) > new Date(openDocument.modified) &&
-              !this.modalService.hasOpenModals()
-            ) {
-              const modal = this.modalService.open(ConfirmDialogComponent)
-              modal.componentInstance.title = $localize`Document changes detected`
-              modal.componentInstance.messageBold = $localize`The version of this document in your browser session appears older than the existing version.`
-              modal.componentInstance.message = $localize`Saving the document here may overwrite other changes that were made. To restore the existing version, discard your changes or close the document.`
-              modal.componentInstance.cancelBtnClass = 'visually-hidden'
-              modal.componentInstance.btnCaption = $localize`Ok`
-              modal.componentInstance.confirmClicked.subscribe(() =>
-                modal.close()
-              )
+          let useDoc = openDocument || doc
+          if (openDocument && forceRemote) {
+            Object.assign(openDocument, doc)
+            openDocument.__changedFields = []
+            this.openDocumentService.setDirty(openDocument, false)
+            this.openDocumentService.save()
+            useDoc = openDocument
+          } else if (openDocument) {
+            if (new Date(doc.modified) > new Date(openDocument.modified)) {
+              if (this.hasLocalEdits(openDocument)) {
+                this.showIncomingUpdateModal(doc.modified)
+              } else {
+                // No local edits to preserve, so keep the tab in sync automatically.
+                Object.assign(openDocument, doc)
+                openDocument.__changedFields = []
+                this.openDocumentService.setDirty(openDocument, false)
+                this.openDocumentService.save()
+                useDoc = openDocument
+              }
            }
          } else {
            this.openDocumentService
@@ -522,6 +588,50 @@ export class DocumentDetailComponent
      })
  }

+  private handleIncomingDocumentUpdated(data: IncomingDocumentUpdate): void {
+    if (
+      !this.documentId ||
+      !this.document ||
+      data.document_id !== this.documentId
+    )
+      return
+    if (this.networkActive) {
+      this.pendingIncomingUpdate = data
+      return
+    }
+    // If modified timestamp of the incoming update is the same as the last local save,
+    // we assume this update is from our own save and dont notify
+    const incomingModified = data.modified
+    if (
+      incomingModified &&
+      this.lastLocalSaveModified &&
+      incomingModified === this.lastLocalSaveModified
+    ) {
+      this.lastLocalSaveModified = null
+      return
+    }
+    this.lastLocalSaveModified = null
+
+    if (this.openDocumentService.isDirty(this.document)) {
+      this.showIncomingUpdateModal(data.modified)
+    } else {
+      this.docChangeNotifier.next(this.documentId)
+      this.loadDocument(this.documentId, true)
+      this.toastService.showInfo(
+        $localize`Document reloaded with latest changes.`
+      )
+    }
+  }
+
+  private reloadRemoteVersion() {
+    if (!this.documentId) return
+
+    this.closeIncomingUpdateModal()
+    this.docChangeNotifier.next(this.documentId)
+    this.loadDocument(this.documentId, true)
+    this.toastService.showInfo($localize`Document reloaded.`)
+  }
+
  ngOnInit(): void {
    this.setZoom(
      this.settings.get(SETTINGS_KEYS.PDF_VIEWER_ZOOM_SETTING) as PdfZoomScale
@@ -580,6 +690,11 @@ export class DocumentDetailComponent

    this.getCustomFields()

+    this.websocketStatusService
+      .onDocumentUpdated()
+      .pipe(takeUntil(this.unsubscribeNotifier))
+      .subscribe((data) => this.handleIncomingDocumentUpdated(data))
+
    this.route.paramMap
      .pipe(
        filter(
@@ -914,6 +1029,7 @@ export class DocumentDetailComponent
      )
      .subscribe({
        next: (doc) => {
+          this.closeIncomingUpdateModal()
          Object.assign(this.document, doc)
          doc['permissions_form'] = {
            owner: doc.owner,
@@ -960,6 +1076,8 @@ export class DocumentDetailComponent
      .pipe(first())
      .subscribe({
        next: (docValues) => {
+          this.closeIncomingUpdateModal()
+          this.lastLocalSaveModified = docValues.modified ?? null
          // in case data changed while saving eg removing inbox_tags
          this.documentForm.patchValue(docValues)
          const newValues = Object.assign({}, this.documentForm.value)
@@ -974,16 +1092,19 @@ export class DocumentDetailComponent
          this.networkActive = false
          this.error = null
          if (close) {
+            this.pendingIncomingUpdate = null
            this.close(() =>
              this.openDocumentService.refreshDocument(this.documentId)
            )
          } else {
            this.openDocumentService.refreshDocument(this.documentId)
+            this.flushPendingIncomingUpdate()
          }
          this.savedViewService.maybeRefreshDocumentCounts()
        },
        error: (error) => {
          this.networkActive = false
+          this.lastLocalSaveModified = null
          const canEdit =
            this.permissionsService.currentUserHasObjectPermissions(
              PermissionAction.Change,
@@ -1003,6 +1124,7 @@ export class DocumentDetailComponent
              error
            )
          }
+          this.flushPendingIncomingUpdate()
        },
      })
  }
@@ -1039,8 +1161,11 @@ export class DocumentDetailComponent
      .pipe(first())
      .subscribe({
        next: ({ updateResult, nextDocId, closeResult }) => {
+          this.closeIncomingUpdateModal()
          this.error = null
          this.networkActive = false
+          this.pendingIncomingUpdate = null
+          this.lastLocalSaveModified = null
          if (closeResult && updateResult && nextDocId) {
            this.router.navigate(['documents', nextDocId])
            this.titleInput?.focus()
@@ -1048,8 +1173,10 @@ export class DocumentDetailComponent
        },
        error: (error) => {
          this.networkActive = false
+          this.lastLocalSaveModified = null
          this.error = error.error
          this.toastService.showError($localize`Error saving document`, error)
+          this.flushPendingIncomingUpdate()
        },
      })
  }
@@ -1135,7 +1262,7 @@ export class DocumentDetailComponent
        .subscribe({
          next: () => {
            this.toastService.showInfo(
-              $localize`Reprocess operation for "${this.document.title}" will begin in the background. Close and re-open or reload this document after the operation has completed to see new content.`
+              $localize`Reprocess operation for "${this.document.title}" will begin in the background.`
            )
            if (modal) {
              modal.close()
--- a/src-ui/src/app/data/document.ts
+++ b/src-ui/src/app/data/document.ts
@@ -128,15 +128,15 @@ export interface Document extends ObjectWithPermissions {
  checksum?: string

  // UTC
-  created?: Date
+  created?: string // ISO string

-  modified?: Date
+  modified?: string // ISO string

-  added?: Date
+  added?: string // ISO string

  mime_type?: string

-  deleted_at?: Date
+  deleted_at?: string // ISO string

  original_file_name?: string

--- a/src-ui/src/app/data/websocket-document-updated-message.ts
+++ b/src-ui/src/app/data/websocket-document-updated-message.ts
@@ -0,0 +1,7 @@
+export interface WebsocketDocumentUpdatedMessage {
+  document_id: number
+  modified: string
+  owner_id?: number
+  users_can_view?: number[]
+  groups_can_view?: number[]
+}
--- a/src-ui/src/app/data/workflow-action.ts
+++ b/src-ui/src/app/data/workflow-action.ts
@@ -6,7 +6,6 @@ export enum WorkflowActionType {
  Email = 3,
  Webhook = 4,
  PasswordRemoval = 5,
-  MoveToTrash = 6,
 }

 export interface WorkflowActionEmail extends ObjectWithId {
--- a/src-ui/src/app/services/websocket-status.service.spec.ts
+++ b/src-ui/src/app/services/websocket-status.service.spec.ts
@@ -416,4 +416,42 @@ describe('ConsumerStatusService', () => {
    websocketStatusService.disconnect()
    expect(deleted).toBeTruthy()
  })
+
+  it('should trigger updated subject on document updated', () => {
+    let updated = false
+    websocketStatusService.onDocumentUpdated().subscribe((data) => {
+      updated = true
+      expect(data.document_id).toEqual(12)
+    })
+
+    websocketStatusService.connect()
+    server.send({
+      type: WebsocketStatusType.DOCUMENT_UPDATED,
+      data: {
+        document_id: 12,
+        modified: '2026-02-17T00:00:00Z',
+        owner_id: 1,
+      },
+    })
+
+    websocketStatusService.disconnect()
+    expect(updated).toBeTruthy()
+  })
+
+  it('should ignore document updated events the user cannot view', () => {
+    let updated = false
+    websocketStatusService.onDocumentUpdated().subscribe(() => {
+      updated = true
+    })
+
+    websocketStatusService.handleDocumentUpdated({
+      document_id: 12,
+      modified: '2026-02-17T00:00:00Z',
+      owner_id: 2,
+      users_can_view: [],
+      groups_can_view: [],
+    })
+
+    expect(updated).toBeFalsy()
+  })
 })
--- a/src-ui/src/app/services/websocket-status.service.ts
+++ b/src-ui/src/app/services/websocket-status.service.ts
@@ -2,6 +2,7 @@ import { Injectable, inject } from '@angular/core'
 import { Subject } from 'rxjs'
 import { environment } from 'src/environments/environment'
 import { User } from '../data/user'
+import { WebsocketDocumentUpdatedMessage } from '../data/websocket-document-updated-message'
 import { WebsocketDocumentsDeletedMessage } from '../data/websocket-documents-deleted-message'
 import { WebsocketProgressMessage } from '../data/websocket-progress-message'
 import { SettingsService } from './settings.service'
@@ -9,6 +10,7 @@ import { SettingsService } from './settings.service'
 export enum WebsocketStatusType {
  STATUS_UPDATE = 'status_update',
  DOCUMENTS_DELETED = 'documents_deleted',
+  DOCUMENT_UPDATED = 'document_updated',
 }

 // see ProgressStatusOptions in src/documents/plugins/helpers.py
@@ -93,17 +95,20 @@ export class FileStatus {
  providedIn: 'root',
 })
 export class WebsocketStatusService {
-  private settingsService = inject(SettingsService)
+  private readonly settingsService = inject(SettingsService)

  private statusWebSocket: WebSocket

  private consumerStatus: FileStatus[] = []

-  private documentDetectedSubject = new Subject<FileStatus>()
-  private documentConsumptionFinishedSubject = new Subject<FileStatus>()
-  private documentConsumptionFailedSubject = new Subject<FileStatus>()
-  private documentDeletedSubject = new Subject<boolean>()
-  private connectionStatusSubject = new Subject<boolean>()
+  private readonly documentDetectedSubject = new Subject<FileStatus>()
+  private readonly documentConsumptionFinishedSubject =
+    new Subject<FileStatus>()
+  private readonly documentConsumptionFailedSubject = new Subject<FileStatus>()
+  private readonly documentDeletedSubject = new Subject<boolean>()
+  private readonly documentUpdatedSubject =
+    new Subject<WebsocketDocumentUpdatedMessage>()
+  private readonly connectionStatusSubject = new Subject<boolean>()

  private get(taskId: string, filename?: string) {
    let status =
@@ -169,7 +174,10 @@ export class WebsocketStatusService {
        data: messageData,
      }: {
        type: WebsocketStatusType
-        data: WebsocketProgressMessage | WebsocketDocumentsDeletedMessage
+        data:
+          | WebsocketProgressMessage
+          | WebsocketDocumentsDeletedMessage
+          | WebsocketDocumentUpdatedMessage
      } = JSON.parse(ev.data)

      switch (type) {
@@ -177,6 +185,12 @@ export class WebsocketStatusService {
          this.documentDeletedSubject.next(true)
          break

+        case WebsocketStatusType.DOCUMENT_UPDATED:
+          this.handleDocumentUpdated(
+            messageData as WebsocketDocumentUpdatedMessage
+          )
+          break
+
        case WebsocketStatusType.STATUS_UPDATE:
          this.handleProgressUpdate(messageData as WebsocketProgressMessage)
          break
@@ -184,7 +198,11 @@ export class WebsocketStatusService {
    }
  }

-  private canViewMessage(messageData: WebsocketProgressMessage): boolean {
+  private canViewMessage(messageData: {
+    owner_id?: number
+    users_can_view?: number[]
+    groups_can_view?: number[]
+  }): boolean {
    // see paperless.consumers.StatusConsumer._can_view
    const user: User = this.settingsService.currentUser
    return (
@@ -244,6 +262,15 @@ export class WebsocketStatusService {
    }
  }

+  handleDocumentUpdated(messageData: WebsocketDocumentUpdatedMessage) {
+    // fallback if backend didn't restrict message
+    if (!this.canViewMessage(messageData)) {
+      return
+    }
+
+    this.documentUpdatedSubject.next(messageData)
+  }
+
  fail(status: FileStatus, message: string) {
    status.message = message
    status.phase = FileStatusPhase.FAILED
@@ -297,6 +324,10 @@ export class WebsocketStatusService {
    return this.documentDeletedSubject
  }

+  onDocumentUpdated() {
+    return this.documentUpdatedSubject
+  }
+
  onConnectionStatus() {
    return this.connectionStatusSubject.asObservable()
  }
--- a/src/conftest.py
+++ b/src/conftest.py
@@ -0,0 +1,11 @@
+import pytest
+from pytest_django.fixtures import SettingsWrapper
+
+
+@pytest.fixture(autouse=True)
+def in_memory_channel_layers(settings: SettingsWrapper) -> None:
+    settings.CHANNEL_LAYERS = {
+        "default": {
+            "BACKEND": "channels.layers.InMemoryChannelLayer",
+        },
+    }
--- a/src/documents/apps.py
+++ b/src/documents/apps.py
@@ -15,6 +15,7 @@ class DocumentsConfig(AppConfig):
        from documents.signals.handlers import add_to_index
        from documents.signals.handlers import run_workflows_added
        from documents.signals.handlers import run_workflows_updated
+        from documents.signals.handlers import send_websocket_document_updated
        from documents.signals.handlers import set_correspondent
        from documents.signals.handlers import set_document_type
        from documents.signals.handlers import set_storage_path
@@ -29,6 +30,7 @@ class DocumentsConfig(AppConfig):
        document_consumption_finished.connect(run_workflows_added)
        document_consumption_finished.connect(add_or_update_document_in_llm_index)
        document_updated.connect(run_workflows_updated)
+        document_updated.connect(send_websocket_document_updated)

        import documents.schema  # noqa: F401

--- a/src/documents/migrations/0012_alter_workflowaction_type.py
+++ b/src/documents/migrations/0012_alter_workflowaction_type.py
@@ -1,29 +0,0 @@
-# Generated by Django 5.2.11 on 2026-02-14 19:19
-
-from django.db import migrations
-from django.db import models
-
-
-class Migration(migrations.Migration):
-    dependencies = [
-        ("documents", "0011_optimize_integer_field_sizes"),
-    ]
-
-    operations = [
-        migrations.AlterField(
-            model_name="workflowaction",
-            name="type",
-            field=models.PositiveSmallIntegerField(
-                choices=[
-                    (1, "Assignment"),
-                    (2, "Removal"),
-                    (3, "Email"),
-                    (4, "Webhook"),
-                    (5, "Password removal"),
-                    (6, "Move to trash"),
-                ],
-                default=1,
-                verbose_name="Workflow Action Type",
-            ),
-        ),
-    ]
--- a/src/documents/models.py
+++ b/src/documents/models.py
@@ -1409,10 +1409,6 @@ class WorkflowAction(models.Model):
            5,
            _("Password removal"),
        )
-        MOVE_TO_TRASH = (
-            6,
-            _("Move to trash"),
-        )

    type = models.PositiveSmallIntegerField(
        _("Workflow Action Type"),
--- a/src/documents/plugins/helpers.py
+++ b/src/documents/plugins/helpers.py
@@ -1,4 +1,5 @@
 import enum
+from collections.abc import Mapping
 from typing import TYPE_CHECKING

 from asgiref.sync import async_to_sync
@@ -47,7 +48,7 @@ class BaseStatusManager:
            async_to_sync(self._channel.flush)
            self._channel = None

-    def send(self, payload: dict[str, str | int | None]) -> None:
+    def send(self, payload: Mapping[str, object]) -> None:
        # Ensure the layer is open
        self.open()

@@ -73,26 +74,28 @@ class ProgressManager(BaseStatusManager):
        max_progress: int,
        extra_args: dict[str, str | int | None] | None = None,
    ) -> None:
-        payload = {
-            "type": "status_update",
-            "data": {
-                "filename": self.filename,
-                "task_id": self.task_id,
-                "current_progress": current_progress,
-                "max_progress": max_progress,
-                "status": status,
-                "message": message,
-            },
+        data: dict[str, object] = {
+            "filename": self.filename,
+            "task_id": self.task_id,
+            "current_progress": current_progress,
+            "max_progress": max_progress,
+            "status": status,
+            "message": message,
        }
        if extra_args is not None:
-            payload["data"].update(extra_args)
+            data.update(extra_args)
+
+        payload: dict[str, object] = {
+            "type": "status_update",
+            "data": data,
+        }

        self.send(payload)


 class DocumentsStatusManager(BaseStatusManager):
    def send_documents_deleted(self, documents: list[int]) -> None:
-        payload = {
+        payload: dict[str, object] = {
            "type": "documents_deleted",
            "data": {
                "documents": documents,
@@ -100,3 +103,25 @@ class DocumentsStatusManager(BaseStatusManager):
        }

        self.send(payload)
+
+    def send_document_updated(
+        self,
+        *,
+        document_id: int,
+        modified: str,
+        owner_id: int | None = None,
+        users_can_view: list[int] | None = None,
+        groups_can_view: list[int] | None = None,
+    ) -> None:
+        payload: dict[str, object] = {
+            "type": "document_updated",
+            "data": {
+                "document_id": document_id,
+                "modified": modified,
+                "owner_id": owner_id,
+                "users_can_view": users_can_view or [],
+                "groups_can_view": groups_can_view or [],
+            },
+        }
+
+        self.send(payload)
--- a/src/documents/signals/handlers.py
+++ b/src/documents/signals/handlers.py
@@ -4,6 +4,7 @@ import logging
 import shutil
 from pathlib import Path
 from typing import TYPE_CHECKING
+from typing import Any

 from celery import shared_task
 from celery import states
@@ -23,6 +24,7 @@ from django.db.models import Q
 from django.dispatch import receiver
 from django.utils import timezone
 from filelock import FileLock
+from rest_framework import serializers

 from documents import matching
 from documents.caching import clear_document_caches
@@ -45,10 +47,10 @@ from documents.models import WorkflowAction
 from documents.models import WorkflowRun
 from documents.models import WorkflowTrigger
 from documents.permissions import get_objects_for_user_owner_aware
+from documents.plugins.helpers import DocumentsStatusManager
 from documents.templating.utils import convert_format_str_to_template_format
 from documents.workflows.actions import build_workflow_action_context
 from documents.workflows.actions import execute_email_action
-from documents.workflows.actions import execute_move_to_trash_action
 from documents.workflows.actions import execute_password_removal_action
 from documents.workflows.actions import execute_webhook_action
 from documents.workflows.mutations import apply_assignment_to_document
@@ -59,13 +61,12 @@ from documents.workflows.utils import get_workflows_for_trigger
 from paperless.config import AIConfig

 if TYPE_CHECKING:
-    import uuid
-
    from documents.classifier import DocumentClassifier
    from documents.data_models import ConsumableDocument
    from documents.data_models import DocumentMetadataOverrides

 logger = logging.getLogger("paperless.handlers")
+DRF_DATETIME_FIELD = serializers.DateTimeField()


 def add_inbox_tags(sender, document: Document, logging_group=None, **kwargs) -> None:
@@ -730,7 +731,7 @@ def add_to_index(sender, document, **kwargs) -> None:
 def run_workflows_added(
    sender,
    document: Document,
-    logging_group: uuid.UUID | None = None,
+    logging_group=None,
    original_file=None,
    **kwargs,
 ) -> None:
@@ -746,7 +747,7 @@ def run_workflows_added(
 def run_workflows_updated(
    sender,
    document: Document,
-    logging_group: uuid.UUID | None = None,
+    logging_group=None,
    **kwargs,
 ) -> None:
    run_workflows(
@@ -756,11 +757,33 @@ def run_workflows_updated(
    )


+def send_websocket_document_updated(
+    sender,
+    document: Document,
+    **kwargs,
+) -> None:
+    # At this point, workflows may already have applied additional changes.
+    document.refresh_from_db()
+
+    from documents.data_models import DocumentMetadataOverrides
+
+    doc_overrides = DocumentMetadataOverrides.from_document(document)
+
+    with DocumentsStatusManager() as status_mgr:
+        status_mgr.send_document_updated(
+            document_id=document.id,
+            modified=DRF_DATETIME_FIELD.to_representation(document.modified),
+            owner_id=doc_overrides.owner_id,
+            users_can_view=doc_overrides.view_users,
+            groups_can_view=doc_overrides.view_groups,
+        )
+
+
 def run_workflows(
    trigger_type: WorkflowTrigger.WorkflowTriggerType,
    document: Document | ConsumableDocument,
    workflow_to_run: Workflow | None = None,
-    logging_group: uuid.UUID | None = None,
+    logging_group=None,
    overrides: DocumentMetadataOverrides | None = None,
    original_file: Path | None = None,
 ) -> tuple[DocumentMetadataOverrides, str] | None:
@@ -786,33 +809,14 @@ def run_workflows(

    for workflow in workflows:
        if not use_overrides:
-            if TYPE_CHECKING:
-                assert isinstance(document, Document)
-            try:
-                # This can be called from bulk_update_documents, which may be running multiple times
-                # Refresh this so the matching data is fresh and instance fields are re-freshed
-                # Otherwise, this instance might be behind and overwrite the work another process did
-                document.refresh_from_db()
-                doc_tag_ids = list(document.tags.values_list("pk", flat=True))
-            except Document.DoesNotExist:
-                # Document was hard deleted by a previous workflow or another process
-                logger.info(
-                    "Document no longer exists, skipping remaining workflows",
-                    extra={"group": logging_group},
-                )
-                break
-
-            # Check if document was soft deleted (moved to trash)
-            if document.is_deleted:
-                logger.info(
-                    "Document was moved to trash, skipping remaining workflows",
-                    extra={"group": logging_group},
-                )
-                break
+            # This can be called from bulk_update_documents, which may be running multiple times
+            # Refresh this so the matching data is fresh and instance fields are re-freshed
+            # Otherwise, this instance might be behind and overwrite the work another process did
+            document.refresh_from_db()
+            doc_tag_ids = list(document.tags.values_list("pk", flat=True))

        if matching.document_matches_workflow(document, workflow, trigger_type):
            action: WorkflowAction
-            has_move_to_trash_action = False
            for action in workflow.actions.order_by("order", "pk"):
                message = f"Applying {action} from {workflow}"
                if not use_overrides:
@@ -856,8 +860,6 @@ def run_workflows(
                    )
                elif action.type == WorkflowAction.WorkflowActionType.PASSWORD_REMOVAL:
                    execute_password_removal_action(action, document, logging_group)
-                elif action.type == WorkflowAction.WorkflowActionType.MOVE_TO_TRASH:
-                    has_move_to_trash_action = True

            if not use_overrides:
                # limit title to 128 characters
@@ -872,12 +874,7 @@ def run_workflows(
                document=document if not use_overrides else None,
            )

-            if has_move_to_trash_action:
-                execute_move_to_trash_action(action, document, logging_group)
-
    if use_overrides:
-        if TYPE_CHECKING:
-            assert overrides is not None
        return overrides, "\n".join(messages)


@@ -1029,7 +1026,11 @@ def add_or_update_document_in_llm_index(sender, document, **kwargs):


@receiver(models.signals.post_delete, sender=Document)
-def delete_document_from_llm_index(sender, instance: Document, **kwargs):
+def delete_document_from_llm_index(
+    sender: Any,
+    instance: Document,
+    **kwargs: Any,
+) -> None:
    """
    Delete a document from the LLM index when it is deleted.
    """
--- a/src/documents/tasks.py
+++ b/src/documents/tasks.py
@@ -60,6 +60,7 @@ from documents.sanity_checker import SanityCheckFailedException
 from documents.signals import document_updated
 from documents.signals.handlers import cleanup_document_deletion
 from documents.signals.handlers import run_workflows
+from documents.signals.handlers import send_websocket_document_updated
 from documents.workflows.utils import get_workflows_for_trigger
 from paperless.config import AIConfig
 from paperless_ai.indexing import llm_index_add_or_update_document
@@ -534,6 +535,11 @@ def check_scheduled_workflows() -> None:
                            workflow_to_run=workflow,
                            document=document,
                        )
+                        # Scheduled workflows dont send document_updated signal, so send a websocket update here to ensure clients are updated
+                        send_websocket_document_updated(
+                            sender=None,
+                            document=document,
+                        )


 def update_document_parent_tags(tag: Tag, new_parent: Tag) -> None:
--- a/src/documents/tests/test_api_documents.py
+++ b/src/documents/tests/test_api_documents.py
@@ -1206,7 +1206,11 @@ class TestDocumentApi(DirectoriesMixin, DocumentConsumeDelayMixin, APITestCase):
        input_doc, overrides = self.get_last_consume_delay_call_args()

        self.assertEqual(input_doc.original_file.name, "simple.pdf")
-        self.assertIn(Path(settings.SCRATCH_DIR), input_doc.original_file.parents)
+        self.assertTrue(
+            input_doc.original_file.resolve(strict=False).is_relative_to(
+                Path(settings.SCRATCH_DIR).resolve(strict=False),
+            ),
+        )
        self.assertIsNone(overrides.title)
        self.assertIsNone(overrides.correspondent_id)
        self.assertIsNone(overrides.document_type_id)
@@ -1255,7 +1259,11 @@ class TestDocumentApi(DirectoriesMixin, DocumentConsumeDelayMixin, APITestCase):
        input_doc, overrides = self.get_last_consume_delay_call_args()

        self.assertEqual(input_doc.original_file.name, "simple.pdf")
-        self.assertIn(Path(settings.SCRATCH_DIR), input_doc.original_file.parents)
+        self.assertTrue(
+            input_doc.original_file.resolve(strict=False).is_relative_to(
+                Path(settings.SCRATCH_DIR).resolve(strict=False),
+            ),
+        )
        self.assertIsNone(overrides.title)
        self.assertIsNone(overrides.correspondent_id)
        self.assertIsNone(overrides.document_type_id)
--- a/src/documents/tests/test_api_workflows.py
+++ b/src/documents/tests/test_api_workflows.py
@@ -896,210 +896,3 @@ class TestApiWorkflows(DirectoriesMixin, APITestCase):
                "Passwords are required",
                str(response.data["non_field_errors"][0]),
            )
-
-    def test_trash_action_validation(self) -> None:
-        """
-        GIVEN:
-            - API request to create a workflow with a trash action
-        WHEN:
-            - API is called
-        THEN:
-            - Correct HTTP response
-        """
-        response = self.client.post(
-            self.ENDPOINT,
-            json.dumps(
-                {
-                    "name": "Workflow 2",
-                    "order": 1,
-                    "triggers": [
-                        {
-                            "type": WorkflowTrigger.WorkflowTriggerType.CONSUMPTION,
-                            "sources": [DocumentSource.ApiUpload],
-                            "filter_filename": "*",
-                        },
-                    ],
-                    "actions": [
-                        {
-                            "type": WorkflowAction.WorkflowActionType.MOVE_TO_TRASH,
-                        },
-                    ],
-                },
-            ),
-            content_type="application/json",
-        )
-        self.assertEqual(response.status_code, status.HTTP_201_CREATED)
-
-        response = self.client.post(
-            self.ENDPOINT,
-            json.dumps(
-                {
-                    "name": "Workflow 3",
-                    "order": 2,
-                    "triggers": [
-                        {
-                            "type": WorkflowTrigger.WorkflowTriggerType.CONSUMPTION,
-                            "sources": [DocumentSource.ApiUpload],
-                            "filter_filename": "*",
-                        },
-                    ],
-                    "actions": [
-                        {
-                            "type": WorkflowAction.WorkflowActionType.MOVE_TO_TRASH,
-                        },
-                    ],
-                },
-            ),
-            content_type="application/json",
-        )
-        self.assertEqual(response.status_code, status.HTTP_201_CREATED)
-
-    def test_trash_action_as_last_action_valid(self) -> None:
-        """
-        GIVEN:
-            - API request to create a workflow with multiple actions
-            - Move to trash action is the last action
-        WHEN:
-            - API is called
-        THEN:
-            - Workflow is created successfully
-        """
-        response = self.client.post(
-            self.ENDPOINT,
-            json.dumps(
-                {
-                    "name": "Workflow with Move to Trash Last",
-                    "order": 1,
-                    "triggers": [
-                        {
-                            "type": WorkflowTrigger.WorkflowTriggerType.CONSUMPTION,
-                            "sources": [DocumentSource.ApiUpload],
-                            "filter_filename": "*",
-                        },
-                    ],
-                    "actions": [
-                        {
-                            "type": WorkflowAction.WorkflowActionType.ASSIGNMENT,
-                            "assign_title": "Assigned Title",
-                        },
-                        {
-                            "type": WorkflowAction.WorkflowActionType.REMOVAL,
-                            "remove_all_tags": True,
-                        },
-                        {
-                            "type": WorkflowAction.WorkflowActionType.MOVE_TO_TRASH,
-                        },
-                    ],
-                },
-            ),
-            content_type="application/json",
-        )
-        self.assertEqual(response.status_code, status.HTTP_201_CREATED)
-
-    def test_update_workflow_add_trash_at_end_valid(self) -> None:
-        """
-        GIVEN:
-            - Existing workflow without trash action
-        WHEN:
-            - PATCH to add trash action at end
-        THEN:
-            - HTTP 200 success
-        """
-        response = self.client.post(
-            self.ENDPOINT,
-            json.dumps(
-                {
-                    "name": "Workflow to Add Move to Trash",
-                    "order": 1,
-                    "triggers": [
-                        {
-                            "type": WorkflowTrigger.WorkflowTriggerType.CONSUMPTION,
-                            "sources": [DocumentSource.ApiUpload],
-                            "filter_filename": "*",
-                        },
-                    ],
-                    "actions": [
-                        {
-                            "type": WorkflowAction.WorkflowActionType.ASSIGNMENT,
-                            "assign_title": "First Action",
-                        },
-                    ],
-                },
-            ),
-            content_type="application/json",
-        )
-        self.assertEqual(response.status_code, status.HTTP_201_CREATED)
-        workflow_id = response.data["id"]
-
-        response = self.client.patch(
-            f"{self.ENDPOINT}{workflow_id}/",
-            json.dumps(
-                {
-                    "actions": [
-                        {
-                            "type": WorkflowAction.WorkflowActionType.ASSIGNMENT,
-                            "assign_title": "First Action",
-                        },
-                        {
-                            "type": WorkflowAction.WorkflowActionType.MOVE_TO_TRASH,
-                        },
-                    ],
-                },
-            ),
-            content_type="application/json",
-        )
-        self.assertEqual(response.status_code, status.HTTP_200_OK)
-
-    def test_update_workflow_remove_trash_action_valid(self) -> None:
-        """
-        GIVEN:
-            - Existing workflow with trash action
-        WHEN:
-            - PATCH to remove trash action
-        THEN:
-            - HTTP 200 success
-        """
-        response = self.client.post(
-            self.ENDPOINT,
-            json.dumps(
-                {
-                    "name": "Workflow to Remove move to trash",
-                    "order": 1,
-                    "triggers": [
-                        {
-                            "type": WorkflowTrigger.WorkflowTriggerType.CONSUMPTION,
-                            "sources": [DocumentSource.ApiUpload],
-                            "filter_filename": "*",
-                        },
-                    ],
-                    "actions": [
-                        {
-                            "type": WorkflowAction.WorkflowActionType.ASSIGNMENT,
-                            "assign_title": "First Action",
-                        },
-                        {
-                            "type": WorkflowAction.WorkflowActionType.MOVE_TO_TRASH,
-                        },
-                    ],
-                },
-            ),
-            content_type="application/json",
-        )
-        self.assertEqual(response.status_code, status.HTTP_201_CREATED)
-        workflow_id = response.data["id"]
-
-        response = self.client.patch(
-            f"{self.ENDPOINT}{workflow_id}/",
-            json.dumps(
-                {
-                    "actions": [
-                        {
-                            "type": WorkflowAction.WorkflowActionType.ASSIGNMENT,
-                            "assign_title": "Only Action",
-                        },
-                    ],
-                },
-            ),
-            content_type="application/json",
-        )
-        self.assertEqual(response.status_code, status.HTTP_200_OK)
--- a/src/documents/tests/test_workflows.py
+++ b/src/documents/tests/test_workflows.py
@@ -7,7 +7,6 @@ from collections.abc import Callable
 from datetime import timedelta
 from pathlib import Path
 from typing import TYPE_CHECKING
-from typing import Any
 from unittest import mock

 import pytest
@@ -57,7 +56,6 @@ from documents.models import WorkflowActionEmail
 from documents.models import WorkflowActionWebhook
 from documents.models import WorkflowRun
 from documents.models import WorkflowTrigger
-from documents.plugins.base import StopConsumeTaskError
 from documents.serialisers import WorkflowTriggerSerializer
 from documents.signals import document_consumption_finished
 from documents.tests.utils import DirectoriesMixin
@@ -643,7 +641,9 @@ class TestWorkflows(

        expected_str = f"Document did not match {w}"
        self.assertIn(expected_str, cm.output[0])
-        expected_str = f"Document path {test_file} does not match"
+        expected_str = (
+            f"Document path {Path(test_file).resolve(strict=False)} does not match"
+        )
        self.assertIn(expected_str, cm.output[1])

    def test_workflow_no_match_mail_rule(self) -> None:
@@ -1968,6 +1968,36 @@ class TestWorkflows(
        doc.refresh_from_db()
        self.assertEqual(doc.owner, self.user2)

+    @mock.patch("documents.tasks.send_websocket_document_updated")
+    def test_workflow_scheduled_trigger_sends_websocket_update(
+        self,
+        mock_send_websocket_document_updated,
+    ) -> None:
+        trigger = WorkflowTrigger.objects.create(
+            type=WorkflowTrigger.WorkflowTriggerType.SCHEDULED,
+            schedule_offset_days=1,
+            schedule_date_field=WorkflowTrigger.ScheduleDateField.CREATED,
+        )
+        action = WorkflowAction.objects.create(assign_owner=self.user2)
+        workflow = Workflow.objects.create(name="Workflow 1", order=0)
+        workflow.triggers.add(trigger)
+        workflow.actions.add(action)
+
+        doc = Document.objects.create(
+            title="sample test",
+            correspondent=self.c,
+            original_filename="sample.pdf",
+            created=timezone.now() - timedelta(days=2),
+        )
+
+        tasks.check_scheduled_workflows()
+
+        self.assertEqual(mock_send_websocket_document_updated.call_count, 1)
+        self.assertEqual(
+            mock_send_websocket_document_updated.call_args.kwargs["document"].pk,
+            doc.pk,
+        )
+
    def test_workflow_scheduled_trigger_added(self) -> None:
        """
        GIVEN:
@@ -3917,427 +3947,6 @@ class TestWorkflows(
        )
        assert mock_remove_password.call_count == 2

-    def test_workflow_trash_action_soft_delete(self):
-        """
-        GIVEN:
-            - Document updated workflow with delete action
-        WHEN:
-            - Document that matches is updated
-        THEN:
-            - Document is moved to trash (soft deleted)
-        """
-        trigger = WorkflowTrigger.objects.create(
-            type=WorkflowTrigger.WorkflowTriggerType.DOCUMENT_UPDATED,
-        )
-        action = WorkflowAction.objects.create(
-            type=WorkflowAction.WorkflowActionType.MOVE_TO_TRASH,
-        )
-        w = Workflow.objects.create(
-            name="Workflow 1",
-            order=0,
-        )
-        w.triggers.add(trigger)
-        w.actions.add(action)
-        w.save()
-
-        doc = Document.objects.create(
-            title="sample test",
-            correspondent=self.c,
-            original_filename="sample.pdf",
-        )
-
-        self.assertEqual(Document.objects.count(), 1)
-        self.assertEqual(Document.deleted_objects.count(), 0)
-
-        run_workflows(WorkflowTrigger.WorkflowTriggerType.DOCUMENT_UPDATED, doc)
-
-        self.assertEqual(Document.objects.count(), 0)
-        self.assertEqual(Document.deleted_objects.count(), 1)
-
-    @override_settings(
-        PAPERLESS_EMAIL_HOST="localhost",
-        EMAIL_ENABLED=True,
-        PAPERLESS_URL="http://localhost:8000",
-    )
-    @mock.patch("django.core.mail.message.EmailMessage.send")
-    def test_workflow_trash_with_email_action(self, mock_email_send):
-        """
-        GIVEN:
-            - Workflow with email action, then move to trash action
-        WHEN:
-            - Document matches and workflow runs
-        THEN:
-            - Email is sent first
-            - Document is moved to trash (soft deleted)
-        """
-        mock_email_send.return_value = 1
-
-        trigger = WorkflowTrigger.objects.create(
-            type=WorkflowTrigger.WorkflowTriggerType.DOCUMENT_UPDATED,
-        )
-        email_action = WorkflowActionEmail.objects.create(
-            subject="Document deleted: {doc_title}",
-            body="Document {doc_title} will be deleted",
-            to="user@example.com",
-            include_document=False,
-        )
-        email_workflow_action = WorkflowAction.objects.create(
-            type=WorkflowAction.WorkflowActionType.EMAIL,
-            email=email_action,
-        )
-        trash_workflow_action = WorkflowAction.objects.create(
-            type=WorkflowAction.WorkflowActionType.MOVE_TO_TRASH,
-        )
-        w = Workflow.objects.create(
-            name="Workflow with email then move to trash",
-            order=0,
-        )
-        w.triggers.add(trigger)
-        w.actions.add(email_workflow_action, trash_workflow_action)
-        w.save()
-
-        doc = Document.objects.create(
-            title="sample test",
-            correspondent=self.c,
-            original_filename="sample.pdf",
-        )
-
-        self.assertEqual(Document.objects.count(), 1)
-        self.assertEqual(Document.deleted_objects.count(), 0)
-
-        run_workflows(WorkflowTrigger.WorkflowTriggerType.DOCUMENT_UPDATED, doc)
-
-        mock_email_send.assert_called_once()
-        self.assertEqual(Document.objects.count(), 0)
-        self.assertEqual(Document.deleted_objects.count(), 1)
-
-    @override_settings(
-        PAPERLESS_URL="http://localhost:8000",
-    )
-    @mock.patch("documents.workflows.webhooks.send_webhook.delay")
-    def test_workflow_trash_with_webhook_action(self, mock_webhook_delay):
-        """
-        GIVEN:
-            - Workflow with webhook action (include_document=True), then move to trash action
-        WHEN:
-            - Document matches and workflow runs
-        THEN:
-            - Webhook .delay() is called with complete data including file bytes
-            - Document is moved to trash (soft deleted)
-            - Webhook task has all necessary data and doesn't rely on document existence
-        """
-        trigger = WorkflowTrigger.objects.create(
-            type=WorkflowTrigger.WorkflowTriggerType.DOCUMENT_UPDATED,
-        )
-        webhook_action = WorkflowActionWebhook.objects.create(
-            use_params=True,
-            params={
-                "title": "{{doc_title}}",
-                "message": "Document being deleted",
-            },
-            url="https://paperless-ngx.com/webhook",
-            include_document=True,
-        )
-        webhook_workflow_action = WorkflowAction.objects.create(
-            type=WorkflowAction.WorkflowActionType.WEBHOOK,
-            webhook=webhook_action,
-        )
-        trash_workflow_action = WorkflowAction.objects.create(
-            type=WorkflowAction.WorkflowActionType.MOVE_TO_TRASH,
-        )
-        w = Workflow.objects.create(
-            name="Workflow with webhook then move to trash",
-            order=0,
-        )
-        w.triggers.add(trigger)
-        w.actions.add(webhook_workflow_action, trash_workflow_action)
-        w.save()
-
-        test_file = shutil.copy(
-            self.SAMPLE_DIR / "simple.pdf",
-            self.dirs.scratch_dir / "simple.pdf",
-        )
-
-        doc = Document.objects.create(
-            title="sample test",
-            correspondent=self.c,
-            original_filename="simple.pdf",
-            filename=test_file,
-            mime_type="application/pdf",
-        )
-
-        self.assertEqual(Document.objects.count(), 1)
-        self.assertEqual(Document.deleted_objects.count(), 0)
-
-        run_workflows(WorkflowTrigger.WorkflowTriggerType.DOCUMENT_UPDATED, doc)
-
-        mock_webhook_delay.assert_called_once()
-        call_kwargs = mock_webhook_delay.call_args[1]
-        self.assertEqual(call_kwargs["url"], "https://paperless-ngx.com/webhook")
-        self.assertEqual(
-            call_kwargs["data"],
-            {"title": "sample test", "message": "Document being deleted"},
-        )
-        self.assertIsNotNone(call_kwargs["files"])
-        self.assertIn("file", call_kwargs["files"])
-        self.assertEqual(call_kwargs["files"]["file"][0], "simple.pdf")
-        self.assertEqual(call_kwargs["files"]["file"][2], "application/pdf")
-        self.assertIsInstance(call_kwargs["files"]["file"][1], bytes)
-
-        self.assertEqual(Document.objects.count(), 0)
-        self.assertEqual(Document.deleted_objects.count(), 1)
-
-    @override_settings(
-        PAPERLESS_EMAIL_HOST="localhost",
-        EMAIL_ENABLED=True,
-        PAPERLESS_URL="http://localhost:8000",
-    )
-    @mock.patch("django.core.mail.message.EmailMessage.send")
-    def test_workflow_trash_after_email_failure(self, mock_email_send) -> None:
-        """
-        GIVEN:
-            - Workflow with email action (that fails), then move to trash action
-        WHEN:
-            - Document matches and workflow runs
-            - Email action raises exception
-        THEN:
-            - Email failure is logged
-            - Move to Trash still executes successfully (soft delete)
-        """
-        mock_email_send.side_effect = Exception("Email server error")
-
-        trigger = WorkflowTrigger.objects.create(
-            type=WorkflowTrigger.WorkflowTriggerType.DOCUMENT_UPDATED,
-        )
-        email_action = WorkflowActionEmail.objects.create(
-            subject="Document deleted: {doc_title}",
-            body="Document {doc_title} will be deleted",
-            to="user@example.com",
-            include_document=False,
-        )
-        email_workflow_action = WorkflowAction.objects.create(
-            type=WorkflowAction.WorkflowActionType.EMAIL,
-            email=email_action,
-        )
-        trash_workflow_action = WorkflowAction.objects.create(
-            type=WorkflowAction.WorkflowActionType.MOVE_TO_TRASH,
-        )
-        w = Workflow.objects.create(
-            name="Workflow with failing email then move to trash",
-            order=0,
-        )
-        w.triggers.add(trigger)
-        w.actions.add(email_workflow_action, trash_workflow_action)
-        w.save()
-
-        doc = Document.objects.create(
-            title="sample test",
-            correspondent=self.c,
-            original_filename="sample.pdf",
-        )
-
-        self.assertEqual(Document.objects.count(), 1)
-        self.assertEqual(Document.deleted_objects.count(), 0)
-
-        with self.assertLogs("paperless.workflows.actions", level="ERROR") as cm:
-            run_workflows(WorkflowTrigger.WorkflowTriggerType.DOCUMENT_UPDATED, doc)
-
-            expected_str = "Error occurred sending notification email"
-            self.assertIn(expected_str, cm.output[0])
-
-        self.assertEqual(Document.objects.count(), 0)
-        self.assertEqual(Document.deleted_objects.count(), 1)
-
-    def test_multiple_workflows_trash_then_assignment(self):
-        """
-        GIVEN:
-            - Workflow 1 (order=0) with move to trash action
-            - Workflow 2 (order=1) with assignment action
-            - Both workflows match the same document
-        WHEN:
-            - Workflows run sequentially
-        THEN:
-            - First workflow runs and deletes document (soft delete)
-            - Second workflow does not trigger (document no longer exists)
-            - Logs confirm move to trash and skipping of remaining workflows
-        """
-        trigger1 = WorkflowTrigger.objects.create(
-            type=WorkflowTrigger.WorkflowTriggerType.DOCUMENT_UPDATED,
-        )
-        trash_workflow_action = WorkflowAction.objects.create(
-            type=WorkflowAction.WorkflowActionType.MOVE_TO_TRASH,
-        )
-        w1 = Workflow.objects.create(
-            name="Workflow 1 - Move to Trash",
-            order=0,
-        )
-        w1.triggers.add(trigger1)
-        w1.actions.add(trash_workflow_action)
-        w1.save()
-
-        trigger2 = WorkflowTrigger.objects.create(
-            type=WorkflowTrigger.WorkflowTriggerType.DOCUMENT_UPDATED,
-        )
-        assignment_action = WorkflowAction.objects.create(
-            type=WorkflowAction.WorkflowActionType.ASSIGNMENT,
-            assign_correspondent=self.c2,
-        )
-        w2 = Workflow.objects.create(
-            name="Workflow 2 - Assignment",
-            order=1,
-        )
-        w2.triggers.add(trigger2)
-        w2.actions.add(assignment_action)
-        w2.save()
-
-        doc = Document.objects.create(
-            title="sample test",
-            correspondent=self.c,
-            original_filename="sample.pdf",
-        )
-
-        self.assertEqual(Document.objects.count(), 1)
-        self.assertEqual(Document.deleted_objects.count(), 0)
-
-        with self.assertLogs("paperless", level="DEBUG") as cm:
-            run_workflows(WorkflowTrigger.WorkflowTriggerType.DOCUMENT_UPDATED, doc)
-
-        self.assertEqual(Document.objects.count(), 0)
-        self.assertEqual(Document.deleted_objects.count(), 1)
-
-        # We check logs instead of WorkflowRun.objects.count() because when the document
-        # is soft-deleted, the WorkflowRun is cascade-deleted (hard delete) since it does
-        # not inherit from the SoftDeleteModel. The logs confirm that the first workflow
-        # executed the move to trash and remaining workflows were skipped.
-        log_output = "\n".join(cm.output)
-        self.assertIn("Moved document", log_output)
-        self.assertIn("to trash", log_output)
-        self.assertIn(
-            "Document was moved to trash, skipping remaining workflows",
-            log_output,
-        )
-
-    def test_workflow_delete_action_during_consumption(self):
-        """
-        GIVEN:
-            - Workflow with consumption trigger and delete action
-        WHEN:
-            - Document is being consumed and workflow runs
-        THEN:
-            - StopConsumeTaskError is raised to halt consumption
-            - Original file is deleted
-            - No document is created
-        """
-        trigger = WorkflowTrigger.objects.create(
-            type=WorkflowTrigger.WorkflowTriggerType.CONSUMPTION,
-            sources=f"{DocumentSource.ConsumeFolder}",
-            filter_filename="*",
-        )
-        action = WorkflowAction.objects.create(
-            type=WorkflowAction.WorkflowActionType.MOVE_TO_TRASH,
-        )
-        w = Workflow.objects.create(
-            name="Workflow Delete During Consumption",
-            order=0,
-        )
-        w.triggers.add(trigger)
-        w.actions.add(action)
-        w.save()
-
-        # Create a test file to be consumed
-        test_file = shutil.copy(
-            self.SAMPLE_DIR / "simple.pdf",
-            self.dirs.scratch_dir / "simple.pdf",
-        )
-        test_file_path = Path(test_file)
-        self.assertTrue(test_file_path.exists())
-
-        # Create a ConsumableDocument
-        consumable_doc = ConsumableDocument(
-            source=DocumentSource.ConsumeFolder,
-            original_file=test_file_path,
-        )
-
-        self.assertEqual(Document.objects.count(), 0)
-
-        # Run workflows with overrides (consumption flow)
-        with self.assertRaises(StopConsumeTaskError) as context:
-            run_workflows(
-                WorkflowTrigger.WorkflowTriggerType.CONSUMPTION,
-                consumable_doc,
-                overrides=DocumentMetadataOverrides(),
-            )
-
-        self.assertIn("deleted by workflow action", str(context.exception))
-
-        # File should be deleted
-        self.assertFalse(test_file_path.exists())
-
-        # No document should be created
-        self.assertEqual(Document.objects.count(), 0)
-
-    def test_workflow_delete_action_during_consumption_with_assignment(self):
-        """
-        GIVEN:
-            - Workflow with consumption trigger, assignment action, then delete action
-        WHEN:
-            - Document is being consumed and workflow runs
-        THEN:
-            - StopConsumeTaskError is raised to halt consumption
-            - Original file is deleted
-            - No document is created (even though assignment would have worked)
-        """
-        trigger = WorkflowTrigger.objects.create(
-            type=WorkflowTrigger.WorkflowTriggerType.CONSUMPTION,
-            sources=f"{DocumentSource.ConsumeFolder}",
-            filter_filename="*",
-        )
-        assignment_action = WorkflowAction.objects.create(
-            type=WorkflowAction.WorkflowActionType.ASSIGNMENT,
-            assign_title="This should not be applied",
-            assign_correspondent=self.c,
-        )
-        trash_workflow_action = WorkflowAction.objects.create(
-            type=WorkflowAction.WorkflowActionType.MOVE_TO_TRASH,
-        )
-        w = Workflow.objects.create(
-            name="Workflow Assignment then Delete During Consumption",
-            order=0,
-        )
-        w.triggers.add(trigger)
-        w.actions.add(assignment_action, trash_workflow_action)
-        w.save()
-
-        # Create a test file to be consumed
-        test_file = shutil.copy(
-            self.SAMPLE_DIR / "simple.pdf",
-            self.dirs.scratch_dir / "simple2.pdf",
-        )
-        test_file_path = Path(test_file)
-        self.assertTrue(test_file_path.exists())
-
-        # Create a ConsumableDocument
-        consumable_doc = ConsumableDocument(
-            source=DocumentSource.ConsumeFolder,
-            original_file=test_file_path,
-        )
-
-        self.assertEqual(Document.objects.count(), 0)
-
-        # Run workflows with overrides (consumption flow)
-        with self.assertRaises(StopConsumeTaskError):
-            run_workflows(
-                WorkflowTrigger.WorkflowTriggerType.CONSUMPTION,
-                consumable_doc,
-                overrides=DocumentMetadataOverrides(),
-            )
-
-        # File should be deleted
-        self.assertFalse(test_file_path.exists())
-
-        # No document should be created
-        self.assertEqual(Document.objects.count(), 0)
-

 class TestWebhookSend:
    def test_send_webhook_data_or_json(
@@ -4380,17 +3989,13 @@ class TestWebhookSend:


@pytest.fixture
-def resolve_to(monkeypatch: pytest.MonkeyPatch) -> Callable[[str], None]:
+def resolve_to(monkeypatch):
    """
    Force DNS resolution to a specific IP for any hostname.
    """

-    def _set(ip: str) -> None:
-        def fake_getaddrinfo(
-            host: str,
-            *_args: object,
-            **_kwargs: object,
-        ) -> list[tuple[Any, ...]]:
+    def _set(ip: str):
+        def fake_getaddrinfo(host, *_args, **_kwargs):
            return [(socket.AF_INET, None, None, "", (ip, 0))]

        monkeypatch.setattr(socket, "getaddrinfo", fake_getaddrinfo)
@@ -4597,7 +4202,7 @@ class TestDateWorkflowLocalization(
        self,
        title_template: str,
        expected_title: str,
-    ) -> None:
+    ):
        """
        GIVEN:
            - Document added workflow with title template using localize_date filter
@@ -4662,7 +4267,7 @@ class TestDateWorkflowLocalization(
        self,
        title_template: str,
        expected_title: str,
-    ) -> None:
+    ):
        """
        GIVEN:
            - Document updated workflow with title template using localize_date filter
@@ -4738,7 +4343,7 @@ class TestDateWorkflowLocalization(
        settings: SettingsWrapper,
        title_template: str,
        expected_title: str,
-    ) -> None:
+    ):
        trigger = WorkflowTrigger.objects.create(
            type=WorkflowTrigger.WorkflowTriggerType.CONSUMPTION,
            sources=f"{DocumentSource.ApiUpload}",
--- a/src/documents/workflows/actions.py
+++ b/src/documents/workflows/actions.py
@@ -1,6 +1,5 @@
 import logging
 import re
-import uuid
 from pathlib import Path

 from django.conf import settings
@@ -16,7 +15,6 @@ from documents.models import Document
 from documents.models import DocumentType
 from documents.models import WorkflowAction
 from documents.models import WorkflowTrigger
-from documents.plugins.base import StopConsumeTaskError
 from documents.signals import document_consumption_finished
 from documents.templating.workflows import parse_w_workflow_placeholders
 from documents.workflows.webhooks import send_webhook
@@ -340,33 +338,3 @@ def execute_password_removal_action(
        document.pk,
        extra={"group": logging_group},
    )
-
-
-def execute_move_to_trash_action(
-    action: WorkflowAction,
-    document: Document | ConsumableDocument,
-    logging_group: uuid.UUID | None,
-) -> None:
-    """
-    Execute a move to trash action for a workflow on an existing document or a
-    document in consumption. In case of an existing document it soft-deletes
-    the document. In case of consumption it aborts consumption and deletes the
-    file.
-    """
-    if isinstance(document, Document):
-        document.delete()
-        logger.debug(
-            f"Moved document {document} to trash",
-            extra={"group": logging_group},
-        )
-    else:
-        if document.original_file.exists():
-            document.original_file.unlink()
-        logger.info(
-            f"Workflow move to trash action triggered during consumption, "
-            f"deleting file {document.original_file}",
-            extra={"group": logging_group},
-        )
-        raise StopConsumeTaskError(
-            "Document deleted by workflow action during consumption",
-        )
--- a/src/locale/en_US/LC_MESSAGES/django.po
+++ b/src/locale/en_US/LC_MESSAGES/django.po
@@ -2,7 +2,7 @@ msgid ""
 msgstr ""
 "Project-Id-Version: paperless-ngx\n"
 "Report-Msgid-Bugs-To: \n"
-"POT-Creation-Date: 2026-02-24 00:43+0000\n"
+"POT-Creation-Date: 2026-02-16 17:32+0000\n"
 "PO-Revision-Date: 2022-02-17 04:17\n"
 "Last-Translator: \n"
 "Language-Team: English\n"
@@ -89,7 +89,7 @@ msgstr ""
 msgid "Automatic"
 msgstr ""

-#: documents/models.py:66 documents/models.py:444 documents/models.py:1663
+#: documents/models.py:66 documents/models.py:444 documents/models.py:1659
 #: paperless_mail/models.py:23 paperless_mail/models.py:143
 msgid "name"
 msgstr ""
@@ -252,7 +252,7 @@ msgid "The position of this document in your physical document archive."
 msgstr ""

 #: documents/models.py:313 documents/models.py:688 documents/models.py:742
-#: documents/models.py:1706
+#: documents/models.py:1702
 msgid "document"
 msgstr ""

@@ -1093,197 +1093,193 @@ msgid "Password removal"
 msgstr ""

 #: documents/models.py:1414
-msgid "Move to trash"
-msgstr ""
-
-#: documents/models.py:1418
 msgid "Workflow Action Type"
 msgstr ""

-#: documents/models.py:1423 documents/models.py:1665
+#: documents/models.py:1419 documents/models.py:1661
 #: paperless_mail/models.py:145
 msgid "order"
 msgstr ""

-#: documents/models.py:1426
+#: documents/models.py:1422
 msgid "assign title"
 msgstr ""

-#: documents/models.py:1430
+#: documents/models.py:1426
 msgid "Assign a document title, must  be a Jinja2 template, see documentation."
 msgstr ""

-#: documents/models.py:1438 paperless_mail/models.py:274
+#: documents/models.py:1434 paperless_mail/models.py:274
 msgid "assign this tag"
 msgstr ""

-#: documents/models.py:1447 paperless_mail/models.py:282
+#: documents/models.py:1443 paperless_mail/models.py:282
 msgid "assign this document type"
 msgstr ""

-#: documents/models.py:1456 paperless_mail/models.py:296
+#: documents/models.py:1452 paperless_mail/models.py:296
 msgid "assign this correspondent"
 msgstr ""

-#: documents/models.py:1465
+#: documents/models.py:1461
 msgid "assign this storage path"
 msgstr ""

-#: documents/models.py:1474
+#: documents/models.py:1470
 msgid "assign this owner"
 msgstr ""

-#: documents/models.py:1481
+#: documents/models.py:1477
 msgid "grant view permissions to these users"
 msgstr ""

-#: documents/models.py:1488
+#: documents/models.py:1484
 msgid "grant view permissions to these groups"
 msgstr ""

-#: documents/models.py:1495
+#: documents/models.py:1491
 msgid "grant change permissions to these users"
 msgstr ""

-#: documents/models.py:1502
+#: documents/models.py:1498
 msgid "grant change permissions to these groups"
 msgstr ""

-#: documents/models.py:1509
+#: documents/models.py:1505
 msgid "assign these custom fields"
 msgstr ""

-#: documents/models.py:1513
+#: documents/models.py:1509
 msgid "custom field values"
 msgstr ""

-#: documents/models.py:1517
+#: documents/models.py:1513
 msgid "Optional values to assign to the custom fields."
 msgstr ""

-#: documents/models.py:1526
+#: documents/models.py:1522
 msgid "remove these tag(s)"
 msgstr ""

-#: documents/models.py:1531
+#: documents/models.py:1527
 msgid "remove all tags"
 msgstr ""

-#: documents/models.py:1538
+#: documents/models.py:1534
 msgid "remove these document type(s)"
 msgstr ""

-#: documents/models.py:1543
+#: documents/models.py:1539
 msgid "remove all document types"
 msgstr ""

-#: documents/models.py:1550
+#: documents/models.py:1546
 msgid "remove these correspondent(s)"
 msgstr ""

-#: documents/models.py:1555
+#: documents/models.py:1551
 msgid "remove all correspondents"
 msgstr ""

-#: documents/models.py:1562
+#: documents/models.py:1558
 msgid "remove these storage path(s)"
 msgstr ""

-#: documents/models.py:1567
+#: documents/models.py:1563
 msgid "remove all storage paths"
 msgstr ""

-#: documents/models.py:1574
+#: documents/models.py:1570
 msgid "remove these owner(s)"
 msgstr ""

-#: documents/models.py:1579
+#: documents/models.py:1575
 msgid "remove all owners"
 msgstr ""

-#: documents/models.py:1586
+#: documents/models.py:1582
 msgid "remove view permissions for these users"
 msgstr ""

-#: documents/models.py:1593
+#: documents/models.py:1589
 msgid "remove view permissions for these groups"
 msgstr ""

-#: documents/models.py:1600
+#: documents/models.py:1596
 msgid "remove change permissions for these users"
 msgstr ""

-#: documents/models.py:1607
+#: documents/models.py:1603
 msgid "remove change permissions for these groups"
 msgstr ""

-#: documents/models.py:1612
+#: documents/models.py:1608
 msgid "remove all permissions"
 msgstr ""

-#: documents/models.py:1619
+#: documents/models.py:1615
 msgid "remove these custom fields"
 msgstr ""

-#: documents/models.py:1624
+#: documents/models.py:1620
 msgid "remove all custom fields"
 msgstr ""

-#: documents/models.py:1633
+#: documents/models.py:1629
 msgid "email"
 msgstr ""

-#: documents/models.py:1642
+#: documents/models.py:1638
 msgid "webhook"
 msgstr ""

-#: documents/models.py:1646
+#: documents/models.py:1642
 msgid "passwords"
 msgstr ""

-#: documents/models.py:1650
+#: documents/models.py:1646
 msgid ""
 "Passwords to try when removing PDF protection. Separate with commas or new "
 "lines."
 msgstr ""

-#: documents/models.py:1655
+#: documents/models.py:1651
 msgid "workflow action"
 msgstr ""

-#: documents/models.py:1656
+#: documents/models.py:1652
 msgid "workflow actions"
 msgstr ""

-#: documents/models.py:1671
+#: documents/models.py:1667
 msgid "triggers"
 msgstr ""

-#: documents/models.py:1678
+#: documents/models.py:1674
 msgid "actions"
 msgstr ""

-#: documents/models.py:1681 paperless_mail/models.py:154
+#: documents/models.py:1677 paperless_mail/models.py:154
 msgid "enabled"
 msgstr ""

-#: documents/models.py:1692
+#: documents/models.py:1688
 msgid "workflow"
 msgstr ""

-#: documents/models.py:1696
+#: documents/models.py:1692
 msgid "workflow trigger type"
 msgstr ""

-#: documents/models.py:1710
+#: documents/models.py:1706
 msgid "date run"
 msgstr ""

-#: documents/models.py:1716
+#: documents/models.py:1712
 msgid "workflow run"
 msgstr ""

-#: documents/models.py:1717
+#: documents/models.py:1713
 msgid "workflow runs"
 msgstr ""

--- a/src/paperless/consumers.py
+++ b/src/paperless/consumers.py
@@ -1,4 +1,5 @@
 import json
+from typing import Any

 from asgiref.sync import async_to_sync
 from channels.exceptions import AcceptConnection
@@ -52,3 +53,10 @@ class StatusConsumer(WebsocketConsumer):
            self.close()
        else:
            self.send(json.dumps(event))
+
+    def document_updated(self, event: Any) -> None:
+        if not self._authenticated():
+            self.close()
+        else:
+            if self._can_view(event["data"]):
+                self.send(json.dumps(event))
--- a/src/paperless/tests/test_websockets.py
+++ b/src/paperless/tests/test_websockets.py
@@ -48,6 +48,20 @@ class TestWebSockets(TestCase):
        mock_close.assert_called_once()
        mock_close.reset_mock()

+        message = {
+            "type": "document_updated",
+            "data": {"document_id": 10, "modified": "2026-02-17T00:00:00Z"},
+        }
+
+        await channel_layer.group_send(
+            "status_updates",
+            message,
+        )
+        await communicator.receive_nothing()
+
+        mock_close.assert_called_once()
+        mock_close.reset_mock()
+
        message = {"type": "documents_deleted", "data": {"documents": [1, 2, 3]}}

        await channel_layer.group_send(
@@ -158,6 +172,40 @@ class TestWebSockets(TestCase):

        await communicator.disconnect()

+    @mock.patch("paperless.consumers.StatusConsumer._can_view")
+    @mock.patch("paperless.consumers.StatusConsumer._authenticated")
+    async def test_receive_document_updated(self, _authenticated, _can_view) -> None:
+        _authenticated.return_value = True
+        _can_view.return_value = True
+
+        communicator = WebsocketCommunicator(application, "/ws/status/")
+        connected, _ = await communicator.connect()
+        self.assertTrue(connected)
+
+        message = {
+            "type": "document_updated",
+            "data": {
+                "document_id": 10,
+                "modified": "2026-02-17T00:00:00Z",
+                "owner_id": 1,
+                "users_can_view": [1],
+                "groups_can_view": [],
+            },
+        }
+
+        channel_layer = get_channel_layer()
+        assert channel_layer is not None
+        await channel_layer.group_send(
+            "status_updates",
+            message,
+        )
+
+        response = await communicator.receive_json_from()
+
+        self.assertEqual(response, message)
+
+        await communicator.disconnect()
+
    @mock.patch("channels.layers.InMemoryChannelLayer.group_send")
    def test_manager_send_progress(self, mock_group_send) -> None:
        with ProgressManager(task_id="test") as manager:
@@ -190,7 +238,10 @@ class TestWebSockets(TestCase):
        )

    @mock.patch("channels.layers.InMemoryChannelLayer.group_send")
-    def test_manager_send_documents_deleted(self, mock_group_send) -> None:
+    def test_manager_send_documents_deleted(
+        self,
+        mock_group_send: mock.MagicMock,
+    ) -> None:
        with DocumentsStatusManager() as manager:
            manager.send_documents_deleted([1, 2, 3])

--- a/src/paperless_ai/embedding.py
+++ b/src/paperless_ai/embedding.py
@@ -23,7 +23,6 @@ def get_embedding_model() -> BaseEmbedding:
            return OpenAIEmbedding(
                model=config.llm_embedding_model or "text-embedding-3-small",
                api_key=config.llm_api_key,
-                api_base=config.llm_endpoint or None,
            )
        case LLMEmbeddingBackend.HUGGINGFACE:
            return HuggingFaceEmbedding(
--- a/src/paperless_ai/tests/test_embedding.py
+++ b/src/paperless_ai/tests/test_embedding.py
@@ -65,14 +65,12 @@ def test_get_embedding_model_openai(mock_ai_config):
    mock_ai_config.return_value.llm_embedding_backend = LLMEmbeddingBackend.OPENAI
    mock_ai_config.return_value.llm_embedding_model = "text-embedding-3-small"
    mock_ai_config.return_value.llm_api_key = "test_api_key"
-    mock_ai_config.return_value.llm_endpoint = "http://test-url"

    with patch("paperless_ai.embedding.OpenAIEmbedding") as MockOpenAIEmbedding:
        model = get_embedding_model()
        MockOpenAIEmbedding.assert_called_once_with(
            model="text-embedding-3-small",
            api_key="test_api_key",
-            api_base="http://test-url",
        )
        assert model == MockOpenAIEmbedding.return_value

--- a/src/paperless_mail/mail.py
+++ b/src/paperless_mail/mail.py
@@ -536,7 +536,6 @@ class MailAccountHandler(LoggingMixin):
        self.log.debug(f"Processing mail account {account}")

        total_processed_files = 0
-        consumed_messages: set[tuple[str, str]] = set()
        try:
            with get_mailbox(
                account.imap_server,
@@ -575,7 +574,6 @@ class MailAccountHandler(LoggingMixin):
                            M,
                            rule,
                            supports_gmail_labels=supports_gmail_labels,
-                            consumed_messages=consumed_messages,
                        )
                        if total_processed_files > 0 and rule.stop_processing:
                            self.log.debug(
@@ -607,7 +605,6 @@ class MailAccountHandler(LoggingMixin):
        rule: MailRule,
        *,
        supports_gmail_labels: bool,
-        consumed_messages: set[tuple[str, str]],
    ):
        folders = [rule.folder]
        # In case of MOVE, make sure also the destination exists
@@ -655,26 +652,11 @@ class MailAccountHandler(LoggingMixin):

        mails_processed = 0
        total_processed_files = 0
-        rule_seen_messages: set[tuple[str, str]] = set()

        for message in messages:
            if TYPE_CHECKING:
                assert isinstance(message, MailMessage)

-            message_key = (rule.folder, message.uid)
-            if message_key in rule_seen_messages:
-                self.log.debug(
-                    f"Skipping duplicate fetched mail '{message.uid}' subject '{message.subject}' from '{message.from_}'.",
-                )
-                continue
-            rule_seen_messages.add(message_key)
-
-            if message_key in consumed_messages:
-                self.log.debug(
-                    f"Skipping mail '{message.uid}' subject '{message.subject}' from '{message.from_}', already queued by a previous rule in this run.",
-                )
-                continue
-
            if ProcessedMail.objects.filter(
                rule=rule,
                uid=message.uid,
@@ -687,8 +669,6 @@ class MailAccountHandler(LoggingMixin):

            try:
                processed_files = self._handle_message(message, rule)
-                if processed_files > 0:
-                    consumed_messages.add(message_key)

                total_processed_files += processed_files
                mails_processed += 1
--- a/src/paperless_mail/tests/test_mail.py
+++ b/src/paperless_mail/tests/test_mail.py
@@ -863,66 +863,6 @@ class TestMail(

        self.assertEqual(len(self.mailMocker.bogus_mailbox.messages), 0)

-    def test_handle_mail_account_overlapping_rules_only_first_consumes(self):
-        account = MailAccount.objects.create(
-            name="test",
-            imap_server="",
-            username="admin",
-            password="secret",
-        )
-
-        first_rule = MailRule.objects.create(
-            name="testrule-first",
-            account=account,
-            action=MailRule.MailAction.DELETE,
-            filter_subject="Claim",
-            order=1,
-        )
-        _ = MailRule.objects.create(
-            name="testrule-second",
-            account=account,
-            action=MailRule.MailAction.DELETE,
-            filter_subject="Claim",
-            order=2,
-        )
-
-        self.mail_account_handler.handle_mail_account(account)
-        self.mailMocker.apply_mail_actions()
-
-        self.assertEqual(self.mailMocker._queue_consumption_tasks_mock.call_count, 1)
-        queued_rule = self.mailMocker._queue_consumption_tasks_mock.call_args.kwargs[
-            "rule"
-        ]
-        self.assertEqual(queued_rule.id, first_rule.id)
-
-    def test_handle_mail_account_skip_duplicate_uids_from_fetch(self):
-        account = MailAccount.objects.create(
-            name="test",
-            imap_server="",
-            username="admin",
-            password="secret",
-        )
-        _ = MailRule.objects.create(
-            name="testrule",
-            account=account,
-            action=MailRule.MailAction.DELETE,
-            filter_subject="Duplicated mail",
-        )
-
-        duplicated_message = self.mailMocker.messageBuilder.create_message(
-            subject="Duplicated mail",
-        )
-        self.mailMocker.bogus_mailbox.messages = [
-            duplicated_message,
-            duplicated_message,
-        ]
-        self.mailMocker.bogus_mailbox.updateClient()
-
-        self.mail_account_handler.handle_mail_account(account)
-        self.mailMocker.apply_mail_actions()
-
-        self.assertEqual(self.mailMocker._queue_consumption_tasks_mock.call_count, 1)
-
    @pytest.mark.flaky(reruns=4)
    def test_handle_mail_account_flag(self) -> None:
        account = MailAccount.objects.create(
Author	SHA1	Message	Date
shamoon	4387635091	Update .mypy-baseline.txt	2026-02-22 16:15:06 -08:00
shamoon	47d15273f9	Modified is always going to be set	2026-02-22 16:15:06 -08:00
shamoon	53e2d9b850	Update test_websockets.py	2026-02-22 16:15:06 -08:00
shamoon	33a26e50d9	Some random frontend coverage	2026-02-22 16:15:06 -08:00
shamoon	3788144484	sonar	2026-02-22 16:15:06 -08:00
shamoon	90da16f5d4	Update .mypy-baseline.txt	2026-02-22 16:15:06 -08:00
shamoon	26501800e4	Let LLM fix mypy stuff	2026-02-22 16:15:06 -08:00
shamoon	f03d8d1476	mypy stuff	2026-02-22 16:15:06 -08:00
shamoon	3a66ece118	Use in-memory channel layers in tests	2026-02-22 16:15:06 -08:00
shamoon	17295a963a	Make sure to use same date formatting in backend	2026-02-22 16:15:06 -08:00
shamoon	3ce4d3cfdd	Actually these are not Dates	2026-02-22 16:15:06 -08:00
shamoon	3d30bbbe48	Dont trigger notification for regular save "echoes"	2026-02-22 16:15:06 -08:00
shamoon	81049476d9	Queue updates to handle workflow triggering	2026-02-22 16:15:06 -08:00
shamoon	679738e610	Make scheduled trigger update	2026-02-22 16:15:06 -08:00
shamoon	d9f8862e1f	Fix test	2026-02-22 16:15:06 -08:00
shamoon	2863a32146	Actually use a modal	2026-02-22 16:15:06 -08:00
shamoon	d73be8bf43	Frontend handle this	2026-02-22 16:15:06 -08:00
shamoon	946e2367ca	Frontend service doc updated ws	2026-02-22 16:15:06 -08:00
shamoon	e19eddc078	Backend doc updated ws	2026-02-22 16:15:06 -08:00