tests: Replace 2 second sleep with offseting updated_at

diff --git a/test/conversation/participation_test.exs b/test/conversation/participation_test.exs
index 9b2c97963a8c56b1f9d7d677a6f9dee6ae2e7c7c..88dc321984311af31bb3edb717dfdbcd3841c796 100644 (file)
--- a/test/conversation/participation_test.exs
+++ b/test/conversation/participation_test.exs
@@ -5,7 +5,9 @@
 defmodule Pleroma.Conversation.ParticipationTest do
   use Pleroma.DataCase
   import Pleroma.Factory
 defmodule Pleroma.Conversation.ParticipationTest do
   use Pleroma.DataCase
   import Pleroma.Factory

+  alias Pleroma.Conversation

   alias Pleroma.Conversation.Participation
   alias Pleroma.Conversation.Participation

+  alias Pleroma.Repo

   alias Pleroma.User
   alias Pleroma.Web.CommonAPI
 
   alias Pleroma.User
   alias Pleroma.Web.CommonAPI
 


@@ -97,8 +99,10 @@ defmodule Pleroma.Conversation.ParticipationTest do
 
     assert participation.user_id == user.id
     assert participation.conversation_id == conversation.id
 
     assert participation.user_id == user.id
     assert participation.conversation_id == conversation.id

-
+    
+    # Needed because updated_at is accurate down to a second

     :timer.sleep(1000)
     :timer.sleep(1000)

+

     # Creating again returns the same participation
     {:ok, %Participation{} = participation_two} =
       Participation.create_for_user_and_conversation(user, conversation)
     # Creating again returns the same participation
     {:ok, %Participation{} = participation_two} =
       Participation.create_for_user_and_conversation(user, conversation)


@@ -150,9 +154,7 @@ defmodule Pleroma.Conversation.ParticipationTest do
   test "gets all the participations for a user, ordered by updated at descending" do
     user = insert(:user)
     {:ok, activity_one} = CommonAPI.post(user, %{"status" => "x", "visibility" => "direct"})
   test "gets all the participations for a user, ordered by updated at descending" do
     user = insert(:user)
     {:ok, activity_one} = CommonAPI.post(user, %{"status" => "x", "visibility" => "direct"})

-    :timer.sleep(1000)

     {:ok, activity_two} = CommonAPI.post(user, %{"status" => "x", "visibility" => "direct"})
     {:ok, activity_two} = CommonAPI.post(user, %{"status" => "x", "visibility" => "direct"})

-    :timer.sleep(1000)

 
     {:ok, activity_three} =
       CommonAPI.post(user, %{
 
     {:ok, activity_three} =
       CommonAPI.post(user, %{


@@ -161,6 +163,17 @@ defmodule Pleroma.Conversation.ParticipationTest do
         "in_reply_to_status_id" => activity_one.id
       })
 
         "in_reply_to_status_id" => activity_one.id
       })
 

+    # Offset participations because the accuracy of updated_at is down to a second
+
+    for {activity, offset} <- [{activity_two, 1}, {activity_three, 2}] do
+      conversation = Conversation.get_for_ap_id(activity.data["context"])
+      participation = Participation.for_user_and_conversation(user, conversation)
+      updated_at = NaiveDateTime.add(Map.get(participation, :updated_at), offset)
+
+      Ecto.Changeset.change(participation, %{updated_at: updated_at})
+      |> Repo.update!()
+    end
+

     assert [participation_one, participation_two] = Participation.for_user(user)
 
     object2 = Pleroma.Object.normalize(activity_two)
     assert [participation_one, participation_two] = Participation.for_user(user)
 
     object2 = Pleroma.Object.normalize(activity_two)