Sync agent queue replacements before success

[onechat] / daemon_message.go

diff --git a/daemon_message.go b/daemon_message.go
index 7665678468186a29b88e53ef38b1ddbad79d57e0..59733be7022e89ce73fe433afe2866ff16651c4a 100644 (file)
--- a/daemon_message.go
+++ b/daemon_message.go
@@ -193,7 +193,7 @@ func (m *DaemonMessages) save() error {
                return fmt.Errorf("encode agent messages: %w", err)
        }
 
                return fmt.Errorf("encode agent messages: %w", err)
        }
 

-       err = writeFileAtomic(m.path, append(data, '\n'))
+       err = writeFileDurable(m.path, append(data, '\n'))

        if err != nil {
                return fmt.Errorf("save agent messages: %w", err)
        }
        if err != nil {
                return fmt.Errorf("save agent messages: %w", err)
        }