AshPowell\APAnalytics\Listeners\TrackAnalyticListener::handle()

Complexity

Conditions	10
Paths	60

Size

Total Lines	43
Code Lines	28

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

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

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

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

            try {
                if ($postEvent) {
                    foreach ($items as $object) {
                        $basename = strtolower(class_basename($object));

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

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

                        $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);
            } catch (\Exception $e) {
                Log::error('Error Logging Event', ['error' => $e->getMessage()]);
            }