Spinen\Discourse\Listeners\LogoutDiscourseUser

Complexity

Total Complexity

6

Size/Duplication

Total Lines	76
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	8
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	handle()	0	36	5

<?php

namespace Spinen\Discourse\Listeners;

use GuzzleHttp\Client;
use GuzzleHttp\Exception\BadResponseException;
use Illuminate\Contracts\Config\Repository;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Support\Facades\Log;
use Symfony\Component\HttpKernel\Log\Logger;

/**
 * Class LogoutDiscourseUser
 *
 * Send a Logout request to Discourse for the corresponding Laravel User.
 *
 * @package Spinen\Discourse\Listeners
 */
class LogoutDiscourseUser implements ShouldQueue
{
    /**
     * @var Client
     */
    public $client;

    /**
     * @var Repository
     */
    public $config_repository;

    /**
     * @var Logger
     */
    public $logger;

    /**
     * Create the event listener.
     *
     * @param Client $client
     * @param Repository $config_repository
     * @param Logger $logger
     *
     * @return void
     */
    public function __construct(Client $client, Repository $config_repository, Logger $logger)
    {
        $this->client = $client;
        $this->config_repository = $config_repository;
        $this->logger = $logger;
    }

    /**
     * Handle the event.
     *
     * @param mixed $event
     *
     * @return void
     */
    public function handle($event)
    {
        if (!$event->user) {
            return;
        }

        $configs = [
            'base_uri' => $this->config_repository->get('services.discourse.url'),
            'headers'  => [
                'Api-Key'      => $this->config_repository->get('services.discourse.api.key'),
                'Api-Username' => $this->config_repository->get('services.discourse.api.user'),
            ],
        ];

        try {
            // Get Discourse user to match this one, and send a Logout request to Discourse and get the response
            $response = $this->client->get("users/by-external/{$event->user->id}.json", $configs);
        } catch (BadResponseException $e) {
            $response = $e->getResponse();
        }

        if ($response->getStatusCode() !== 200) {
            $this->logger->error(
                "When getting user {$event->user->id} Discourse returned status code {$response->getStatusCode()}",
                ['reason' => $response->getReasonPhrase()]
            );
            return;
        }

        $user = json_decode($response->getBody())->user;
        $response = $this->client->post("admin/users/{$user->id}/log_out", $configs);

        if ($response->getStatusCode() !== 200) {
            $this->logger->notice(
                "When logging out user {$event->user->id} Discourse returned status code {$response->getStatusCode()}:",
                ['reason' => $response->getReasonPhrase()]
            );
        }
    }
}