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/converter.go

@@ -413,6 +413,7 @@ func convTagTodomainTag(src Tag) (dst domain.Tag) {
 func convUserTodomainUser(src User) (dst domain.User) {
 	dst.ID = src.ID
 	dst.State = src.State
+	dst.Privileged = src.Privilege
 	dst.Provider = &domain.Provider{
 		Issuer:  src.Provider.Issuer,
 		Subject: src.Provider.Subject,

infra/db/event.go

@@ -76,31 +76,104 @@
 
 func createEvent(db *gorm.DB, args domain.UpsertEventArgs) (*Event, error) {
 	event := ConvWriteEventParamsToEvent(args)
+	var err error
+	var r *Room
+	r, err = getRoom(db, event.RoomID)
+	if err != nil {
+		return nil, err
+	}
+	event.Room = *r
+
+	// tagを生成する
+	for i := range event.Tags {
+		tag, err := createOrGetTag(db, event.Tags[i].Tag.Name)
+		if err != nil {
+			return nil, err
+		}
+		event.Tags[i].EventID = event.ID
+		event.Tags[i].TagID = tag.ID
+		event.Tags[i].Tag = *tag
+	}
 
-	err := db.Create(&event).Error
+	// 対応する 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
+
+	// tagは自動生成する
+	for i := range event.Tags {
+		tag, err := createOrGetTag(db, event.Tags[i].Tag.Name)
+		if err != nil {
+			return nil, err
+		}
+		event.Tags[i].EventID = event.ID
+		event.Tags[i].TagID = tag.ID
+	}
+
+	// 対応する Room, Group はService層で確認済み
+	err = db.Save(&event).Error
+	if err != nil {
+		return nil, err
+	}
+
+	for _, admin := range event.Admins {
+		err = db.Save(&admin).Error
+		if err != nil {
+			return nil, err
+		}
+	}
+	for _, attendee := range event.Attendees {
+		err = db.Save(&attendee).Error
+		if err != nil {
+			return nil, err
+		}
+	}
+	for _, etag := range event.Tags {
+		err = db.Save(&etag).Error
+		if err != nil {
+			return nil, err
+		}
+	}
 
-	err := db.Session(&gorm.Session{FullSaveAssociations: true}).
-		Omit("CreatedAt").Save(&event).Error
 	return &event, err
 }
 
 func addEventTag(db *gorm.DB, eventID uuid.UUID, params domain.EventTagParams) error {
 	eventTag := ConvdomainEventTagParamsToEventTag(params)
 	eventTag.EventID = eventID
-	err := db.Create(&eventTag).Error
+	tag, err := createOrGetTag(db, eventTag.Tag.Name)
+	eventTag.TagID = tag.ID
+	err = db.Create(&eventTag).Error
 	if errors.Is(defaultErrorHandling(err), ErrDuplicateEntry) {
 		return db.Omit("CreatedAt").Save(&eventTag).Error
 	}
 	return err
 }
 
 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,41 @@ 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 {
+		err = db.Save(&member).Error
+		if err != nil {
+			return nil, err
+		}
+	}
+	// GroupAdmin の更新
+	for _, admin := range group.Admins {
+		err := db.Save(&admin).Error
+		if err != nil {
+			return nil, err
+		}
+	}
 	return &group, err
 }
 
@@ -121,14 +160,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 +187,7 @@ func deleteMemberOfGroup(db *gorm.DB, groupID, userID uuid.UUID) error {
 		GroupID: groupID,
 		UserID:  userID,
 	}
+	// 1メンバーの削除 hooksは登録なし
 	return db.Delete(&groupMember).Error
 }