fixing of writing of snapshot

store/ligthstore.db

@@ -0,0 +1,40 @@
+set;
+0
+bar+0
+end;
+set;
+1
+bar+1
+end;
+set;
+2
+bar+2
+end;
+set;
+3
+bar+3
+end;
+set;
+4
+bar+4
+end;
+set;
+5
+bar+5
+end;
+set;
+6
+bar+6
+end;
+set;
+7
+bar+7
+end;
+set;
+8
+bar+8
+end;
+set;
+9
+bar+9
+end;

store/snapshot.go

@@ -50,7 +50,15 @@ func (so *Snapshot) Write(w io.Writer) error {
 			Key:   itm.Key(),
 			Value: itm.ValueData(),
 		}
-		err := binary.Write(buf, binary.LittleEndian, data)
+		err := binary.Write(w, binary.LittleEndian, uint64(data.Size()))
+		if err != nil {
+			return errors.Wrap(err, "unable to write size info")
+		}
+		bufWr, err := data.Marshal()
+		if err != nil {
+			return errors.Wrap(err, "unable to marshal data")
+		}
+		_, err = w.Write(bufWr)
 		if err != nil {
 			return errors.Wrap(err, "unable to write data")
 		}

store/snapshot_test.go

@@ -1,6 +1,7 @@
 package store
 
 import (
+	"os"
 	"testing"
 )
 
@@ -21,8 +22,13 @@ func TestSnapshot(t *testing.T) {
 		t.Fatalf("unable to write data: %v", err)
 	}
 
+	f, err := os.Create("/tmp/dat2")
+	if err != nil {
+		t.Fatalf("unable to write data: %v", err)
+	}
+	defer f.Close()
 	snap := NewSnapshot(light.getStore(), "./snapshot1")
-	err = snap.Write(nil)
+	err = snap.Write(f)
 	if err != nil {
 		t.Fatalf("unable to write snapshot: %v", err)
 	}