Modes inside dm models

smecalculus · Oct 21, 2023 · 7ec9af1 · 7ec9af1
1 parent 80919ca
commit 7ec9af1
Show file tree

Hide file tree

Showing 63 changed files with 278 additions and 268 deletions.
diff --git a/apps/sepuling/src/main/java/smecalculus/bezmen/construction/App.java b/apps/sepuling/src/main/java/smecalculus/bezmen/construction/App.java
@@ -1,8 +1,8 @@
 package smecalculus.bezmen.construction;
 
-import static smecalculus.bezmen.configuration.MessagingMappingMode.SPRING_MVC;
-import static smecalculus.bezmen.configuration.StorageMappingMode.MY_BATIS;
-import static smecalculus.bezmen.configuration.StorageMappingMode.SPRING_DATA;
+import static smecalculus.bezmen.configuration.MessagingDm.MappingMode.SPRING_MVC;
+import static smecalculus.bezmen.configuration.StorageDm.MappingMode.MY_BATIS;
+import static smecalculus.bezmen.configuration.StorageDm.MappingMode.SPRING_DATA;
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.context.annotation.Bean;
@@ -37,7 +37,7 @@ public static void main(String[] args) {
     }
 
     @Bean
-    @ConditionalOnMessageMappingModes(SPRING_MVC)
+    @ConditionalOnMessagingMappingModes(SPRING_MVC)
     SepulkaController sepulkaControllerSpringMvc(SepulkaClient client) {
         return new SepulkaController(client);
     }
@@ -68,13 +68,13 @@ SepulkaStateMapper sepulkaStateMapper() {
     }
 
     @Bean
-    @ConditionalOnStateMappingMode(SPRING_DATA)
+    @ConditionalOnStorageMappingMode(SPRING_DATA)
     SepulkaDaoSpringData sepulkaDaoSpringData(SepulkaStateMapper mapper, SepulkaRepository repository) {
         return new SepulkaDaoSpringData(mapper, repository);
     }
 
     @Bean
-    @ConditionalOnStateMappingMode(MY_BATIS)
+    @ConditionalOnStorageMappingMode(MY_BATIS)
     SepulkaDaoMyBatis sepulkaDaoMyBatis(SepulkaStateMapper recMapper, SepulkaSqlMapper sqlMapper) {
         return new SepulkaDaoMyBatis(recMapper, sqlMapper);
     }

diff --git a/apps/sepuling/src/main/java/smecalculus/bezmen/core/SepulkaServiceImpl.java b/apps/sepuling/src/main/java/smecalculus/bezmen/core/SepulkaServiceImpl.java
@@ -7,10 +7,10 @@
 import java.util.List;
 import lombok.NonNull;
 import lombok.RequiredArgsConstructor;
-import smecalculus.bezmen.core.MessageDomain.PreviewRequest;
-import smecalculus.bezmen.core.MessageDomain.PreviewResponse;
-import smecalculus.bezmen.core.MessageDomain.RegistrationRequest;
-import smecalculus.bezmen.core.MessageDomain.RegistrationResponse;
+import smecalculus.bezmen.core.MessageDm.PreviewRequest;
+import smecalculus.bezmen.core.MessageDm.PreviewResponse;
+import smecalculus.bezmen.core.MessageDm.RegistrationRequest;
+import smecalculus.bezmen.core.MessageDm.RegistrationResponse;
 import smecalculus.bezmen.storage.SepulkaDao;
 
 @RequiredArgsConstructor

diff --git a/apps/sepuling/src/main/java/smecalculus/bezmen/messaging/SepulkaClientImpl.java b/apps/sepuling/src/main/java/smecalculus/bezmen/messaging/SepulkaClientImpl.java
@@ -3,8 +3,8 @@
 import lombok.NonNull;
 import lombok.RequiredArgsConstructor;
 import smecalculus.bezmen.core.SepulkaService;
