75ac268c53
Co-Authored-By: Claude Fable 5.1 <noreply@anthropic.com> Claude-Session: https://claude.ai/code/session_01BCrwHHnGCB5XH968Nxokqw
105 lines
3.8 KiB
PHP
105 lines
3.8 KiB
PHP
<?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 Illuminate\Http\JsonResponse;
|
|
use Illuminate\Http\Request;
|
|
use Illuminate\Support\Str;
|
|
|
|
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');
|
|
$states = $request->query('state')
|
|
? [$request->query('state')]
|
|
: EventState::nonTerminalValues();
|
|
|
|
$events = $user->events()->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' => \Carbon\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();
|
|
}
|
|
}
|