datatable.directory/app/Http/Controllers/TableEditController.php

<?php


namespace App\Http\Controllers;

use App\Models\Table;
use App\Models\User;
use App\Tables\Changeset;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Input;
use MightyPork\Exceptions\SimpleValidationException;
use MightyPork\Utils\Utils;

class TableEditController extends Controller
{
    /**
     * Initialize the session-stored changeset, if not set yet
     *
     * @param Table $table
     * @return Changeset
     */
    private function getChangeset(Table $table)
    {
        if (Input::has('reset')) {
            session()->forget($table->draftSessionKey);
        }

        /** @var Changeset $changeset */
        return session()->remember($table->draftSessionKey, function () use ($table) {
            $changeset = new Changeset();
            $changeset->table = $table;
            $changeset->revision = $table->revision;
            return $changeset;
        });
    }

    /**
     * Store the changeset to session
     *
     * @param Changeset $changeset
     */
    private function storeChangeset(Changeset $changeset)
    {
        session()->put($changeset->table->draftSessionKey, $changeset);
    }

    /**
     * Discard draft and redirect to table view
     */
    public function discard(User $user, string $table)
    {
        /** @var Table $tableModel */
        $tableModel = $user->tables()->where('name', $table)->first();
        if ($tableModel === null) abort(404, "No such table.");

        session()->forget($tableModel->draftSessionKey);

        return redirect($tableModel->viewRoute);
    }

    #region Draft tabs

    /**
     * Show the table edit view with tabs
     *
     * @param User $user - table owner
     * @param string $table - table name
     * @param string|null $tab - page tab name, kebab-case
     * @return \Illuminate\View\View;
     */
    public function draft(User $user, string $table, $tab = null)
    {
        /** @var Table $tableModel */
        $tableModel = $user->tables()->where('name', $table)->first();
        if ($tableModel === null) abort(404, "No such table.");

        if ($tab == null) $tab = 'edit-rows';

        $method = camel_case('tab-'.$tab);
        if (!method_exists($this, $method)) abort(404, "No such tab: $tab");

        $changeset = $this->getChangeset($tableModel);

        if (Input::has('dump')) {
            dd($changeset);
        }

        return $this->$method($changeset);
    }

    /** @noinspection PhpUnusedPrivateMethodInspection */
    private function tabEditRows(Changeset $changeset)
    {
        $revision = $changeset->revision;
        $columns = $changeset->fetchAndTransformColumns();
        $rows = $revision->rowsData($columns, true, false)->paginate(25, []);

        return view('table.propose.edit-rows', [
            'changeset' => $changeset,
            'table' => $changeset->table,
            'columns' => collect($columns),
            'rows' => $rows,
        ]);
    }

    /** @noinspection PhpUnusedPrivateMethodInspection */
    private function tabAddRows(Changeset $changeset)
    {
        $columns = $changeset->fetchAndTransformColumns();
        $rows = $changeset->getAddedRows(25);

        return view('table.propose.add-rows', [
            'changeset' => $changeset,
            'table' => $changeset->table,
            'columns' => collect($columns),
            'rows' => $rows,
        ]);
    }

    /** @noinspection PhpUnusedPrivateMethodInspection */
    private function tabAddRowsCsv(Changeset $changeset)
    {
        $columns = $changeset->fetchAndTransformColumns();

        return view('table.propose.add-rows-csv', [
            'changeset' => $changeset,
            'table' => $changeset->table,
            'columns' => collect($columns),
        ]);
    }

    /** @noinspection PhpUnusedPrivateMethodInspection */
    private function tabManageColumns(Changeset $changeset)
    {
        $columns = $changeset->fetchAndTransformColumns();

        return view('table.propose.manage-columns', [
            'changeset' => $changeset,
            'table' => $changeset->table,
            'columns' => collect($columns),
        ]);
    }

    /** @noinspection PhpUnusedPrivateMethodInspection */
    private function tabReview(Changeset $changeset)
    {
        return view('table.propose.review', [
            'changeset' => $changeset,
            'table' => $changeset->table,
        ]);
    }

