Удалил ненужный PersonSettingService.java

bot-context/bot-context-quarkus/src/main/java/dev/struchkov/godfather/quarkus/context/repository/PersonSettingRepository.java

@@ -1,17 +0,0 @@
-package dev.struchkov.godfather.quarkus.context.repository;
-
-import io.smallrye.mutiny.Uni;
-
-import java.util.Set;
-
-public interface PersonSettingRepository {
-
-    Uni<Set<String>> findAllByAllowedProcessing(Set<String> personIds);
-
-    Uni<Void> disableMessageProcessing(String personId);
-
-    Uni<Void> enableMessageProcessing(String personId);
-
-    Uni<Boolean> findStateByPersonId(String personId);
-
-}

bot-context/bot-context-quarkus/src/main/java/dev/struchkov/godfather/quarkus/context/service/PersonSettingService.java

@@ -1,18 +0,0 @@
-package dev.struchkov.godfather.quarkus.context.service;
-
-import io.smallrye.mutiny.Uni;
-import org.jetbrains.annotations.NotNull;
-
-import java.util.Set;
-
-public interface PersonSettingService {
-
-    Uni<Set<String>> getAllPersonIdDisableMessages(@NotNull Set<String> personIds);
-
-    Uni<Boolean> getStateProcessingByPersonId(@NotNull String personId);
-
-    Uni<Void> disableMessageProcessing(@NotNull String personId);
-
-    Uni<Void> enableMessageProcessing(@NotNull String personId);
-
-}

bot-context/bot-context-simple/src/main/java/dev/struchkov/godfather/simple/context/repository/PersonSettingRepository.java

@@ -1,16 +0,0 @@
-package dev.struchkov.godfather.simple.context.repository;
-
-import java.util.Optional;
-import java.util.Set;
-
-public interface PersonSettingRepository {
-
-    Set<String> findAllByAllowedProcessing(Set<String> personIds);
-
-    void disableMessageProcessing(String personId);
-
-    void enableMessageProcessing(String personId);
-
-    Optional<Boolean> findStateByPersonId(String personId);
-
-}

bot-context/bot-context-simple/src/main/java/dev/struchkov/godfather/simple/context/service/PersonSettingService.java

@@ -1,18 +0,0 @@
-package dev.struchkov.godfather.simple.context.service;
-
-import org.jetbrains.annotations.NotNull;
-
-import java.util.Optional;
-import java.util.Set;
-
-public interface PersonSettingService {
-
-    Set<String> getAllPersonIdDisableMessages(@NotNull Set<String> personIds);
-
-    Optional<Boolean> getStateProcessingByPersonId(@NotNull String personId);
-
-    void disableMessageProcessing(@NotNull String personId);
-
-    void enableMessageProcessing(@NotNull String personId);
-
-}

bot-core/bot-core-quarkus/src/main/java/dev/struchkov/godfather/quarkus/core/GeneralAutoResponder.java

@@ -4,7 +4,6 @@ import dev.struchkov.godfather.main.domain.content.Message;
 import dev.struchkov.godfather.main.domain.unit.UnitActiveType;
 import dev.struchkov.godfather.quarkus.context.service.ErrorHandler;
 import dev.struchkov.godfather.quarkus.context.service.Modifiable;
-import dev.struchkov.godfather.quarkus.context.service.PersonSettingService;
 import dev.struchkov.godfather.quarkus.core.action.ActionUnit;
 import dev.struchkov.godfather.quarkus.core.service.StorylineService;
 import dev.struchkov.godfather.quarkus.domain.unit.MainUnit;
@@ -20,27 +19,19 @@ import java.util.Map;
 import java.util.Optional;
 import java.util.Set;
 import java.util.function.Function;
-import java.util.stream.Collectors;
 
 import static dev.struchkov.haiti.utils.Checker.checkEmpty;
 import static dev.struchkov.haiti.utils.Checker.checkNotNull;
-import static java.lang.Boolean.TRUE;
 import static java.util.Collections.emptyList;
