Beachcasts\Airtable\Request\TableRequest

Complexity

Total Complexity

9

Size/Duplication

Total Lines	131
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	3
Bugs	0	Features	1

5 Methods

Rating	Name	Duplication	Size	Complexity
A	readRecords()	0	10	1
A	createRecords()	0	36	3
A	updateRecords()	0	38	2
A	listRecords()	0	10	1
A	deleteRecords()	0	19	2

<?php

declare(strict_types=1);

namespace Beachcasts\Airtable\Request;

use Assert\Assert;
use GuzzleHttp\Psr7\Request;

class TableRequest extends Request
{
    public static function createRecords(string $tableName, array $records): Request
    {
        Assert::that($tableName)
            ->notEmpty('Table name must not be empty');

        Assert::that($records)
            ->notEmpty('Records must not be empty');

        // we want to make sure we don't pass a k-v array, but numeric indexed
        // as api expects records to be of
        $records = array_values($records);

        foreach ($records as $idx => &$record) {
            Assert::that($record)
                ->keyExists('fields', sprintf('Record[%d] should contain a "fields" entry', $idx));

            Assert::that($record['fields'])
                ->isArray(sprintf('Record[%d] "fields" should be Array', $idx));

            if (empty($record['fields'])) {
                $record['fields'] = new \stdClass(); // API requires fields to be object
            } else {
                Assert::thatAll(array_keys($record['fields']))
                    ->string('All "fields" must be string-keyed');
            }
        }

        return new self(
            'POST',
            $tableName,
            [
                'Content-Type' => 'application/json',
            ],
            json_encode(
                [
                    'records' => $records
                ]
            )
        );
    }

    public static function readRecords(string $tableName, string $recordId): Request
    {
        Assert::that($tableName)
            ->notEmpty('Table name must not be empty');
        Assert::that($recordId)
            ->notEmpty('Record Id must not be empty');

        return new self(
            'GET',
            $tableName . '/' . $recordId
        );
    }

    public static function updateRecords(string $tableName, array $records, string $type): Request
    {
        Assert::that($tableName)
            ->notEmpty('Table name must not be empty');

        Assert::that($records)
            ->notEmpty('Records must not be empty');

        Assert::that(strtoupper($type))
            ->inArray(['PUT', 'PATCH'], 'Update type should be either PATCH or PUT');

        // we want to make sure we don't pass a k-v array, but numeric indexed
        // as api expects records to be of
        $records = array_values($records);

        foreach ($records as $idx => $record) {
            Assert::that($record)
                ->keyExists('id', sprintf('Record[%d] requires an "id" entry', $idx))
                ->notEmptyKey('id', sprintf('Record[%d] requires "id" to not be empty', $idx))
                ->keyExists('fields', sprintf('Record[%d] should contain a "fields" entry', $idx));

            Assert::that($record['fields'])
                ->isArray(sprintf('Record[%d] "fields" should be Array', $idx))
                ->notEmpty(sprintf('Record[%d] "fields" should not be empty', $idx));

            Assert::thatAll(array_keys($record['fields']))
                ->string(sprintf('Record[%d] "fields" should be string-keyed', $idx));
        }

        return new self(
            strtoupper($type),
            $tableName,
            [
                'Content-Type' => 'application/json',
            ],
            json_encode(
                [
                    'records' => $records
                ]
            )
        );
    }

    public static function deleteRecords(string $tableName, array $records): Request
    {
        Assert::that($tableName)
            ->notEmpty('Table name must not be empty');

        Assert::that($records)
            ->notEmpty('Records must not be empty');

        $params = [];

        $i = 0;
        foreach ($records as $record) {
            $params['records'][] = $record[$i]['id'];
            $i++;
        }

        return new self(
            'DELETE',
            $tableName . '?' . http_build_query($params)
        );
    }

    public static function listRecords(string $tableName, array $params)
    {
        Assert::that($tableName)
            ->notEmpty('Table name must not be empty');

        $queryString = http_build_query($params);

        return new self(
            'GET',
            $tableName . '?' . $queryString
        );
    }
}