    #endregion

    /**
     * API hook called by AJAX or via forms.
     * Generally applies modifications to the Changeset stored in session.
     *
     * @param Request $request
     * @param User $user
     * @param string $table
     * @return \Symfony\Component\HttpFoundation\Response
     */
    public function draftUpdate(Request $request, User $user, string $table)
    {
        /** @var Table $tableModel */
        $tableModel = $user->tables()->where('name', $table)->first();
        if ($tableModel === null) abort(404, "No such table.");

        $changeset = $this->getChangeset($tableModel);

        $input = objBag($request->all(), false);

        $resp = null;
        $code = 200;

        try {
            switch ($input->action) {
                case 'row.update':
                    $data = (object)$input->data;
                    $resp = $changeset->rowUpdate($data);
                    break;

                case 'row.update-many':
                    $newVals = $input->data;
                    $updated = [];
                    foreach ($newVals as $rowUpdate) {
                        $r = $changeset->rowUpdate($rowUpdate);
                        $updated[$r->_id] = $r;
                    }
                    $resp = $updated;
                    break;

                case 'row.add-csv':
                    $fname = 'csv-file';
                    if ($request->hasFile($fname)) {
                        try {
                            $file = $request->file($fname);
                            if ($file->isValid() && $file->isReadable()) {
                                $handle = $file->openFile();
                                $csv = Utils::csvToArray($handle);
                                if (empty($csv)) throw new \Exception("Failed to parse CSV file.");

                                $changeset->addFilledRows($csv);
                                $handle = null;
                            } else {
                                throw new \Exception("File not valid.");
                            }
                        } catch (\Exception $e) {
                            return $this->backWithErrors(['csv-file' => $e->getMessage()]);
                        }
                    }
                    else {
                        try {
                            $text = trim($input->data);
                            if (empty($text)) throw new \Exception("Empty CSV field and no file uploaded.");
                            $changeset->addFilledRows(Utils::csvToArray($text));
                        } catch (\Exception $e) {
                            return $this->backWithErrors(['data' => $e->getMessage()]);
                        }
                    }
                    break;

                case 'row.remove':
                    $isNew = $changeset->isNewRow($input->id);
                    $changeset->rowRemove($input->id);
                    $resp = $isNew ? null : $changeset->fetchAndTransformRow($input->id);
                    break;

                case 'row.remove-empty-new':
                    $changeset->removeEmptyNewRows();
                    break;

                case 'row.restore':
                    $changeset->rowRestore($input->id);
                    $resp = $changeset->fetchAndTransformRow($input->id);
                    break;

                case 'rows.add':
                    $changeset->addBlankRows($input->count);
                    break;

                case 'col.update':
                    $data = (object)$input->data;
                    $resp = $changeset->columnUpdate($data);
                    break;

                case 'col.remove':
                    $isNew = $changeset->isNewColumn($input->id);
                    $changeset->columnRemove($input->id);
                    $resp = $isNew ? null : $changeset->fetchAndTransformColumn($input->id);
                    break;

                case 'col.restore':
                    $changeset->columnRestore($input->id);
                    $resp = $changeset->fetchAndTransformColumn($input->id);
                    break;

                case 'col.add':
                    $resp = $changeset->addBlankCol();
                    break;

                case 'col.sort':
                    $changeset->setColOrder($input->order);
                    break;

                case 'col.reset-sort':
                    $changeset->columnOrder = [];
                    $resp = $changeset->fetchAndTransformColumns();
                    break;

                default:
                    $resp = "Bad Action";
                    $code = 400;
                    break;
            }
        } catch (SimpleValidationException $e) {
            return $this->jsonResponse(['errors' => $e->getMessageBag()->getMessages()], 400);
        }

        $this->storeChangeset($changeset);

        // Redirect requested via form
        if ($code == 200 && $input->has('redirect')) {
            return redirect($input->redirect);
        }

        return $this->jsonResponse($resp, $code);
    }
}