fix(users): update user's image

Author: Mario G.

src/liceo/infra/adapters/migrations/20250915_initial_migration.sql

@@ -77,7 +77,11 @@ CREATE TABLE IF NOT EXISTS liceo_users_images (
     dimension TEXT DEFAULT 'original', -- small, medium, large, original
     created_at TIMESTAMP NOT NULL,
     created_by TEXT NOT NULL,
+    last_updated_at TIMESTAMP,
+    last_updated_by TEXT,
+    UNIQUE("user_id", "dimension"),
     CONSTRAINT fk_users_images_created_by FOREIGN KEY (created_by) REFERENCES liceo_users(id),
+    CONSTRAINT fk_users_images_last_updated_by FOREIGN KEY (last_updated_by) REFERENCES liceo_users(id),
     CONSTRAINT fk_users_images_users FOREIGN KEY (user_id) REFERENCES liceo_users(id),
     CONSTRAINT fk_users_images_storage FOREIGN KEY (storage_id) REFERENCES liceo_storage(id)
 );

src/liceo/security/users/adapters/repositories.py

@@ -1,5 +1,5 @@
 from liceo.infra.domain.vo import Paged, AuditInfo
-from liceo.security.users.application.dtos import FilterUsersDTO, UserDTO, SaveUserImageDTO
+from liceo.security.users.application.dtos import FilterUsersDTO, UserDTO, UpsertUserImageDTO
 from liceo.security.users.domain.entities import User
 from liceo.labs.db.sql import SQLRepository, sql
 from ..application.repository import UsersRepository, UsersImagesRepository
@@ -137,12 +137,16 @@ def update_security(self, user: User) -> User:
 
 
 class SQLUsersImagesRepository(UsersImagesRepository, SQLRepository):
-    def save_user_image(self, dto: SaveUserImageDTO) -> None:
+    def save_user_image(self, dto: UpsertUserImageDTO) -> None:
         sql = self.resolve_sql(self.save_user_image)
-        self._get_connection().execute(sql, params={
+        params = params = {
             "user_id": dto.user_id,
             "storage_id": dto.photo_id,
             "dimension": dto.dimension,
             "created_at": dto.created_at,
-            "created_by": dto.created_by
-        })
+            "created_by": dto.created_by,
+            "last_updated_by": dto.last_updated_by,
+            "last_updated_at": dto.last_updated_at
+        }
+        print(params)
+        self._get_connection().execute(sql, params)

src/liceo/security/users/adapters/service.py

@@ -1,3 +1,4 @@
+from datetime import datetime
 from dataclasses import dataclass
 from liceo.infra.domain.vo import Paged
 from liceo.labs.sherlock.application.service import EventStoreService
@@ -53,7 +54,7 @@ def list(self, input: dtos.FilterUsersDTO) -> Paged[dtos.UserDTO]:
     def _save_user_photo(self, user: entities.User) -> None:
         if user.photo:
             self.images.save_user_image(
-                dtos.SaveUserImageDTO(
+                dtos.UpsertUserImageDTO(
                     user_id=user.id.id,
                     photo_id=user.photo,
                     dimension="original",
@@ -62,6 +63,21 @@ def _save_user_photo(self, user: entities.User) -> None:
                 )
             )
 
+    def _update_user_photo(self, user: entities.User, updated_by: dtos.CurrentUserDTO) -> None:
+        if user.photo:
+            photo_created_at = datetime.now()
+            self.images.save_user_image(
+                dtos.UpsertUserImageDTO(
+                    user_id=user.id.id,
+                    photo_id=user.photo,
+                    dimension="original",
+                    created_at=photo_created_at,
+                    created_by=updated_by.id,
+                    last_updated_at=photo_created_at,
+                    last_updated_by=updated_by.id
+                )
+            )
+
     @transactional()
     def create_user(self, input: dtos.CreateUserDTO) -> entities.User:
         command = entities.User.CreateUserCommand(
@@ -99,8 +115,8 @@ def update_user(self, input: dtos.UpdateUserDetailsDTO) -> entities.User | None:
         ))
         # saving user
         saved_user = self.users.update_user(updated)
-        # saving user photo
-        self._save_user_photo(saved_user)
+        # update user photo
+        self._update_user_photo(saved_user, input.updated_by)
         # saving event trail
         self.event_store.append(saved_user)
         # return saved_user

src/liceo/security/users/adapters/sql/save_user_image.sql

@@ -13,4 +13,10 @@ VALUES
     :dimension,
     :created_at,
     :created_by
-);
+)
+ON CONFLICT (user_id, dimension)
+DO UPDATE SET
+    storage_id=:storage_id,
+    dimension=:dimension,
+    last_updated_at=:last_updated_at,
+    last_updated_by=:last_updated_by;

src/liceo/security/users/application/dtos.py

@@ -41,12 +41,14 @@ class UserDTO:
 
 
 @dataclass
-class SaveUserImageDTO:
+class UpsertUserImageDTO:
     user_id: str
     photo_id: str
     dimension: str
-    created_by: str
-    created_at: datetime
+    created_by: str | None = field(default=None)
+    created_at: datetime | None = field(default=datetime.now())
+    last_updated_by: str | None = field(default=None)
+    last_updated_at: datetime | None = field(default=datetime.now())
 
 
 @dataclass

src/liceo/security/users/application/repository.py

@@ -2,7 +2,7 @@
 from liceo.infra.application.output import AbstractRepository
 from liceo.infra.domain.vo import Paged
 from ..domain.entities import User
-from .dtos import FilterUsersDTO, UserDTO, SaveUserImageDTO
+from .dtos import FilterUsersDTO, UserDTO, UpsertUserImageDTO
 
 
 class UsersRepository(AbstractRepository):
@@ -33,5 +33,5 @@ def update_security(self, user: User) -> User:
 
 class UsersImagesRepository(AbstractRepository):
     @abstractmethod
-    def save_user_image(self, dto: SaveUserImageDTO) -> None:
+    def save_user_image(self, dto: UpsertUserImageDTO) -> None:
         pass

src/liceo/security/users/domain/entities.py

@@ -31,6 +31,7 @@ class DetailsChanged(AggregateEvent):
 
         def handle(self, aggregate: "User"):
             aggregate.mark_updated_by(self.changed_by)
+            aggregate.photo = self.photo
             aggregate.name = self.name
             aggregate.surname = self.surname
             aggregate.username = self.username