Add USER_GROUP_UPDATED bot event

service/bot/event/events.go

@@ -39,6 +39,8 @@ const (
 	TagRemoved model.BotEventType = "TAG_REMOVED"
 	// UserGroupCreated グループ作成イベント
 	UserGroupCreated model.BotEventType = "USER_GROUP_CREATED"
+	// UserGroupUpdated グループ更新イベント
+	UserGroupUpdated model.BotEventType = "USER_GROUP_UPDATED"
 	// UserGroupDeleted グループ削除イベント
 	UserGroupDeleted model.BotEventType = "USER_GROUP_DELETED"
 )

service/bot/event/payload/ev_user_group_updated.go

@@ -0,0 +1,20 @@
+package payload
+
+import (
+	"time"
+
+	"github.com/traPtitech/traQ/model"
+)
+
+// UserGroupUpdated USER_GROUP_UPDATEDイベントペイロード
+type UserGroupUpdated struct {
+	Base
+	Group model.UserGroup `json:"group"`
+}
+
+func MakeUserGroupUpdated(eventTime time.Time, group model.UserGroup) *UserGroupUpdated {
+	return &UserGroupUpdated{
+		Base:  MakeBase(eventTime),
+		Group: group,
+	}
+}

service/bot/handler/ev_user_group_updated.go

@@ -0,0 +1,32 @@
+package handler
+
+import (
+	"fmt"
+	"time"
+
+	"github.com/leandro-lugaresi/hub"
+
+	"github.com/traPtitech/traQ/model"
+	"github.com/traPtitech/traQ/service/bot/event"
+	"github.com/traPtitech/traQ/service/bot/event/payload"
+)
+
+func UserGroupUpdated(ctx Context, datetime time.Time, _ string, fields hub.Fields) error {
+	group := fields["group"].(model.UserGroup)
+	bots, err := ctx.GetBots(event.UserGroupUpdated)
+	if err != nil {
+		return fmt.Errorf("failed to GetBots: %w", err)
+	}
+	if len(bots) == 0 {
+		return nil
+	}
+
+	if err := ctx.Multicast(
+		event.UserGroupUpdated,
+		payload.MakeUserGroupUpdated(datetime, group),
+		bots,
+	); err != nil {
+		return fmt.Errorf("failed to multicast: %w", err)
+	}
+	return nil
+}

service/bot/handler/ev_user_group_updated_test.go

@@ -0,0 +1,57 @@
+package handler
+
+import (
+	"testing"
+	"time"
+
+	"github.com/gofrs/uuid"
+	"github.com/golang/mock/gomock"
+	"github.com/leandro-lugaresi/hub"
+	"github.com/stretchr/testify/assert"
+
+	intevent "github.com/traPtitech/traQ/event"
+	"github.com/traPtitech/traQ/model"
+	"github.com/traPtitech/traQ/service/bot/event"
+	"github.com/traPtitech/traQ/service/bot/event/payload"
+	"github.com/traPtitech/traQ/service/bot/handler/mock_handler"
+)
+
+func TestUserGroupUpdated(t *testing.T) {
+	t.Parallel()
+
+	b := &model.Bot{
+		ID:              uuid.NewV3(uuid.Nil, "b"),
+		BotUserID:       uuid.NewV3(uuid.Nil, "bu"),
+		SubscribeEvents: model.BotEventTypesFromArray([]string{event.UserGroupUpdated.String()}),
+		State:           model.BotActive,
+	}
+
+	t.Run("success", func(t *testing.T) {
+		t.Parallel()
+		ctrl := gomock.NewController(t)
+		handlerCtx := mock_handler.NewMockContext(ctrl)
+		registerBot(t, handlerCtx, b)
+
+		user := &model.User{
+			ID:     uuid.NewV3(uuid.Nil, "u"),
+			Name:   "new_user",
+			Status: model.UserAccountStatusActive,
+			Bot:    false,
+		}
+		group := model.UserGroup{
+			ID:          uuid.NewV3(uuid.Nil, "g"),
+			Name:        "new_group",
+			Description: "new_group_description",
+			Type:        "new_group_type",
+		}
+		group.Admins = append(group.Admins, &model.UserGroupAdmin{GroupID: group.ID, UserID: user.ID})
+		group.Members = append(group.Members, &model.UserGroupMember{GroupID: group.ID, UserID: user.ID})
+		et := time.Now()
+
+		expectMulticast(handlerCtx, event.UserGroupUpdated, payload.MakeUserGroupUpdated(et, group), []*model.Bot{b})
+		assert.NoError(t, UserGroupUpdated(handlerCtx, et, intevent.UserGroupUpdated, hub.Fields{
+			"group_id": group.ID,
+			"group":    group,
+		}))
+	})
+}

service/bot/handlers.go

@@ -26,5 +26,6 @@ var eventHandlerSet = map[string]eventHandler{
 	intevent.UserTagRemoved:       handler.UserTagRemoved,
 	intevent.MessageStampsUpdated: handler.MessageStampsUpdated,
 	intevent.UserGroupCreated:     handler.UserGroupCreated,
+	intevent.UserGroupUpdated:     handler.UserGroupUpdated,
 	intevent.UserGroupDeleted:     handler.UserGroupDeleted,
 }