]> git.giacomolli.uk - onechat/blobdiff - whatsapp_inbox_test.go
Keep test daemon sockets under the path limit
[onechat] / whatsapp_inbox_test.go
index a0a0f9dfc4e61cd53139907edb994acf3f124799..1ce9a72da56d66c0af5891b1aac8a40f00d13bb3 100644 (file)
@@ -147,7 +147,7 @@ func TestWhatsAppRunClosesABatchAfterQuietTime(t *testing.T) {
                synctest.Wait()
                require.True(t, test.fake.Emit(whatsappTestMessage(whatsappTestAna, whatsappTestOwn, "m1", "On my way.", time.Now())))
                synctest.Wait()
                synctest.Wait()
                require.True(t, test.fake.Emit(whatsappTestMessage(whatsappTestAna, whatsappTestOwn, "m1", "On my way.", time.Now())))
                synctest.Wait()
-               time.Sleep(whatsappBatchQuiet - time.Nanosecond)
+               time.Sleep(whatsappBatchIdleTimeout - time.Nanosecond)
                synctest.Wait()
                require.Zero(t, test.loop.memory.Len())
 
                synctest.Wait()
                require.Zero(t, test.loop.memory.Len())
 
@@ -268,7 +268,7 @@ func TestWhatsAppCatchupEndsAfterItsLimit(t *testing.T) {
                require.NoError(t, test.whatsapp.inbox.deliver(t.Context(), test.loop, test.whatsapp.link(), false))
                require.Zero(t, test.loop.memory.Len())
 
                require.NoError(t, test.whatsapp.inbox.deliver(t.Context(), test.loop, test.whatsapp.link(), false))
                require.Zero(t, test.loop.memory.Len())
 
-               time.Sleep(whatsappCatchupLimit)
+               time.Sleep(whatsappCatchupTimeout)
                synctest.Wait()
                require.NoError(t, test.whatsapp.inbox.deliver(t.Context(), test.loop, test.whatsapp.link(), false))
                require.Equal(t, 1, test.loop.memory.Len())
                synctest.Wait()
                require.NoError(t, test.whatsapp.inbox.deliver(t.Context(), test.loop, test.whatsapp.link(), false))
                require.Equal(t, 1, test.loop.memory.Len())