added env variable for bacalhau results directory

.local.dev

@@ -30,4 +30,5 @@ WEB3_USERS_ADDRESS=0x0DCd1Bf9A1b36cE34237eEaFef220932846BCD82
 BACALHAU_API_HOST=localhost
 BACALHAU_API_PORT=20000
 JOB_STATUS_POLL_INTERVAL=5
+BACALHAU_RESULTS_DIRECTORY=
 

pkg/executor/bacalhau/bacalhau.go

@@ -34,6 +34,7 @@ type BacalhauExecutorOptions struct {
 	ApiHost string
 	ApiPort               string
 	JobStatusPollInterval uint64
+	ResultsDirectory      string
 }
 
 type BacalhauExecutor struct {
@@ -160,12 +161,7 @@ func (executor *BacalhauExecutor) RunJob(
 
 func (executor *BacalhauExecutor) prepareResults(jobId string, executionId string) (cid string, resultsDir string, err error) {
 
-	home, err := os.UserHomeDir()
-	if err != nil {
-		return "", "", fmt.Errorf("error getting home directory: %s", err.Error())
-	}
-
-	resultsPath := filepath.Join(home, ".bacalhau", "compute", "results", "local-publisher", fmt.Sprintf("%s.tar.gz", executionId))
+	resultsPath := filepath.Join(executor.Options.ResultsDirectory, fmt.Sprintf("%s.tar.gz", executionId))
 
 	gzipFile, err := os.Open(resultsPath)
 	if err != nil {

pkg/options/bacalhau.go

@@ -2,16 +2,30 @@ package options
 
 import (
 	"fmt"
+	"os"
+	"path/filepath"
 
 	"github.com/lilypad-tech/lilypad/pkg/executor/bacalhau"
 	"github.com/spf13/cobra"
 )
 
 func GetDefaultBacalhauOptions() bacalhau.BacalhauExecutorOptions {
+	home, err := os.UserHomeDir()
+	if err != nil {
+		panic(fmt.Errorf("error getting home directory: %s", err.Error()))
+	}
+
+	resultsPath := filepath.Join(home, ".bacalhau", "compute", "results", "local-publisher")
+
+
+
+
+
 	return bacalhau.BacalhauExecutorOptions{
 		ApiHost: GetDefaultServeOptionString("BACALHAU_API_HOST", "localhost"),
 		ApiPort: GetDefaultServeOptionString("BACALHAU_API_PORT", "20000"),
 		JobStatusPollInterval: GetDefaultServeOptionUint64("JOB_STATUS_POLL_INTERVAL", 5),
+		ResultsDirectory:      GetDefaultServeOptionString("BACALHAU_RESULTS_DIRECTORY", resultsPath),
 	}
 }