add assign role to staff feature

authorizationapp/delivery/http/handler.go

@@ -42,3 +42,18 @@ func (r RoleHandler) Update(c echo.Context) error {
 
 	return c.JSON(http.StatusOK, echo.Map{"message": fmt.Sprintf("role %s updated successfully", role.Title_fa)})
 }
+
+func (r RoleHandler) AssignRoleToStaff(c echo.Context) error {
+	var request service.AssignRoleToStaffRequest
+
+	if err := c.Bind(&request); err != nil {
+		return c.JSON(http.StatusBadRequest, echo.Map{"error": "Invalid request body", "details": err.Error()})
+	}
+
+	err := r.service.AssignRoleToStaff(c.Request().Context(), request)
+	if err != nil {
+		return c.JSON(http.StatusBadRequest, echo.Map{"error": "Failed to assign roles to staff", "details": err.Error()})
+	}
+
+	return c.JSON(http.StatusOK, echo.Map{"message": fmt.Sprintf("Roles assigned to staff ID %d successfully", request.StaffID)})
+}

authorizationapp/delivery/http/server.go

@@ -25,6 +25,7 @@ func (s RoleServer) Start() {
 	group := e.Group("/role")
 	group.POST("/create", s.handler.Store)
 	group.PUT("/update/:id", s.handler.Update)
+	group.POST("/assign", s.handler.AssignRoleToStaff)
 
 	address := fmt.Sprintf("%s:%s", s.cfg.Host, s.cfg.Port)
 	err := e.Start(address)

domain/authorization/repository/migrations/1779100308_create_role_user_table.sql

@@ -0,0 +1,20 @@
+    -- +migrate Up
+    CREATE TABLE IF NOT EXISTS `role_staff` (
+        `staff_id` BIGINT NOT NULL,
+        `role_id` BIGINT NOT NULL,
+        `created_at` TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+        PRIMARY KEY (`staff_id`, `role_id`),
+        CONSTRAINT `fk_role_staff_staff`
+            FOREIGN KEY (`staff_id`) REFERENCES `staffs` (`id`)
+            ON DELETE CASCADE
+            ON UPDATE CASCADE,
+        CONSTRAINT `fk_role_staff_role`
+            FOREIGN KEY (`role_id`) REFERENCES `roles` (`id`)
+            ON DELETE CASCADE
+            ON UPDATE CASCADE,
+        INDEX `idx_role_staff_staff_id` (`staff_id`),
+        INDEX `idx_role_staff_role_id` (`role_id`)
+    ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci;
+
+    -- +migrate Down
+    DROP TABLE IF EXISTS `role_staff`;

domain/authorization/repository/mysql_repo.go

@@ -51,7 +51,6 @@ func (m RoleRepo) Update(ctx context.Context, req service.UpdateRoleRequest) (ty
 	return types.ID(req.ID), nil
 }
 
-
 func (m RoleRepo) IsRoleExistsByID(ctx context.Context, id types.ID) error {
 	const op = "domain.authorization.repository.role.is_exists_by_id"
 
@@ -62,3 +61,25 @@ func (m RoleRepo) IsRoleExistsByID(ctx context.Context, id types.ID) error {
 	}
 	return nil
 }
+
+func (m RoleRepo) AssignRoleToStaff(ctx context.Context, staffID types.ID, rolesID []types.ID) error {
+	const op = "domain.authorization.repository.role.assign_role_to_staff"
+
+	query := "INSERT INTO role_staff (staff_id, role_id) VALUES "
+	var args []interface{}
+
+	for i, roleID := range rolesID {
+		if i > 0 {
+			query += ", "
+		}
+		query += "(?, ?)"
+		args = append(args, staffID, roleID)
+	}
+
+	_, err := m.conn.Conn().ExecContext(ctx, query, args...)
+	if err != nil {
+		return richerror.New(op).WithErr(err)
+	}
+
+	return nil
+}

domain/authorization/service/assign.go

@@ -0,0 +1,15 @@
+package service
+
+import (
+	"context"
+	richerror "git.gocasts.ir/ebhomengo/niki/pkg/rich_error"
+)
+
+func (a Authorization) AssignRoleToStaff(ctx context.Context, req AssignRoleToStaffRequest) error {
+	const op = "service.authorization.assign_role_to_staff"
+
+	if err := a.roleRepo.AssignRoleToStaff(ctx, req.StaffID, req.RolesID); err != nil {
+		return richerror.New(op).WithErr(err)
+	}
+	return nil
+}

domain/authorization/service/param.go

@@ -15,3 +15,8 @@ type UpdateRoleRequest struct {
 	ID types.ID `json:"id"`
 	RoleRequest
 }
+
+type AssignRoleToStaffRequest struct {
+	StaffID types.ID `json:"staff_id"`
+	RolesID []types.ID `json:"roles_id"`
+}

domain/authorization/service/repo_contract.go

@@ -9,4 +9,5 @@ type RoleRepo interface {
 	Store(ctx context.Context, req StoreRoleRequest) (types.ID, error)
 	Update(ctx context.Context, req UpdateRoleRequest) (types.ID, error)
 	IsRoleExistsByID(ctx context.Context, id types.ID) error
+	AssignRoleToStaff(ctx context.Context, staffID types.ID, rolesID []types.ID) error
 }