<?php

namespace App\Actions\Tickets;

use App\Enums\TicketWorklogEntryType;
use App\Models\Project;
use App\Models\Ticket;
use App\Models\TicketLink;
use App\Models\User;
use Illuminate\Support\Arr;
use Illuminate\Support\Facades\DB;

class StoreProjectTicketLink
{
    public function __construct(
        private readonly CreateTicketWorklogEntry $createTicketWorklogEntry,
    ) {}

    /**
     * @param  array{linked_ticket_id: int, ticket_link_type_id: int, link_direction?: 'source'|'counterpart'}  $validated
     */
    public function handle(Project $project, Ticket $ticket, User $user, array $validated): TicketLink
    {
        $linkedTicketId = Arr::get($validated, 'linked_ticket_id');
        $ticketLinkTypeId = Arr::get($validated, 'ticket_link_type_id');
        $isSourceTicket = Arr::get($validated, 'link_direction', 'source') === 'source';

        $linkedTicket = Ticket::query()
            ->where('project_id', $project->id)
            ->findOrFail($linkedTicketId);
        $sourceTicket = $isSourceTicket ? $ticket : $linkedTicket;
        $targetTicket = $isSourceTicket ? $linkedTicket : $ticket;

        return DB::transaction(function () use ($linkedTicket, $user, $ticketLinkTypeId, $ticket, $sourceTicket, $targetTicket, $isSourceTicket): TicketLink {
            Ticket::query()
                ->whereKey([$ticket->id, $linkedTicket->id])
                ->orderBy('id')
                ->lockForUpdate()
                ->get(['id']);

            $ticketLink = TicketLink::query()
                ->where(function ($query) use ($ticket, $linkedTicket): void {
                    $query
                        ->where('source_ticket_id', $ticket->id)
                        ->where('target_ticket_id', $linkedTicket->id);
                })
                ->orWhere(function ($query) use ($ticket, $linkedTicket): void {
                    $query
                        ->where('source_ticket_id', $linkedTicket->id)
                        ->where('target_ticket_id', $ticket->id);
                })
                ->first();

            if ($ticketLink === null) {
                $ticketLink = TicketLink::query()->create([
                    'source_ticket_id' => $sourceTicket->id,
                    'target_ticket_id' => $targetTicket->id,
                    'ticket_link_type_id' => $ticketLinkTypeId,
                ]);
            } else {
                $ticketLink->update([
                    'source_ticket_id' => $sourceTicket->id,
                    'target_ticket_id' => $targetTicket->id,
                    'ticket_link_type_id' => $ticketLinkTypeId,
                ]);
            }

            $ticketLink->load('ticketLinkType');

            $ticketLabel = $ticketLink->ticketLinkType->labelForSource($isSourceTicket);
            $linkedTicketLabel = $ticketLink->ticketLinkType->labelForSource(! $isSourceTicket);

            $this->createTicketWorklogEntry->handle(
                $ticket,
                $user,
                TicketWorklogEntryType::LinkUpdated,
                "Linked {$linkedTicket->ticket_key} as {$ticketLabel}.",
                [
                    'linked_ticket_key' => $linkedTicket->ticket_key,
                    'ticket_link_type' => $ticketLabel,
                ],
            );

            $this->createTicketWorklogEntry->handle(
                $linkedTicket,
                $user,
                TicketWorklogEntryType::LinkUpdated,
                "Linked {$ticket->ticket_key} as {$linkedTicketLabel}.",
                [
                    'linked_ticket_key' => $ticket->ticket_key,
                    'ticket_link_type' => $linkedTicketLabel,
                ],
            );

            return $ticketLink;
        });
    }
}