diff --git a/domains/usecases/authenticate.go b/domains/usecases/authenticate.go index aaca40a..9f8d453 100644 --- a/domains/usecases/authenticate.go +++ b/domains/usecases/authenticate.go @@ -77,11 +77,15 @@ func (uc AuthenticateUsecase) Build(params AuthenticateParam) domains.Unauthoriz UserID: auth.User().ID().String(), CreatedAt: time.Now(), } + + // Eventのpublishに失敗しても意図的にエラーはレスポンスせずErrorのレポートのみとしておく + // 非同期処理のエラーは別途手動で復旧作業を行う if err := uc.Publisher.Publish(event); err.NotNil() { uc.Logger.Errorf(uc.Ctx, "Failed publishing event: %s", err.Error()) + } else { + uc.Logger.Infof(uc.Ctx, "Event published: %s", event.ID()) } - uc.Logger.Infof(uc.Ctx, "Event published: %s", event.ID()) uc.OutputPort.Write(session) }) } diff --git a/domains/usecases/create_todo.go b/domains/usecases/create_todo.go index 7e30d0a..305ad7e 100644 --- a/domains/usecases/create_todo.go +++ b/domains/usecases/create_todo.go @@ -91,11 +91,15 @@ func (uc CreateTodoUsecase) Build(params CreateTodoParam) domains.AuthorizedUsec Description: newTodo.Description().Value(), CreatedAt: time.Now(), } + + // Eventのpublishに失敗しても意図的にエラーはレスポンスせずErrorのレポートのみとしておく + // 非同期処理のエラーは別途手動で復旧作業を行う if err := uc.Publisher.Publish(event); err.NotNil() { uc.Logger.Errorf(uc.Ctx, "Failed publishing event: %s", err.Error()) + } else { + uc.Logger.Infof(uc.Ctx, "Event published: %s", event.ID()) } - uc.Logger.Infof(uc.Ctx, "Event published: %s", event.ID()) uc.OutputPort.Write(newTodo) }) } diff --git a/domains/usecases/signup.go b/domains/usecases/signup.go index b0425be..acb3336 100644 --- a/domains/usecases/signup.go +++ b/domains/usecases/signup.go @@ -82,11 +82,15 @@ func (uc SignupUsecase) Build(params SignupParam) domains.UnauthorizedUsecase { Name_: auth.User().Name().Value(), CreatedAt: time.Now(), } + + // Eventのpublishに失敗しても意図的にエラーはレスポンスせずErrorのレポートのみとしておく + // 非同期処理のエラーは別途手動で復旧作業を行う if err := uc.Publisher.Publish(event); err.NotNil() { uc.Logger.Errorf(uc.Ctx, "Failed publishing event: %s", err.Error()) + } else { + uc.Logger.Infof(uc.Ctx, "Event published: %s", event.ID()) } - uc.Logger.Infof(uc.Ctx, "Event published: %s", event.ID()) uc.OutputPort.Write(auth) }) }