fix local debug files (#460)

magefile.go

@@ -21,7 +21,7 @@ import (
 	"encoding/json"
 	"fmt"
 	"os"
-	"path/filepath"
+	"path"
 	"strings"
 
 	"github.com/livekit/mageutil"
@@ -104,9 +104,11 @@ func Integration(configFile string) error {
 
 	defer func() {
 		// for some reason, these can't be deleted from within the docker container
-		dirs, _ := filepath.Glob("test/output/EG_*")
-		for _, dir := range dirs {
-			_ = os.Remove(dir)
+		files, _ := os.ReadDir("test/output")
+		for _, file := range files {
+			if file.IsDir() {
+				_ = os.RemoveAll(path.Join("test/output", file.Name()))
+			}
 		}
 	}()
 

pkg/pipeline/debug.go

@@ -25,7 +25,6 @@ import (
 
 	"github.com/tinyzimmer/go-gst/gst"
 
-	"github.com/livekit/egress/pkg/config"
 	"github.com/livekit/egress/pkg/errors"
 	"github.com/livekit/egress/pkg/pipeline/sink/uploader"
 	"github.com/livekit/egress/pkg/types"
@@ -114,8 +113,15 @@ func (p *Pipeline) uploadPProf(u uploader.Uploader) {
 }
 
 func (p *Pipeline) uploadDebugFile(u uploader.Uploader, data []byte, fileExtension string) {
+	var dir string
+	if p.Debug.ToUploadConfig() == nil {
+		dir = p.Debug.PathPrefix
+	} else {
+		dir = p.TmpDir
+	}
+
 	filename := fmt.Sprintf("%s%s", p.Info.EgressId, fileExtension)
-	local := path.Join(config.TmpDir, filename)
+	local := path.Join(dir, filename)
 	storage := path.Join(p.Debug.PathPrefix, filename)
 
 	f, err := os.Create(local)