Em flush (#364)

* createSubscriberList

* ProcessQueueCommand

* Dispatch CampaignProcessorMessage for processing

* Fix tests

* Fix style

* CleanUpOldSessionTokens

* Move bounce processing into the Bounce folder

* delete/remove

* Remove hardcoded TatevikGrRssBundle mapping

* Fix configs

* Add sync

* Fix: DQL in MessageRepository.php

* PhpMD

* SubscriberBlacklistService, SubscriberBlacklistManager

* AdministratorManager

* BounceManager

* SendProcessManager

* TemplateManager

* SubscribePageManager

* Fix: tests

* BounceManager

* rest of flushes

* save

* fix test

* CouplingBetweenObjects 15

---------

Co-authored-by: Tatevik <tatevikg1@gmail.com>

Author: TatevikGr

config/PHPMD/rules.xml

@@ -45,7 +45,11 @@
     <rule ref="rulesets/design.xml/GotoStatement"/>
     <rule ref="rulesets/design.xml/NumberOfChildren"/>
     <rule ref="rulesets/design.xml/DepthOfInheritance"/>
-    <rule ref="rulesets/design.xml/CouplingBetweenObjects"/>
+    <rule ref="rulesets/design.xml/CouplingBetweenObjects">
+        <properties>
+            <property name="maximum" value="15"/>
+        </properties>
+    </rule>
     <rule ref="rulesets/design.xml/DevelopmentCodeFragment"/>
 
     <!-- rules from the "naming" rule set -->

config/doctrine.yml

@@ -17,12 +17,6 @@ doctrine:
     naming_strategy: doctrine.orm.naming_strategy.underscore
     auto_mapping: false
     mappings:
-      TatevikGrRssBundle:
-        is_bundle: false
-        type: attribute
-        dir: '%kernel.project_dir%/vendor/tatevikgr/rss-feed/src/Entity'
-        prefix: 'TatevikGr\RssFeedBundle\Entity'
-        alias: 'RssBundle'
       Identity:
         is_bundle: false
         type: attribute

config/packages/messenger.yaml

@@ -6,6 +6,7 @@ framework:
 
         transports:
             # https://symfony.com/doc/current/messenger.html#transport-configuration
+            sync: 'sync://'
             async_email:
                 dsn: '%env(MESSENGER_TRANSPORT_DSN)%'
                 options:
@@ -25,3 +26,8 @@ framework:
             # Route your messages to the transports
             'PhpList\Core\Domain\Messaging\Message\AsyncEmailMessage': async_email
             'PhpList\Core\Domain\Messaging\Message\SubscriberConfirmationMessage': async_email
+            'PhpList\Core\Domain\Messaging\Message\SubscriptionConfirmationMessage': async_email
+            'PhpList\Core\Domain\Messaging\Message\PasswordResetMessage': async_email
+            'PhpList\Core\Domain\Messaging\Message\CampaignProcessorMessage': async_email
+            'PhpList\Core\Domain\Messaging\Message\SyncCampaignProcessorMessage': sync
+

config/services/commands.yml

@@ -12,7 +12,7 @@ services:
     resource: '../../src/Domain/Identity/Command'
     tags: ['console.command']
 
-  PhpList\Core\Domain\Messaging\Command\ProcessBouncesCommand:
+  PhpList\Core\Bounce\Command\ProcessBouncesCommand:
     arguments:
       $protocolProcessors: !tagged_iterator 'phplist.bounce_protocol_processor'
 

config/services/managers.yml

@@ -80,7 +80,7 @@ services:
     autowire: true
     autoconfigure: true
 
-  PhpList\Core\Domain\Messaging\Service\Manager\BounceManager:
+  PhpList\Core\Bounce\Service\Manager\BounceManager:
     autowire: true
     autoconfigure: true
 

config/services/messenger.yml

@@ -1,6 +1,7 @@
 services:
     # Register message handlers for Symfony Messenger
     PhpList\Core\Domain\Messaging\MessageHandler\:
+        autowire: true
         resource: '../../src/Domain/Messaging/MessageHandler'
         tags: [ 'messenger.message_handler' ]
 
@@ -24,7 +25,7 @@ services:
             $passwordResetUrl: '%app.password_reset_url%'
 
     PhpList\Core\Domain\Messaging\MessageHandler\SubscriptionConfirmationMessageHandler:
-      autowire: true
-      autoconfigure: true
-      tags: [ 'messenger.message_handler' ]
+        autowire: true
+        autoconfigure: true
+        tags: [ 'messenger.message_handler' ]
 

config/services/processor.yml

@@ -4,18 +4,18 @@ services:
     autoconfigure: true
     public: false
 
-  PhpList\Core\Domain\Messaging\Service\Processor\PopBounceProcessor:
+  PhpList\Core\Bounce\Service\Processor\PopBounceProcessor:
     arguments:
       $host: '%imap_bounce.host%'
       $port: '%imap_bounce.port%'
       $mailboxNames: '%imap_bounce.mailbox_name%'
     tags: ['phplist.bounce_protocol_processor']
 
-  PhpList\Core\Domain\Messaging\Service\Processor\MboxBounceProcessor:
+  PhpList\Core\Bounce\Service\Processor\MboxBounceProcessor:
     tags: ['phplist.bounce_protocol_processor']
 
-  PhpList\Core\Domain\Messaging\Service\Processor\AdvancedBounceRulesProcessor: ~
+  PhpList\Core\Bounce\Service\Processor\AdvancedBounceRulesProcessor: ~
 
-  PhpList\Core\Domain\Messaging\Service\Processor\UnidentifiedBounceReprocessor: ~
+  PhpList\Core\Bounce\Service\Processor\UnidentifiedBounceReprocessor: ~
 
-  PhpList\Core\Domain\Messaging\Service\Processor\BounceDataProcessor: ~
+  PhpList\Core\Bounce\Service\Processor\BounceDataProcessor: ~

config/services/resolvers.yml

@@ -10,6 +10,6 @@ services:
     autowire: true
     autoconfigure: true
 
-  PhpList\Core\Domain\Messaging\Service\BounceActionResolver:
+  PhpList\Core\Bounce\Service\BounceActionResolver:
     arguments:
       - !tagged_iterator { tag: 'phplist.bounce_action_handler' }

config/services/services.yml

@@ -31,11 +31,6 @@ services:
     autoconfigure: true
     public: true
 
-  PhpList\Core\Domain\Messaging\Service\Processor\CampaignProcessor:
-    autowire: true
-    autoconfigure: true
-    public: true
-
   PhpList\Core\Domain\Messaging\Service\SendRateLimiter:
     autowire: true
     autoconfigure: true
@@ -52,7 +47,7 @@ services:
     autowire: true
     autoconfigure: true
 
-  PhpList\Core\Domain\Messaging\Service\ConsecutiveBounceHandler:
+  PhpList\Core\Bounce\Service\ConsecutiveBounceHandler:
     autowire: true
     autoconfigure: true
     arguments:
@@ -61,7 +56,7 @@ services:
 
   Webklex\PHPIMAP\ClientManager: ~
 
-  PhpList\Core\Domain\Messaging\Service\WebklexImapClientFactory:
+  PhpList\Core\Bounce\Service\WebklexImapClientFactory:
     autowire: true
     autoconfigure: true
     arguments:
@@ -78,34 +73,34 @@ services:
       $username: '%imap_bounce.email%'
       $password: '%imap_bounce.password%'
 
-  PhpList\Core\Domain\Messaging\Service\NativeBounceProcessingService:
+  PhpList\Core\Bounce\Service\NativeBounceProcessingService:
     autowire: true
     autoconfigure: true
     arguments:
       $purgeProcessed: '%imap_bounce.purge%'
       $purgeUnprocessed: '%imap_bounce.purge_unprocessed%'
 
-  PhpList\Core\Domain\Messaging\Service\WebklexBounceProcessingService:
+  PhpList\Core\Bounce\Service\WebklexBounceProcessingService:
     autowire: true
     autoconfigure: true
     arguments:
       $purgeProcessed: '%imap_bounce.purge%'
       $purgeUnprocessed: '%imap_bounce.purge_unprocessed%'
 
-  PhpList\Core\Domain\Messaging\Service\LockService:
+  PhpList\Core\Bounce\Service\LockService:
     autowire: true
     autoconfigure: true
 
-  PhpList\Core\Domain\Subscription\Service\SubscriberBlacklistService:
+  PhpList\Core\Bounce\Service\SubscriberBlacklistService:
     autowire: true
     autoconfigure: true
 
-  PhpList\Core\Domain\Messaging\Service\MessageParser:
+  PhpList\Core\Bounce\Service\MessageParser:
     autowire: true
     autoconfigure: true
 
   _instanceof:
-    PhpList\Core\Domain\Messaging\Service\Handler\BounceActionHandlerInterface:
+    PhpList\Core\Bounce\Service\Handler\BounceActionHandlerInterface:
       tags:
         - { name: 'phplist.bounce_action_handler' }
 

resources/translations/messages.en.xlf

@@ -726,6 +726,10 @@ Thank you.</target>
         <source>No data changed</source>
         <target>__No data changed</target>
       </trans-unit>
+      <trans-unit id="n7nf5lh" resname="Campaign not found or not in submitted status">
+        <source>Campaign not found or not in submitted status</source>
+        <target>__Campaign not found or not in submitted status</target>
+      </trans-unit>
     </body>
   </file>
 </xliff>