Added batch events creation

Author: BeMySlaveDarlin

docs/api.md

@@ -4,7 +4,7 @@
 
 ### Create Event
 
-**POST** `/events`
+**POST** `/event`
 
 Create a new user event.
 
@@ -37,6 +37,51 @@ Create a new user event.
 }
 ```
 
+### Batch Create Events
+
+**POST** `/events`
+
+Create multiple events.
+
+**Request Body:**
+
+```json
+[
+  {
+    "user_id": 8,
+    "event_type": "page_view",
+    "timestamp": "2025-06-08T10:30:00Z",
+    "metadata": {
+      "page": "/dashboard",
+      "referrer": "https://google.com"
+    }
+  },
+  {
+    "user_id": 9,
+    "event_type": "page_view",
+    "timestamp": "2025-06-08T10:30:00Z",
+    "metadata": {
+      "page": "/main",
+      "referrer": "https://ya.ru"
+    }
+  }
+]
+```
+
+**Response (201):**
+
+```json
+{
+  "data": "queued"
+}
+```
+
+```json
+{
+  "data": "failed to queue"
+}
+```
+
 ### List Events
 
 **GET** `/events?page=1&limit=100`
@@ -71,6 +116,35 @@ Get paginated list of events sorted by timestamp.
 }
 ```
 
+### Total Events Count
+
+**GET** `/events/total`
+
+Get total count of events.
+
+**Response (200):**
+
+```json
+{
+  "data": [
+    {
+      "id": 1,
+      "user_id": "123",
+      "type": "click",
+      "timestamp": "2025-05-28T12:34:56+00:00",
+      "metadata": {
+        "page": "/home"
+      }
+    }
+  ],
+  "query": {
+    "page": 1,
+    "limit": 100,
+    "total": 1000
+  }
+}
+```
+
 ### Delete Events
 
 **DELETE** `/events?before=2025-01-01T00:00:00Z`
