<?php

namespace ProcessMaker\Traits;

use DomainException;

use Facades\ProcessMaker\JsonColumnIndex;

trait Indexable

{

public function getFieldsFromPmql($pmql)

{

return ExtendedPMQL::getFields($pmql);

}

public function addJsonColumnsIndex($fields)

{

foreach ($fields as $field) {

$table = $this->getTableToLook($this->table, $this->type, $this->meta);

[$column, $path] = $this->getColumnAndPath($field);

if ($column && $path) {

\Log::info('Updating JSON path: ' . $path . ' indexes for table: ' . $table);

JsonColumnIndex::add($table, $column, $path);

}

}

}

public function addJsonColumnsIndexBatch($indexes)

{

foreach ($indexes as $index) {

[$column, $path] = $this->getColumnAndPath($index['field']);

JsonColumnIndex::add($index['table'], $column, $path);

}

}

public function deleteJsonColumnsIndexBatch($indexes)

{

foreach ($indexes as $index) {

[$column, $path] = $this->getColumnAndPath($index['field']);

JsonColumnIndex::remove($index['table'], $column, $path);

}

}

private function getColumnAndPath($field)

{

$exploded = explode('.', $field);

// Only columns in format data.field

if (count($exploded) > 1) {

$column = $exploded[0];

array_shift($exploded);

$path = '$.' . implode('.', $exploded);

return [$column, $path];

}

return null;

}

public function getTableToLook($table, $type, $meta)

{

if ($table !== 'saved_searches') {

return $table;

}

// If table is saved search, return the corresponding table

switch ($type) {

case 'request':

case 'task':

return 'process_requests';

case 'collection':

if ($meta && isset($meta->collection_id)) {

$collectionId = $meta->collection_id;

return 'collection_' . $collectionId;

}

default:

throw new DomainException('Unknown saved search type: ' . $type);

}

}

}