Anomaly\Streams\Platform\Message\MessageBag

Complexity

Total Complexity

12

Size/Duplication

Total Lines	143
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes	1
Bugs	0	Features	0

10 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	merge()	0	16	3
A	has()	0	4	1
A	get()	0	4	1
A	pull()	0	4	1
A	error()	0	6	1
A	info()	0	6	1
A	success()	0	6	1
A	warning()	0	6	1
A	flush()	0	9	1

<?php namespace Anomaly\Streams\Platform\Message;

use Illuminate\Session\Store;

/**
 * Class MessageBag
 *
 * @link          http://anomaly.is/streams-platform
 * @author        AnomalyLabs, Inc. <hello@anomaly.is>
 * @author        Ryan Thompson <ryan@anomaly.is>
 * @package       Anomaly\Streams\Platform\MessageBag
 */
class MessageBag
{

    /**
     * The session store.
     *
     * @var Store
     */
    protected $session;

    /**
     * Create a new MessageBag instance.
     *
     * @param Store $session
     */
    public function __construct(Store $session)
    {
        $this->session = $session;
    }

    /**
     * Merge a message onto the session.
     *
     * @param $type
     * @param $message
     */
    protected function merge($type, $message)
    {
        $messages = $this->session->get($type, []);

        if (is_array($message)) {
            $messages = array_merge($messages, $message);
        }

        if (is_string($message)) {
            array_push($messages, $message);
        }

        $messages = array_unique($messages);

        $this->session->set($type, $messages);
    }

    /**
     * Return whether messages exist.
     *
     * @param $type
     * @return bool
     */
    public function has($type)
    {
        return $this->session->has($type);
    }

    /**
     * Get messages.
     *
     * @param $type
     * @return bool
     */
    public function get($type)
    {
        return $this->session->get($type);
    }

    /**
     * Pull the messages.
     *
     * @param $type
     * @return array
     */
    public function pull($type)
    {
        return $this->session->pull($type);
    }

    /**
     * Add an error message.
     *
     * @param $message
     * @return $this
     */
    public function error($message)
    {
        $this->merge(__FUNCTION__, $message);

        return $this;
    }

    /**
     * Add an info message.
     *
     * @param $message
     * @return $this
     */
    public function info($message)
    {
        $this->merge(__FUNCTION__, $message);

        return $this;
    }

    /**
     * Add a success message.
     *
     * @param $message
     * @return $this
     */
    public function success($message)
    {
        $this->merge(__FUNCTION__, $message);

        return $this;
    }

    /**
     * Add a warning message.
     *
     * @param $message
     * @return $this
     */
    public function warning($message)
    {
        $this->merge(__FUNCTION__, $message);

        return $this;
    }

    /**
     * Flush the messages.
     *
     * @return $this
     */
    public function flush()
    {
        $this->session->forget('info');
        $this->session->forget('error');
        $this->session->forget('success');
        $this->session->forget('warning');

        return $this;
    }
}