-import smecalculus.bezmen.messaging.MessageEdge.RegistrationRequest;
-import smecalculus.bezmen.messaging.MessageEdge.RegistrationResponse;
+import smecalculus.bezmen.messaging.MessageEm.RegistrationRequest;
+import smecalculus.bezmen.messaging.MessageEm.RegistrationResponse;
 import smecalculus.bezmen.validation.EdgeValidator;
 
 @RequiredArgsConstructor

diff --git a/apps/sepuling/src/main/java/smecalculus/bezmen/messaging/springmvc/SepulkaController.java b/apps/sepuling/src/main/java/smecalculus/bezmen/messaging/springmvc/SepulkaController.java
@@ -8,8 +8,8 @@
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
-import smecalculus.bezmen.messaging.MessageEdge.RegistrationRequest;
-import smecalculus.bezmen.messaging.MessageEdge.RegistrationResponse;
+import smecalculus.bezmen.messaging.MessageEm.RegistrationRequest;
+import smecalculus.bezmen.messaging.MessageEm.RegistrationResponse;
 import smecalculus.bezmen.messaging.SepulkaClient;
 
 @RestController

diff --git a/apps/sepuling/src/main/java/smecalculus/bezmen/storage/SepulkaDao.java b/apps/sepuling/src/main/java/smecalculus/bezmen/storage/SepulkaDao.java
@@ -2,10 +2,10 @@
 
 import java.util.Optional;
 import java.util.UUID;
