fix empty context bug

.tiltignore

@@ -0,0 +1,3 @@
+.git
+tilt_modules
+vendor

cmd/d8s/main.go

@@ -333,7 +333,6 @@ func localServer(localAddr string) (int, error) {
 
 func uploadContextHandlerFunc(proxy *httputil.ReverseProxy, localAddr string) http.HandlerFunc {
 	re := regexp.MustCompile(`^/[^/]+/build$`)
-	chunksList := bytes.Buffer{}
 
 	return func(w http.ResponseWriter, r *http.Request) {
 		if !re.MatchString(r.URL.Path) {
@@ -342,6 +341,7 @@ func uploadContextHandlerFunc(proxy *httputil.ReverseProxy, localAddr string) ht
 		}
 
 		chnker := chunker.New(r.Body, staticPol)
+		chunksList := bytes.Buffer{}
 
 		for {
 			c, err := chnker.Next(nil)

pkg/build.go

@@ -70,7 +70,16 @@ func (s Service) build(w http.ResponseWriter, r *http.Request) {
 		}
 		defer os.Remove(tempfile.Name())
 
-		err = s.restoreContext(ctx, r.Body, tempfile)
+		buf := new(bytes.Buffer)
+		_, err = buf.ReadFrom(r.Body)
+		if err != nil {
+			w.WriteHeader(http.StatusInternalServerError)
+			w.Write([]byte(fmt.Sprintf("read chunk list: %v", err)))
+			log.Printf("read chunk list: %v", err)
+			return
+		}
+
+		err = s.restoreContext(ctx, buf, tempfile)
 		if err != nil {
 			w.WriteHeader(http.StatusInternalServerError)
 			w.Write([]byte(fmt.Sprintf("restore context: %v", err)))
@@ -93,7 +102,7 @@ func (s Service) build(w http.ResponseWriter, r *http.Request) {
 	if err != nil {
 		w.WriteHeader(http.StatusInternalServerError)
 		w.Write([]byte(fmt.Sprintf("store context: %v", err)))
-		log.Printf("execute build: %v", err)
+		log.Printf("store context: %v", err)
 		return
 	}
 	defer func() {
@@ -367,7 +376,7 @@ unset x
 
 echo download build context
 cd ~ && mkdir context && cd context
-wget -O - "%s" | tar -xf -
+wget -O - "${CONTEXT_URL}" | tar -xf -
 
 set -x
 buildctl-daemonless.sh \
@@ -382,7 +391,7 @@ buildctl-daemonless.sh \
  %s \
  --export-cache=type=registry,ref=wedding-registry:5000/cache-repo,mode=max \
  --import-cache=type=registry,ref=wedding-registry:5000/cache-repo
-`, presignedContextURL, dockerfileDir, dockerfileName, buildargs, labels, target, destination)
+`, dockerfileDir, dockerfileName, buildargs, labels, target, destination)
 
 	buildkitdMemory := 100 * 1024 * 1024
 
@@ -407,6 +416,12 @@ buildctl-daemonless.sh \
 							Name:      "buildkitd-config",
 						},
 					},
+					Env: []corev1.EnvVar{
+						{
+							Name:  "CONTEXT_URL",
+							Value: presignedContextURL,
+						},
+					},
 					Resources: corev1.ResourceRequirements{
 						Limits: corev1.ResourceList{
 							corev1.ResourceCPU:    resource.MustParse(fmt.Sprintf("%dm", cfg.cpuMilliseconds)),

pkg/chunks.go

@@ -80,8 +80,6 @@ func (s Service) addChunk(w http.ResponseWriter, r *http.Request) {
 	hashHex := make([]byte, hex.EncodedLen(len(hash)))
 	hex.Encode(hashHex, hash)
 
-	log.Printf("calculated hash: %v", string(hashHex))
-
 	path := filepath.Join("chunks", string(hashHex))
 
 	_, err = s.objectStore.Uploader.UploadWithContext(r.Context(), &s3manager.UploadInput{