Andreshg112\DatosAbiertos\Datasets\BaseDataset

Complexity

Total Complexity

5

Size/Duplication

Total Lines	85
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	8	1
	getColumns()	0	1	?
	getDatasetIdentifier()	0	1	?
A	addMacroMethods()	0	16	3
A	getData()	0	6	1

<?php

namespace Andreshg112\DatosAbiertos\Datasets;

use Illuminate\Support\Str;
use allejo\Socrata\SodaClient;
use allejo\Socrata\SodaDataset;
use Spatie\Macroable\Macroable;

abstract class BaseDataset
{
    use Macroable;

    const SOURCE_DOMAIN = 'datos.gov.co';

    /** @var SodaClient $sodaClient */
    protected $sodaClient;

    /** @var SodaDataset $sodaDataset */
    protected $sodaDataset;

    #region Funciones mágicas

    public function __construct()
    {
        $this->sodaClient = new SodaClient(self::SOURCE_DOMAIN, config('datos-abiertos.token'));

        $this->sodaDataset = new SodaDataset($this->sodaClient, $this->getDatasetIdentifier());

        $this->addMacroMethods();
    }

    #endregion

    #region Funciones abstractas

    /**
     * Retorna las columnas del dataset (recurso).
     *
     * @return string[]
     */
    abstract public function getColumns();

    /**
     * Retorna el identificador del dataset (recurso).
     *
     * @return string
     */
    abstract protected function getDatasetIdentifier();

    #endregion

    #region Funciones

    /**
     * Agrega métodos dinámicos para consultar un dataset (recurso) por cada columna que tenga.
     *
     * @return void
     */
    private function addMacroMethods()
    {
        $columns = $this->getColumns();

        foreach ($columns as $column) {
            static::macro(
                'getBy' . ucfirst(Str::camel($column['name'])),
                function ($value) use ($column) {
                    $data = $this->getData([$column['name']  => $value]);

                    return empty($column['unique'])
                        ? $data : ($data[0] ?? null);
                }
            );
        }
    }

    /**
     * Consulta el listado del recurso de acuerdo a los parámetros.
     * Si no se especifican, por defecto trae todos.
     * Para saber cómo usar los filtros, consultar en el siguiente enlace:
     * https://github.com/allejo/PhpSoda/wiki/Simple-Filters.
     *
     * @param array|string|\allejo\Socrata\SoqlQuery $filterOrSoqlQuery Los parámetros de la consulta.
     * @return array[]
     */
    public function getData($filterOrSoqlQuery = '')
    {
        $data = $this->sodaDataset->getData($filterOrSoqlQuery);

        return $data;
    }

    #endregion
}