Rename NotifyJoinMatchCommand to CreateBattleCommand

internal/subscriber/match_changed.go

@@ -16,10 +16,10 @@ const (
 var _ Subscriber = &MatchChangedSubscriber{}
 
 type MatchChangedSubscriber struct {
-	notifyJoinMatch *usecase.NotifyJoinMatchCommand
+	notifyJoinMatch *usecase.CreateBattleCommand
 }
 
-func NewMatchChangedSubscriber(notifyJoinMatch *usecase.NotifyJoinMatchCommand) *MatchChangedSubscriber {
+func NewMatchChangedSubscriber(notifyJoinMatch *usecase.CreateBattleCommand) *MatchChangedSubscriber {
 	return &MatchChangedSubscriber{
 		notifyJoinMatch: notifyJoinMatch,
 	}
@@ -46,7 +46,7 @@ func (s *MatchChangedSubscriber) Handler(msg *message.Message) error {
 		matchId = change.Before.Id
 	}
 
-	_, err := s.notifyJoinMatch.Execute(msg.Context(), &usecase.NotifyJoinMatchInput{
+	_, err := s.notifyJoinMatch.Execute(msg.Context(), &usecase.CreateBattleInput{
 		MatchId: matchId,
 	})
 	if err != nil {

internal/subscriber/subscriber.go

@@ -19,7 +19,7 @@ type Subscriber interface {
 type DatabaseSubscriber Subscriber
 
 func ProvideDatabaseSubscribers(
-	notifyJoinMatch *usecase.NotifyJoinMatchCommand,
+	notifyJoinMatch *usecase.CreateBattleCommand,
 ) []DatabaseSubscriber {
 	return []DatabaseSubscriber{
 		NewMatchChangedSubscriber(notifyJoinMatch),

internal/usecase/notify_join_match_command.go → internal/usecase/create_battle_command.go

@@ -6,31 +6,31 @@ import (
 	"github.com/elct9620/wvs/pkg/event"
 )
 
-type NotifyJoinMatchInput struct {
+type CreateBattleInput struct {
 	MatchId string
 }
 
-type NotifyJoinMatchOutput struct {
+type CreateBattleOutput struct {
 }
 
-var _ Command[*NotifyJoinMatchInput, *NotifyJoinMatchOutput] = &NotifyJoinMatchCommand{}
+var _ Command[*CreateBattleInput, *CreateBattleOutput] = &CreateBattleCommand{}
 
-type NotifyJoinMatchCommand struct {
+type CreateBattleCommand struct {
 	matchs  MatchRepository
 	streams StreamRepository
 }
 
-func NewNotifyJoinMatchCommand(
+func NewCreateBattleCommand(
 	matchs MatchRepository,
 	streams StreamRepository,
-) *NotifyJoinMatchCommand {
-	return &NotifyJoinMatchCommand{
+) *CreateBattleCommand {
+	return &CreateBattleCommand{
 		matchs:  matchs,
 		streams: streams,
 	}
 }
 
-func (c *NotifyJoinMatchCommand) Execute(ctx context.Context, input *NotifyJoinMatchInput) (*NotifyJoinMatchOutput, error) {
+func (c *CreateBattleCommand) Execute(ctx context.Context, input *CreateBattleInput) (*CreateBattleOutput, error) {
 	match, err := c.matchs.Find(ctx, input.MatchId)
 	if err != nil {
 		return nil, err
@@ -48,5 +48,5 @@ func (c *NotifyJoinMatchCommand) Execute(ctx context.Context, input *NotifyJoinM
 		}
 	}
 
-	return &NotifyJoinMatchOutput{}, nil
+	return &CreateBattleOutput{}, nil
 }

internal/usecase/usecase.go

@@ -11,8 +11,8 @@ var DefaultSet = wire.NewSet(
 	wire.Bind(new(Command[*CreateMatchInput, *CreateMatchOutput]), new(*CreateMatchCommand)),
 	NewSubscribeCommand,
 	wire.Bind(new(Command[*SubscribeCommandInput, *SubscribeCommandOutput]), new(*SubscribeCommand)),
-	NewNotifyJoinMatchCommand,
-	wire.Bind(new(Command[*NotifyJoinMatchInput, *NotifyJoinMatchOutput]), new(*NotifyJoinMatchCommand)),
+	NewCreateBattleCommand,
+	wire.Bind(new(Command[*CreateBattleInput, *CreateBattleOutput]), new(*CreateBattleCommand)),
 )
 
 type Command[I any, O any] interface {