MartinGeorgiev\Utils\PostgresJsonToPHPArrayTransformer

Complexity

Total Complexity

8

Size/Duplication

Total Lines	46
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes	1
Bugs	1	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	transformPostgresJsonEncodedValueToPHPValue()	0	7	2
A	transformPostgresArrayToPHPArray()	0	13	3
A	transformPostgresJsonEncodedValueToPHPArray()	0	11	3

<?php

declare(strict_types=1);

namespace MartinGeorgiev\Utils;

use MartinGeorgiev\Doctrine\DBAL\Types\Exceptions\InvalidJsonArrayItemForPHPException;
use MartinGeorgiev\Doctrine\DBAL\Types\Exceptions\InvalidJsonItemForPHPException;

/**
 * Handles transformation from PostgreSQL JSON(B) values to PHP values.
 *
 * @since 3.0
 *
 * @author Martin Georgiev <martin.georgiev@gmail.com>
 */
class PostgresJsonToPHPArrayTransformer
{
    private const POSTGRESQL_EMPTY_ARRAY = '{}';

    public static function transformPostgresArrayToPHPArray(string $postgresValue): array
    {
        if ($postgresValue === self::POSTGRESQL_EMPTY_ARRAY) {
            return [];
        }

        $trimmedPostgresArray = \mb_substr($postgresValue, 2, -2);
        $phpArray = \explode('},{', $trimmedPostgresArray);
        foreach ($phpArray as &$item) {
            $item = '{'.$item.'}';
        }

        return $phpArray;
    }

    /**
     * @throws InvalidJsonArrayItemForPHPException When the PostgreSQL value is not a JSON
     */
    public static function transformPostgresJsonEncodedValueToPHPArray(string $postgresValue): array
    {
        try {
            $transformedValue = \json_decode($postgresValue, true, 512, JSON_THROW_ON_ERROR);
            if (!\is_array($transformedValue)) {
                throw InvalidJsonArrayItemForPHPException::forInvalidType($postgresValue);
            }

            return $transformedValue;
        } catch (\JsonException) {
            throw InvalidJsonArrayItemForPHPException::forInvalidFormat($postgresValue);
        }
    }

    /**
     * @throws InvalidJsonItemForPHPException When the PostgreSQL value is not JSON-decodable
     */
    public static function transformPostgresJsonEncodedValueToPHPValue(string $postgresValue): null|array|bool|float|int|string
    {
        try {
            // @phpstan-ignore-next-line
            return \json_decode($postgresValue, true, 512, JSON_THROW_ON_ERROR);
        } catch (\JsonException) {
            throw InvalidJsonItemForPHPException::forInvalidType($postgresValue);
        }
    }
}