Resume queued appends at their saved log ID

[onechat] / whatsapp_groups.go

diff --git a/whatsapp_groups.go b/whatsapp_groups.go
index 56676e5264fb363e709b2785bd095c6c9d42c012..ec5c892309e4aa282412730f5be35f95125acdb0 100644 (file)
--- a/whatsapp_groups.go
+++ b/whatsapp_groups.go
@@ -2,7 +2,7 @@ package main
 
 import (
        "context"
 
 import (
        "context"

-       "log"
+       "log/slog"

        "maps"
        "sync"
        "time"
        "maps"
        "sync"
        "time"


@@ -23,7 +23,7 @@ const (
 
 // newWhatsAppGroups returns the names of the groups with no names yet. logger
 // gets the failures of a read.
 
 // newWhatsAppGroups returns the names of the groups with no names yet. logger
 // gets the failures of a read.

-func newWhatsAppGroups(logger *log.Logger) *WhatsAppGroups {
+func newWhatsAppGroups(logger *slog.Logger) *WhatsAppGroups {

        return &WhatsAppGroups{
                logger: logger,
                names:  make(map[string]string),
        return &WhatsAppGroups{
                logger: logger,
                names:  make(map[string]string),


@@ -36,7 +36,7 @@ func newWhatsAppGroups(logger *log.Logger) *WhatsAppGroups {
 // read, and readAt the time of the last read that succeeded. The mutex
 // protects all fields after logger.
 type WhatsAppGroups struct {
 // read, and readAt the time of the last read that succeeded. The mutex
 // protects all fields after logger.
 type WhatsAppGroups struct {

-       logger *log.Logger
+       logger *slog.Logger

 
        mutex   sync.Mutex
        names   map[string]string
 
        mutex   sync.Mutex
        names   map[string]string


@@ -82,7 +82,7 @@ func (g *WhatsAppGroups) read(ctx context.Context, link WhatsAppLink) bool {
 
        groups, err := link.client.GetJoinedGroups(ctx)
        if err != nil {
 
        groups, err := link.client.GetJoinedGroups(ctx)
        if err != nil {

-               g.logger.Printf("group list failed: %s", whatsappRedact(link.own, err.Error()))
+               g.logger.Warn("group list failed", "err", whatsappRedact(link.own, err.Error()))

        }
 
        g.mutex.Lock()
        }
 
        g.mutex.Lock()