diff options
author | rinpatch <rinpatch@sdf.org> | 2018-12-01 18:12:27 +0300 |
---|---|---|
committer | rinpatch <rinpatch@sdf.org> | 2018-12-01 18:12:27 +0300 |
commit | fe2759bc9f2dad044b49f4954693ac09f9368041 (patch) | |
tree | 59dd9c5026f433d976defa303de0d6782d435d1e /test/web/retry_queue_test.exs | |
parent | ba6e3eba33f16bdd2fede086d5fb5c86201cb57b (diff) | |
parent | 8c3ff06e35e11a40cf4eb35a41a2019b7496e62c (diff) | |
download | pleroma-fe2759bc9f2dad044b49f4954693ac09f9368041.tar.gz pleroma-fe2759bc9f2dad044b49f4954693ac09f9368041.zip |
Attempt to resolve merge conflict
Diffstat (limited to 'test/web/retry_queue_test.exs')
-rw-r--r-- | test/web/retry_queue_test.exs | 31 |
1 files changed, 31 insertions, 0 deletions
diff --git a/test/web/retry_queue_test.exs b/test/web/retry_queue_test.exs new file mode 100644 index 000000000..ce2964993 --- /dev/null +++ b/test/web/retry_queue_test.exs @@ -0,0 +1,31 @@ +defmodule MockActivityPub do + def publish_one(ret) do + {ret, "success"} + end +end + +defmodule Pleroma.ActivityTest do + use Pleroma.DataCase + alias Pleroma.Web.Federator.RetryQueue + + @small_retry_count 0 + @hopeless_retry_count 10 + + test "failed posts are retried" do + {:retry, _timeout} = RetryQueue.get_retry_params(@small_retry_count) + + assert {:noreply, %{delivered: 1}} == + RetryQueue.handle_info({:send, :ok, MockActivityPub, @small_retry_count}, %{ + delivered: 0 + }) + end + + test "posts that have been tried too many times are dropped" do + {:drop, _timeout} = RetryQueue.get_retry_params(@hopeless_retry_count) + + assert {:noreply, %{dropped: 1}} == + RetryQueue.handle_cast({:maybe_enqueue, %{}, nil, @hopeless_retry_count}, %{ + dropped: 0 + }) + end +end |