Add first installment of queries + refactor: rename

docker/docker-compose.infra.yml

@@ -17,7 +17,7 @@ services:
       - "9093:9093"
       - "9094:9094"
     healthcheck:
-      test: ["CMD", "kafka-topics.sh", "--bootstrap-server=localhost:9094", "--list"]
+      test: [ "CMD", "kafka-topics.sh", "--bootstrap-server=localhost:9094", "--list" ]
       interval: 3s
       timeout: 2s
       retries: 10

services/basket-producer/src/main/java/lrskyum/sbdemo/app/queries/BasketViewModel.java

@@ -0,0 +1,18 @@
+package lrskyum.sbdemo.app.queries;
+
+import lrskyum.sbdemo.business.aggregates.basket.BasketStatus;
+import lrskyum.sbdemo.business.aggregates.basket.PaymentMethod;
+
+import java.time.Instant;
+
+public class BasketViewModel {
+    public record BasketDto(
+            String externalId,
+            Instant basketDateUtc,
+            BasketStatus basketStatus,
+            String buyerName,
+            PaymentMethod paymentMethod,
+            String product,
+            Integer request_count) {
+    }
+}

services/basket-producer/src/main/java/lrskyum/sbdemo/infrastructure/outbox/OutboxServiceImpl.java

@@ -51,12 +51,12 @@ public void saveEvent(IntegrationEvent event, String topic) {
         }
     }
 
-    private void updateEventStatus(OutboxEntry eventLogEntry, EventState eventState) {
-        eventLogEntry.setEventState(eventState);
+    private void updateEventStatus(OutboxEntry outboxEntry, EventState eventState) {
+        outboxEntry.setEventState(eventState);
         if (EventState.InProgress.equals(eventState))
-            eventLogEntry.incrementTimesSent();
+            outboxEntry.incrementTimesSent();
 
-        outboxRepository.save(eventLogEntry).subscribe();
+        outboxRepository.save(outboxEntry).subscribe();
     }
 
     @SneakyThrows

services/basket-producer/src/main/resources/db/changelog/db.changelog-master.yaml

@@ -1,3 +1,5 @@
 databaseChangeLog:
   - include:
-      file: db/migrations/001-create-orders.sql
+      file: db/migrations/001-create-basket.sql
+  - include:
+      file: db/migrations/002-query-basket.sql

services/basket-producer/src/main/resources/db/migrations/002-query-basket.sql

@@ -0,0 +1,13 @@
+create materialized view v_basket_request_count as
+select b.ext_id,
+       b.basket_date_utc,
+       b.basket_status,
+       b.buyer_name,
+       b.payment_method,
+       b.product,
+       count(cr.ext_id) as request_count
+from basket b
+         left outer join client_request cr
+                         on b.ext_id = cr.ext_id
+group by b.ext_id, b.basket_date_utc, b.basket_status, b.buyer_name, b.payment_method, b.product;
+