fix(archi): clean archi of the project

Author: MayuriXx

Dockerfile

@@ -18,16 +18,16 @@ RUN ./mvnw package -DskipTests -B
 FROM eclipse-temurin:25-jre
 WORKDIR /app
 
-# Create a non-root user and group for running the application securely
+# Create a non-root userDAO and group for running the application securely
 RUN groupadd --system appgroup && useradd --system --gid appgroup appuser
 
 # Copy the built JAR from the build stage using a stable pattern so version changes do not break the image build
 COPY --from=build /app/target/*.jar app.jar
 
-# Ensure the non-root user owns the application files
+# Ensure the non-root userDAO owns the application files
 RUN chown -R appuser:appgroup /app
 
-# Switch to the non-root user
+# Switch to the non-root userDAO
 USER appuser
 
 # Document the port the application listens on

README.md

@@ -77,11 +77,11 @@ The Dockerfile uses two stages to produce a lightweight, secure final image:
 | Stage | Image | Role |
 |-------|-------|------|
 | **Build** | `eclipse-temurin:25-jdk` | Compiles the JAR with Maven (full JDK) |
-| **Run** | `eclipse-temurin:25-jre` | Runs the application (lightweight JRE, non-root user) |
+| **Run** | `eclipse-temurin:25-jre` | Runs the application (lightweight JRE, non-root userDAO) |
 
 > **Why Eclipse Temurin?** Reference OpenJDK distribution: free, open-source, maintained by the Eclipse Foundation (Adoptium).
 
-> **Security:** The final image runs as a non-root user (`appuser`), without source code or build tools.
+> **Security:** The final image runs as a non-root userDAO (`appuser`), without source code or build tools.
 
 ### Compose Profiles
 
@@ -152,10 +152,10 @@ dummy.api.base-url=https://dummyjson.com/
 | Method | Path                     | Description | Status |
 |--------|--------------------------|-------------|--------|
 | `GET` | `/random-users?page=1&size=10&source=DUMMY` | Fetch and save users from selected external API source | ✅ |
-| `GET` | `/random-users/{id}`     | Get user by ID | ✅ |
-| `POST` | `/random-users`          | Create a new user | ✅ |
-| `PUT` | `/random-users/{id}`     | Update user | ✅ |
-| `DELETE` | `/random-users/{id}`     | Delete user | ✅ |
+| `GET` | `/random-users/{id}`     | Get userDAO by ID | ✅ |
+| `POST` | `/random-users`          | Create a new userDAO | ✅ |
+| `PUT` | `/random-users/{id}`     | Update userDAO | ✅ |
+| `DELETE` | `/random-users/{id}`     | Delete userDAO | ✅ |
 | `GET` | `/random-users/filter` | Filter users by criteria | ✅ |
 
 ### Example Request
@@ -167,10 +167,10 @@ curl -X GET "http://localhost:8080/random-users?page=1&size=10&source=DUMMY"
 # Fetch 10 users from randomuser.me and store them
 curl -X GET "http://localhost:8080/random-users?page=1&size=10&source=RANDOM_USER"
 
-# Get user by ID
+# Get userDAO by ID
 curl -X GET "http://localhost:8080/random-users/1"
 
-# Create user
+# Create userDAO
 curl -X POST "http://localhost:8080/random-users" \
   -H "Content-Type: application/json" \
   -d '{
@@ -190,7 +190,7 @@ curl -X GET "http://localhost:8080/random-users/filter?gender=MALE&nat=FR"
 # Filter users by firstname (partial match, case-insensitive)
 curl -X GET "http://localhost:8080/random-users/filter?firstname=john"
 
-# Update user
+# Update userDAO
 curl -X PUT "http://localhost:8080/random-users/1" \
   -H "Content-Type: application/json" \
   -d '{
@@ -257,7 +257,7 @@ curl -X PUT "http://localhost:8080/random-users/1" \
 ### Domain Service Ports
 
 - `LocalUserService`: local persistence operations (save, read, delete) backed by PostgreSQL.
-- `RemoteUserService`: external user source contract used by use cases.
+- `RemoteUserService`: external userDAO source contract used by use cases.
 
 ### External Source Adapter
 
@@ -431,8 +431,8 @@ This project integrates with **DummyJSON Users API**:
 - **Users Endpoint**: https://dummyjson.com/users
 - **Documentation**: https://dummyjson.com/docs/users
 - **Features**:
-  - Paginated user retrieval (`limit`, `skip`)
-  - Stable JSON schema for user fixtures
+  - Paginated userDAO retrieval (`limit`, `skip`)
+  - Stable JSON schema for userDAO fixtures
   - Fast sandbox API for development/testing
 
 ---
@@ -442,9 +442,9 @@ This project integrates with **DummyJSON Users API**:
 Contributions are welcome! Please follow these steps:
 
 1. Fork the repository
-2. Create a feature branch (`git checkout -b feature/amazing-feature`)
-3. Commit changes (`git commit -m 'Add amazing feature'`)
-4. Push to branch (`git push origin feature/amazing-feature`)
+2. Create a features branch (`git checkout -b features/amazing-features`)
+3. Commit changes (`git commit -m 'Add amazing features'`)
+4. Push to branch (`git push origin features/amazing-features`)
 5. Open a Pull Request
 
 ---

mvnw.cmd

@@ -31,7 +31,7 @@
 		<testcontainers.version>2.0.4</testcontainers.version>
 		<skipDocker>false</skipDocker>
 		<sonar.coverage.exclusions>**/*Application.java</sonar.coverage.exclusions>
