lucent-laravel/src/Http/Controller/RecordController.php

<?php

namespace Lucent\Http\Controller;

use App\Http\Controllers\Controller;
use Illuminate\Http\Request;
use Lucent\Account\AccountService;
use Lucent\Account\AuthService;
use Lucent\Channel\ChannelService;
use Lucent\LucentException;
use Lucent\Query\Operator\OperatorRegistry;
use Lucent\Query\Query;
use Lucent\Record\InputData\EdgeInputData;
use Lucent\Record\InputData\RecordInputData;
use Lucent\Record\Manager;
use Lucent\Record\QueryRecord;
use Lucent\Record\RecordService;
use Lucent\Record\Status;
use Lucent\Schema\System;
use Lucent\Schema\Ui\Reference;
use Lucent\Schema\Validator\ValidatorException;
use Lucent\Svelte\Svelte;
use Lucent\ViewModel\ViewModel;
use function Lucent\Response\fail;
use function Lucent\Response\ok;

class RecordController extends Controller
{
    public function __construct(
        private readonly RecordService    $recordService,
        private readonly AccountService   $accountService,
        private readonly ChannelService   $channelService,
        private readonly Svelte           $svelte,
        private readonly Query            $query,
        private readonly Manager          $recordManager,
        private readonly OperatorRegistry $operatorRegistry,
        private readonly ViewModel $viewModel,
    )
    {
    }

    public function index(Request $request)
    {
        $schemaName = $request->route("schemaName");

        if (!in_array($schemaName, $this->accountService->currentReadableSchemas())) {
            return $this->svelte->render(
                layout: "channel",
                view: "recordNotFound",
                title: "Schema Not Found",
            );
        }

        $users = $this->accountService->all();
        $schema = $this->channelService->getSchema($schemaName)->get();
        $urlParams = $request->all();
        $sort = data_get($urlParams, "sort") ?? $schema->sortBy;
        $filter = data_get($urlParams, "filter") ?? [];

        $arguments = array_merge([
            "schema" => $schema->name,
            "status_in" => "draft,published",
        ], $filter);



        $skip = data_get($urlParams, "skip") ?? 0;
        $limit = 30;
        $records = [];
        $graphArray = null;

        $graph = $this->query
            ->filter($arguments)
            ->notLinked($request->input("notlinked") ?? "")
            ->limit($limit)
            ->status(explode(",", $arguments["status_in"]))
            ->skip($skip)
            ->sort($sort)
            ->childrenFields($schema?->visible ?? [])
            ->childrenDepth(1)
            ->parentsDepth(0)
            ->runWithCount();


        $records = $graph->getRootRecords()->toArray();

        $data = [
            "schemas" => $this->channelService->channel->schemas,
            "schema" => $schema,
            "users" => $users,
            "records" => $records,
            "graph" => toArray($graph),
            "systemFields" => array_values(System::list()),
            "operators" => $this->operatorRegistry->all(),
            "sortParam" => $sort,
            "sortField" => $schema->fields->merge(array_values(System::list()))->firstWhere(fn($field) => $field->name === $sort || "-" . $field->name === $sort || "data." . $field->name === $sort || "-data." . $field->name === $sort),
            "limit" => $limit,
            "skip" => $skip,
            "total" => $graph->total ?? 0,
            "filter" => $request->input("filter") ?? [],
            "inModal" => true,
            "isWritable" => in_array($schemaName, $this->accountService->currentWritableSchemas())
        ];

        if ($request->ajax()) {
            $data["modalUrl"] = $request->fullUrl();
            if (str_starts_with(config("lucent.url"), "https")) {
                $data["modalUrl"] = str_replace("http://", "https://", $request->fullUrl());
            }
            return $data;
        }
        $data["inModal"] = false;
        return $this->svelte->render(
            layout: "channel",
            view: "contentIndex",
            title: "Records",
            data: $data
        );
    }

