MedianetDev\PConnector\AuthManager

Complexity

Total Complexity

39

Size/Duplication

Total Lines	190
Duplicated Lines	0 %

Importance

Changes	10
Bugs	2	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	getAuthenticationHeader()	0	18	4
B	deleteTokenFor()	0	24	8
C	getToken()	0	38	16
B	loginToGateway()	0	63	10

<?php

namespace MedianetDev\PConnector;

use InvalidArgumentException;

class AuthManager
{
    /**
     * @var \MedianetDev\PConnector\Contracts\Http
     *
     * The http client
     */
    private $httpClient;

    public function __construct()
    {
        $httpClient = config('p-connector.http_client');
        $this->httpClient = new $httpClient(false);
    }

    /**
     * Delete token for a profile.
     *
     * @param  string  $profile
     * @return void
     */
    public static function deleteTokenFor($profile)
    {
        if ('basic' !== config('p-connector.profiles.'.$profile.'.auth.auth_method', config('p-connector.auth.auth_method', 'basic'))) {
            if (config('p-connector.profiles.'.$profile.'.session')) {
                if (session()->has('p-connector.session_'.$profile)) {
                    $value = session()->get('p-connector.session_'.$profile);
                    $value['token'] = null;

                    session()->put(['p-connector.session_'.$profile => $value]);
                }
                session()->save();
            } elseif (config('p-connector.session')) {
                if (session()->has(config('p-connector.session_name'))) {
                    foreach (session()->get(config('p-connector.session_name')) as $key => $value) {
                        if ($value['gateway_profile'] === $profile) {
                            $value['token'] = null;
                        }
                    }
                }
                session()->save();
            } else {
                app('db')->table(config('p-connector.table', 'p_connector'))->updateOrInsert(
                    ['gateway_profile' => $profile],
                    ['token' => null, 'updated_at' => date('Y-m-d H:i:s')]
                );
            }
        }
    }

    /**
     * Get the authentication header for a profile.
     *
     * @param  string  $profile
     * @return array
     */
    public function getAuthenticationHeader($profile)
    {
        $token = $this->getToken($profile);
        $authMethod = config('p-connector.profiles.'.$profile.'.auth.auth_method', config('p-connector.auth.auth_method', 'basic'));

        switch ($authMethod) {
            case 'api_key':
                return [config('p-connector.profiles.'.$profile.'.auth.api_key', config(
                    'p-connector.auth.api_key',
                    'X-AUTH-TOKEN'
                )) => $token];
            case 'basic':
                return ['Authorization' => 'Basic '.$token];
            case 'bearer':
                return ['Authorization' => 'Bearer '.$token];

            default:
                throw new InvalidArgumentException('Invalid method "'.$authMethod.'".');
        }
    }

    /**
     * get access token from database.
     *
     * @return string
     */
    private function getToken($profile)
    {
        if ('basic' === config('p-connector.profiles.'.$profile.'.auth.auth_method', config('p-connector.auth.auth_method', 'basic'))) {
            $auth = config('p-connector.profiles.'.$profile.'.auth.credentials', config('p-connector.auth.credentials', []));
            if (! array_key_exists('username', $auth) || ! array_key_exists('password', $auth)) {
                throw new InvalidArgumentException("config('p-connector.profiles.$profile.auth.credentials') array must have a username and password keys.");
            }

            return base64_encode($auth['username'].':'.$auth['password']);
        }

        if (config('p-connector.profiles.'.$profile.'.session')) {
            if (session()->has('p-connector.session_'.$profile)) {
                $token = session()->get('p-connector.session_'.$profile);

                if ($token && ! empty($token['token'])) {
                    return $token['token'];
                }
            }
        } elseif (config('p-connector.session')) {
            if (session()->has(config('p-connector.session_name'))) {
                foreach (session()->get(config('p-connector.session_name')) as $token) {
                    if ($token['gateway_profile'] === $profile) {
                        if ($token && ! empty($token['token'])) {
                            return $token['token'];
                        }
                    }
                }
            }
        } else {
            $token = app('db')->table(config('p-connector.table', 'p_connector'))->where('gateway_profile', $profile)->first();

            if ($token && ! empty($token->token)) {
                return $token->token;
            }
        }

        return $this->loginToGateway($profile);
    }

    /**
     * Send request to login to the gateway, save the received token and return it.
     *
     * @return string
     */
    private function loginToGateway($profile)
    {
        $result = $this->httpClient->send(
            build_url(config('p-connector.profiles.'.$profile.'.auth.login_path', config('p-connector.auth.login_path', 'login')), $profile),
            config('p-connector.profiles.'.$profile.'.auth.credentials', config('p-connector.auth.credentials', [])),
            strtoupper(config('p-connector.profiles.'.$profile.'.auth.login_http_method', config('p-connector.auth.login_http_method', 'POST'))),
            $profile,
            false,
            config('p-connector.profiles.'.$profile.'.auth.headers', config('p-connector.auth.headers', [])),
        );

        if ($result['status'] && in_array($result['response']['status_code'], config('p-connector.profiles.'.$profile.'.auth.success_login_code', config('p-connector.auth.success_login_code', [])))) {
            $token = _get(json_decode($result['response']['body']), explode('.', config('p-connector.profiles.'.$profile.'.auth.token_path', config('p-connector.auth.token_path', 'token'))), '');
            if ('string' !== gettype($token)) {
                throw new InvalidArgumentException('The returned token is not of type string (type: "'.gettype($token).'").');
            }

            if (config('p-connector.profiles.'.$profile.'.session')) {
                $data = [
                    'gateway_profile' => $profile,
                    'token' => $token,
                ];

                session()->put(['p-connector.session_'.$profile => $data]);

                session()->save();
            } elseif (config('p-connector.session')) {
                $data = [
                    'gateway_profile' => $profile,
                    'token' => $token,
                ];

                if (session()->has(config('p-connector.session_name'))) {
                    $index = -1;
                    foreach (session()->get(config('p-connector.session_name')) as $key => $value) {
                        if ($value['gateway_profile'] === $profile) {
                            $index = $key;
                            break;
                        }
                    }
                    if ($index != -1) {
                        session()->get(config('p-connector.session_name'))[$index] = $token;
                    } else {
                        session()->push(config('p-connector.session_name'), $data);
                    }
                } else {
                    session()->put([
                        config('p-connector.session_name') => [$data],
                    ]);
                }

                session()->save();
            } else {
                app('db')->table(config('p-connector.table', 'p_connector'))->updateOrInsert(
                    ['gateway_profile' => $profile],
                    ['token' => $token, 'updated_at' => date('Y-m-d H:i:s')]
                );
            }

            return $token;
        }

        return null;
    }
}