合宿への参加登録

backend/handler/camps.go

@@ -174,3 +174,51 @@ func (s *Server) PutCamp(e echo.Context, campID CampId, params PutCampParams) er
 
 	return e.JSON(http.StatusOK, response)
 }
+
+func (s *Server) PostCampParticipant(e echo.Context, campID CampId, params PostCampParticipantParams) error {
+	user, err := s.repo.GetOrCreateUser(*params.XForwardedUser)
+
+	if err != nil {
+		e.Logger().Errorf("failed to get or create user: %v", err)
+
+		return echo.NewHTTPError(http.StatusInternalServerError, "Internal server error")
+	}
+
+	if err := s.repo.AddUserToCamp(uint(campID), user); err != nil {
+		if errors.Is(err, model.ErrNotFound) {
+			return echo.NewHTTPError(http.StatusNotFound, "Not found")
+		}
+
+		if errors.Is(err, model.ErrAlreadyExists) {
+			return echo.NewHTTPError(http.StatusConflict, "User already exists in camp")
+		}
+
+		e.Logger().Errorf("failed to add user to camp: %v", err)
+
+		return echo.NewHTTPError(http.StatusInternalServerError, "Internal server error")
+	}
+
+	return e.NoContent(http.StatusNoContent)
+}
+
+func (s *Server) DeleteCampParticipant(e echo.Context, campID CampId, params DeleteCampParticipantParams) error {
+	user, err := s.repo.GetOrCreateUser(*params.XForwardedUser)
+
+	if err != nil {
+		e.Logger().Errorf("failed to get or create user: %v", err)
+
+		return echo.NewHTTPError(http.StatusInternalServerError, "Internal server error")
+	}
+
+	if err := s.repo.RemoveUserFromCamp(uint(campID), user); err != nil {
+		if errors.Is(err, model.ErrNotFound) {
+			return echo.NewHTTPError(http.StatusNotFound, "Not found")
+		}
+
+		e.Logger().Errorf("failed to remove user from camp: %v", err)
+
+		return echo.NewHTTPError(http.StatusInternalServerError, "Internal server error")
+	}
+
+	return e.NoContent(http.StatusNoContent)
+}

backend/model/camp.go

@@ -8,6 +8,7 @@ type Camp struct {
 	Name           string
 	Description    string
 	IsDraft        bool
+	Participants   []User `gorm:"many2many:camp_participants;"`
 	Budgets        []Budget
 	Events         []Event
 	QuestionGroups []QuestionGroup

backend/repository/camp.go

@@ -2,6 +2,7 @@ package repository
 
 import (
 	"errors"
+	"fmt"
 
 	"github.com/go-sql-driver/mysql"
 	"github.com/traP-jp/rucQ/backend/model"
@@ -73,3 +74,55 @@ func (r *Repository) UpdateCamp(campID uint, camp *model.Camp) error {
 
 	return nil
 }
+
+func (r *Repository) AddUserToCamp(campID uint, user *model.User) error {
+	var camp model.Camp
+
+	if err := r.db.First(&camp, campID).Error; err != nil {
+		return fmt.Errorf("failed to get camp: %w", err)
+	}
+
+	count := r.db.
+		Model(&camp).
+		Where(&model.User{
+			TraqID: user.TraqID,
+		}).
+		Association("Participants").
+		Count()
+
+	if count > 0 {
+		return model.ErrAlreadyExists
+	}
+
+	if err := r.db.Model(&camp).Association("Participants").Append(user); err != nil {
+		return fmt.Errorf("failed to append participant: %w", err)
+	}
+
+	return nil
+}
+
+func (r *Repository) RemoveUserFromCamp(campID uint, user *model.User) error {
+	var camp model.Camp
+
+	if err := r.db.First(&camp, campID).Error; err != nil {
+		return fmt.Errorf("failed to get camp: %w", err)
+	}
+
+	count := r.db.
+		Model(&camp).
+		Where(&model.User{
+			TraqID: user.TraqID,
+		}).
+		Association("Participants").
+		Count()
+
+	if count == 0 {
+		return model.ErrNotFound
+	}
+
+	if err := r.db.Model(&camp).Association("Participants").Delete(user); err != nil {
+		return fmt.Errorf("failed to delete participant: %w", err)
+	}
+
+	return nil
+}