Basis\Job\Module\Handle::run()

Complexity

Conditions	10
Paths	99

Size

Total Lines

71

Duplication

Lines	8
Ratio	11.27 %

Code Coverage

Tests	0
CRAP Score	110

Importance

Changes

0

<?php
    public function run(Application $app, Dispatcher $dispatcher, Event $event, Service $service)
    {
        $start = microtime(1);
        $subscription = $event->getSubscription();

        $patterns = [];
        foreach (array_keys($subscription) as $pattern) {
            if ($service->eventMatch($this->event, $pattern)) {
                $patterns[] = $pattern;
            }
        }

        if (!count($patterns)) {
            $service->unsubscribe($this->event);
            return $dispatcher->send('event.feedback', [
                'eventId' => $this->eventId,
                'service' => $service->getName(),
                'result' => [
                    'message' => 'no subscription'
                ],
            ]);
        }

        $this->get(Context::class)->event = $this->eventId;

        $parts = explode('.', $this->event);
        $action = array_pop($parts);
        $space = implode('.', $parts);

        $listeners = [];
        foreach ($patterns as $pattern) {
            foreach ($subscription[$pattern] as $listener) {
                if (!array_key_exists($listener, $listeners)) {
                    $listeners[$listener] = $app->get('Listener\\'.$listener);
                    $listeners[$listener]->event = $this->event;
                    $listeners[$listener]->eventId = $this->eventId;
                    $listeners[$listener]->context = $this->context;
                    $listeners[$listener]->space = $space;
                    $listeners[$listener]->action = $action;
                }
            }
        }


        $data = [];
        $issues = [];
        foreach ($listeners as $nick => $listener) {

This code seems to be duplicated across your project.

            try {
                $data[$nick] = $app->call([$listener, 'run']);
                $event->fireChanges($nick);
            } catch (Exception $e) {
                $issues[$nick] =  $e->getMessage();
            }
        }

        $result = [
            'data' => $data,
            'issues' => $issues,
            'time' => microtime(1) - $start,
        ];

        if ($this->sync) {

The property sync does not exist. Did you maybe forget to declare it?

            return $result;
        }

        $dispatcher->send('event.feedback', [
            'eventId' => $this->eventId,
            'service' => $service->getName(),
            'result' => $result
        ]);
    }
}