X-Git-Url: https://git.giacomolli.uk/onechat/blobdiff_plain/fc0503be49438775c5d08499046852df59bd7377..d7bc0a6ac452bfc646610fdfd7c8eccb5c55218f:/whatsapp_import_test.go?ds=inline

diff --git a/whatsapp_import_test.go b/whatsapp_import_test.go
index 553a2cb..382d4bf 100644
--- a/whatsapp_import_test.go
+++ b/whatsapp_import_test.go
@@ -704,6 +704,27 @@ func TestWhatsAppImportRefusesPendingDeliveriesAndKeepsRestartSafe(t *testing.T)
 	}
 }
 
+func TestWhatsAppImportBlocksPendingNotificationsButNotCompletedReceipts(t *testing.T) {
+	server := newModelFake(t)
+	test := newDaemonMessageTest(t, t.TempDir(), server)
+	_, err := test.messages.Notify(&NotifyInput{
+		Source: "check",
+		ID:     "1",
+		Text:   "A result.",
+	})
+	require.NoError(t, err)
+
+	root := test.agents[0].agent
+	directory := root.dir
+	require.ErrorContains(t, whatsappImportIdle(directory, root), "pending deliveries")
+	require.NoError(t, whatsappImportIdle(directory, test.agents[1].agent))
+	require.NoError(t, test.messages.Notifications(test.loops[0]))
+	require.NoError(t, test.loops[0].turn(t.Context()))
+	require.Len(t, test.Queue(t).Notifications, 1)
+	require.Empty(t, test.Queue(t).Pending)
+	require.NoError(t, whatsappImportIdle(directory, root))
+}
+
 func TestWhatsAppImportPendingDeliveriesBlockOnlyTheirTarget(t *testing.T) {
 	dir := t.TempDir()
 	t.Setenv("ONECHAT_DIR", dir)