fix logic in handler
All checks were successful
Build and Publish / build-release (push) Successful in 1m43s
All checks were successful
Build and Publish / build-release (push) Successful in 1m43s
This commit is contained in:
@@ -17,12 +17,16 @@ defmodule WorkloadService.Handlers.TaskCompletedHandler do
|
|||||||
def handle(%TaskCompleted{} = event, _metadata) do
|
def handle(%TaskCompleted{} = event, _metadata) do
|
||||||
aggregate_module =
|
aggregate_module =
|
||||||
case event.id.type do
|
case event.id.type do
|
||||||
"quote" -> QuoteTask
|
"quote" -> {:ok, QuoteTask}
|
||||||
# "solicitation" -> SolicitationTask
|
# "solicitation" -> SolicitationTask
|
||||||
_ -> nil
|
_ -> {:error, "aggregate module not found for event type #{event.id}"}
|
||||||
end
|
end
|
||||||
|
|
||||||
if aggregate_module do
|
case aggregate_module do
|
||||||
|
{:error, reason} ->
|
||||||
|
{:error, reason}
|
||||||
|
|
||||||
|
{:ok, module} ->
|
||||||
case Aggregate.aggregate_state(
|
case Aggregate.aggregate_state(
|
||||||
WorkloadService.CommandedApp,
|
WorkloadService.CommandedApp,
|
||||||
aggregate_module,
|
aggregate_module,
|
||||||
@@ -41,11 +45,5 @@ defmodule WorkloadService.Handlers.TaskCompletedHandler do
|
|||||||
Logger.info("TaskCompletedHandler: published for #{event.id}")
|
Logger.info("TaskCompletedHandler: published for #{event.id}")
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
:ok
|
|
||||||
rescue
|
|
||||||
e ->
|
|
||||||
Logger.error("TaskCompletedHandler: failed to process - #{inspect(e)}")
|
|
||||||
:ok
|
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|||||||
Reference in New Issue
Block a user