Sprint 2 by Naz1anmak · Pull Request #2 · Naz1anmak/EventHub

Naz1anmak · 2026-02-10T18:12:41Z

Redis | FeignClient | Circuit breaker
PR сервиса обогащения данных tag-analytics-service

@CacheEvict

- Добавлен RedisCacheConfig для настройки кэширования - Обновлён application.yml для конфигурации Redis - Добавлены аннотации @Cacheable и @CacheEvict в сервисы для категорий, событий, тегов, пользователей и проектов - Обновлён docker-compose.yml для запуска Redis

- Добавлен клиент TagAnalyticsClient для работы с API аналитики тегов - Обновлён TagService для получения статистики тегов - Изменён метод getTagByEvent в TagService для возврата TagWithStatsDto - Добавлен новый DTO TagWithStatsDto для передачи данных о тегах с их статистикой - Обновлён mappers для поддержки нового DTO - Обновлён application.yml для добавления URL сервиса аналитики

- Добавлен класс TagAnalyticsFallback для обработки ошибок - Обновлён TagAnalyticsClient с использованием fallback - Настроены параметры Circuit Breaker в application.yml - Добавлена зависимость spring-cloud-starter-circuitbreaker-resilience4j в build.gradle

Copilot

Pull request overview

PR добавляет интеграции для Redis-кэша, Feign-клиента к сервису аналитики тегов и circuit breaker/retry (Resilience4j), а также расширяет контракт API, чтобы возвращать тег вместе со статистикой.

Changes:

Добавлен Redis-кэш (CacheManager + аннотации кэширования в сервисах).
Добавлен FeignClient TagAnalyticsClient с fallback и конфигурацией circuit breaker/retry.
Обновлён OpenAPI-контракт и DTO/маппинг для ответа TagWithStatsDto.

Reviewed changes

Copilot reviewed 23 out of 24 changed files in this pull request and generated 8 comments.

Show a summary per file

