balex74/post-hub-platform-k7m2xq9wnp
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

del token exceed

Browse Source
This commit is contained in:
balex
2026-02-23 14:49:06 +01:00
parent dda0773ad1
commit 3757874f37
6 changed files with 4 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
analytics-service/src/main/java/com/posthub/analytics/dto/UserEvent.java
View File

@@ -26,7 +26,6 @@ public class UserEvent {
USER_CREATED, USER_CREATED,
CHAT_CREATED, CHAT_CREATED,
CHAT_DELETED, CHAT_DELETED,
QUERY_SENT, QUERY_SENT
RAG_CONTEXT_HIT
} }
} }

7
analytics-service/src/main/java/com/posthub/analytics/service/AnalyticsService.java
View File

@@ -65,12 +65,6 @@ public class AnalyticsService {
daily.setTotalTokensUsed(daily.getTotalTokensUsed() + event.getTokensUsed()); daily.setTotalTokensUsed(daily.getTotalTokensUsed() + event.getTokensUsed());
} }
} }
case RAG_CONTEXT_HIT -> {
daily.setTotalRagHits(daily.getTotalRagHits() + 1);
if (event.getDocumentsFound() != null) {
daily.setTotalDocumentsFound(daily.getTotalDocumentsFound() + event.getDocumentsFound());
}
}
} }
dailyStatsRepository.save(daily); dailyStatsRepository.save(daily);
@@ -93,7 +87,6 @@ public class AnalyticsService {
userStats.setTotalTokensUsed(userStats.getTotalTokensUsed() + event.getTokensUsed()); userStats.setTotalTokensUsed(userStats.getTotalTokensUsed() + event.getTokensUsed());
} }
} }
case RAG_CONTEXT_HIT -> userStats.setTotalRagHits(userStats.getTotalRagHits() + 1);
default -> { /* no user-level aggregation needed */ } default -> { /* no user-level aggregation needed */ }
} }

3
rag-service/src/main/java/com/balex/rag/controller/ChatEntryController.java
View File

@@ -41,8 +41,7 @@ public class ChatEntryController {
eventPublisher.publishQuerySent( eventPublisher.publishQuerySent(
chat.getIdOwner().toString(), chat.getIdOwner().toString(),
chatId.toString(), chatId.toString());
0); // TODO: add tokensUsed when usage info is available from Groq response
return ResponseEntity.ok(entry); return ResponseEntity.ok(entry);
} }

2
rag-service/src/main/java/com/balex/rag/model/dto/UserEvent.java
View File

@@ -22,8 +22,6 @@ public class UserEvent {
private EventType type; private EventType type;
private String userId; private String userId;
private String chatId; private String chatId;
private Integer tokensUsed;
private Integer documentsFound;
@Builder.Default @Builder.Default
private Instant timestamp = Instant.now(); private Instant timestamp = Instant.now();

2
rag-service/src/main/java/com/balex/rag/service/EventPublisher.java
View File

@@ -6,7 +6,7 @@ public interface EventPublisher {
void publishChatDeleted(String userId, String chatId); void publishChatDeleted(String userId, String chatId);
void publishQuerySent(String userId, String chatId, int tokensUsed); void publishQuerySent(String userId, String chatId);
void publishUserCreated(String userId); void publishUserCreated(String userId);
} }

3
rag-service/src/main/java/com/balex/rag/service/impl/EventPublisherImpl.java
View File

@@ -38,12 +38,11 @@ public class EventPublisherImpl implements EventPublisher {
} }
@Override @Override
public void publishQuerySent(String userId, String chatId, int tokensUsed) { public void publishQuerySent(String userId, String chatId) {
publish(UserEvent.builder() publish(UserEvent.builder()
.type(EventType.QUERY_SENT) .type(EventType.QUERY_SENT)
.userId(userId) .userId(userId)
.chatId(chatId) .chatId(chatId)
.tokensUsed(tokensUsed)
.build()); .build());
} }