    public function exportCSV(Request $request)
    {
        $schemaName = $request->route("schemaName");
        $schema = $this->channelService->channel->schemas->where("name", $schemaName)->first();

        $urlParams = $request->all();

        $sort = data_get($urlParams, "sort") ?? "-_sys.updatedAt";
        $filter = data_get($urlParams, "filter") ?? [];
        $arguments = array_merge([
            "schema" => $schema->name,
            "status_in" => "draft,published",
        ], $filter);


        $records = $this->query
            ->filter($arguments)
            ->limit(-1)
            ->status(explode(",", $arguments["status_in"]))
            ->childrenDepth(1)
            // ->skip($skip)
            ->sort($sort)
            ->run()
            ->tree();

        header('Content-Type: application/csv');
        header('Content-Disposition: attachment; filename="' . $schemaName . '.csv";');
        $handle = fopen('php://output', 'w');
        $relationColumns = $this->makeCsvRelationColumns($schema);
        $csvRow = ["id", ...array_keys($records[0]->data->toArray()),...$relationColumns];
        fputcsv($handle, $csvRow, ',');
        foreach ($records as $record) {

            $csvRow = [$record->id, ...$record->data->toArray()];
            $csvRow = array_merge($csvRow,$this->makeCsvRelationColumnValues($schema,$record->_children));
            $csvRow = array_values($csvRow);
            fputcsv($handle, $csvRow, ',');
        }
        fclose($handle);
        echo $handle;
        exit;
    }

    private function makeCsvRelationColumns($schema):array{
        return $schema->fields->filter(fn($f) => get_class($f) === Reference::class)->reduce(function($c,$f){
           $c[] = $f->name." id";
           $c[] = $f->name." name";
           return $c;
        },[]);
    }

    private function makeCsvRelationColumnValues($schema, $children):array{
        return $schema->fields->filter(fn($f) => get_class($f) === Reference::class)->reduce(function($c,$f) use($children){

            $fieldRecords = data_get($children,$f->name);
            if(empty($fieldRecords)){
                $c[] = "";
                $c[] = "";
            }elseif (count($fieldRecords) === 1){
                $c[] = data_get($fieldRecords,"0.id");
                $c[] = $this->viewModel->getRecordName($fieldRecords[0]);
            }else{
                $c[] = collect($fieldRecords)->pluck("id")->join("::");
                $c[] = collect($fieldRecords)->pluck("data.name")->join("::");
            }
            return $c;
        },[]);
    }

    public function new(Request $request)
    {
        if (!in_array($request->input("schema"), $this->accountService->currentWritableSchemas())) {
            return $this->svelte->render(
                layout: "channel",
                view: "recordNotFound",
                title: "Schema Not Found",
            );
        }

        $schema = $this->channelService->channel->schemas->where("name", $request->input("schema"))->first();
        $recordHistory = $this->recordManager->fromSession($request->session())->getRecords();
        $record = $this->recordService->createEmpty($schema);
        $queryRecord = QueryRecord::fromRecord($record);
        return $this->svelte->render(
            layout: "channel",
            view: "recordEdit",
            title: "New Record",
            data: [
                "schema" => $schema,
                "record" => $queryRecord,
                "recordHistory" => $recordHistory,
                "isCreateMode" => true,
                "isWritable" => in_array($record->schema, $this->accountService->currentWritableSchemas())
            ]
        );
    }


    public function newInline(Request $request)
    {
        if (!in_array($request->input("schema"), $this->accountService->currentWritableSchemas())) {
            return $this->svelte->render(
                layout: "channel",
                view: "recordNotFound",
                title: "Schema Not Found",
            );
        }

        $schema = $this->channelService->getSchema($request->input("schema"))->get();
        $record = $this->recordService->createEmpty($schema);
        $queryRecord = QueryRecord::fromRecord($record);

        return [
            "schema" => $schema,
            "record" => $queryRecord,
            "isCreateMode" => true,
            "isWritable" => in_array($record->schema, $this->accountService->currentWritableSchemas())
        ];
    }

