Support zlib compression

1 files changed, 13 insertions, 1 deletions

diff --git a/inform/codec.go b/inform/codec.go
index 8147986..ac49aa1 100644
--- a/inform/codec.go
+++ b/inform/codec.go
@@ -2,6 +2,7 @@ package inform
 
 import (
         "bytes"
+        "compress/zlib"
         "encoding/binary"
         "errors"
         "io"
@@ -56,7 +57,18 @@ func (c *Codec) Unmarshal(fp io.Reader) (*InformWrapper, error) {
                         return nil, err
                 }
         } else if w.IsZlibCompressed() {
-                return nil, errors.New("payload is zlib compressed, not supported")
+                rb := bytes.NewReader(u)
+                wb := &bytes.Buffer{}
+
+                r, err := zlib.NewReader(rb)
+                if err != nil {
+                        return nil, err
+                }
+
+                io.Copy(wb, r)
+                r.Close()
+
+                w.Payload = wb.Bytes()
         } else {
                 w.Payload = u
         }