diff --git a/msg.go b/msg.go index cd64c80..06017b6 100644 --- a/msg.go +++ b/msg.go @@ -340,9 +340,19 @@ func UnzipMessages(z []byte) error { if err != nil { return err } - bkp := DataBackup{} - err = json.NewDecoder(rc).Decode(bkp) + data, err := ioutil.ReadAll(rc) + logOnError(err, "UnzipMessages : ReadAll") + if err != nil { + return err + } + log.Printf("UnzipMessages : %d uncompressed bytes.\n", len(data)) rc.Close() + bkp := DataBackup{} + err = json.Unmarshal(data, &bkp) + logOnError(err, "UnzipMessages : Unmarshal") + if err != nil { + return err + } log.Printf("UnzipMessages : %d messages.\n", len(bkp.Messages)) return nil }