fix failure case for domain-event publishing

IzumiSy · Sep 1, 2021 · 6f95c24 · 6f95c24
1 parent f863037
commit 6f95c24
Show file tree

Hide file tree

Showing 3 changed files with 15 additions and 3 deletions.
diff --git 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
@@ -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
@@ -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)
 	})
 }