internal/telemetry: implement temporary telemetry fix for configurations

contrib/internal/httptrace/httptrace.go

@@ -11,6 +11,7 @@ import (
 	"context"
 	"fmt"
 	"gopkg.in/DataDog/dd-trace-go.v1/internal/log"
+	"gopkg.in/DataDog/dd-trace-go.v1/internal/telemetry"
 	"net/http"
 	"strconv"
 	"strings"
@@ -67,6 +68,8 @@ func StartRequestSpan(r *http.Request, opts ...ddtrace.StartSpanOption) (tracer.
 					}
 				}
 				inferredProxySpan = startInferredProxySpan(requestProxyContext, spanParentCtx, inferredStartSpanOpts...)
+				telemetry.GlobalClient.IntegrationConfigChange([]telemetry.Configuration{{Name: "inferred_proxy_services_enabled",
+					Value: cfg.inferredProxyServicesEnabled}})
 			}
 		}
 	}

internal/telemetry/client.go

@@ -32,6 +32,7 @@ import (
 type Client interface {
 	RegisterAppConfig(name string, val interface{}, origin Origin)
 	ProductChange(namespace Namespace, enabled bool, configuration []Configuration)
+	IntegrationConfigChange(configuration []Configuration)
 	ConfigChange(configuration []Configuration)
 	Record(namespace Namespace, metric MetricKind, name string, value float64, tags []string, common bool)
 	Count(namespace Namespace, name string, value float64, tags []string, common bool)

internal/telemetry/telemetry.go

@@ -45,6 +45,29 @@ func (c *client) ProductChange(namespace Namespace, enabled bool, configuration
 	}
 }
 
+// IntegrationConfigChange is a thread-safe method to enqueue an app-started event.
+func (c *client) IntegrationConfigChange(configuration []Configuration) {
+	c.mu.Lock()
+	defer c.mu.Unlock()
+	c.integrationConfigChange(configuration)
+}
+
+// integrationConfigChange enqueues an app-started event to be flushed.
+// Must be called with c.mu locked.
+func (c *client) integrationConfigChange(configuration []Configuration) {
+	if !c.started {
+		log("attempted to send config change event, but telemetry client has not started")
+		return
+	}
+	if len(configuration) > 0 {
+		configChange := new(ConfigurationChange)
+		configChange.Configuration = configuration
+		configReq := c.newRequest(RequestTypeAppStarted)
+		configReq.Body.Payload = configChange
+		c.scheduleSubmit(configReq)
+	}
+}
+
 // ConfigChange is a thread-safe method to enqueue an app-client-configuration-change event.
 func (c *client) ConfigChange(configuration []Configuration) {
 	c.mu.Lock()

internal/telemetry/telemetry_test.go

@@ -47,6 +47,20 @@ func TestConfigChange(t *testing.T) {
 	Check(t, configPayload.Configuration, "delta_profiles", true)
 }
 
+func TestIntegrationConfigChange(t *testing.T) {
+	client := new(client)
+	client.start(nil, NamespaceTracers, true)
+	client.integrationConfigChange([]Configuration{BoolConfig("delta_profiles", true)})
+	require.Len(t, client.requests, 1)
+
+	body := client.requests[0].Body
+	assert.Equal(t, RequestTypeAppStarted, body.RequestType)
+	var configPayload = client.requests[0].Body.Payload.(*ConfigurationChange)
+	require.Len(t, configPayload.Configuration, 1)
+
+	Check(t, configPayload.Configuration, "delta_profiles", true)
+}
+
 // mockServer initializes a server that expects a strict amount of telemetry events. It saves these
 // events in a slice until the expected number of events is reached.
 // the `genTelemetry` argument accepts a function that should generate the expected telemetry events via calls to the global client

internal/telemetry/telemetrytest/telemetrytest.go

@@ -101,3 +101,9 @@ func (c *MockClient) ConfigChange(args []telemetry.Configuration) {
 	c.On("ConfigChange", args).Return()
 	_ = c.Called(args)
 }
+
+// IntegrationConfigChange is a mock for the IntegrationConfigChange method.
+func (c *MockClient) IntegrationConfigChange(args []telemetry.Configuration) {
+	c.On("IntegrationConfigChange", args).Return()
+	_ = c.Called(args)
+}