fix(pgs): close any open readers

pgs/uploader.go

@@ -236,8 +236,8 @@ func (h *UploadAssetHandler) findDenylist(bucket sst.Bucket, project *db.Project
 	if err != nil {
 		return "", fmt.Errorf("_pgs_ignore not found")
 	}
-
 	defer fp.Close()
+
 	buf := new(strings.Builder)
 	_, err = io.Copy(buf, fp)
 	if err != nil {
@@ -306,11 +306,14 @@ func (h *UploadAssetHandler) Write(s ssh.Session, entry *sendutils.FileEntry) (s
 	// calculate the filsize difference between the same file already
 	// stored and the updated file being uploaded
 	assetFilename := shared.GetAssetFileName(entry)
-	_, info, _ := h.Storage.GetObject(bucket, assetFilename)
+	obj, info, _ := h.Storage.GetObject(bucket, assetFilename)
 	var curFileSize int64
 	if info != nil {
 		curFileSize = info.Size
 	}
+	if obj != nil {
+		defer obj.Close()
+	}
 
 	denylist := getDenylist(s)
 	if denylist == nil {

pgs/web_asset_handler.go

@@ -85,10 +85,11 @@ func (h *ApiAssetHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 			// before redirecting, this saves a hop that will just end up a 404
 			if !hasProtocol(fp.Filepath) && strings.HasSuffix(fp.Filepath, "/") {
 				next := filepath.Join(h.ProjectDir, fp.Filepath, "index.html")
-				_, _, err := h.Storage.GetObject(h.Bucket, next)
+				obj, _, err := h.Storage.GetObject(h.Bucket, next)
 				if err != nil {
 					continue
 				}
+				defer obj.Close()
 			}
 			logger.Info(
 				"redirecting request",