GetStream\Doctrine\ModelListener

Complexity

Total Complexity

4

Size/Duplication

Total Lines	56
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	createActivity()	0	10	1
A	activityCreated()	0	7	1
A	activityDeleting()	0	5	1
A	__construct()	0	3	1

<?php

namespace GetStream\Doctrine;

use Doctrine\ORM\Mapping as ORM;
use GetStream\Doctrine\Activity;

class ModelListener
{
    /**
     * @var FeedManagerInterface
     */
    private $feedManager;

    /**
     * @param FeedManagerInterface $feedManager
     */
    public function __construct(FeedManagerInterface $feedManager)
    {
        $this->feedManager = $feedManager;
    }

    /**
     * @ORM\PostPersist
     *
     * @param ActivityInterface $instance
     */
    public function activityCreated(ActivityInterface $instance)
    {
        $activity = $this->createActivity($instance);

        $this->feedManager
            ->getUserFeed($instance->activityActorId())
            ->addActivity($activity);
    }

    /**
     * @ORM\PreRemove
     *
     * @param ActivityInterface $instance
     */
    public function activityDeleting(ActivityInterface $instance)
    {
        $this->feedManager
            ->getUserFeed($instance->activityActorId())
            ->removeActivity($instance->activityForeignId(), true);
    }

    /**
     * @param ActivityInterface $instance
     *
     * @return array
     */
    private function createActivity(ActivityInterface $instance)
    {
        return array_merge([
            'actor' => $instance->activityActor(),
            'verb' => $instance->activityVerb(),
            'object' => $instance->activityObject(),
            'foreign_id' => $instance->activityForeignId(),
            'time' => $instance->activityTime()->format(DATE_ISO8601),
            'to' => $instance->activityNotify(),
        ], $instance->activityExtraData());
    }
}