-		<sonar.test.exclusions>**/feature/SpringIntegrationTest.java</sonar.test.exclusions>
+		<sonar.test.exclusions>**/features/SpringIntegrationTest.java</sonar.test.exclusions>
 		<sonar.coverage.jacoco.xmlReportPaths>${project.build.directory}/site/jacoco/jacoco.xml</sonar.coverage.jacoco.xmlReportPaths>
 	</properties>
 

pom.xml

@@ -2,40 +2,40 @@
 
 import com.xpeho.spring_boot_java_random_user.data.models.api.dummy.DummyUserResultDTO;
 import com.xpeho.spring_boot_java_random_user.data.models.api.randomuser.RandomUserResultDTO;
-import com.xpeho.spring_boot_java_random_user.data.models.database.User;
+import com.xpeho.spring_boot_java_random_user.data.models.database.UserDAO;
 import com.xpeho.spring_boot_java_random_user.domain.entities.UserEntity;
 import org.springframework.stereotype.Service;
 
 
 @Service
 public class UserConverter {
     // Domain -> DAO
-    public User toDao(UserEntity entity) {
-        User user = new User();
-        user.setId(entity.id());
-        user.setGender(entity.gender());
-        user.setFirstname(entity.firstname());
-        user.setLastname(entity.lastname());
-        user.setCivility(entity.civility());
-        user.setEmail(entity.email());
-        user.setPhone(entity.phone());
-        user.setPicture(entity.picture());
-        user.setNationality(entity.nat());
-        return user;
+    public UserDAO toDao(UserEntity entity) {
+        UserDAO userDAO = new UserDAO();
+        userDAO.setId(entity.id());
+        userDAO.setGender(entity.gender());
+        userDAO.setFirstname(entity.firstname());
+        userDAO.setLastname(entity.lastname());
+        userDAO.setCivility(entity.civility());
+        userDAO.setEmail(entity.email());
+        userDAO.setPhone(entity.phone());
+        userDAO.setPicture(entity.picture());
+        userDAO.setNationality(entity.nat());
+        return userDAO;
     }
 
     // DAO -> Domain
-    public UserEntity toDomain(User user) {
+    public UserEntity toDomain(UserDAO userDAO) {
         return new UserEntity(
-                user.getId(),
-                user.getGender(),
-                user.getFirstname(),
-                user.getLastname(),
-                user.getCivility(),
-                user.getEmail(),
-                user.getPhone(),
-                user.getPicture(),
-                user.getNationality()
+                userDAO.getId(),
+                userDAO.getGender(),
+                userDAO.getFirstname(),
+                userDAO.getLastname(),
+                userDAO.getCivility(),
+                userDAO.getEmail(),
+                userDAO.getPhone(),
+                userDAO.getPicture(),
+                userDAO.getNationality()
         );
     }
 

src/main/java/com/xpeho/spring_boot_java_random_user/data/converters/UserConverter.java

@@ -9,7 +9,7 @@
 
 @Entity
 @Table(name = "users")
-public class User {
+public class UserDAO {
     @Id
     @GeneratedValue(strategy = GenerationType.IDENTITY)
     @Column(name = "id")
@@ -32,7 +32,7 @@ public class User {
     private String nationality;
 
     // Required by JPA
-    public User() {
+    public UserDAO() {
         // No initialization needed
     }
 

…ndom_user/data/models/database/User.java …m_user/data/models/database/UserDAO.javasrc/main/java/com/xpeho/spring_boot_java_random_user/data/models/database/User.java renamed to src/main/java/com/xpeho/spring_boot_java_random_user/data/models/database/UserDAO.java src/main/java/com/xpeho/spring_boot_java_random_user/data/models/database/User.java renamed to src/main/java/com/xpeho/spring_boot_java_random_user/data/models/database/UserDAO.java

@@ -1,33 +1,48 @@
 package com.xpeho.spring_boot_java_random_user.data.services;
 
 import com.xpeho.spring_boot_java_random_user.data.converters.UserConverter;
-import com.xpeho.spring_boot_java_random_user.data.models.database.User;
+import com.xpeho.spring_boot_java_random_user.data.models.database.UserDAO;
+import com.xpeho.spring_boot_java_random_user.data.sources.api.RemoteUserService;
 import com.xpeho.spring_boot_java_random_user.data.sources.database.UserRepository;
 import com.xpeho.spring_boot_java_random_user.data.sources.database.UserSpecifications;
+import com.xpeho.spring_boot_java_random_user.domain.entities.PaginatedUsers;
 import com.xpeho.spring_boot_java_random_user.domain.entities.UserEntity;
 import com.xpeho.spring_boot_java_random_user.domain.entities.UserFilter;
-import com.xpeho.spring_boot_java_random_user.domain.services.LocalUserService;
+import com.xpeho.spring_boot_java_random_user.domain.enums.UserSource;
+import com.xpeho.spring_boot_java_random_user.domain.services.UserService;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.Pageable;
 import org.springframework.stereotype.Service;
 
+import java.io.IOException;
 import java.util.List;
+import java.util.Map;
 import java.util.Optional;
+import java.util.function.Function;
+import java.util.stream.Collectors;
 import java.util.stream.StreamSupport;
 
 @Service
-
-public class UserServiceImpl implements LocalUserService {
+public class UserServiceImpl implements UserService {
     private final UserRepository userRepository;
     private final UserConverter userConverter;
+    private final Map<UserSource, RemoteUserService> remoteUserServices;
 
-    public UserServiceImpl(UserRepository userRepository, UserConverter userConverter) {
+    public UserServiceImpl(
+            UserRepository userRepository,
+            UserConverter userConverter,
+            List<RemoteUserService> remoteUserServices
+    ) {
         this.userRepository = userRepository;
         this.userConverter = userConverter;
+        this.remoteUserServices = remoteUserServices.stream()
+                .collect(Collectors.toMap(RemoteUserService::getSource, Function.identity()));
     }
 
     @Override
     public List<UserEntity> saveAll(List<UserEntity> users) {
-        List<User> daoUsers = users.stream().map(userConverter::toDao).toList();
-        Iterable<User> saved = userRepository.saveAll(daoUsers);
+        List<UserDAO> daoUserDAOS = users.stream().map(userConverter::toDao).toList();
+        Iterable<UserDAO> saved = userRepository.saveAll(daoUserDAOS);
         return StreamSupport.stream(saved.spliterator(), false)
                 .map(userConverter::toDomain)
                 .toList();
@@ -41,8 +56,8 @@ public Optional<UserEntity> getById(long id) {
 
     @Override
     public UserEntity save(UserEntity user) {
-        User savedUser = userRepository.save(userConverter.toDao(user));
-        return userConverter.toDomain(savedUser);
+        UserDAO savedUserDAO = userRepository.save(userConverter.toDao(user));
+        return userConverter.toDomain(savedUserDAO);
     }
 
     @Override
@@ -51,9 +66,19 @@ public void deleteById(long id) {
     }
 
     @Override
-    public List<UserEntity> filterUsers(UserFilter filter) {
-        return userRepository.findAll(UserSpecifications.byFilter(filter)).stream()
-                .map(userConverter::toDomain)
-                .toList();
+    public Page<UserEntity> filterUsers(UserFilter filter, Pageable pageable) {
+        return userRepository.findAll(UserSpecifications.byFilter(filter), pageable)
+                .map(userConverter::toDomain);
+    }
+
+    @Override
+    public PaginatedUsers fetchAndSaveUsers(int page, int size, UserSource source) throws IOException {
+        RemoteUserService remoteService = remoteUserServices.get(source);
+        if (remoteService == null) {
+            throw new IllegalStateException("No remote service configured for source: " + source);
+        }
+        PaginatedUsers response = remoteService.fetchUsers(page, size);
+        saveAll(response.data());
+        return response;
     }
 }

src/main/java/com/xpeho/spring_boot_java_random_user/data/services/UserServiceImpl.java

@@ -1,4 +1,4 @@
-package com.xpeho.spring_boot_java_random_user.domain.services;
+package com.xpeho.spring_boot_java_random_user.data.sources.api;
 
 import com.xpeho.spring_boot_java_random_user.domain.entities.PaginatedUsers;
 import com.xpeho.spring_boot_java_random_user.domain.enums.UserSource;

…r/domain/services/RemoteUserService.java …/data/sources/api/RemoteUserService.javasrc/main/java/com/xpeho/spring_boot_java_random_user/domain/services/RemoteUserService.java renamed to src/main/java/com/xpeho/spring_boot_java_random_user/data/sources/api/RemoteUserService.java src/main/java/com/xpeho/spring_boot_java_random_user/domain/services/RemoteUserService.java renamed to src/main/java/com/xpeho/spring_boot_java_random_user/data/sources/api/RemoteUserService.java

@@ -0,0 +1,60 @@
+package com.xpeho.spring_boot_java_random_user.data.sources.api;
+
+import com.xpeho.spring_boot_java_random_user.data.sources.api.dummy.DummyUserApi;
+import com.xpeho.spring_boot_java_random_user.data.sources.api.randomuser.RandomUserApi;
+import jakarta.annotation.PreDestroy;
+import okhttp3.OkHttpClient;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.core.env.Environment;
+import retrofit2.Retrofit;
+import retrofit2.converter.gson.GsonConverterFactory;
+
+@Configuration
+public class UserApiConfig {
+
+    private OkHttpClient okHttpClient;
+
+    @Bean
+    public OkHttpClient okHttpClient() {
+        okHttpClient = new OkHttpClient.Builder().build();
+        return okHttpClient;
+    }
+
+    @Bean(name = "dummyUserRetrofit")
+    public Retrofit dummyUserRetrofit(OkHttpClient okHttpClient, Environment env) {
+        return new Retrofit.Builder()
+                .baseUrl(env.getRequiredProperty("dummy.api.base-url"))
+                .client(okHttpClient)
+                .addConverterFactory(GsonConverterFactory.create())
+                .build();
+    }
+
+    @Bean
+    public DummyUserApi dummyUserApi(@Qualifier("dummyUserRetrofit") Retrofit dummyUserRetrofit) {
+        return dummyUserRetrofit.create(DummyUserApi.class);
+    }
+
+    @Bean(name = "randomUserRetrofit")
+    public Retrofit randomUserRetrofit(OkHttpClient okHttpClient, Environment env) {
+        return new Retrofit.Builder()
+                .baseUrl(env.getRequiredProperty("randomuser.api.base-url"))
+                .client(okHttpClient)
+                .addConverterFactory(GsonConverterFactory.create())
+                .build();
+    }
+
+    @Bean
+    public RandomUserApi randomUserApi(@Qualifier("randomUserRetrofit") Retrofit randomUserRetrofit) {
+        return randomUserRetrofit.create(RandomUserApi.class);
+    }
+
+    @PreDestroy
+    public void destroy() {
+        if (okHttpClient != null) {
+            okHttpClient.dispatcher().executorService().shutdown();
+            okHttpClient.connectionPool().evictAll();
+        }
+    }
+}