File	Description
src/main/resources/openapi/openapi.yml	Обновление ответа метода получения тега по событию + добавление схемы TagWithStatsDto
src/main/resources/application.yml	Конфигурация Redis cache, Feign circuitbreaker, Resilience4j, URL сервиса tag-analytics
src/main/java/ru/practicum/eventhub/infrastructure/TagAnalyticsClient.java	Feign-клиент для tag-analytics
src/main/java/ru/practicum/eventhub/infrastructure/fallback/TagAnalyticsFallback.java	Fallback для недоступности tag-analytics
src/main/java/ru/practicum/eventhub/config/RedisCacheConfig.java	Конфигурация RedisCacheManager и TTL
src/main/java/ru/practicum/eventhub/domain/service/impl/*ReadService.java	Добавлены @Cacheable для чтений (users/tags/events/categories/userMetadata)
src/main/java/ru/practicum/eventhub/domain/service/impl/*ServiceImpl.java	Добавлены @CachePut/@CacheEvict на update/delete (users/tags/events/categories/projects)
src/main/java/ru/practicum/eventhub/domain/service/impl/TagServiceImpl.java	Вызов tag-analytics (incrementUsage/getStats) и возврат TagWithStatsDto
src/main/java/ru/practicum/eventhub/domain/service/TagService.java	Сигнатура getTagByEvent теперь возвращает TagWithStatsDto
src/main/java/ru/practicum/eventhub/controller/EventTagController.java	Эндпоинт getTagByEventId теперь возвращает TagWithStatsDto
src/main/java/ru/practicum/eventhub/api/mapper/TagMapper.java	Добавлен маппинг в TagWithStatsDto
src/main/java/ru/practicum/eventhub/api/dto/response/TagWithStatsDto.java	Новый DTO для тега со статистикой
src/main/java/ru/practicum/eventhub/api/dto/response/TagStatsDto.java	Новый DTO статистики тега
src/main/java/ru/practicum/eventhub/EventHubApplication.java	Включены @EnableCaching и @EnableFeignClients
build.gradle / gradle.properties	Подключены зависимости cache/redis/feign/resilience4j и вынесены версии в gradle.properties
docker-compose.yml	Добавлен сервис redis

src/main/java/ru/practicum/eventhub/domain/service/impl/ProjectServiceImpl.java

src/main/java/ru/practicum/eventhub/service/impl/UserServiceImpl.java

src/main/java/ru/practicum/eventhub/service/impl/CategoryServiceImpl.java

src/main/java/ru/practicum/eventhub/domain/service/impl/EventServiceImpl.java

src/main/java/ru/practicum/eventhub/service/impl/TagServiceImpl.java

src/main/java/ru/practicum/eventhub/config/RedisCacheConfig.java

src/main/resources/openapi/openapi.yml

src/main/java/ru/practicum/eventhub/infrastructure/fallback/TagAnalyticsFallback.java

- Добавлен класс CategoryCacheInvalidator для удаления кэша при удалении категории - Добавлен класс CategoryCacheService для обновления кэша категорий - Добавлен класс ProjectCacheIndexService для управления индексом проектов по категориям - Обновлены методы в CategoryServiceImpl и ProjectServiceImpl для работы с кэшированием - Обновлены DTO классы для соответствия изменениям

Agastud · 2026-02-15T17:38:59Z

src/main/java/ru/practicum/eventhub/domain/repository/TagRepository.java

+    @Query("""
+                select t from Tag t
+                join t.events e
+                where t.id = :tagId and e.id in :eventIds


Добавь for update skip locked

Agastud · 2026-02-15T17:39:56Z

src/main/java/ru/practicum/eventhub/domain/service/impl/EventServiceImpl.java

        event = eventRepository.save(event);
+
+        Set<UUID> addedTagIds = event.getTags().stream().map(Tag::getId).collect(Collectors.toSet());
+        addedTagIds.removeAll(oldTagIds);


Не очень понял, а зачем удалять все старые?

Agastud · 2026-02-15T17:41:17Z

src/main/java/ru/practicum/eventhub/domain/service/impl/EventServiceImpl.java

+        for (UUID tagId : addedTagIds) {
+            relationIndexService.add(EVENT_TAG_RELATION, id, tagId);
+        }
+        eventCacheService.refresh(id);


Правильно ли я понял, что из-за составного ключа ты делаешь refresh ручной вместо CachePut?

Agastud · 2026-02-15T17:49:14Z

src/main/resources/application.yml

+
+  retry:
+    instances:
+      tagAnalytics:


Если не ошибаюсь, у тебя так как нейминг другой в feignclient это не будет работать либо прокинь в feignclient contextId = "tagAnalytics"

Agastud · 2026-02-15T17:51:24Z

src/main/resources/db/migration/V1__create_initial_tables.sql

  name varchar(100) not null unique,
  description varchar(255),
-  category_id uuid not null references categories(id) on delete restrict,
+  category_id uuid not null references categories(id) on delete cascade,


Миграции работают так, если ты прошел мр, фича раскатилась и на сервере применились миграции, если ты изменишь миграции, то поменяется хэшсумма, из-за чего приложение не встанет, у нас все также применяется правило 1 пр/мр - 1 миграция, также не добавил каскадирование на обновление

Agastud · 2026-02-15T17:53:08Z

src/main/resources/application.yml

+  retry:
+    instances:
+      tagAnalytics:
+        maxAttempts: 3


Сейчас ты ретраишь все подряд, к примеру 400-ки не надо ретраить, а сразу вернуть исключение, что такого объекта к примеру не существует, то есть все логические ошибки мы не ретраим, ретраим только 500-ки

- Обновлён конфиг для Feign клиента с добавлением кастомного ErrorDecoder - Добавлены исключения для обработки ошибок TagAnalyticsClient - Изменены пакеты для классов кэширования и сервисов - Обновлены методы кэширования тегов для использования нового подхода - Добавлены новые классы исключений для обработки ошибок

Agastud · 2026-02-22T15:04:49Z

src/main/java/ru/practicum/eventhub/infrastructure/feign/fallback/TagAnalyticsFallback.java

+
+    @Override
+    public TagStatsDto getStats(UUID id) {
+        log.warn("Сервис Tag Analytics недоступен. Не удалось получить статистику для тега с id={}", id);


Если у тебя есть декодер и он у тебя возвращает исключение, не уверен, что это будет работать и вообще нужно, там должно быть нужное логгирование и верный ответ

Agastud · 2026-02-22T15:09:42Z

src/main/java/ru/practicum/eventhub/domain/service/impl/TagServiceImpl.java

+        eventCacheService.refresh(eventId);
+        tagCacheService.refresh(tagId);
+
+        tagAnalyticsClient.createIfAbsent(tag.getId());


Вот сейчас у тебя тут две потенциальные ошибки
1-е, ты очень долго можешь держать открытой транзакцию это можно починить TransactionTemplate https://docs.spring.io/spring-framework/reference/data-access/transaction/programmatic.html
https://habr.com/ru/companies/otus/articles/431508/
2-е у тебя в бд другого сервиса могут создаться данные, а тут нет так мы получаем неконсистентность данных, поэтому давай реализуем с тобой сагу в реализации через оркестрацию
https://habr.com/ru/companies/otus/articles/751134/
https://habr.com/ru/articles/906166/
https://habr.com/ru/articles/427705/
https://habr.com/ru/companies/alfa/articles/759224/

Также не вижу как данные ты отсюда получаешь и все в одну дто складываешь

Agastud · 2026-02-22T15:10:38Z

src/main/java/ru/practicum/eventhub/domain/service/impl/TagServiceImpl.java

        tag = tagRepository.save(tag);
+
+        Set<UUID> eventIds = relationIndexService.getLeftIds(EVENT_TAG_RELATION, tagId);
+        tagCacheService.refreshCompositeCacheForTag(tagId, eventIds);


Также здесь можешь долго держать транзакцию

- Добавлен класс TagAnalyticsFacade для работы с Tag Analytics - Реализован TagAnalyticsSagaOrchestrator для управления добавлением тегов к событиям - Обновлены сервисы TagService и TagCacheService для использования нового фасада - Изменены методы в контроллерах для работы с новыми классами - Обновлены конфигурации Feign для работы с Tag Analytics

Agastud · 2026-03-10T16:27:48Z

src/main/java/ru/practicum/eventhub/application/cache/EventCacheService.java

+        return eventMapper.toDto(event);
+    }
+
+    public void evict(UUID eventId) {


Только сейчас заметил, все операции где участвует только один кэш - выносим в конфигурацию кэша, это тут не нужно

@cACHEpUT

- Удалён ненужный CacheManager из EventCacheService - Добавлены аннотации @cACHEpUT и @CacheEvict в EventServiceImpl - Переименован метод createIfAbsent в incrementUsage в TagAnalyticsClient - Обновлён метод sendAnalytics на incrementUsage в TagAnalyticsFacade - Изменён возврат TagStatsDto в TagAnalyticsFallbackFactory

Agastud · 2026-03-14T10:48:05Z

src/main/java/ru/practicum/eventhub/application/cache/TagCacheService.java

+        log.info("Обновлен кэш тега с id={} для всех связанных событий", tagId);
+    }
+
+    public void evictAll(UUID tagId) {


Это тоже в конфиг можно вынести, общий метод, надо все общие методы убрать в конфиг и переисользовать их, без переопределения в будущем

Agastud · 2026-03-14T10:51:24Z

src/main/java/ru/practicum/eventhub/application/openapi/UserPageMapper.java

 @Service
 @RequiredArgsConstructor
-public class UserApplicationService {
+public class UserPageMapper {


Сервис называется маппером но при это вызывает метод чтения и почему-то он в папке openapi хотя тут ничего нет связанно со сваггером

Agastud · 2026-03-14T10:53:26Z

src/main/java/ru/practicum/eventhub/application/cache/CategoryCacheInvalidator.java

Также убери папку кэш, я в архитектуре запутался ты ее сильно переусложнил, для кэша отдельный класс сервис не нужен

Agastud · 2026-03-14T10:54:19Z

src/main/java/ru/practicum/eventhub/application/saga/TagAnalyticsSagaOrchestrator.java

Для саги также отдельный класс не нужен, сначала напиши в сервисе, если логика будет слишком сложная для него одного, потом будем разделять

Agastud · 2026-03-14T10:55:53Z

src/main/java/ru/practicum/eventhub/service/impl/CategoryServiceImpl.java

Только сейчас заметил в domain у нас только сущности, из domain все что не связано с сущностями

Agastud · 2026-03-14T10:57:00Z

src/main/java/ru/practicum/eventhub/config/feign/fallback/TagAnalyticsFallbackFactory.java

+        }
+
+        @Override
+        public void deleteTagAnalytics(UUID id) {


Нам нужны только два метода, пост и гет, удали все ненужные методы

- Создан класс CompensationAction для хранения информации о компенсационных действиях - Реализован CompensationService для обработки и сохранения компенсационных действий - Добавлен CompensationScheduler для периодической обработки компенсаций - Обновлены пакеты и импорты в нескольких классах - Исправлены пути к классам и методам в соответствии с новой структурой

Agastud · 2026-04-03T13:36:14Z

src/main/java/ru/practicum/eventhub/config/feign/exception/TagAnalyticsClientException.java

Ошибки не находятся в конфиге

Agastud · 2026-04-03T13:36:23Z

src/main/java/ru/practicum/eventhub/config/feign/config/FeignConfig.java

Убери вторую папку конфиг

Agastud · 2026-04-03T13:36:49Z

src/main/java/ru/practicum/eventhub/config/feign/TagAnalyticsClient.java

Это должно находиться в папке клиент

Agastud · 2026-04-03T13:37:08Z

src/main/java/ru/practicum/eventhub/config/redis/ManyToManyCacheIndexService.java

Здесь тоже 2-я папка конфиг не нужна

Agastud · 2026-04-03T13:38:12Z

src/main/java/ru/practicum/eventhub/service/impl/CompensationScheduler.java

+    @Scheduled(fixedDelay = 180000)
+    @Transactional
+    public void processCompensations() {
+        List<CompensationAction> actions = repository.findAll();


Лучше доставай сразу с нужным статусом, иначе будешь доставать обработавшиеся, а это лишняя работа

И если пустое то сразу делай return

Agastud · 2026-04-03T13:39:40Z

src/main/java/ru/practicum/eventhub/service/impl/CompensationScheduler.java

Все шедулеры вынеси в отдельную папку

Agastud · 2026-04-03T13:42:39Z

src/main/java/ru/practicum/eventhub/service/impl/TagServiceImpl.java

+            Tag tag = addTagLocal(eventId, tagId);
+            tagAdded = true;
+
+            TagStatsDto tagStatsDto = tagAnalyticsFacade.createTagAnalytics(tagId);


По заданию для саги ты должен делать сохранение еще в локальную бд, не вижу этой операции

Naz1anmak added 3 commits February 9, 2026 20:39

Copilot AI review requested due to automatic review settings February 10, 2026 18:12

Copilot started reviewing on behalf of Naz1anmak February 10, 2026 18:13 View session

Copilot AI reviewed Feb 10, 2026

View reviewed changes

Naz1anmak marked this pull request as draft February 10, 2026 20:01

Agastud suggested changes Feb 15, 2026

View reviewed changes

Naz1anmak force-pushed the feature/redis-cache-and-feign branch from f9e41e5 to d981c1c Compare February 18, 2026 21:26

Agastud suggested changes Feb 22, 2026

View reviewed changes

Agastud suggested changes Mar 10, 2026

View reviewed changes

Naz1anmak marked this pull request as ready for review March 12, 2026 16:21

Agastud suggested changes Mar 14, 2026

View reviewed changes

Agastud suggested changes Apr 3, 2026

View reviewed changes

Conversation

Naz1anmak commented Feb 10, 2026 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Uh oh!

Copilot AI left a comment

Choose a reason for hiding this comment

Pull request overview

Reviewed changes

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

3 participants

Naz1anmak commented Feb 10, 2026 •

edited

Loading