frictionlessdata\tableschema\InferSchema

Complexity

Total Complexity

7

Size/Duplication

Total Lines	59
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes	1
Bugs	0	Features	1

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	2
A	descriptor()	0	4	1
A	castRow()	0	18	3
A	lock()	0	6	1

<?php

namespace frictionlessdata\tableschema;

/**
 *  Table Schema which updates the descriptor based on input data.
 */
class InferSchema extends Schema
{
    /**
     * InferSchema constructor.
     *
     * @param null $descriptor optional descriptor object - will be used as an initial descriptor
     * @param bool $lenient    if true - infer just basic types, without strict format requirements
     */
    public function __construct($descriptor = null, $lenient = false)
    {
        $this->descriptor = empty($descriptor) ? (object) ['fields' => []] : $descriptor;
        $this->fieldsInferer = new Fields\FieldsInferrer(null, $lenient);
    }

    /**
     * @return object
     */
    public function descriptor()
    {
        return $this->descriptor;
    }

    /**
     * @param mixed[] $row
     *
     * @return mixed[]
     *
     * @throws Exceptions\FieldValidationException
     */
    public function castRow($row)
    {
        if ($this->isLocked) {
            // schema is locked, no more inferring is needed
            return parent::castRow($row);
        } else {
            // add the row to the inferrer, update the descriptor according to the best inferred fields
            $this->fieldsInferer->addRows([$row]);
            $this->descriptor->fields = [];
            foreach ($this->fieldsInferer->infer() as $fieldName => $inferredField) {
                /* @var Fields\BaseField $inferredField */
                $this->descriptor->fields[] = $inferredField->descriptor();
            }
            $this->castRows = $this->fieldsInferer->castRows();

            return $this->castRows[count($this->castRows) - 1];
        }
    }

    public function lock()
    {
        $this->isLocked = true;

        return $this->castRows;
    }

    protected $isLocked = false;
    protected $fieldsInferer;
    protected $castRows;
}