AshPowell\APAnalytics\Jobs\Track::handle()

Complexity

Conditions	14
Paths	840

Size

Total Lines	56
Code Lines	36

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public function handle()
    {
        $connection = $this->mongodb_connection;
        $collection = $this->collection;
        $items      = $this->items;
        $userId     = $this->userId;
        $params     = $this->params;
        $type       = $this->type;

        $valid = ($items instanceof Collection) ? $items->count() : ($items instanceof Model) ? 1 : $type != 'update' ? count($items) : 1;

        if ($valid) {
            $collection = str_plural($collection);
            $items      = $type == 'update' ? $items : array_wrap(($items instanceof Paginator || $items instanceof LengthAwarePaginator) ? $items->items() : $items);
            $postEvent  = in_array($collection, config('apanalytics.format_collections'));
            $event      = $postEvent || $type == 'update' ? [] : $this->addExtraEventData($items, $userId, $params);

            try {
                if ($type == 'insert') {
                    if ($postEvent) {
                        foreach ($items as $item) {
                            $basename = strtolower(class_basename($item));

                            $data = [
                                $basename => [
                                    'id'   => $item->id ?? null,
                                    'type' => $item->type ?? null,
                                ],
                                'business' => [
                                    'id' => $item->business->id ?? null,
                                ],
                            ];

                            // Add Extra Stuff
                            $data = $this->addExtraEventData($data, $userId, $params);

                            event(new AnalyticTracked($collection, $basename, $data));

                            $event[] = $data;
                        }
                    }

                    return DB::connection($connection)
                        ->collection($collection)

The method collection() does not exist on Illuminate\Database\ConnectionInterface. It seems like you code against a sub-type of Illuminate\Database\ConnectionInterface such as Jenssegers\Mongodb\Connection.

                        ->insert($event);
                }

                // Type is update
                $basename = strtolower(str_singular($collection));

                return DB::connection($connection)
                        ->collection($collection)
                        ->where("{$basename}_id", $items)
                        ->update($params);
            } catch (\Exception $e) {
                Log::error('Error Logging Event', ['error' => $e->getMessage()]);
            }