Refactor/hooks

domain/event.go

@@ -80,6 +80,10 @@ type WriteEventParams struct {
 	Open          bool
 }
 
+func (e *WriteEventParams) TimeConsistency() bool {
+	return e.TimeStart.Before((e.TimeEnd))
+}
+
 type EventTagParams struct {
 	Name   string
 	Locked bool

domain/room.go

@@ -152,6 +152,10 @@ type WriteRoomParams struct {
 	Admins []uuid.UUID
 }
 
+func (r *WriteRoomParams) TimeConsistency() bool {
+	return r.TimeStart.Before((r.TimeEnd))
+}
+
 type RoomService interface {
 	CreateUnVerifiedRoom(ctx context.Context, reqID uuid.UUID, params WriteRoomParams) (*Room, error)
 	CreateVerifiedRoom(ctx context.Context, reqID uuid.UUID, params WriteRoomParams) (*Room, error)

infra/db/event.go

@@ -76,17 +76,46 @@ func (repo *gormRepository) GetAllEvents(expr filters.Expr) ([]*domain.Event, er
 
 func createEvent(db *gorm.DB, args domain.UpsertEventArgs) (*Event, error) {
 	event := ConvWriteEventParamsToEvent(args)
-
-	err := db.Create(&event).Error
+	var err error
+	var r *Room
+	r, err = getRoom(db, event.RoomID)
+	if err != nil {
+		return nil, err
+	}
+	event.Room = *r
+	// 対応する Room, Group はService層で確認済み
+	event.ID, err = uuid.NewV4()
+	if err != nil {
+		return nil, err
+	}
+	err = db.Create(&event).Error
 	return &event, err
 }
 
 func updateEvent(db *gorm.DB, eventID uuid.UUID, args domain.UpsertEventArgs) (*Event, error) {
 	event := ConvWriteEventParamsToEvent(args)
 	event.ID = eventID
+	var err error
+	var r *Room
+	r, err = getRoom(db, event.RoomID)
+	if err != nil {
+		return nil, err
+	}
+	event.Room = *r
+
+	// 対応する Room, Group はService層で確認済み
+	err = db.Save(&event).Error
+	if err != nil {
+		return nil, err
+	}
+
+	for _, admin := range event.Admins {
+		db.Save(&admin)
+	}
+	for _, attendee := range event.Attendees {
+		db.Save(&attendee)
+	}
 
-	err := db.Session(&gorm.Session{FullSaveAssociations: true}).
-		Omit("CreatedAt").Save(&event).Error
 	return &event, err
 }
 
@@ -101,6 +130,14 @@ func addEventTag(db *gorm.DB, eventID uuid.UUID, params domain.EventTagParams) e
 }
 
 func deleteEvent(db *gorm.DB, eventID uuid.UUID) error {
+	err := db.Where("event_id = ?", eventID).Delete(&EventTag{}).Error
+	if err != nil {
+		return err
+	}
+	err = db.Where("event_id = ?", eventID).Delete(&EventAdmin{}).Error
+	if err != nil {
+		return err
+	}
 	return db.Delete(&Event{ID: eventID}).Error
 }
 

infra/db/group.go

@@ -97,7 +97,13 @@ func convSPGroupToSuuidUUID(src []*Group) (dst []uuid.UUID) {
 
 func createGroup(db *gorm.DB, args domain.UpsertGroupArgs) (*Group, error) {
 	group := ConvWriteGroupParamsToGroup(args)
-	err := db.Create(&group).Error
+	// IDを新規発行
+	var err error
+	group.ID, err = uuid.NewV4()
+	if err != nil {
+		return nil, err
+	}
+	err = db.Create(&group).Error
 	if err != nil {
 		return nil, err
 	}
@@ -107,8 +113,35 @@ func createGroup(db *gorm.DB, args domain.UpsertGroupArgs) (*Group, error) {
 func updateGroup(db *gorm.DB, groupID uuid.UUID, args domain.UpsertGroupArgs) (*Group, error) {
 	group := ConvWriteGroupParamsToGroup(args)
 	group.ID = groupID
-	err := db.Session(&gorm.Session{FullSaveAssociations: true}).
-		Omit("CreatedAt").Save(&group).Error
+	// groupIDは存在する
+	var err error
+	// CreatedBy は readonly
+	// GroupMember, GroupAdmin も User は readonly
+
+	// err = db.Session(&gorm.Session{FullSaveAssociations: true}).
+	// Omit("CreatedAt").Save(&group).Error
+
+	// GroupMenberの削除
+	err = db.Where("group_id = ?", group.ID).Delete(&GroupMember{}).Error
+	if err != nil {
+		return nil, err
+	}
+	// GroupAdminの削除
+	err = db.Where("group_id = ?", group.ID).Delete(&GroupAdmin{}).Error
+	if err != nil {
+		return nil, err
+	}
+
+	err = db.Omit("CreatedAt").Save(&group).Error
+
+	// GroupMember の更新
+	for member := range group.Members {
+		db.Save(&member)
+	}
+	// GroupAdmin の更新
+	for admin := range group.Admins {
+		db.Save(&admin)
+	}
 	return &group, err
 }
 
@@ -121,14 +154,25 @@ func addMemberToGroup(db *gorm.DB, groupID, userID uuid.UUID) error {
 	onConflictClause := clause.OnConflict{
 		DoUpdates: clause.AssignmentColumns([]string{"updated_at", "deleted_at"}),
 	}
-
+	// groupMemberはhook登録なし
 	return db.Clauses(onConflictClause).Create(&groupMember).Error
 }
 
 func deleteGroup(db *gorm.DB, groupID uuid.UUID) error {
 	group := Group{
 		ID: groupID,
 	}
+	// Group の GroupMember を削除
+	err := db.Where("group_id = ?", group.ID).Delete(&GroupMember{}).Error
+	if err != nil {
+		return err
+	}
+	// GroupAdmin を削除
+	err = db.Where("group_id = ?", group.ID).Delete(&GroupAdmin{}).Error
+	if err != nil {
+		return err
+	}
+	// Group を削除
 	return db.Delete(&group).Error
 }
 
@@ -137,6 +181,7 @@ func deleteMemberOfGroup(db *gorm.DB, groupID, userID uuid.UUID) error {
 		GroupID: groupID,
 		UserID:  userID,
 	}
+	// 1メンバーの削除 hooksは登録なし
 	return db.Delete(&groupMember).Error
 }