-import smecalculus.bezmen.core.StateDomain.AggregateState;
-import smecalculus.bezmen.core.StateDomain.ExistenceState;
-import smecalculus.bezmen.core.StateDomain.PreviewState;
-import smecalculus.bezmen.core.StateDomain.TouchState;
+import smecalculus.bezmen.core.StateDm.AggregateState;
+import smecalculus.bezmen.core.StateDm.ExistenceState;
+import smecalculus.bezmen.core.StateDm.PreviewState;
+import smecalculus.bezmen.core.StateDm.TouchState;
 
 /**
  * Port: server side

diff --git a/apps/sepuling/src/main/java/smecalculus/bezmen/storage/SepulkaDaoMyBatis.java b/apps/sepuling/src/main/java/smecalculus/bezmen/storage/SepulkaDaoMyBatis.java
@@ -4,10 +4,10 @@
 import java.util.UUID;
 import lombok.NonNull;
 import lombok.RequiredArgsConstructor;
-import smecalculus.bezmen.core.StateDomain.AggregateState;
-import smecalculus.bezmen.core.StateDomain.ExistenceState;
-import smecalculus.bezmen.core.StateDomain.PreviewState;
-import smecalculus.bezmen.core.StateDomain.TouchState;
+import smecalculus.bezmen.core.StateDm.AggregateState;
+import smecalculus.bezmen.core.StateDm.ExistenceState;
+import smecalculus.bezmen.core.StateDm.PreviewState;
+import smecalculus.bezmen.core.StateDm.TouchState;
 import smecalculus.bezmen.storage.mybatis.SepulkaSqlMapper;
 
 @RequiredArgsConstructor

diff --git a/apps/sepuling/src/main/java/smecalculus/bezmen/storage/SepulkaDaoSpringData.java b/apps/sepuling/src/main/java/smecalculus/bezmen/storage/SepulkaDaoSpringData.java
@@ -4,7 +4,7 @@
 import java.util.UUID;
 import lombok.NonNull;
 import lombok.RequiredArgsConstructor;
-import smecalculus.bezmen.core.StateDomain;
+import smecalculus.bezmen.core.StateDm;
 import smecalculus.bezmen.storage.springdata.SepulkaRepository;
 
 @RequiredArgsConstructor
@@ -17,27 +17,27 @@ public class SepulkaDaoSpringData implements SepulkaDao {
     private SepulkaRepository repository;
 
     @Override
-    public StateDomain.AggregateState add(@NonNull StateDomain.AggregateState state) {
+    public StateDm.AggregateState add(@NonNull StateDm.AggregateState state) {
         var stateEdge = repository.save(mapper.toEdge(state));
         return mapper.toDomain(stateEdge);
     }
 
     @Override
-    public Optional<StateDomain.ExistenceState> getBy(@NonNull String externalId) {
+    public Optional<StateDm.ExistenceState> getBy(@NonNull String externalId) {
         return repository
-                .findByExternalId(externalId, StateEdge.ExistenceState.class)
+                .findByExternalId(externalId, StateEm.ExistenceState.class)
                 .map(mapper::toDomain);
     }
 
     @Override
-    public Optional<StateDomain.PreviewState> getBy(@NonNull UUID internalId) {
+    public Optional<StateDm.PreviewState> getBy(@NonNull UUID internalId) {
         return repository
-                .findByInternalId(internalId.toString(), StateEdge.PreviewState.class)
+                .findByInternalId(internalId.toString(), StateEm.PreviewState.class)
                 .map(mapper::toDomain);
     }
 
     @Override
-    public void updateBy(StateDomain.TouchState state, UUID internalId) {
+    public void updateBy(StateDm.TouchState state, UUID internalId) {
         var stateEdge = mapper.toEdge(state);
         var matchedCount = repository.updateBy(stateEdge, internalId.toString());
         if (matchedCount == 0) {

diff --git a/apps/sepuling/src/main/java/smecalculus/bezmen/storage/SepulkaStateMapper.java b/apps/sepuling/src/main/java/smecalculus/bezmen/storage/SepulkaStateMapper.java
@@ -1,20 +1,20 @@
 package smecalculus.bezmen.storage;
 
 import org.mapstruct.Mapper;
-import smecalculus.bezmen.core.StateDomain;
+import smecalculus.bezmen.core.StateDm;
 import smecalculus.bezmen.mapping.EdgeMapper;
 
 @Mapper
 public interface SepulkaStateMapper extends EdgeMapper {
-    StateEdge.AggregateState toEdge(StateDomain.AggregateState state);
+    StateEm.AggregateState toEdge(StateDm.AggregateState state);
 
-    StateDomain.AggregateState toDomain(StateEdge.AggregateState state);
+    StateDm.AggregateState toDomain(StateEm.AggregateState state);
 
-    StateEdge.TouchState toEdge(StateDomain.TouchState state);
+    StateEm.TouchState toEdge(StateDm.TouchState state);
 
-    StateDomain.ExistenceState toDomain(StateEdge.ExistenceState state);
+    StateDm.ExistenceState toDomain(StateEm.ExistenceState state);
 
-    StateEdge.PreviewState toEdge(StateDomain.PreviewState state);
+    StateEm.PreviewState toEdge(StateDm.PreviewState state);
 
-    StateDomain.PreviewState toDomain(StateEdge.PreviewState state);
+    StateDm.PreviewState toDomain(StateEm.PreviewState state);
 }
diff --git a/...smecalculus/bezmen/storage/StateEdge.java → ...a/smecalculus/bezmen/storage/StateEm.java b/...smecalculus/bezmen/storage/StateEdge.java → ...a/smecalculus/bezmen/storage/StateEm.java
@@ -8,7 +8,7 @@
 import org.springframework.data.relational.core.mapping.Column;
 import org.springframework.data.relational.core.mapping.Table;
 
-public abstract class StateEdge {
+public abstract class StateEm {
     @Data
     public static class ExistenceState {
         UUID internalId;

diff --git a/apps/sepuling/src/main/java/smecalculus/bezmen/storage/mybatis/SepulkaSqlMapper.java b/apps/sepuling/src/main/java/smecalculus/bezmen/storage/mybatis/SepulkaSqlMapper.java
@@ -5,10 +5,10 @@
 import org.apache.ibatis.annotations.Param;
 import org.apache.ibatis.annotations.Select;
 import org.apache.ibatis.annotations.Update;
-import smecalculus.bezmen.storage.StateEdge.AggregateState;
-import smecalculus.bezmen.storage.StateEdge.ExistenceState;
-import smecalculus.bezmen.storage.StateEdge.PreviewState;
-import smecalculus.bezmen.storage.StateEdge.TouchState;
+import smecalculus.bezmen.storage.StateEm.AggregateState;
+import smecalculus.bezmen.storage.StateEm.ExistenceState;
+import smecalculus.bezmen.storage.StateEm.PreviewState;
+import smecalculus.bezmen.storage.StateEm.TouchState;
 
 public interface SepulkaSqlMapper {
 

diff --git a/apps/sepuling/src/main/java/smecalculus/bezmen/storage/springdata/SepulkaRepository.java b/apps/sepuling/src/main/java/smecalculus/bezmen/storage/springdata/SepulkaRepository.java
@@ -6,8 +6,8 @@
 import org.springframework.data.repository.CrudRepository;
 import org.springframework.data.repository.query.Param;
 import org.springframework.lang.Nullable;
-import smecalculus.bezmen.storage.StateEdge.AggregateState;
-import smecalculus.bezmen.storage.StateEdge.TouchState;
+import smecalculus.bezmen.storage.StateEm.AggregateState;
+import smecalculus.bezmen.storage.StateEm.TouchState;
 
 public interface SepulkaRepository extends CrudRepository<AggregateState, String> {
 

diff --git a/apps/sepuling/src/test/java/smecalculus/bezmen/construction/SepulkaDaoBeans.java b/apps/sepuling/src/test/java/smecalculus/bezmen/construction/SepulkaDaoBeans.java
@@ -10,7 +10,7 @@
 import org.springframework.context.annotation.Import;
 import org.springframework.jdbc.datasource.embedded.EmbeddedDatabaseBuilder;
 import org.springframework.jdbc.datasource.embedded.EmbeddedDatabaseType;
-import smecalculus.bezmen.configuration.StorageDomain.StorageProps;
+import smecalculus.bezmen.configuration.StorageDm.StorageProps;
 import smecalculus.bezmen.storage.SepulkaDao;
 import smecalculus.bezmen.storage.SepulkaDaoMyBatis;
 import smecalculus.bezmen.storage.SepulkaDaoSpringData;

diff --git a/apps/sepuling/src/test/java/smecalculus/bezmen/construction/StoragePropsBeans.java b/apps/sepuling/src/test/java/smecalculus/bezmen/construction/StoragePropsBeans.java
@@ -1,41 +1,41 @@
 package smecalculus.bezmen.construction;
 
-import static smecalculus.bezmen.configuration.StorageMappingMode.MY_BATIS;
-import static smecalculus.bezmen.configuration.StorageMappingMode.SPRING_DATA;
-import static smecalculus.bezmen.configuration.StorageProtocolMode.H2;
-import static smecalculus.bezmen.configuration.StorageProtocolMode.POSTGRES;
+import static smecalculus.bezmen.configuration.StorageDm.MappingMode.MY_BATIS;
+import static smecalculus.bezmen.configuration.StorageDm.MappingMode.SPRING_DATA;
+import static smecalculus.bezmen.configuration.StorageDm.ProtocolMode.H2;
+import static smecalculus.bezmen.configuration.StorageDm.ProtocolMode.POSTGRES;
 
 import org.springframework.context.annotation.Bean;
-import smecalculus.bezmen.configuration.StorageDomain.StorageProps;
-import smecalculus.bezmen.configuration.StorageDomainEg;
+import smecalculus.bezmen.configuration.StorageDm.StorageProps;
+import smecalculus.bezmen.configuration.StorageDmEg;
 
 public class StoragePropsBeans {
 
     public static class SpringDataPostgres {
         @Bean
         public StorageProps storageProps() {
-            return StorageDomainEg.storageProps(SPRING_DATA, POSTGRES).build();
+            return StorageDmEg.storageProps(SPRING_DATA, POSTGRES).build();
         }
     }
 
     public static class SpringDataH2 {
         @Bean
         public StorageProps storageProps() {
-            return StorageDomainEg.storageProps(SPRING_DATA, H2).build();
+            return StorageDmEg.storageProps(SPRING_DATA, H2).build();
         }
     }
 
     public static class MyBatisPostgres {
         @Bean
         public StorageProps storageProps() {
-            return StorageDomainEg.storageProps(MY_BATIS, POSTGRES).build();
+            return StorageDmEg.storageProps(MY_BATIS, POSTGRES).build();
         }
     }
 
     public static class MyBatisH2 {
         @Bean
         public StorageProps storageProps() {
-            return StorageDomainEg.storageProps(MY_BATIS, H2).build();
+            return StorageDmEg.storageProps(MY_BATIS, H2).build();
         }
     }
 }
diff --git a/apps/sepuling/src/test/java/smecalculus/bezmen/messaging/SepulkaClientIT.java b/apps/sepuling/src/test/java/smecalculus/bezmen/messaging/SepulkaClientIT.java
@@ -11,8 +11,8 @@
 import org.springframework.test.context.ContextConfiguration;
 import org.springframework.test.context.junit.jupiter.SpringExtension;
 import smecalculus.bezmen.construction.SepulkaClientBeans;
-import smecalculus.bezmen.core.MessageDomain.RegistrationRequest;
-import smecalculus.bezmen.core.MessageDomainEg;
+import smecalculus.bezmen.core.MessageDm.RegistrationRequest;
+import smecalculus.bezmen.core.MessageDmEg;
 import smecalculus.bezmen.core.SepulkaService;
 
 @ExtendWith(SpringExtension.class)
@@ -30,12 +30,12 @@ void shouldRegisterSepulka() {
         // given
         var externalId = UUID.randomUUID().toString();
         // and
-        var request = MessageEdgeEg.registrationRequest(externalId);
+        var request = MessageEmEg.registrationRequest(externalId);
         // and
         when(serviceMock.register(any(RegistrationRequest.class)))
-                .thenReturn(MessageDomainEg.registrationResponse(externalId).build());
+                .thenReturn(MessageDmEg.registrationResponse(externalId).build());
         // and
-        var expectedResponse = MessageEdgeEg.registrationResponse(externalId);
+        var expectedResponse = MessageEmEg.registrationResponse(externalId);
         // when
         var actualResponse = externalClient.register(request);
         // then

diff --git a/apps/sepuling/src/test/java/smecalculus/bezmen/storage/SepulkaDaoIT.java b/apps/sepuling/src/test/java/smecalculus/bezmen/storage/SepulkaDaoIT.java
@@ -10,7 +10,7 @@
 import org.springframework.test.context.jdbc.Sql;
 import org.springframework.test.context.junit.jupiter.SpringExtension;
 import smecalculus.bezmen.construction.SepulkaDaoBeans;
-import smecalculus.bezmen.core.StateDomainEg;
+import smecalculus.bezmen.core.StateDmEg;
 
 @DirtiesContext
 @ExtendWith(SpringExtension.class)
@@ -24,10 +24,10 @@ abstract class SepulkaDaoIT {
     @Test
     void shouldAddOneSepulka() {
         // given
-        var expected1 = StateDomainEg.aggregateState().build();
+        var expected1 = StateDmEg.aggregateState().build();
         // and
         var expected2 =
-                StateDomainEg.creationState().internalId(expected1.internalId()).build();
+                StateDmEg.creationState().internalId(expected1.internalId()).build();
         // when
         var actualSaved = sepulkaDao.add(expected1);
         // and
@@ -41,11 +41,11 @@ void shouldAddOneSepulka() {
     @Test
     void shouldViewOneSepulka() {
         // given
-        var aggregate = StateDomainEg.aggregateState().build();
+        var aggregate = StateDmEg.aggregateState().build();
         // and
         sepulkaDao.add(aggregate);
         // and
-        var expected = StateDomainEg.previewState(aggregate).build();
+        var expected = StateDmEg.previewState(aggregate).build();
         // when
         var actual = sepulkaDao.getBy(aggregate.internalId());
         // then
@@ -55,13 +55,13 @@ void shouldViewOneSepulka() {
     @Test
     void shouldUpdateOneSepulka() {
         // given
-        var aggregate = StateDomainEg.aggregateState().build();
+        var aggregate = StateDmEg.aggregateState().build();
         // and
         sepulkaDao.add(aggregate);
         // and
         var updatedAt = aggregate.updatedAt().plusSeconds(1);
         // and
-        var touch = StateDomainEg.touchState(aggregate).updatedAt(updatedAt).build();
+        var touch = StateDmEg.touchState(aggregate).updatedAt(updatedAt).build();
         // when
         sepulkaDao.updateBy(touch, aggregate.internalId());
         // then

diff --git a/...alculus/bezmen/messaging/MessageEdge.java → ...ecalculus/bezmen/messaging/MessageEm.java b/...alculus/bezmen/messaging/MessageEdge.java → ...ecalculus/bezmen/messaging/MessageEm.java
@@ -4,7 +4,7 @@
 import jakarta.validation.constraints.Size;
 import lombok.Data;
 
-public abstract class MessageEdge {
+public abstract class MessageEm {
     @Data
     public static class RegistrationRequest {
         @NotNull

diff --git a/...culus/bezmen/messaging/MessageEdgeEg.java → ...alculus/bezmen/messaging/MessageEmEg.java b/...culus/bezmen/messaging/MessageEdgeEg.java → ...alculus/bezmen/messaging/MessageEmEg.java
@@ -1,10 +1,10 @@
 package smecalculus.bezmen.messaging;
 
 import java.util.UUID;
-import smecalculus.bezmen.messaging.MessageEdge.RegistrationRequest;
-import smecalculus.bezmen.messaging.MessageEdge.RegistrationResponse;
+import smecalculus.bezmen.messaging.MessageEm.RegistrationRequest;
+import smecalculus.bezmen.messaging.MessageEm.RegistrationResponse;
 
-public abstract class MessageEdgeEg {
+public abstract class MessageEmEg {
     public static RegistrationRequest registrationRequest() {
         var requestEdge = new RegistrationRequest();
         requestEdge.setExternalId(UUID.randomUUID().toString());

diff --git a/libs/abstraction-client/src/main/java/smecalculus/bezmen/messaging/SepulkaClient.java b/libs/abstraction-client/src/main/java/smecalculus/bezmen/messaging/SepulkaClient.java
@@ -1,7 +1,7 @@
 package smecalculus.bezmen.messaging;
 
-import smecalculus.bezmen.messaging.MessageEdge.RegistrationRequest;
-import smecalculus.bezmen.messaging.MessageEdge.RegistrationResponse;
+import smecalculus.bezmen.messaging.MessageEm.RegistrationRequest;
+import smecalculus.bezmen.messaging.MessageEm.RegistrationResponse;
 
 /**
  * Port: client side

diff --git a/...mecalculus/bezmen/core/MessageDomain.java → ...va/smecalculus/bezmen/core/MessageDm.java b/...mecalculus/bezmen/core/MessageDomain.java → ...va/smecalculus/bezmen/core/MessageDm.java
@@ -3,7 +3,7 @@
 import lombok.Builder;
 import lombok.NonNull;
 
-public class MessageDomain {
+public class MessageDm {
     @Builder
     public record RegistrationRequest(@NonNull String externalId) {}