diff options
| author | lain <lain@soykaf.club> | 2020-06-05 16:47:02 +0200 |
|---|---|---|
| committer | lain <lain@soykaf.club> | 2020-06-05 16:47:02 +0200 |
| commit | 115d08a7542b92c5e1d889da41c0ee6837a1235e (patch) | |
| tree | 9f1d3aa8a65f53d5a42b9ab64013c2d9a3296a19 /test/web/activity_pub/pipeline_test.exs | |
| parent | 65689ba9bd44e291fc626cce2bd5136b93a5da90 (diff) | |
| download | pleroma-115d08a7542b92c5e1d889da41c0ee6837a1235e.tar.gz pleroma-115d08a7542b92c5e1d889da41c0ee6837a1235e.zip | |
Pipeline: Add a side effects step after the transaction finishes
This is to run things like streaming notifications out, which will
sometimes need data that is created by the transaction, but is
streamed out asynchronously.
Diffstat (limited to 'test/web/activity_pub/pipeline_test.exs')
| -rw-r--r-- | test/web/activity_pub/pipeline_test.exs | 9 |
1 files changed, 6 insertions, 3 deletions
diff --git a/test/web/activity_pub/pipeline_test.exs b/test/web/activity_pub/pipeline_test.exs index 26557720b..8deb64501 100644 --- a/test/web/activity_pub/pipeline_test.exs +++ b/test/web/activity_pub/pipeline_test.exs @@ -33,7 +33,10 @@ defmodule Pleroma.Web.ActivityPub.PipelineTest do { Pleroma.Web.ActivityPub.SideEffects, [], - [handle: fn o, m -> {:ok, o, m} end] + [ + handle: fn o, m -> {:ok, o, m} end, + handle_after_transaction: fn m -> m end + ] }, { Pleroma.Web.Federator, @@ -71,7 +74,7 @@ defmodule Pleroma.Web.ActivityPub.PipelineTest do { Pleroma.Web.ActivityPub.SideEffects, [], - [handle: fn o, m -> {:ok, o, m} end] + [handle: fn o, m -> {:ok, o, m} end, handle_after_transaction: fn m -> m end] }, { Pleroma.Web.Federator, @@ -110,7 +113,7 @@ defmodule Pleroma.Web.ActivityPub.PipelineTest do { Pleroma.Web.ActivityPub.SideEffects, [], - [handle: fn o, m -> {:ok, o, m} end] + [handle: fn o, m -> {:ok, o, m} end, handle_after_transaction: fn m -> m end] }, { Pleroma.Web.Federator, |