-import static java.util.Collections.emptySet;
 
 public class GeneralAutoResponder<M extends Message> {
 
-    protected final PersonSettingService personSettingService;
     protected final StorylineService<M> storyLineService;
     protected Map<String, List<ActionUnit>> actionUnitMap = new HashMap<>();
     protected List<Modifiable<M>> modifiable;
     protected ErrorHandler errorHandler;
 
-    protected GeneralAutoResponder(
+    protected GeneralAutoResponder(StorylineService<M> storyLineService) {
-            PersonSettingService personSettingService,
-            StorylineService<M> storyLineService
-    ) {
-        this.personSettingService = personSettingService;
         this.storyLineService = storyLineService;
     }
 
@@ -67,17 +58,9 @@ public class GeneralAutoResponder<M extends Message> {
     public Uni<Void> processingNewMessage(M newMessage) {
         return Uni.createFrom().item(newMessage)
                 .onItem().ifNotNull().transformToUni(
-                        message -> personSettingService.getStateProcessingByPersonId(newMessage.getFromPersonId())
+                        message -> processing(newMessage)
-                                .replaceIfNullWith(TRUE)
+                )
-                                .chain(
+                .replaceWithVoid();
-                                        state -> {
-                                            if (TRUE.equals(state)) {
-                                                return processing(newMessage);
-                                            }
-                                            return Uni.createFrom().voidItem();
-                                        }
-                                )
-                ).replaceWithVoid();
     }
 
     public Uni<Void> processingNewMessages(List<M> newMessages) {
@@ -85,22 +68,9 @@ public class GeneralAutoResponder<M extends Message> {
                 .onItem().ifNotNull().transformToUni(
                         messages -> {
                             if (checkEmpty(newMessages)) return Uni.createFrom().voidItem();
-
+                            return Multi.createFrom().iterable(newMessages)
-                            final Set<String> personIds = newMessages.stream()
-                                    .map(Message::getFromPersonId)
-                                    .collect(Collectors.toSet());
-                            return personSettingService.getAllPersonIdDisableMessages(personIds)
-                                    .replaceIfNullWith(emptySet())
-                                    .onItem().transformToMulti(
-                                            disableIds -> {
-                                                final List<M> allowedMessages = newMessages.stream()
-                                                        .filter(message -> !disableIds.contains(message.getFromPersonId()))
-                                                        .toList();
-                                                return Multi.createFrom().iterable(allowedMessages);
-                                            }
-                                    )
                                     .onItem().transform(this::processing)
-                                    .toUni().replaceWithVoid();
+                                    .collect().asList().replaceWithVoid();
                         }
                 );
     }

bot-core/bot-core-quarkus/src/main/java/dev/struchkov/godfather/quarkus/core/service/PersonSettingServiceImpl.java

@@ -1,42 +0,0 @@
-package dev.struchkov.godfather.quarkus.core.service;
-
-import dev.struchkov.godfather.quarkus.context.repository.PersonSettingRepository;
-import dev.struchkov.godfather.quarkus.context.service.PersonSettingService;
-import dev.struchkov.haiti.utils.Inspector;
-import io.smallrye.mutiny.Uni;
-import org.jetbrains.annotations.NotNull;
-
-import java.util.Set;
-
-public class PersonSettingServiceImpl implements PersonSettingService {
-
-    private final PersonSettingRepository personSettingRepository;
-
-    public PersonSettingServiceImpl(PersonSettingRepository personSettingRepository) {
-        this.personSettingRepository = personSettingRepository;
-    }
-
-    @Override
-    public Uni<Set<String>> getAllPersonIdDisableMessages(@NotNull Set<String> personIds) {
-        Inspector.isNotNull(personIds);
-        return personSettingRepository.findAllByAllowedProcessing(personIds);
-    }
-
-    @Override
-    public Uni<Boolean> getStateProcessingByPersonId(@NotNull String personId) {
-        return personSettingRepository.findStateByPersonId(personId);
-    }
-
-    @Override
-    public Uni<Void> disableMessageProcessing(@NotNull String personId) {
-        Inspector.isNotNull(personId);
-        return personSettingRepository.disableMessageProcessing(personId);
-    }
-
-    @Override
-    public Uni<Void> enableMessageProcessing(@NotNull String personId) {
-        Inspector.isNotNull(personId);
-        return personSettingRepository.enableMessageProcessing(personId);
-    }
-
-}

bot-core/bot-core-simple/src/main/java/dev/struchkov/godfather/simple/core/GeneralAutoResponder.java

@@ -5,7 +5,6 @@ import dev.struchkov.godfather.main.domain.unit.UnitActiveType;
 import dev.struchkov.godfather.simple.context.service.Accessibility;
 import dev.struchkov.godfather.simple.context.service.ErrorHandler;
 import dev.struchkov.godfather.simple.context.service.Modifiable;
-import dev.struchkov.godfather.simple.context.service.PersonSettingService;
 import dev.struchkov.godfather.simple.core.action.ActionUnit;
 import dev.struchkov.godfather.simple.core.service.StorylineService;
 import dev.struchkov.godfather.simple.domain.unit.MainUnit;
@@ -22,7 +21,6 @@ import java.util.Optional;
 import java.util.Set;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.ExecutorService;
-import java.util.stream.Collectors;
 
 import static dev.struchkov.haiti.utils.Checker.checkNotEmpty;
 import static dev.struchkov.haiti.utils.Checker.checkNotNull;
@@ -31,7 +29,6 @@ public class GeneralAutoResponder<M extends Message> {
 
     private static final Logger log = LoggerFactory.getLogger(GeneralAutoResponder.class);
 
-    protected final PersonSettingService personSettingService;
     protected final StorylineService<M> storyLineService;
 
     protected Map<String, List<ActionUnit>> actionUnitMap = new HashMap<>();
@@ -39,11 +36,7 @@ public class GeneralAutoResponder<M extends Message> {
     protected ErrorHandler errorHandler;
     protected ExecutorService executorService;
 
-    protected GeneralAutoResponder(
+    protected GeneralAutoResponder(StorylineService<M> storyLineService) {
-            PersonSettingService personSettingService,
-            StorylineService<M> storyLineService
-    ) {
-        this.personSettingService = personSettingService;
         this.storyLineService = storyLineService;
     }
 
@@ -75,42 +68,25 @@ public class GeneralAutoResponder<M extends Message> {
         if (checkNotNull(newMessage)) {
             if (checkNotNull(executorService)) {
                 CompletableFuture.runAsync(
-                        () -> {
+                        () -> processing(newMessage), executorService
-                            final boolean state = personSettingService.getStateProcessingByPersonId(newMessage.getFromPersonId())
-                                    .orElse(true);
-                            if (state) {
-                                processing(newMessage);
-                            }
-                        }, executorService
                 ).exceptionally(ex -> {
                     log.error(ex.getMessage(), ex);
                     return null;
                 });
             } else {
-                final boolean state = personSettingService.getStateProcessingByPersonId(newMessage.getFromPersonId())
+                processing(newMessage);
-                        .orElse(true);
-                if (state) {
-                    processing(newMessage);
-                }
             }
         }
     }
 
     public void processingNewMessages(List<M> newMessages) {
         if (checkNotEmpty(newMessages)) {
-            final Set<String> personIds = newMessages.stream()
-                    .map(Message::getFromPersonId)
-                    .collect(Collectors.toSet());
-            final Set<String> disableIds = personSettingService.getAllPersonIdDisableMessages(personIds);
-            final List<M> allowedMessages = newMessages.stream()
-                    .filter(message -> !disableIds.contains(message.getFromPersonId()))
-                    .toList();
             if (checkNotNull(executorService)) {
-                for (M allowedMessage : allowedMessages) {
+                for (M allowedMessage : newMessages) {
                     executorService.submit(() -> processing(allowedMessage));
                 }
             } else {
-                for (M allowedMessage : allowedMessages) {
+                for (M allowedMessage : newMessages) {
                     processing(allowedMessage);
                 }
             }

bot-core/bot-core-simple/src/main/java/dev/struchkov/godfather/simple/core/service/PersonSettingServiceImpl.java

@@ -1,42 +0,0 @@
-package dev.struchkov.godfather.simple.core.service;
-
-import dev.struchkov.godfather.simple.context.repository.PersonSettingRepository;
-import dev.struchkov.godfather.simple.context.service.PersonSettingService;
-import dev.struchkov.haiti.utils.Inspector;
-import org.jetbrains.annotations.NotNull;
-
-import java.util.Optional;
-import java.util.Set;
-
-public class PersonSettingServiceImpl implements PersonSettingService {
-
-    private final PersonSettingRepository personSettingRepository;
-
-    public PersonSettingServiceImpl(PersonSettingRepository personSettingRepository) {
-        this.personSettingRepository = personSettingRepository;
-    }
-
-    @Override
-    public Set<String> getAllPersonIdDisableMessages(@NotNull Set<String> personIds) {
-        Inspector.isNotNull(personIds);
-        return personSettingRepository.findAllByAllowedProcessing(personIds);
-    }
-
-    @Override
-    public Optional<Boolean> getStateProcessingByPersonId(@NotNull String personId) {
-        return personSettingRepository.findStateByPersonId(personId);
-    }
-
-    @Override
-    public void disableMessageProcessing(@NotNull String personId) {
-        Inspector.isNotNull(personId);
-        personSettingRepository.disableMessageProcessing(personId);
-    }
-
-    @Override
-    public void enableMessageProcessing(@NotNull String personId) {
-        Inspector.isNotNull(personId);
-        personSettingRepository.enableMessageProcessing(personId);
-    }
-
-}

bot-data/bot-data-quarkus/src/main/java/dev/struchkov/godfather/quarkus/data/repository/impl/PersonSettingLocalRepository.java

@@ -1,41 +0,0 @@
-package dev.struchkov.godfather.quarkus.data.repository.impl;
-
-import dev.struchkov.godfather.quarkus.context.repository.PersonSettingRepository;
-import io.smallrye.mutiny.Uni;
-
-import java.util.HashMap;
-import java.util.Map;
-import java.util.Set;
-import java.util.stream.Collectors;
-
-public class PersonSettingLocalRepository implements PersonSettingRepository {
-
-    private final Map<String, Boolean> map = new HashMap<>();
-
-    @Override
-    public Uni<Set<String>> findAllByAllowedProcessing(Set<String> personIds) {
-        return Uni.createFrom().item(
-                personIds.stream()
-                        .filter(map::get)
-                        .collect(Collectors.toSet())
-        );
-    }
-
-    @Override
-    public Uni<Void> disableMessageProcessing(String personId) {
-        map.put(personId, false);
-        return Uni.createFrom().voidItem();
-    }
-
-    @Override
-    public Uni<Void> enableMessageProcessing(String personId) {
-        map.put(personId, true);
-        return Uni.createFrom().voidItem();
-    }
-
-    @Override
-    public Uni<Boolean> findStateByPersonId(String personId) {
-        return Uni.createFrom().item(map.get(personId));
-    }
-
-}

bot-data/bot-data-simple/src/main/java/dev/struchkov/godfather/simple/data/repository/impl/PersonSettingLocalRepository.java

@@ -1,37 +0,0 @@
-package dev.struchkov.godfather.simple.data.repository.impl;
-
-import dev.struchkov.godfather.simple.context.repository.PersonSettingRepository;
-
-import java.util.HashMap;
-import java.util.Map;
-import java.util.Optional;
-import java.util.Set;
-import java.util.stream.Collectors;
-
-public class PersonSettingLocalRepository implements PersonSettingRepository {
-
-    private final Map<String, Boolean> map = new HashMap<>();
-
-    @Override
-    public Set<String> findAllByAllowedProcessing(Set<String> personIds) {
-        return personIds.stream()
-                .filter(map::get)
-                .collect(Collectors.toSet());
-    }
-
-    @Override
-    public void disableMessageProcessing(String personId) {
-        map.put(personId, false);
-    }
-
-    @Override
-    public void enableMessageProcessing(String personId) {
-        map.put(personId, true);
-    }
-
-    @Override
-    public Optional<Boolean> findStateByPersonId(String personId) {
-        return Optional.ofNullable(map.get(personId));
-    }
-
-}