Prove direct cancellation during a pending sync

[onechat] / daemon_message_test.go

diff --git a/daemon_message_test.go b/daemon_message_test.go
index 27138d3f895fa57fb24bbe666fda7efecc2daa47..a7792e8c9dfc2937b4cf9feec56e536d15dc6aea 100644 (file)
--- a/daemon_message_test.go
+++ b/daemon_message_test.go
@@ -125,11 +125,11 @@ func TestEmptyChildReplySendsNothingAndWakesNobody(t *testing.T) {
                text string
        }{
                {
-                       name: "empty final reply",
+                       name: "sends nothing for an empty final reply",
                        text: "",
                },
                {
-                       name: "whitespace final reply",
+                       name: "sends nothing for a whitespace final reply",
                        text: " \n\t ",
                },
        }
@@ -465,12 +465,12 @@ func TestParentCanMessageOnlyItsOwnChildren(t *testing.T) {
                        target: "OneChat",
                },
                {
-                       name:   "unknown sender",
+                       name:   "refuses an unknown sender",
                        source: "Other",
                        target: "Garden",
                },
                {
-                       name:   "unknown recipient",
+                       name:   "refuses an unknown recipient",
                        source: "OneChat",
                        target: "Other",
                },
@@ -494,19 +494,19 @@ func TestInvalidAgentMessageQueueStopsStartup(t *testing.T) {
                file string
        }{
                {
-                       name: "broken JSON",
+                       name: "stops startup for broken JSON",
                        file: "{",
                },
                {
-                       name: "unknown sender",
+                       name: "stops startup for unknown sender",
                        file: `{"next":1,"pending":[{"id":1,"source":"Other","target":"Garden","kind":"user"}]}`,
                },
                {
-                       name: "sibling delivery",
+                       name: "stops startup for sibling delivery",
                        file: `{"next":1,"pending":[{"id":1,"source":"Library","target":"Garden","kind":"user"}]}`,
                },
                {
-                       name: "invalid sequence",
+                       name: "stops startup for invalid sequence",
                        file: `{"next":0,"pending":[{"id":1,"source":"OneChat","target":"Garden","kind":"user"}]}`,
                },
        }
@@ -580,14 +580,14 @@ func TestRoutedWhatsAppBatchesWakeOnlyTheirChild(t *testing.T) {
                chat WhatsAppChat
        }{
                {
-                       name: "private chat",
+                       name: "routes a private chat only to its child",
                        chat: WhatsAppChat{
                                ID:   whatsappTestAna.String(),
                                Name: "Ana",
                        },
                },
                {
-                       name: "group without a mention",
+                       name: "routes an unmentioned group only to its child",
                        chat: WhatsAppChat{
                                ID:    whatsappTestFamily.String(),
                                Name:  "Garden plans",
@@ -664,6 +664,7 @@ func TestMissingWhatsAppRouteChildFallsBackToRoot(t *testing.T) {
                ID:   whatsappTestAna.String(),
                Name: "Ana",
        }
+
        require.NoError(t, test.messages.routes.Set("whatsapp:"+chat.ID, "Missing"))
        whatsappRouteTestAdd(t, inbox, chat, "Please check the plan.")
        require.NoError(t, inbox.deliver(t.Context(), test.loops[0], WhatsAppLink{}, true))
@@ -760,11 +761,11 @@ func TestQueuedWhatsAppBatchRecoversBeforeItsLogAppend(t *testing.T) {
                id   *int
        }{
                {
-                       name: "before log ID is stored",
+                       name: "recovers one message before its log ID is stored",
                        id:   nil,
                },
                {
-                       name: "after log ID is stored",
+                       name: "recovers one message after its log ID is stored",
                        id:   new(0),
                },
        }
@@ -819,6 +820,7 @@ func TestQueuedWhatsAppBatchUsesRootIfItsChildIsRemoved(t *testing.T) {
                ID:   whatsappTestAna.String(),
                Name: "Ana",
        }
+
        require.NoError(t, first.messages.routes.Set("whatsapp:"+chat.ID, "Garden"))
        whatsappRouteTestAdd(t, inbox, chat, "Keep the gate plan.")
        require.NoError(t, inbox.deliver(t.Context(), first.loops[0], WhatsAppLink{}, true))
@@ -853,6 +855,7 @@ func TestRoutedWhatsAppBatchesCanCloseOutOfNumberOrder(t *testing.T) {
                Name:  "Garden plans",
                Group: true,
        }
+
        require.NoError(t, test.messages.routes.Set("whatsapp:"+first.ID, "Garden"))
        require.NoError(t, test.messages.routes.Set("whatsapp:"+second.ID, "Garden"))
 
@@ -901,6 +904,7 @@ func TestWhatsAppCatchupSeparatesChildAndRootBatches(t *testing.T) {
                ID:   whatsappTestAna.String(),
                Name: "Ana",
        }
+
        require.NoError(t, test.messages.routes.Set("whatsapp:"+garden.ID, "Garden"))
        require.NoError(t, test.messages.routes.Set("whatsapp:"+library.ID, "Library"))
        inbox.waitForCatchup()
@@ -937,6 +941,7 @@ func TestRoutedWhatsAppQueueFailureKeepsTheInboxBatch(t *testing.T) {
                ID:   whatsappTestAna.String(),
                Name: "Ana",
        }
+
        require.NoError(t, first.messages.routes.Set("whatsapp:"+chat.ID, "Garden"))
        require.NoError(t, os.Mkdir(first.messages.path, 0o700))
        whatsappRouteTestAdd(t, inbox, chat, "Keep the gate plan.")