Medianet-Tunisia / p-connector

src/Http/Guzzle.php

<?php

namespace MedianetDev\PConnector\Http;

use GuzzleHttp\Client;
use MedianetDev\PConnector\Http\Base\BaseHttp;

class Guzzle extends BaseHttp
{
    /**
     * @var \GuzzleHttp\Client
     *
     * The Guzzle http client instance
     */
    private $client;

    public function __construct($withAuth = true)
    {
        parent::__construct($withAuth);
        $this->client = new Client();
    }

    public function post(string $url, $data, string $profile, bool $withAuth, $headers = []): array
    {
        try {
            $payload = $this->prepareGuzzlePayload($profile, $withAuth, $headers);
            if ('array' === gettype($data)) {
                $payload[config('p-connector.profiles.'.$profile.'.request.post_data', config('p-connector.request.post_data', 'json'))] = $data;
            } else {
                $payload['body'] = $data;
            }

            return $this->parser($url, 'POST', $payload, $this->client->post($url, $payload));
        } catch (\GuzzleHttp\Exception\GuzzleException $e) {
            return $this->parser($url, 'POST', $payload, null, false, $e->getMessage());
        }
    }

    public function get(string $url, $data, string $profile, bool $withAuth, $headers = [], bool $withJson = false): array
    {
        try {
            $payload = $this->prepareGuzzlePayload($profile, $withAuth, $headers);
            if ('array' === gettype($data)) {
                if ($withJson) {
                    $payload['json'] = $data;
                } else {
                    $payload['query'] = $data;
                }
            } else {
                $payload['body'] = $data;
            }

            return $this->parser($url, 'GET', $payload, $this->client->get($url, $payload));
        } catch (\GuzzleHttp\Exception\GuzzleException $e) {
            return $this->parser($url, 'GET', $payload, null, false, $e->getMessage());
        }
    }

    public function put(string $url, $data, string $profile, bool $withAuth, $headers = []): array
    {
        try {
            $payload = $this->prepareGuzzlePayload($profile, $withAuth, $headers);
            if ('array' === gettype($data)) {
                $payload[config('p-connector.profiles.'.$profile.'.request.post_data', config('p-connector.request.post_data', 'json'))] = $data;
            } else {
                $payload['body'] = $data;
            }

            return $this->parser($url, 'PUT', $payload, $this->client->put($url, $payload));
        } catch (\GuzzleHttp\Exception\GuzzleException $e) {
            return $this->parser($url, 'PUT', $payload, null, false, $e->getMessage());
        }
    }

    public function patch(string $url, $data, string $profile, bool $withAuth, $headers = []): array
    {
        try {
            $payload = $this->prepareGuzzlePayload($profile, $withAuth, $headers);
            if ('array' === gettype($data)) {
                $payload[config('p-connector.profiles.'.$profile.'.request.post_data', config('p-connector.request.post_data', 'json'))] = $data;
            } else {
                $payload['body'] = $data;
            }

            return $this->parser($url, 'PATCH', $payload, $this->client->put($url, $payload));
        } catch (\GuzzleHttp\Exception\GuzzleException $e) {
            return $this->parser($url, 'PATCH', $payload, null, false, $e->getMessage());
        }
    }

    public function delete(string $url, $data, string $profile, bool $withAuth, $headers = []): array
    {
        try {
            $payload = $this->prepareGuzzlePayload($profile, $withAuth, $headers);
            if ('array' === gettype($data)) {
                $payload[config('p-connector.profiles.'.$profile.'.request.post_data', config('p-connector.request.post_data', 'json'))] = $data;
            } else {
                $payload['body'] = $data;
            }

            return $this->parser($url, 'DELETE', $payload, $this->client->delete($url, $payload));
        } catch (\GuzzleHttp\Exception\GuzzleException $e) {
            return $this->parser($url, 'DELETE', $payload, null, false, $e->getMessage());
        }
    }

    protected function parser(string $url, string $method, array $payload, $response, bool $status = true, ?string $errorMessage = null): array
    {
        $result['status'] = $status;

$result was never initialized. Although not strictly required by PHP, it is generally a good practice to add $result = array(); before regardless.

        $result['request'] = [
            'url' => $url,
            'method' => $method,
            'payload' => $payload,
        ];
        if (! is_null($response)) {
            $result['response'] = [
                'status_code' => $response->getStatusCode(),
                'headers' => $response->getHeaders(),
                'body' => $response->getBody()->getContents(),
            ];
        } else {
            $result['response'] = [
                'status_code' => 0,
                'headers' => [],
                'body' => '{}',
            ];
        }
        if (! is_null($errorMessage)) {
            $result['error_message'] = $errorMessage;
        }

        return $result;
    }

    /**
     * Build the guzzle payload.
     *
     * @param  string  $profile
     * @param  bool  $withAuth
     * @param  array  $headers
     * @return array
     */
    protected function prepareGuzzlePayload($profile, $withAuth, $headers)
    {
        $payload['headers'] = array_merge(config(

$payload was never initialized. Although not strictly required by PHP, it is generally a good practice to add $payload = array(); before regardless.

            'p-connector.profiles.'.$profile.'.request.headers',
            config('p-connector.request.headers', ['Accept' => 'application/json'])
        ), $headers);
        if ($withAuth) {
            $payload['headers'] = array_merge($payload['headers'], $this->authManager->getAuthenticationHeader($profile));
        }
        $payload['http_errors'] = config(
            'p-connector.profiles.'.$profile.'.request.http_errors',
            config('p-connector.request.http_errors', false)
        );
        $payload['connect_timeout'] = config(
            'p-connector.profiles.'.$profile.'.request.connect_timeout',
            config('p-connector.request.connect_timeout', 3)
        );
        $payload['timeout'] = config(
            'p-connector.profiles.'.$profile.'.request.timeout',
            config('p-connector.request.timeout', 3)
        );
        $payload['verify'] = config(
            'p-connector.profiles.'.$profile.'.request.verify',
            config('p-connector.request.verify', true)
        );

        return $payload;
    }
}