A/B testing - extract and store dashboard id (#914)

quesma/ab_testing/collector/collector.go

@@ -34,6 +34,8 @@ type EnrichedResults struct {
 	QuesmaVersion   string           `json:"quesma_version"`
 	QuesmaBuildHash string           `json:"quesma_hash"`
 	Errors          []string         `json:"errors,omitempty"`
+
+	KibanaDashboardId string `json:"kibana_dashboard_id,omitempty"`
 }
 
 type pipelineProcessor interface {
@@ -78,6 +80,7 @@ func NewCollector(ctx context.Context, healthQueue chan<- ab_testing.HealthMessa
 		cancelFunc:   cancel,
 		pipeline: []pipelineProcessor{
 			&probabilisticSampler{ratio: 1},
+			&extractKibanaIds{},
 			&unifySyncAsyncResponse{},
 			&diffTransformer{},
 			//&ppPrintFanout{},

quesma/ab_testing/collector/processors.go

@@ -6,6 +6,7 @@ import (
 	"encoding/json"
 	"fmt"
 	"quesma/quesma/types"
+	"regexp"
 )
 
 // unifySyncAsyncResponse is a processor that processes that removes async "wrapper" from the response
@@ -58,3 +59,34 @@ func (t *unifySyncAsyncResponse) process(in EnrichedResults) (out EnrichedResult
 
 	return in, false, nil
 }
+
+type extractKibanaIds struct {
+}
+
+func (t *extractKibanaIds) name() string {
+	return "extractKibanaIds"
+}
+
+var opaqueIdKibanaDashboardIdRegexp = regexp.MustCompile(`dashboards:([0-9a-f-]+)`)
+
+func (t *extractKibanaIds) process(in EnrichedResults) (out EnrichedResults, drop bool, err error) {
+
+	opaqueId := in.OpaqueID
+
+	// TODO maybe we should extract panel id as well
+
+	if opaqueId == "" {
+		in.KibanaDashboardId = "n/a"
+		return in, false, nil
+	}
+
+	matches := opaqueIdKibanaDashboardIdRegexp.FindStringSubmatch(opaqueId)
+
+	if len(matches) < 2 {
+		in.KibanaDashboardId = "n/a"
+		return in, false, nil
+	}
+
+	in.KibanaDashboardId = matches[1]
+	return in, false, nil
+}