always calling item pushed on stale handler

Author: samnotsowise

src/Commands/PushStaleToCyclopsCommand.php

@@ -9,8 +9,8 @@ abstract class PushStaleToCyclopsCommand extends PushStateToCyclopsCommand
     final function executeUseCase()
     {
         $pushUseCase = new PushStaleToCyclopsUseCase($this->getService());
-        $pushUseCase->execute($this->getList(), $this->onCustomerCreated());
+        $pushUseCase->execute($this->getList(), $this->getCustomerPushedHandler());
     }
 
-    abstract protected function onCustomerCreated(): callable;
+    abstract protected function getCustomerPushedHandler(): callable;
 }

src/UseCases/PushStaleToCyclopsUseCase.php

@@ -18,23 +18,18 @@ public function __construct(CyclopsService $cyclopsService)
         $this->cyclopsService = $cyclopsService;
     }
 
-    public function execute(CyclopsCustomerListEntity $list, callable $onCustomerCreated = null)
+    public function execute(CyclopsCustomerListEntity $list, callable $onItemPushed)
     {
         foreach ($list->items as $item) {
             try {
                 $this->cyclopsService->setBrandOptInStatus($item);
-
-                if ($onCustomerCreated !== null) {
-                    $onCustomerCreated($item);
-                }
+                $onItemPushed($item, false);
             } catch (CustomerNotFoundException $exception) {
                 $customer = $this->cyclopsService->loadCustomer($item->identity);
                 $customer->brandOptIn = $item->brandOptIn;
                 $this->cyclopsService->setBrandOptInStatus($customer);
 
-                if ($onCustomerCreated !== null) {
-                    $onCustomerCreated($customer);
-                }
+                $onItemPushed($customer, true);
             }
         }
     }