very WIP implementation of #587 to enable getting test run id

cmd/run.go

@@ -236,6 +236,9 @@ func (c *cmdRun) run(cmd *cobra.Command, args []string) (err error) {
 		stopOutputs(err)
 	}()
 
+	conf.Outputs = outputManager.JSONConfig()
+	test.initRunner.SetOptions(conf.Options)
+
 	if !testRunState.RuntimeOptions.NoThresholds.Bool {
 		finalizeThresholds := metricsEngine.StartThresholdCalculations(
 			metricsIngester, runAbort, executionState.GetCurrentTestRunDuration,

lib/options.go

@@ -342,6 +342,8 @@ type Options struct {
 
 	// Specify client IP ranges and/or CIDR from which VUs will make requests
 	LocalIPs types.NullIPPool `json:"-" envconfig:"K6_LOCAL_IPS"`
+
+	Outputs map[string]json.RawMessage `json:"outputs"`
 }
 
 // Apply returns the result of overwriting any fields with any that are set on the argument.
@@ -511,6 +513,9 @@ func (o Options) Apply(opts Options) Options {
 	if opts.DNS.Policy.Valid {
 		o.DNS.Policy = opts.DNS.Policy
 	}
+	if opts.Outputs != nil {
+		o.Outputs = opts.Outputs
+	}
 
 	return o
 }

output/cloud/output.go

@@ -2,6 +2,7 @@
 package cloud
 
 import (
+	"encoding/json"
 	"errors"
 	"fmt"
 	"path/filepath"
@@ -186,6 +187,7 @@ func (out *Output) Start() error {
 		return err
 	}
 	out.testRunID = response.ReferenceID
+	out.config.PushRefID = null.StringFrom(out.testRunID)
 
 	if response.ConfigOverride != nil {
 		out.logger.WithFields(logrus.Fields{
@@ -208,6 +210,14 @@ func (out *Output) Start() error {
 	return nil
 }
 
+func (out *Output) JSONConfig() json.RawMessage {
+	res, err := json.Marshal(out.config)
+	if err != nil {
+		panic(err) // TODO FIX
+	}
+	return res
+}
+
 // Description returns the URL with the test run results.
 func (out *Output) Description() string {
 	return fmt.Sprintf("cloud (%s)", cloudapi.URLForResults(out.testRunID, out.config))

output/manager.go

@@ -1,6 +1,7 @@
 package output
 
 import (
+	"encoding/json"
 	"sync"
 	"time"
 
@@ -82,6 +83,18 @@ func (om *Manager) Start(samplesChan chan metrics.SampleContainer) (wait func(),
 	return wait, finish, nil
 }
 
+func (om *Manager) JSONConfig() map[string]json.RawMessage {
+	result := make(map[string]json.RawMessage)
+	for _, output := range om.outputs {
+		o, ok := output.(interface{ JSONConfig() json.RawMessage })
+		if !ok {
+			continue
+		}
+		result["cloud"] = o.JSONConfig() // TODO fix
+	}
+	return result
+}
+
 // startOutputs spins up all configured outputs. If some output fails to start,
 // it stops the already started ones. This may take some time, since some
 // outputs make initial network requests to set up whatever remote services are