HexMakina\TightORM\RelationManyToMany

Complexity

Total Complexity

12

Size/Duplication

Total Lines	64
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	otm()	0	5	2
B	setManyByIds()	0	40	8
A	setMany()	0	8	2

<?php

namespace HexMakina\TightORM;

use HexMakina\Crudites\CruditesException;
use HexMakina\BlackBox\ORM\ModelInterface;

trait RelationManyToMany
{
    abstract public static function model_type(): string;

    //------------------------------------------------------------  Data Relation
    // returns true on success, error message on failure
    public static function setMany($linked_models, ModelInterface $m)
    {
        $linked_ids = [];
        foreach ($linked_models as $m) {
            $linked_ids[] = $m->getId();
        }

        return static::setManyByIds($linked_ids, $m);
    }

    // returns true on success, error message on failure
    public static function setManyByIds($linked_ids, ModelInterface $m)
    {
        $join_info = static::otm();

        $j_table = static::inspect($join_info['t']);
        $j_table_key = $join_info['k'];

        if (empty($j_table) || empty($j_table_key)) {
            throw new CruditesException('ERR_JOIN_INFO');
        }

        $assoc_data = ['model_id' => $m->getId(), 'model_type' => get_class($m)::model_type()];

        $j_table->connection()->transact();
        try {
            $res = $j_table->delete($assoc_data)->run();
            if (!$res->isSuccess()) {
                throw new CruditesException('QUERY_FAILED');
            }

            if (!empty($linked_ids)) {
                $join_data = $assoc_data;

                $Query = $j_table->insert($join_data);

                foreach ($linked_ids as $linked_id) {
                    $Query->addBinding($j_table_key, $linked_id);
                    $res = $Query->run();

                    if (!$res->isSuccess()) {
                        throw new CruditesException('QUERY_FAILED');
                    }
                }
            }
            $j_table->connection()->commit();
        } catch (\Exception $e) {
            $j_table->connection()->rollback();
            return $e->getMessage();
        }
        return true;
    }

    public static function otm($k = null)
    {
        $type = static::model_type();
        $d = ['t' => $type . 's_models', 'k' => $type . '_id', 'a' => $type . 's_otm'];
        return is_null($k) ? $d : $d[$k];
    }
}