test(destination): add DestinationHttpClient integration test

Author: jplbrun

tests/destination/integration/destination.feature

@@ -227,6 +227,19 @@ Feature: Destination Service Integration
   #   And I clean up the instance destination "test-v2-full-options"
   #   And I clean up the instance fragment "test-v2-full-fragment"
 
+  Scenario: DestinationHttpClient sends an authenticated request using token fetched from BTP
+    Given I have a destination named "sdk-test-http-client" of type "HTTP"
+    And the destination has URL "https://httpbin.org"
+    And the destination has authentication "OAuth2ClientCredentials"
+    And the destination has OAuth2 credentials from environment
+    When I create the destination at instance level
+    Then the destination creation should be successful
+    When I fetch the destination using the v2 API
+    And I create a DestinationHttpClient from the destination
+    And I send a GET request to "/headers"
+    Then the response contains an Authorization header
+    And I clean up the instance destination "sdk-test-http-client"
+
   Scenario: Manage labels for subaccount destination
     Given I have a destination named "test-dest-labels" of type "HTTP"
     And the destination has URL "https://labels.example.com"
@@ -303,3 +316,4 @@ Feature: Destination Service Integration
   #   Then the destination creation should be successful
   #   When I get subaccount destination "test-dest-sub-isolation" with "PROVIDER_ONLY" access strategy
   #   Then the destination should not be found
+

tests/destination/integration/test_destination_bdd.py

@@ -1,6 +1,7 @@
 """BDD step definitions for Destination integration tests."""
 
 import concurrent.futures
+import os
 from typing import List, Optional
 
 import pytest
@@ -17,6 +18,7 @@
     ConsumptionOptions,
     PatchLabels,
 )
+from sap_cloud_sdk.destination._destination_http_client import DestinationHttpClient
 from sap_cloud_sdk.destination.exceptions import (
     HttpError,
     DestinationOperationError,
@@ -57,6 +59,8 @@ def __init__(self):
         self.updated_certificate_content: Optional[str] = None
         self.tenant: Optional[str] = None
         self.retrieved_labels: List[Label] = []
+        self.http_client: Optional[DestinationHttpClient] = None
+        self.http_response = None
 
 
 @pytest.fixture
@@ -1572,3 +1576,38 @@ def certificate_should_have_label(context, key, value):
         lbl.key == key and value in lbl.values
         for lbl in context.retrieved_labels
     ), f"Expected label key='{key}' value='{value}' in {context.retrieved_labels}"
+
+
+# ==================== DESTINATION HTTP CLIENT STEPS ====================
+
+@given("the destination has OAuth2 credentials from environment")
+def destination_has_oauth2_credentials(context):
+    context.destination.properties.update({
+        "clientId":        os.environ["CLOUD_SDK_CFG_DESTINATION_DEFAULT_CLIENTID"],
+        "clientSecret":    os.environ["CLOUD_SDK_CFG_DESTINATION_DEFAULT_CLIENTSECRET"],
+        "tokenServiceURL": os.environ["CLOUD_SDK_CFG_DESTINATION_DEFAULT_URL"] + "/oauth/token",
+    })
+
+
+@when("I fetch the destination using the v2 API")
+def fetch_destination_v2(context, destination_client):
+    context.retrieved_destination = destination_client.get_destination(context.destination.name)
+
+
+@when("I create a DestinationHttpClient from the destination")
+def create_http_client(context):
+    context.http_client = DestinationHttpClient(context.retrieved_destination)
+
+
+@when(parsers.parse('I send a GET request to "{path}"'))
+def send_get_request(context, path):
+    context.http_response = context.http_client.request("GET", path)
+
+
+@then("the response contains an Authorization header")
+def assert_authorization_header_present(context):
+    echoed = context.http_response.json().get("headers", {})
+    assert "Authorization" in echoed, (
+        f"Expected Authorization header in response, got: {list(echoed.keys())}. "
+        "Check that BTP returned an auth token for the destination."
+    )