Share general review and documentation rules

[onechat] / backup_test.go

diff --git a/backup_test.go b/backup_test.go
index 1638ed0d40be2673dfa6cef0c3e6b09b132e9558..81fefd9affeaa5494254809b4f604ff66047def1 100644 (file)
--- a/backup_test.go
+++ b/backup_test.go
@@ -125,9 +125,10 @@ func TestBackupKeepsPendingNotificationsAndCompletedRetryReceipts(t *testing.T)
        require.NoError(t, test.loops[0].turn(t.Context()))
 
        _, err = test.messages.Notify(&NotifyInput{
        require.NoError(t, test.loops[0].turn(t.Context()))
 
        _, err = test.messages.Notify(&NotifyInput{

-               Source: "check",
-               ID:     "pending",
-               Text:   "A pending result.",
+               Source:  "check",
+               ID:      "pending",
+               AgentID: test.agents[1].agent.config.ID,
+               Text:    "A pending result.",

        })
        require.NoError(t, err)
 
        })
        require.NoError(t, err)
 


@@ -149,6 +150,7 @@ func TestBackupKeepsPendingNotificationsAndCompletedRetryReceipts(t *testing.T)
 
        recovered := newDaemonMessageTest(t, restored, server)
        require.Len(t, recovered.Queue(t).Pending, 1)
 
        recovered := newDaemonMessageTest(t, restored, server)
        require.Len(t, recovered.Queue(t).Pending, 1)

+       require.Equal(t, test.agents[1].agent.config.ID, recovered.Queue(t).Pending[0].TargetID)

        require.Len(t, recovered.Queue(t).Notifications, 2)
 
        duplicate, err := recovered.messages.Notify(&NotifyInput{
        require.Len(t, recovered.Queue(t).Notifications, 2)
 
        duplicate, err := recovered.messages.Notify(&NotifyInput{