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;