<?php

namespace App\Http\Controllers\Me;

use App\Delivery\EventActions;
use App\Enums\EventState;
use App\Http\Controllers\Api\EventsController as ApiPresenter;
use App\Http\Controllers\Controller;
use App\Ingest\EventUpserter;
use App\Models\Event;
use App\Models\Source;
use App\Models\User;
use Carbon\CarbonImmutable;
use Illuminate\Http\JsonResponse;
use Illuminate\Http\Request;
use Illuminate\Support\Str;
use Illuminate\Validation\Rule;

class EventsController extends Controller
{
    public function __construct(private readonly EventActions $actions, private readonly EventUpserter $upserter) {}

    public function index(Request $request): JsonResponse
    {
        /** @var User $user */
        $user = $request->attributes->get('user');
        $request->validate([
            'state' => ['sometimes', Rule::in(array_map(fn ($s) => $s->value, EventState::cases()))],
        ]);
        $states = $request->query('state')
            ? [$request->query('state')]
            : EventState::nonTerminalValues();

        $events = $user->events()->with('source')->whereIn('state', $states)->orderBy('due_date')->orderBy('due_instant')->get();

        return response()->json(['events' => $events->map(fn (Event $e) => ApiPresenter::present($e) + ['source' => $e->source->name])->values()]);
    }

    public function ack(Request $request, int $event): JsonResponse
    {
        $model = $this->own($request, $event);
        $this->actions->ack($model);

        return response()->json(ApiPresenter::present($model->fresh()));
    }

    public function done(Request $request, int $event): JsonResponse
    {
        $model = $this->own($request, $event);
        $this->actions->done($model);

        return response()->json(ApiPresenter::present($model->fresh()));
    }

    public function store(Request $request): JsonResponse
    {
        /** @var User $user */
        $user = $request->attributes->get('user');
        $data = $request->validate([
            'title' => ['required', 'string', 'max:200'],
            'subtitle' => ['sometimes', 'nullable', 'string', 'max:200'],
            'due_date' => ['required', 'date_format:Y-m-d'],
            'due_time' => ['sometimes', 'nullable', 'date_format:H:i'],
        ]);

        $source = Source::firstOrCreate(['name' => 'manual'], ['token_hash' => hash('sha256', Str::random(64))]);
        $dueAt = $data['due_date'].(empty($data['due_time']) ? '' : 'T'.$data['due_time']);

        [$result] = $this->upserter->upsert($source, [[
            'user' => $user->login,
            'source_ref' => 'manual:'.Str::ulid(),
            'topic' => '',
            'due_at' => $dueAt,
            'fire_at' => CarbonImmutable::createFromFormat('Y-m-d', $data['due_date'])->subDays(30)->format('Y-m-d'),
            'after_due' => 'keep',
            'payload' => array_filter([
                'title' => $data['title'],
                'subtitle' => $data['subtitle'] ?? null,
                'done_label' => 'Сделано',
            ], fn ($v) => $v !== null && $v !== ''),
        ]]);

        $event = Event::with('source')->findOrFail($result['id']);

        return response()->json(ApiPresenter::present($event) + ['source' => $event->source->name], 201);
    }

    public function archive(Request $request): JsonResponse
    {
        /** @var User $user */
        $user = $request->attributes->get('user');
        $events = $user->events()->with('source')
            ->whereIn('state', [EventState::Done->value, EventState::Expired->value])
            ->orderByDesc('updated_at')->limit(100)->get();

        return response()->json(['events' => $events->map(fn (Event $e) => ApiPresenter::present($e) + [
            'source' => $e->source->name,
            'closed_as' => $e->state === EventState::Expired ? 'Истекло' : ($e->payload['done_label'] ?? 'Сделано'),
        ])->values()]);
    }

    private function own(Request $request, int $id): Event
    {
        /** @var User $user */
        $user = $request->attributes->get('user');

        return $user->events()->whereKey($id)->firstOrFail();
    }
}