UpdateID: 1,
Message: message,
}))
+
test.events.WaitFor(t, "idle", 1)
files, err := os.ReadDir(test.agent.Images().dir)
failure: "exceeds 20 MB",
},
}
+
for _, tc := range testCases {
t.Run(tc.name, func(t *testing.T) {
text, err := telegramImageText(t.Context(), api, store, &TelegramMessage{Document: &tc.document})
return 0, ""
}
+
bot, logs := telegramStartTestBot(t, telegram)
- bot.minWait = time.Millisecond
- bot.maxWait = 5 * time.Millisecond
server := newModelFake(t)
socket := daemonStartTestWithBot(t, server, bot)
terminal := terminalStartTestClient(t, socket)
Width: 2,
Height: 2,
}}
+
telegram.Add(TelegramUpdate{
UpdateID: 7,
Message: message,
})
+
terminal.WaitFor(t, "[done]")
require.Eventually(t, func() bool {
offset, err := telegramLoadOffset(bot.offsetPath)
return err == nil && offset == 8
}, 10*time.Second, time.Millisecond)
+
require.Contains(t, logs.String(), "receive failed")
require.Contains(t, logs.String(), "receive back")
require.NotContains(t, logs.String(), telegramTestToken)
Width: 2,
Height: 2,
}}
+
err := bot.handle(t.Context(), test.loop, nil, TelegramUpdate{
UpdateID: 1,
Message: message,