import (
"context"
"fmt"
- "io"
- "log"
+ "log/slog"
"os"
"path/filepath"
"slices"
// 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
}
}
// GetQRChannel gives a new channel of pairing items to the test.
-func (f *WhatsAppFake) GetQRChannel(ctx context.Context) (<-chan whatsmeow.QRChannelItem, error) {
+func (f *WhatsAppFake) GetQRChannel(_ context.Context) (<-chan whatsmeow.QRChannelItem, error) {
items := make(chan whatsmeow.QRChannelItem, 8)
f.pairings <- items
}
// PairPhone keeps phone and returns whatsappTestCode.
-func (f *WhatsAppFake) PairPhone(ctx context.Context, phone string, showPushNotification bool, clientType whatsmeow.PairClientType, clientDisplayName string) (string, error) {
+func (f *WhatsAppFake) PairPhone(_ context.Context, phone string, _ bool, _ whatsmeow.PairClientType, _ string) (string, error) {
f.mutex.Lock()
defer f.mutex.Unlock()
}
// Logout counts the logouts and returns logoutErr.
-func (f *WhatsAppFake) Logout(ctx context.Context) error {
+func (f *WhatsAppFake) Logout(_ context.Context) error {
f.mutex.Lock()
defer f.mutex.Unlock()
}
// GetJoinedGroups returns groups.
-func (f *WhatsAppFake) GetJoinedGroups(ctx context.Context) ([]*types.GroupInfo, error) {
+func (f *WhatsAppFake) GetJoinedGroups(_ context.Context) ([]*types.GroupInfo, error) {
f.mutex.Lock()
defer f.mutex.Unlock()
}
// SendMessage keeps the send and returns sendErr.
-func (f *WhatsAppFake) SendMessage(ctx context.Context, to types.JID, message *waE2E.Message, extra ...whatsmeow.SendRequestExtra) (whatsmeow.SendResponse, error) {
+func (f *WhatsAppFake) SendMessage(_ context.Context, to types.JID, message *waE2E.Message, extra ...whatsmeow.SendRequestExtra) (whatsmeow.SendResponse, error) {
f.mutex.Lock()
defer f.mutex.Unlock()
// 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()
}
// newClient keeps handle and returns the fake as the client of device.
-func (f *WhatsAppFake) newClient(device *store.Device, handle func(event any) bool) WhatsAppClient {
+func (f *WhatsAppFake) newClient(_ *store.Device, handle func(event any) bool) WhatsAppClient {
f.mutex.Lock()
defer f.mutex.Unlock()
}
logs := &SyncBuffer{}
- whatsapp, err := openWhatsApp(t.Context(), dir, clock.Now, log.New(logs, "", 0), fake.newClient)
+ whatsapp, err := openWhatsApp(t.Context(), dir, clock.Now, daemonTestLogger(logs), fake.newClient)
require.NoError(t, err)
t.Cleanup(func() {
}
// whatsappDiscardLog is a logger for a WhatsApp whose log a test does not read.
-func whatsappDiscardLog() *log.Logger {
- return log.New(io.Discard, "", 0)
+func whatsappDiscardLog() *slog.Logger {
+ return slog.New(slog.DiscardHandler)
}
// whatsappTestMessage returns the event of the text message id of sender in
}, 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"))