-
Notifications
You must be signed in to change notification settings - Fork 560
/
Copy pathmain.go
110 lines (99 loc) · 2.43 KB
/
main.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
// Copyright 2018 Amazon.com, Inc. or its affiliates. All Rights Reserved
package main
import (
"archive/zip"
"flag"
"fmt"
"io/ioutil" //nolint: staticcheck
"log"
"os"
"path/filepath"
)
const usage = `build-lambda-zip - Puts an executable and supplemental files into a zip file that works with AWS Lambda.
usage:
build-lambda-zip [options] handler-exe [paths...]
options:
-o, --output output file path for the zip. (default: ${handler-exe}.zip)
-h, --help prints usage
`
func main() {
var outputZip string
flag.StringVar(&outputZip, "o", "", "")
flag.StringVar(&outputZip, "output", "", "")
flag.Usage = func() {
fmt.Fprint(os.Stderr, usage)
}
flag.Parse()
if len(flag.Args()) == 0 {
log.Fatal("no input provided")
}
inputExe := flag.Arg(0)
if outputZip == "" {
outputZip = fmt.Sprintf("%s.zip", filepath.Base(inputExe))
}
if err := compressExeAndArgs(outputZip, inputExe, flag.Args()[1:]); err != nil {
log.Fatalf("failed to compress file: %v", err)
}
log.Printf("wrote %s", outputZip)
}
func writeExe(writer *zip.Writer, pathInZip string, data []byte) error {
if pathInZip != "bootstrap" {
header := &zip.FileHeader{Name: "bootstrap", Method: zip.Deflate}
header.SetMode(0755 | os.ModeSymlink)
link, err := writer.CreateHeader(header)
if err != nil {
return err
}
if _, err := link.Write([]byte(pathInZip)); err != nil {
return err
}
}
exe, err := writer.CreateHeader(&zip.FileHeader{
CreatorVersion: 3 << 8, // indicates Unix
ExternalAttrs: 0777 << 16, // -rwxrwxrwx file permissions
Name: pathInZip,
Method: zip.Deflate,
})
if err != nil {
return err
}
_, err = exe.Write(data)
return err
}
func compressExeAndArgs(outZipPath string, exePath string, args []string) error {
zipFile, err := os.Create(outZipPath)
if err != nil {
return err
}
defer func() {
closeErr := zipFile.Close()
if closeErr != nil {
fmt.Fprintf(os.Stderr, "Failed to close zip file: %v\n", closeErr)
}
}()
zipWriter := zip.NewWriter(zipFile)
defer zipWriter.Close()
data, err := ioutil.ReadFile(exePath)
if err != nil {
return err
}
err = writeExe(zipWriter, filepath.Base(exePath), data)
if err != nil {
return err
}
for _, arg := range args {
writer, err := zipWriter.Create(arg)
if err != nil {
return err
}
data, err := ioutil.ReadFile(arg)
if err != nil {
return err
}
_, err = writer.Write(data)
if err != nil {
return err
}
}
return err
}