Tapp\Airtable\Api\AirtableApiClient

Complexity

Total Complexity

15

Size/Duplication

Total Lines	134
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes

0

12 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	buildClient()	0	10	1
A	get()	0	6	1
A	getAllPages()	0	15	1
A	delete()	0	6	1
A	responseToJson()	0	6	1
A	jsonToObject()	0	10	2
A	jsonToArray()	0	10	2
A	getEndpointUrl()	0	19	2
A	post()	0	8	1
A	put()	0	8	1
A	patch()	0	8	1

<?php

namespace Tapp\Airtable\Api;

use GuzzleHttp\Client;
use Illuminate\Support\Str;

class AirtableApiClient implements ApiClient
{
    private $client;

    private $base;
    private $table;

    private $pageSize = 100;
    private $maxRecords = 100;

    public function __construct($base, $table, $access_token)
    {
        $this->base = $base;
        $this->table = $table;
        $this->client = $this->buildClient($access_token);
    }

    private function buildClient($access_token)
    {
        return new Client([
            'base_uri' => 'https://api.airtable.com',
            'headers' => [
                'Authorization' => "Bearer {$access_token}",
                'content-type' => 'application/json',
            ],
        ]);
    }

    public function get(string $id = null)
    {
        $url = $this->getEndpointUrl($id);

        return $this->jsonToObject($this->client->get($url));
    }

    public function getAllPages()
    {
        $url = $this->getEndpointUrl();

        $response = $this->client->get($url, [
            'query' => [
                'pageSize' => $this->pageSize,
                'maxRecords' => $this->maxRecords,
            ],
        ]);

        //TODO: loop through offset to get more than one page when more than 100 records exist

        return $this->jsonToObject($response);
    }

    public function post($contents = null)
    {
        $url = $this->getEndpointUrl();

        $params = ['json' => ['fields' => (object) $contents]];

        return $this->jsonToObject($this->client->post($url, $params));
    }

    public function put(string $id, $contents = null)
    {
        $url = $this->getEndpointUrl($id);

        $params = ['json' => ['fields' => (object) $contents]];

        return $this->jsonToObject($this->client->put($url, $params));
    }

    public function patch(string $id, $contents = null)
    {
        $url = $this->getEndpointUrl($id);

        $params = ['json' => ['fields' => (object) $contents]];

        return $this->jsonToObject($this->client->patch($url, $params));
    }

    public function delete(string $id)
    {
        $url = $this->getEndpointUrl($id);

        return $this->jsonToObject($this->client->delete($url));
    }

    public function responseToJson($response)
    {
        $body = (string) $response->getBody();

        return $body;
    }

    public function jsonToObject($response)
    {
        $body = (string) $response->getBody();

        if ($body === '') {
            return collect([]);
        }

        return collect(json_decode($body));
    }

    public function jsonToArray($response)
    {
        $body = (string) $response->getBody();

        if ($body === '') {
            return [];
        }

        return json_decode($body, true);
    }

    protected function getEndpointUrl(?string $id = null): string
    {
        if ($id) {
            $url = '/v0/?/?/?';

            return Str::replaceArray('?', [
                $this->base,
                $this->table,
                $id,
            ], $url);
        }

        $url = '/v0/?/?';

        return Str::replaceArray('?', [
            $this->base,
            $this->table,
        ], $url);
    }
}