Merge signals

pyproject.toml

@@ -203,9 +203,6 @@ lint.per-file-ignores."docker/wait-for-redis.py" = [
 lint.per-file-ignores."src/documents/migrations/1012_fix_archive_files.py" = [
   "PTH",
 ] # TODO Enable & remove
-lint.per-file-ignores."src/documents/signals/handlers.py" = [
-  "PTH",
-] # TODO Enable & remove
 lint.per-file-ignores."src/documents/tests/test_consumer.py" = [
   "PTH",
 ] # TODO Enable & remove
@@ -257,6 +254,9 @@ lint.per-file-ignores."src/paperless/parsers.py" = [
 lint.per-file-ignores."src/paperless/settings.py" = [
   "PTH",
 ] # TODO Enable & remove
+lint.per-file-ignores."src/paperless/signals/handlers.py" = [
+  "PTH",
+] # TODO Enable & remove
 lint.per-file-ignores."src/paperless/views.py" = [
   "PTH",
 ] # TODO Enable & remove

src/documents/apps.py

@@ -8,16 +8,16 @@ class DocumentsConfig(AppConfig):
     verbose_name = _("Documents")
 
     def ready(self):
-        from documents.signals import document_consumption_finished
-        from documents.signals import document_updated
-        from documents.signals.handlers import add_inbox_tags
-        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 set_correspondent
-        from documents.signals.handlers import set_document_type
-        from documents.signals.handlers import set_storage_path
-        from documents.signals.handlers import set_tags
+        from paperless.signals import document_consumption_finished
+        from paperless.signals import document_updated
+        from paperless.signals.handlers import add_inbox_tags
+        from paperless.signals.handlers import add_to_index
+        from paperless.signals.handlers import run_workflows_added
+        from paperless.signals.handlers import run_workflows_updated
+        from paperless.signals.handlers import set_correspondent
+        from paperless.signals.handlers import set_document_type
+        from paperless.signals.handlers import set_storage_path
+        from paperless.signals.handlers import set_tags
 
         document_consumption_finished.connect(add_inbox_tags)
         document_consumption_finished.connect(set_correspondent)

src/documents/tests/test_api_documents.py

@@ -24,7 +24,6 @@ from guardian.shortcuts import assign_perm
 from rest_framework import status
 from rest_framework.test import APITestCase
 
-from documents.signals.handlers import run_workflows
 from documents.tests.utils import DirectoriesMixin
 from documents.tests.utils import DocumentConsumeDelayMixin
 from paperless.caching import CACHE_50_MINUTES
@@ -46,6 +45,7 @@ from paperless.models import Tag
 from paperless.models import Workflow
 from paperless.models import WorkflowAction
 from paperless.models import WorkflowTrigger
+from paperless.signals.handlers import run_workflows
 
 
 class TestDocumentApi(DirectoriesMixin, DocumentConsumeDelayMixin, APITestCase):

src/documents/tests/test_matchables.py

@@ -8,12 +8,12 @@ from django.contrib.auth.models import User
 from django.test import TestCase
 from django.test import override_settings
 
-from documents.signals import document_consumption_finished
 from paperless import matching
 from paperless.models import Correspondent
 from paperless.models import Document
 from paperless.models import DocumentType
 from paperless.models import Tag
+from paperless.signals import document_consumption_finished
 
 
 class _TestMatchingBase(TestCase):

src/documents/tests/test_task_signals.py

@@ -4,16 +4,16 @@ from unittest import mock
 import celery
 from django.test import TestCase
 
-from documents.signals.handlers import before_task_publish_handler
-from documents.signals.handlers import task_failure_handler
-from documents.signals.handlers import task_postrun_handler
-from documents.signals.handlers import task_prerun_handler
 from documents.tests.test_consumer import fake_magic_from_file
 from documents.tests.utils import DirectoriesMixin
 from paperless.data_models import ConsumableDocument
 from paperless.data_models import DocumentMetadataOverrides
 from paperless.data_models import DocumentSource
 from paperless.models import PaperlessTask
+from paperless.signals.handlers import before_task_publish_handler
+from paperless.signals.handlers import task_failure_handler
+from paperless.signals.handlers import task_postrun_handler
+from paperless.signals.handlers import task_prerun_handler
 
 
 @mock.patch("documents.consumer.magic.from_file", fake_magic_from_file)

src/documents/tests/test_workflows.py

@@ -14,14 +14,13 @@ from httpx import HTTPStatusError
 from pytest_httpx import HTTPXMock
 from rest_framework.test import APITestCase
 
-from documents.signals.handlers import run_workflows
-from documents.signals.handlers import send_webhook
+from paperless.signals.handlers import run_workflows
+from paperless.signals.handlers import send_webhook
 
 if TYPE_CHECKING:
     from django.db.models import QuerySet
 
 
-from documents.signals import document_consumption_finished
 from documents.tests.utils import DirectoriesMixin
 from documents.tests.utils import DummyProgressManager
 from documents.tests.utils import FileSystemAssertsMixin
@@ -44,6 +43,7 @@ from paperless.models import WorkflowActionEmail
 from paperless.models import WorkflowActionWebhook
 from paperless.models import WorkflowRun
 from paperless.models import WorkflowTrigger
+from paperless.signals import document_consumption_finished
 from paperless_mail.models import MailAccount
 from paperless_mail.models import MailRule
 

src/paperless/adapter.py

@@ -11,7 +11,7 @@ from django.forms import ValidationError
 from django.urls import reverse
 
 from paperless.models import Document
-from paperless.signals import handle_social_account_updated
+from paperless.signals.signals import handle_social_account_updated
 
 logger = logging.getLogger("paperless.auth")
 

src/paperless/apps.py

@@ -1,8 +1,8 @@
 from django.apps import AppConfig
 from django.utils.translation import gettext_lazy as _
 
-from paperless.signals import handle_failed_login
-from paperless.signals import handle_social_account_updated
+from paperless.signals.signals import handle_failed_login
+from paperless.signals.signals import handle_social_account_updated
 
 
 class PaperlessConfig(AppConfig):

src/paperless/checks.py

@@ -14,7 +14,7 @@ from django.db import connections
 from django.db.utils import OperationalError
 from django.db.utils import ProgrammingError
 
-from documents.signals import document_consumer_declaration
+from paperless.signals import document_consumer_declaration
 from paperless.templating.utils import convert_format_str_to_template_format
 
 exists_message = "{} is set but doesn't exist."

src/paperless/consumer.py

@@ -15,9 +15,6 @@ from django.utils import timezone
 from filelock import FileLock
 from rest_framework.reverse import reverse
 
-from documents.signals import document_consumption_finished
-from documents.signals import document_consumption_started
-from documents.signals.handlers import run_workflows
 from paperless.classifier import load_classifier
 from paperless.data_models import ConsumableDocument
 from paperless.data_models import DocumentMetadataOverrides
@@ -43,6 +40,9 @@ from paperless.plugins.base import NoCleanupPluginMixin
 from paperless.plugins.base import NoSetupPluginMixin
 from paperless.plugins.helpers import ProgressManager
 from paperless.plugins.helpers import ProgressStatusOptions
+from paperless.signals import document_consumption_finished
+from paperless.signals import document_consumption_started
+from paperless.signals.handlers import run_workflows
 from paperless.templating.workflows import parse_w_workflow_placeholders
 from paperless.utils import copy_basic_file_stats
 from paperless.utils import copy_file_with_basic_stats

src/paperless/management/commands/document_importer.py

@@ -21,8 +21,6 @@ from django.db.models.signals import m2m_changed
 from django.db.models.signals import post_save
 from filelock import FileLock
 
-from documents.signals.handlers import check_paths_and_prune_custom_fields
-from documents.signals.handlers import update_filename_and_move_files
 from paperless import version
 from paperless.file_handling import create_source_path_directory
 from paperless.management.commands.mixins import CryptMixin
@@ -38,6 +36,8 @@ from paperless.settings import EXPORTER_ARCHIVE_NAME
 from paperless.settings import EXPORTER_CRYPTO_SETTINGS_NAME
 from paperless.settings import EXPORTER_FILE_NAME
 from paperless.settings import EXPORTER_THUMBNAIL_NAME
+from paperless.signals.handlers import check_paths_and_prune_custom_fields
+from paperless.signals.handlers import update_filename_and_move_files
 from paperless.utils import copy_file_with_basic_stats
 
 if settings.AUDIT_LOG_ENABLED:

src/paperless/management/commands/document_retagger.py

@@ -3,13 +3,13 @@ import logging
 import tqdm
 from django.core.management.base import BaseCommand
 
-from documents.signals.handlers import set_correspondent
-from documents.signals.handlers import set_document_type
-from documents.signals.handlers import set_storage_path
-from documents.signals.handlers import set_tags
 from paperless.classifier import load_classifier
 from paperless.management.commands.mixins import ProgressBarMixin
 from paperless.models import Document
+from paperless.signals.handlers import set_correspondent
+from paperless.signals.handlers import set_document_type
+from paperless.signals.handlers import set_storage_path
+from paperless.signals.handlers import set_tags
 
 logger = logging.getLogger("paperless.management.retagger")
 

src/paperless/parsers.py

@@ -15,8 +15,8 @@ from typing import TYPE_CHECKING
 from django.conf import settings
 from django.utils import timezone
 
-from documents.signals import document_consumer_declaration
 from paperless.loggers import LoggingMixin
+from paperless.signals import document_consumer_declaration
 from paperless.utils import copy_file_with_basic_stats
 from paperless.utils import run_subprocess
 

src/paperless/tasks.py

@@ -19,9 +19,6 @@ from django.utils import timezone
 from filelock import FileLock
 from whoosh.writing import AsyncWriter
 
-from documents.signals import document_updated
-from documents.signals.handlers import cleanup_document_deletion
-from documents.signals.handlers import run_workflows
 from paperless import index
 from paperless import sanity_checker
 from paperless.barcodes import BarcodePlugin
@@ -52,6 +49,9 @@ from paperless.plugins.base import ProgressManager
 from paperless.plugins.base import StopConsumeTaskError
 from paperless.plugins.helpers import ProgressStatusOptions
 from paperless.sanity_checker import SanityCheckFailedException
+from paperless.signals import document_updated
+from paperless.signals.handlers import cleanup_document_deletion
+from paperless.signals.handlers import run_workflows
 
 if settings.AUDIT_LOG_ENABLED:
     from auditlog.models import LogEntry

src/paperless/tests/test_signals.py

@@ -6,8 +6,8 @@ from django.http import HttpRequest
 from django.test import TestCase
 from django.test import override_settings
 
-from paperless.signals import handle_failed_login
-from paperless.signals import handle_social_account_updated
+from paperless.signals.signals import handle_failed_login
+from paperless.signals.signals import handle_social_account_updated
 
 
 class TestFailedLoginLogging(TestCase):

src/paperless/views.py

@@ -89,7 +89,6 @@ from rest_framework.viewsets import ModelViewSet
 from rest_framework.viewsets import ReadOnlyModelViewSet
 from rest_framework.viewsets import ViewSet
 
-from documents.signals import document_updated
 from paperless import bulk_edit
 from paperless import index
 from paperless import version
@@ -188,6 +187,7 @@ from paperless.serialisers import UserSerializer
 from paperless.serialisers import WorkflowActionSerializer
 from paperless.serialisers import WorkflowSerializer
 from paperless.serialisers import WorkflowTriggerSerializer
+from paperless.signals import document_updated
 from paperless.tasks import consume_file
 from paperless.tasks import empty_trash
 from paperless.tasks import index_optimize

src/paperless_mail/apps.py

@@ -11,7 +11,7 @@ class PaperlessMailConfig(AppConfig):
     verbose_name = _("Paperless mail")
 
     def ready(self):
-        from documents.signals import document_consumer_declaration
+        from paperless.signals import document_consumer_declaration
 
         if settings.TIKA_ENABLED:
             document_consumer_declaration.connect(mail_consumer_declaration)

src/paperless_tesseract/apps.py

@@ -7,7 +7,7 @@ class PaperlessTesseractConfig(AppConfig):
     name = "paperless_tesseract"
 
     def ready(self):
-        from documents.signals import document_consumer_declaration
+        from paperless.signals import document_consumer_declaration
 
         document_consumer_declaration.connect(tesseract_consumer_declaration)
 

src/paperless_text/apps.py

@@ -7,7 +7,7 @@ class PaperlessTextConfig(AppConfig):
     name = "paperless_text"
 
     def ready(self):
-        from documents.signals import document_consumer_declaration
+        from paperless.signals import document_consumer_declaration
 
         document_consumer_declaration.connect(text_consumer_declaration)
 

src/paperless_tika/apps.py

@@ -8,7 +8,7 @@ class PaperlessTikaConfig(AppConfig):
     name = "paperless_tika"
 
     def ready(self):
-        from documents.signals import document_consumer_declaration
+        from paperless.signals import document_consumer_declaration
 
         if settings.TIKA_ENABLED:
             document_consumer_declaration.connect(tika_consumer_declaration)