    public function edit(Request $request)
    {
        $rid = $request->route("rid");

        $graph = $this->query
            ->filter(["id" => $rid])
            ->limit(1)
            ->skip(0)
            ->childrenDepth(2)
            ->childrenLimit(200)
            ->parentsDepth(1)
            ->parentsLimit(200)
            ->run();

        if ($graph->records->isEmpty()) {
            return $this->svelte->render(
                layout: "channel",
                view: "recordNotFound",
                title: "Record Not Found",
            );
        }

        $record = $graph->records->first();

        if (!in_array($record->schema, $this->accountService->currentReadableSchemas())) {
            return $this->svelte->render(
                layout: "channel",
                view: "recordNotFound",
                title: "Schema Not Found",
            );
        }

        $schema = $this->channelService->getSchema($record->schema)->get();
        $recordHistory = $this->recordManager->fromSession($request->session())->push($rid)->getRecords($rid);
        return $this->svelte->render(
            layout: "channel",
            view: "recordEdit",
            title: "Edit Record",
            data: [
                "schema" => $schema,
                "graph" => toArray($graph),
                "record" => toArray($record),
                "users" => $this->accountService->all(),
                "recordHistory" => $recordHistory,
                "isWritable" => in_array($record->schema, $this->accountService->currentWritableSchemas())
            ]
        );
    }

    public function suggestions(Request $request)
    {
        $arguments = [
            "schema" => $request->input("schema"),
        ];

        if ($request->input("value")) {
            if (in_array($request->input("ui"), ["text", "date"])) {
                $arguments["data." . $request->input("field") . "_regex"] = $request->input("value");
            } elseif ($request->input("ui") == "number") {
                $arguments["data." . $request->input("field") . "_eqnum"] = floatval($request->input("value"));
            } elseif ($request->input("ui") == "date") {
            } elseif ($request->input("ui") == "search") {
                $arguments["search_regex"] = $request->input("value");
            }
        }

        $records = $this->query
            ->filter($arguments)
            ->limit(10)
            ->tree();

        if ($records->isEmpty()) {
            return ok([]);
        }

        return ok($records->toArray());
    }

    public function save(Request $request)
    {
        $recordId = $request->input("record.id");
        try {

            if ($request->input("isCreateMode")) {
                $recordId = $this->recordService->create(
                    data: new RecordInputData(
                        $request->input("record.schema"),
                        $recordId ?? "",
                        $request->input("record.data"),
                        Status::from($request->input("record.status")),
                    ),
                    edges: array_map(EdgeInputData::fromArray(...), $request->input("edges") ?? [])
                );
            } else {

                $this->recordService->updateWithEdges(
                    id: $request->input("record.id"),
                    data: $request->input("record.data"),
                    status: Status::from($request->input("record.status")),
                    edges: array_map(EdgeInputData::fromArray(...), $request->input("edges") ?? []),
                );
            }

            $newGraph = $this->query
                ->filter(["id" => $recordId])
                ->limit(10)
                ->childrenDepth(1)
                ->parentsDepth(1)
                ->run();

        } catch (ValidatorException $th) {
            return fail($th->getValidatorErrors());
        } catch (LucentException $th) {
            return fail($th);
        }
        return ok(toArray($newGraph));
    }


    public function clone(Request $request)
    {
        try {

            $newRecordId = $this->recordService->clone(
                recordId: $request->route("rid"),
            );
        } catch (LucentException $th) {
            return fail($th);
        } catch (ValidatorException $e) {
            return fail($e);
        }
        return ok(["id" => $newRecordId]);
    }

    public function status(Request $request)
    {

        $ids = array_map(fn($rec) => $rec["id"], $request->input("records"));


        $this->recordService->changeStatusBulk(
            status: $request->route("status"),
            recordsIds: $ids,
        );
        return ok();
    }

    public function emptyTrash(Request $request)
    {

        $this->recordService->emptyTrash($request->route("schemaName"));
        return redirect($this->channelService->channel->lucentUrl . "/content/" . $request->route("schemaName"));
    }

    public function delete(Request $request)
    {
        $ids = $request->input("ids");

        try {
            $this->recordService->deleteMany($ids);
        } catch (Throwable $th) {
            return fail($th);
        }
        return ok();
    }

    public function rollback(Request $request)
    {
        try {
            $this->recordService->rollback(
                recordId: $request->route("rid"),
                version: (int)$request->route("version")
            );
        } catch (ValidatorException $th) {
            return fail($th->getFirstValidatorError());
        } catch (LucentException|Throwable $th) {
            return fail($th);
        }
        return ok();
    }
}