From dda0773ad141d937b514710152378051e4a362cc Mon Sep 17 00:00:00 2001
From: balex <balexvicx@gmail.com>
Date: Sun, 22 Feb 2026 12:15:11 +0100
Subject: [PATCH] kafka rag

---
 .../com/balex/rag/model/kafka/UserEvent.java  | 31 -------------------
 .../rag/service/impl/EventPublisherImpl.java  |  4 +--
 2 files changed, 2 insertions(+), 33 deletions(-)
 delete mode 100644 rag-service/src/main/java/com/balex/rag/model/kafka/UserEvent.java

diff --git a/rag-service/src/main/java/com/balex/rag/model/kafka/UserEvent.java b/rag-service/src/main/java/com/balex/rag/model/kafka/UserEvent.java
deleted file mode 100644
index 2fcad47..0000000
--- a/rag-service/src/main/java/com/balex/rag/model/kafka/UserEvent.java
+++ /dev/null
@@ -1,31 +0,0 @@
-package com.balex.rag.model.kafka;
-
-import lombok.AllArgsConstructor;
-import lombok.Builder;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-import java.time.Instant;
-
-@Data
-@Builder
-@NoArgsConstructor
-@AllArgsConstructor
-public class UserEvent {
-
-    private EventType type;
-    private String userId;
-    private String chatId;
-    private Integer tokensUsed;
-    private Integer documentsFound;
-
-    @Builder.Default
-    private Instant timestamp = Instant.now();
-
-    public enum EventType {
-        USER_CREATED,
-        CHAT_CREATED,
-        CHAT_DELETED,
-        QUERY_SENT
-    }
-}
\ No newline at end of file
diff --git a/rag-service/src/main/java/com/balex/rag/service/impl/EventPublisherImpl.java b/rag-service/src/main/java/com/balex/rag/service/impl/EventPublisherImpl.java
index 66544d2..0c59bc2 100644
--- a/rag-service/src/main/java/com/balex/rag/service/impl/EventPublisherImpl.java
+++ b/rag-service/src/main/java/com/balex/rag/service/impl/EventPublisherImpl.java
@@ -1,7 +1,7 @@
 package com.balex.rag.service.impl;
 
-import com.balex.rag.model.kafka.UserEvent;
-import com.balex.rag.model.kafka.UserEvent.EventType;
+import com.balex.rag.model.dto.UserEvent;
+import com.balex.rag.model.dto.UserEvent.EventType;
 import com.balex.rag.service.EventPublisher;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;