feat: add 'config' field to proxy request for v0 (#4352)

* feat: add 'config' field to proxy request for v0

* chore: remove logger

---------

Co-authored-by: Dilip Kola <[email protected]>
Co-authored-by: Akash Chetty <[email protected]>

Author: 3 people

router/transformer/transformer_proxy_adapter.go

@@ -25,7 +25,8 @@ type transformerProxyAdapter interface {
 
 type ProxyRequestPayloadV0 struct {
 	integrations.PostParametersT
-	Metadata ProxyRequestMetadata `json:"metadata"`
+	Metadata          ProxyRequestMetadata   `json:"metadata"`
+	DestinationConfig map[string]interface{} `json:"destinationConfig"`
 }
 
 type ProxyResponseV0 struct {
@@ -64,8 +65,9 @@ type (
 
 func (v0 *v0Adapter) getPayload(proxyReqParams *ProxyRequestParams) ([]byte, error) {
 	proxyReqPayload := &ProxyRequestPayloadV0{
-		PostParametersT: proxyReqParams.ResponseData.PostParametersT,
-		Metadata:        proxyReqParams.ResponseData.Metadata[0],
+		PostParametersT:   proxyReqParams.ResponseData.PostParametersT,
+		Metadata:          proxyReqParams.ResponseData.Metadata[0],
+		DestinationConfig: proxyReqParams.ResponseData.DestinationConfig,
 	}
 	return jsonfast.Marshal(proxyReqPayload)
 }

router/transformer/transformer_proxy_adapter_test.go

@@ -45,10 +45,14 @@ func TestV0Adapter(t *testing.T) {
 						JobID: 2,
 					},
 				},
+				DestinationConfig: map[string]interface{}{
+					"key_1": "val_1",
+					"key_2": "val_2",
+				},
 			},
 			DestName: "testDestType",
 		}
-		expectedPayload := `{"type":"a","endpoint":"a.com","method":"","userId":"","headers":null,"params":null,"body":{"jobId":1},"files":null,"metadata":{"jobId":1,"attemptNum":0,"userId":"","sourceId":"","destinationId":"","workspaceId":"","secret":null,"dontBatch":true}}`
+		expectedPayload := `{"type":"a","endpoint":"a.com","method":"","userId":"","headers":null,"params":null,"body":{"jobId":1},"files":null,"metadata":{"jobId":1,"attemptNum":0,"userId":"","sourceId":"","destinationId":"","workspaceId":"","secret":null,"dontBatch":true},"destinationConfig":{"key_1":"val_1","key_2":"val_2"}}`
 
 		payload, err := v0Adapter.getPayload(proxyReqParms)
 		require.Nil(t, err)