first add of tar streamer

1 files changed, 43 insertions, 0 deletions

diff --git a/tar.go b/tar.go
new file mode 100644
index 0000000..e811840
--- /dev/null
+++ b/tar.go
@@ -0,0 +1,43 @@
+package main
+
+import (
+	"archive/tar"
+	"io"
+	"log"
+	"os"
+)
+
+func streamFilesTar(files []File, stream io.WriteCloser) {
+	tarStream := tar.NewWriter(stream)
+	for _, f := range files {
+		file, err := os.Open(f.Path)
+		if err != nil {
+			log.Printf("Error reading file '%s': %s\n", f.Path, err)
+			continue
+		}
+		stat, err := file.Stat()
+		if err != nil {
+			log.Printf("Error getting stat of file '%s': %s\n", f.Path, err)
+			continue
+		}
+		hdr, err := tar.FileInfoHeader(stat, "")
+		if err != nil {
+			log.Printf("Error creating tar header for file '%s': %s\n", f.Path, err)
+			continue
+		}
+		if err := tarStream.WriteHeader(hdr); err != nil {
+			log.Printf("Error writing tar header to stream for file '%s': %s\n", f.Path, err)
+			continue
+		}
+		if _, err := io.Copy(tarStream, file); err != nil {
+			log.Printf("Error writing file to stream '%s': %s\n", f.Path, err)
+			continue
+		}
+	}
+	if err := tarStream.Close(); err != nil {
+		log.Fatal("Error closing tar stream:", err)
+	}
+	if err := stream.Close(); err != nil {
+		log.Fatal("Error closing stream:", err)
+	}
+}