// ConnectContext keeps ctx and tells the test that the daemon connected.
func (f *WhatsAppFake) ConnectContext(ctx context.Context) error {
f.mutex.Lock()
+
f.connections = append(f.connections, ctx)
f.connectTimes = append(f.connectTimes, time.Now())
f.mutex.Unlock()
if len(f.connectErrors) > 0 {
err := f.connectErrors[0]
f.connectErrors = f.connectErrors[1:]
+
return err
}
// Emit gives event to the handler of the daemon and returns its answer.
func (f *WhatsAppFake) Emit(event any) bool {
f.mutex.Lock()
+
handle := f.handle
f.mutex.Unlock()
}, 10*time.Second, time.Millisecond)
var texts []string
+
for id := range memory.Len() {
message, err := memory.Message(id)
require.NoError(t, err)
dir := t.TempDir()
whatsappTestSession(t, dir, true)
+
whatsapp, fake, _ := whatsappStartTest(t, dir, newTestClock())
whatsapp.state.quiet = 50 * time.Millisecond
contacts := whatsapp.device.Contacts
require.NoError(t, contacts.PutContactName(t.Context(), whatsappTestAna, "Ana", "Ana Souza"))
require.NoError(t, contacts.PutContactName(t.Context(), types.NewJID("15550004444", types.DefaultUserServer), "João", "João Silva"))
+
_, _, err := contacts.PutBusinessName(t.Context(), types.NewJID("15550005555", types.DefaultUserServer), "Corner Bakery")
require.NoError(t, err)
require.NoError(t, contacts.PutContactName(t.Context(), whatsappTestOwn, "Me", "Me Souza"))