Merge pull request #35 from moonstream-to/fix-gcs-close

Fix missing close.

storage/factory.go

@@ -13,10 +13,12 @@ import (
 func NewStorage(storageType, basePath string) (Storer, error) {
 	switch storageType {
 	case "filesystem":
+		log.Println("Using filesystem storage")
 		return NewFileStorage(basePath), nil
 	case "gcp-storage":
 		// Google Cloud Storage
 		ctx := context.Background()
+		log.Println("Creating GCS client")
 
 		var client *gcp_storage.Client
 		var clientErr error

storage/gcp_storage.go

@@ -47,6 +47,10 @@ func (g *GCS) Save(batchDir, filename string, bf bytes.Buffer) error {
 		return fmt.Errorf("failed to write object to bucket: %v", err)
 	}
 
+	if err := wc.Close(); err != nil {
+		return fmt.Errorf("failed to close writer: %v", err)
+	}
+
 	return nil
 }
 

version/version.go

@@ -1,3 +1,3 @@
 package version
 
-var SeerVersion string = "0.1.8"
+var SeerVersion string = "0.1.9"