package piperutils import ( "archive/zip" "errors" "fmt" "io" "io/ioutil" "os" "path/filepath" "strings" ) // FileUtils ... type FileUtils interface { FileExists(filename string) (bool, error) Copy(src, dest string) (int64, error) FileRead(path string) ([]byte, error) FileWrite(path string, content []byte, perm os.FileMode) error MkdirAll(path string, perm os.FileMode) error } // Files ... type Files struct { } // FileExists ... func (f Files) FileExists(filename string) (bool, error) { info, err := os.Stat(filename) if os.IsNotExist(err) { return false, nil } if err != nil { return false, err } return !info.IsDir(), nil } // FileExists ... func FileExists(filename string) (bool, error) { return Files{}.FileExists(filename) } // Copy ... func (f Files) Copy(src, dst string) (int64, error) { exists, err := f.FileExists(src) if err != nil { return 0, err } if !exists { return 0, errors.New("Source file '" + src + "' does not exist") } source, err := os.Open(src) if err != nil { return 0, err } defer source.Close() destination, err := os.Create(dst) if err != nil { return 0, err } defer destination.Close() nBytes, err := io.Copy(destination, source) return nBytes, err } // Unzip will decompress a zip archive, moving all files and folders // within the zip file (parameter 1) to an output directory (parameter 2). // from https://golangcode.com/unzip-files-in-go/ with the following license: // MIT License // // Copyright (c) 2017 Edd Turtle // // Permission is hereby granted, free of charge, to any person obtaining a copy // of this software and associated documentation files (the "Software"), to deal // in the Software without restriction, including without limitation the rights // to use, copy, modify, merge, publish, distribute, sublicense, and/or sell // copies of the Software, and to permit persons to whom the Software is // furnished to do so, subject to the following conditions: // // The above copyright notice and this permission notice shall be included in all // copies or substantial portions of the Software. // // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR // IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, // FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE // AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER // LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE // SOFTWARE. func Unzip(src, dest string) ([]string, error) { var filenames []string r, err := zip.OpenReader(src) if err != nil { return filenames, err } defer r.Close() for _, f := range r.File { // Store filename/path for returning and using later on fpath := filepath.Join(dest, f.Name) // Check for ZipSlip. More Info: http://bit.ly/2MsjAWE if !strings.HasPrefix(fpath, filepath.Clean(dest)+string(os.PathSeparator)) { return filenames, fmt.Errorf("%s: illegal file path", fpath) } filenames = append(filenames, fpath) if f.FileInfo().IsDir() { // Make Folder os.MkdirAll(fpath, os.ModePerm) continue } // Make File if err = os.MkdirAll(filepath.Dir(fpath), os.ModePerm); err != nil { return filenames, err } outFile, err := os.OpenFile(fpath, os.O_WRONLY|os.O_CREATE|os.O_TRUNC, f.Mode()) if err != nil { return filenames, err } rc, err := f.Open() if err != nil { return filenames, err } _, err = io.Copy(outFile, rc) // Close the file without defer to close before next iteration of loop outFile.Close() rc.Close() if err != nil { return filenames, err } } return filenames, nil } // Copy ... func Copy(src, dst string) (int64, error) { return Files{}.Copy(src, dst) } //FileRead ... func (f Files) FileRead(path string) ([]byte, error) { return ioutil.ReadFile(path) } // FileWrite ... func (f Files) FileWrite(path string, content []byte, perm os.FileMode) error { return ioutil.WriteFile(path, content, perm) } // MkdirAll ... func (f Files) MkdirAll(path string, perm os.FileMode) error { return os.MkdirAll(path, perm) }