@@ -186,6 +260,20 @@ Get aggregated statistics for events.
 }
 ```
 
+### Clear cache
+
+**GET** `/clear_cache`
+
+Clears caches
+
+**Response (200):**
+
+```json
+{
+  "data": "Ok"
+}
+```
+
 ## Error Responses
 
 All endpoints may return error responses in the following format:

src/Application/Bootloader/Domain/UserAnalyticsBootloader.php

@@ -4,12 +4,14 @@
 
 namespace App\Application\Bootloader;
 
+use App\Domain\UserAnalytics\Task\BatchCreateEventsTask;
 use App\Domain\UserAnalytics\Task\DeleteOldEventsTask;
 use Spiral\Boot\Bootloader\Bootloader;
 
 final class TasksBootloader extends Bootloader
 {
     protected const array SINGLETONS = [
         DeleteOldEventsTask::class => DeleteOldEventsTask::class,
+        BatchCreateEventsTask::class => BatchCreateEventsTask::class,
     ];
 }

src/Application/Bootloader/TasksBootloader.php

@@ -4,10 +4,13 @@
 
 namespace App\Domain\UserAnalytics\Repository;
 
+use App\Domain\UserAnalytics\ValueObject\CreateEventsRequest;
 use Cycle\Database\DatabaseInterface;
 use Cycle\Database\StatementInterface;
 use Cycle\ORM\RepositoryInterface;
 use DateTimeInterface;
+use DomainException;
+use PDO;
 
 readonly class EventRepository implements RepositoryInterface
 {
@@ -133,7 +136,7 @@ public function getStats(
     public function countAll(): int
     {
         $result = $this->database
-            ->query('SELECT COUNT(*) as total FROM events')
+            ->query('SELECT COUNT(id) as total FROM events')
             ->fetch();
 
         return (int)($result['total'] ?? 0);
@@ -225,4 +228,44 @@ public function findAll(array $scope = []): iterable
 
         return $this->database->query($sql, $parameters)->fetchAll();
     }
+
+    public function insertBatch(CreateEventsRequest $events): int
+    {
+        $eventTypeIdMap = $this->database
+            ->select(['name', 'id'])
+            ->from('event_types')
+            ->fetchAll(PDO::FETCH_KEY_PAIR);
+
+        $userIds = $this->database
+            ->select(['id'])
+            ->from('users')
+            ->fetchAll(PDO::FETCH_COLUMN);
+
+        $placeholders = [];
+        $values = [];
+
+        foreach ($events->events as $event) {
+            if (!isset($userIds[$event->userId])) {
+                throw new DomainException("Unknown user_id: {$event->userId}");
+            }
+            if (!isset($eventTypeIdMap[$event->eventType])) {
+                throw new DomainException("Unknown event_type: {$event->eventType}");
+            }
+
+            $placeholders[] = "(?, ?, ?, ?)";
+            array_push(
+                $values,
+                $event->userId,
+                $eventTypeIdMap[$event->eventType],
+                $event->timestamp->format('Y-m-d H:i:s'),
+                json_encode($event->metadata, JSON_THROW_ON_ERROR)
+            );
+        }
+
+        $sql = 'INSERT INTO events (user_id, type_id, timestamp, metadata) VALUES ' . implode(',', $placeholders);
+        $this->database->getDriver()->query($sql, $values);
+        unset($sql, $values, $placeholders, $eventTypeIdMap);
+
+        return count($events->events);
+    }
 }

src/Domain/UserAnalytics/Repository/EventRepository.php

@@ -0,0 +1,32 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Domain\UserAnalytics\Task;
+
+use App\Domain\UserAnalytics\Repository\CachedEventRepository;
+use App\Domain\UserAnalytics\Repository\EventRepository;
+use App\Domain\UserAnalytics\ValueObject\CreateEventsRequest;
+
+readonly class BatchCreateEventsTask implements TaskInterface
+{
+    public function __construct(
+        private CachedEventRepository $cachedEventRepository,
+        private EventRepository $eventRepository
+    ) {
+    }
+
+    public function run(array $data = []): void
+    {
+        $events = $data['events'] ?? null;
+        if (!$events instanceof CreateEventsRequest) {
+            return;
+        }
+
+        $created = $this->eventRepository->insertBatch($events);
+
+        $this->cachedEventRepository->invalidateCache();
+
+        echo "[Task] Create $created events\n";
+    }
+}

src/Domain/UserAnalytics/Task/BatchCreateEventsTask.php

@@ -0,0 +1,27 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Domain\UserAnalytics\UseCase\Event;
+
+use App\Domain\UserAnalytics\Task\BatchCreateEventsTask;
+use App\Domain\UserAnalytics\ValueObject\CreateEventsRequest;
+use App\Infra\Swoole\Server;
+
+final readonly class CreateEventsUseCase
+{
+    public function __construct(
+        private Server $server,
+    ) {
+    }
+
+    public function execute(CreateEventsRequest $request): bool
+    {
+        $this->server->dispatchTask([
+            'taskClass' => BatchCreateEventsTask::class,
+            'events' => $request,
+        ]);
+
+        return true;
+    }
+}

src/Domain/UserAnalytics/UseCase/Event/CreateEventsUseCase.php

@@ -0,0 +1,28 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Domain\UserAnalytics\UseCase\Event;
+
+use App\Domain\UserAnalytics\Repository\CachedEventRepository;
+use App\Domain\UserAnalytics\ValueObject\GetEventsResponse;
+
+final readonly class EventsTotalCountUseCase
+{
+    public function __construct(
+        private CachedEventRepository $eventRepository
+    ) {
+    }
+
+    public function execute(): GetEventsResponse
+    {
+        $total = $this->eventRepository->countAll();
+
+        return new GetEventsResponse(
+            events: [],
+            page: 1,
+            limit: 1,
+            total: $total
+        );
+    }
+}

src/Domain/UserAnalytics/UseCase/Event/EventsTotalCountUseCase.php

@@ -0,0 +1,29 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Domain\UserAnalytics\ValueObject;
+
+use DateTimeImmutable;
+
+final readonly class CreateEventsRequest
+{
+    /**
+     * @var CreateEventRequest[]
+     */
+    public array $events;
+
+    public function __construct(array $events)
+    {
+        $_events = [];
+        foreach ($events as $event) {
+            $_events[] = new CreateEventRequest(
+                userId: $event['user_id'],
+                eventType: $event['event_type'],
+                timestamp: new DateTimeImmutable($event['timestamp']),
+                metadata: $event['metadata'],
+            );
+        }
+        $this->events = $_events;
+    }
+}