diff --git a/lib/philomena/topics.ex b/lib/philomena/topics.ex index 4c757596..0960863f 100644 --- a/lib/philomena/topics.ex +++ b/lib/philomena/topics.ex @@ -62,6 +62,9 @@ defmodule Philomena.Topics do {:ok, count} end) + |> Multi.run(:subscribe, fn _repo, %{topic: topic} -> + create_subscription(topic, attribution[:user]) + end) |> Repo.isolated_transaction(:serializable) end