Implment handlers

Author: snmed

.gitignore

@@ -14,4 +14,5 @@
 # Dependency directories (remove the comment below to include it)
 # vendor/
 
-,idea/
+.idea/
+.vscode/

.idea/.gitignore

@@ -3,15 +3,16 @@ package main
 import (
 	"archive/zip"
 	"errors"
-	"github.com/go-sharp/color"
-	"github.com/jessevdk/go-flags"
 	"io"
 	"io/ioutil"
 	"log"
 	"os"
 	"os/exec"
 	"path/filepath"
 	"strings"
+
+	"github.com/go-sharp/color"
+	"github.com/jessevdk/go-flags"
 )
 
 var commonOpts options
@@ -65,7 +66,7 @@ func createTempWorkDir() (wd string, cleanFn func()) {
 func removeContent(dir string) {
 	defer func() {
 		if err := os.Remove(dir); err != nil {
-			verboseF("can't remove directory %v: %v\n", err)
+			verboseF("can't remove directory: %v\n", err)
 		}
 	}()
 
@@ -99,7 +100,7 @@ func removeContent(dir string) {
 
 		_ = os.Chmod(fpath, 0666)
 		if err := os.Remove(fpath); err != nil {
-			verboseF("can't remove directory %v: %v\n", err)
+			verboseF("can't remove directory: %v\n", err)
 		}
 	}
 }
@@ -143,7 +144,7 @@ func extractZipArchive(src, dst string) error {
 	return nil
 }
 
-func extractToFile(f *zip.File, dst string)  {
+func extractToFile(f *zip.File, dst string) {
 	destF, err := os.OpenFile(dst, os.O_CREATE|os.O_EXCL|os.O_WRONLY, 0666)
 	if err != nil {
 		log.Println(errorRedPrefix, "failed to extract file", f.Name, ":", err)

.idea/go-offline-packager.iml

@@ -1,12 +1,13 @@
 package main
 
 import (
-	"github.com/go-sharp/color"
 	"io/ioutil"
 	"log"
 	"os"
 	"os/exec"
 	"path/filepath"
+
+	"github.com/go-sharp/color"
 )
 
 type PackCmd struct {
@@ -31,7 +32,7 @@ func (p *PackCmd) Execute(args []string) error {
 	defer cleanFn()
 
 	modCache := filepath.Join(workDir, "modcache")
-	if err := os.Mkdir(modCache, 0777); err != nil {
+	if err := os.Mkdir(modCache, 0774); err != nil {
 		log.Fatalf("%v: failed to create mod cache directory: %v\n", color.RedString("error"), err)
 	}
 
@@ -41,12 +42,12 @@ func (p *PackCmd) Execute(args []string) error {
 		if err != nil {
 			log.Fatalf("failed to copy go.mod file: %v\n", color.RedString(err.Error()))
 		}
-		if err := ioutil.WriteFile(filepath.Join(workDir, "go.mod"), modContent, 0666); err != nil {
+		if err := ioutil.WriteFile(filepath.Join(workDir, "go.mod"), modContent, 0664); err != nil {
 			log.Fatalf("failed to copy go.mod file: %v\n", color.RedString(err.Error()))
 		}
 	} else {
 		verboseF("processing modules\n")
-		if err := ioutil.WriteFile(filepath.Join(workDir, "go.mod"), []byte(gomodTemp), 0666); err != nil {
+		if err := ioutil.WriteFile(filepath.Join(workDir, "go.mod"), []byte(gomodTemp), 0664); err != nil {
 			log.Fatalf("failed to write go.mod file: %v\n", color.RedString(err.Error()))
 		}
 
@@ -66,7 +67,7 @@ func (p *PackCmd) Execute(args []string) error {
 	cmd := exec.Command(commonOpts.GoBinPath, "mod", "download", "all")
 	cmd.Dir = workDir
 	cmd.Env = append(os.Environ(), "GOMODCACHE="+modCache)
-	if  err := cmd.Run(); err != nil {
+	if err := cmd.Run(); err != nil {
 		log.Fatalln("failed to download dependencies:", color.RedString(err.Error()))
 	}
 

.idea/modules.xml

@@ -2,12 +2,17 @@ package main
 
 import (
 	"errors"
+	"io"
 	"log"
 	"os"
+	"path/filepath"
+	"strings"
+
+	"github.com/go-sharp/color"
 )
 
 type publishCmd struct {
-	PosArgs struct{
+	PosArgs struct {
 		Archive string `positional-arg-name:"ARCHIVE" description:"Path to archive with dependencies. " default:"gop_dependencies.zip"`
 	} `positional-args:"yes" required:"1"`
 }
@@ -23,24 +28,93 @@ func (f FolderPublishCmd) Execute(args []string) error {
 	workDir, cleanFn := createTempWorkDir()
 	defer cleanFn()
 
+	log.Println("extracting archive")
+
 	defaultErrStr := errorRedPrefix + " failed to extract archive:"
 	if err := extractZipArchive(f.PosArgs.Archive, workDir); err != nil {
 		log.Fatalln(defaultErrStr, err)
 	}
 
+	// Prepare output folder
 	fi, err := os.Stat(f.Output)
 	if err != nil {
 		if !errors.Is(err, os.ErrNotExist) {
 			log.Fatalln(defaultErrStr, err)
 		}
-		if err := os.MkdirAll(f.Output, 0777); err != nil {
+		if err := os.MkdirAll(f.Output, 0774); err != nil {
 			log.Fatalln(defaultErrStr, err)
 		}
 	} else if !fi.IsDir() {
 		log.Fatalln(errorRedPrefix, "output is not a directory:", f.Output)
 	}
 
+	log.Println("processing files")
+	dirPrefix := filepath.Join(workDir, "cache", "download")
+	err = filepath.Walk(dirPrefix, func(path string, info os.FileInfo, err error) error {
+		relPath := strings.TrimLeft(strings.TrimPrefix(path, dirPrefix), string(filepath.Separator))
+
+		if strings.HasPrefix(relPath, "sumdb") && !info.IsDir() {
+			go f.handleCopyFile(path, relPath)
+			return nil
+		}
+
+		if info.IsDir() && strings.HasSuffix(relPath, "@v") {
+			go f.handleModule(path, relPath)
+			return nil
+		}
+
+		return nil
+	})
+
+	if err != nil {
+		log.Println(errorRedPrefix, err)
+	}
+
 	return nil
 }
 
+func (f FolderPublishCmd) handleModule(path, relPath string) {
+	//dstDir := filepath.Join(f.Output, relPath)
 
+}
+
+func (f FolderPublishCmd) handleCopyFile(path, relPath string) {
+	dstPath := filepath.Join(f.Output, relPath)
+	if _, err := os.Stat(dstPath); !errors.Is(err, os.ErrNotExist) {
+		reason := "file exists"
+		if err != nil {
+			reason = err.Error()
+		}
+		verboseF("skipping file %v: %v\n", color.YellowString(relPath), reason)
+		return
+	}
+
+	dstDir := filepath.Dir(dstPath)
+	if st, err := os.Stat(dstDir); errors.Is(err, os.ErrNotExist) {
+		// We don't care if we can't create dir, it will fail when we try to copy the file
+		_ = os.MkdirAll(dstDir, 0774)
+	} else if !st.IsDir() {
+		log.Println(errorRedPrefix, "failed to copy file destination is not a directory: ", dstDir)
+		return
+	}
+
+	srcF, err := os.Open(path)
+	if err != nil {
+		log.Println(errorRedPrefix, "failed to read src:", err)
+		return
+	}
+	defer srcF.Close()
+
+	dstF, err := os.OpenFile(dstPath, os.O_CREATE|os.O_EXCL|os.O_WRONLY, 0664)
+	if err != nil {
+		log.Println(errorRedPrefix, "failed to create file:", err)
+		return
+	}
+	defer dstF.Close()
+
+	if _, err := io.Copy(dstF, srcF); err != nil {
+
+		log.Println(errorRedPrefix, "failed to copy file:", err)
+		return
+	}
+}