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)
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{