Resume queued appends at their saved log ID

[onechat] / whatsapp_state.go

diff --git a/whatsapp_state.go b/whatsapp_state.go
index b8929f008983bea3d71ade8b3fc30b59bce02a92..c09423d83d6e73b97ede0feb152f8f701006a391 100644 (file)
--- a/whatsapp_state.go
+++ b/whatsapp_state.go
@@ -170,6 +170,7 @@ func (s *WhatsAppState) Closed() []WhatsAppBatch {
        defer s.mutex.Unlock()
 
        var closed []WhatsAppBatch
        defer s.mutex.Unlock()
 
        var closed []WhatsAppBatch

+

        for _, batch := range s.file.Batches {
                if batch.Closed {
                        closed = append(closed, batch)
        for _, batch := range s.file.Batches {
                if batch.Closed {
                        closed = append(closed, batch)


@@ -198,6 +199,7 @@ func (s *WhatsAppState) Wait(now time.Time) (time.Duration, bool) {
        defer s.mutex.Unlock()
 
        var first time.Time
        defer s.mutex.Unlock()
 
        var first time.Time

+

        for _, batch := range s.file.Batches {
                deadline := s.deadline(batch)
                if !batch.Closed && (first.IsZero() || deadline.Before(first)) {
        for _, batch := range s.file.Batches {
                deadline := s.deadline(batch)
                if !batch.Closed && (first.IsZero() || deadline.Before(first)) {