add end to end test for declarative config for aws (#2047)

Author: zeitlinger

aws-resources/build.gradle.kts

@@ -21,11 +21,24 @@ dependencies {
   implementation("com.squareup.okhttp3:okhttp")
 
   testImplementation("io.opentelemetry:opentelemetry-sdk-extension-autoconfigure")
+  testImplementation("io.opentelemetry:opentelemetry-sdk-extension-incubator")
   testImplementation("io.opentelemetry:opentelemetry-api-incubator")
   testImplementation("io.opentelemetry:opentelemetry-sdk-testing")
+  testImplementation("io.opentelemetry:opentelemetry-exporter-logging")
 
   testImplementation("com.linecorp.armeria:armeria-junit5")
   testRuntimeOnly("org.bouncycastle:bcpkix-jdk15on")
   testImplementation("com.google.guava:guava")
   testImplementation("org.skyscreamer:jsonassert")
 }
+
+tasks {
+  withType<Test>().configureEach {
+    environment(
+      "AWS_REGION" to "us-east-1",
+      "AWS_LAMBDA_FUNCTION_NAME" to "my-function",
+      "AWS_LAMBDA_FUNCTION_VERSION" to "1.2.3"
+    )
+    jvmArgs("-Dotel.experimental.config.file=${project.projectDir.resolve("src/test/resources/declarative-config.yaml")}")
+  }
+}

aws-resources/src/test/java/io/opentelemetry/contrib/aws/resource/ResourceComponentProviderTest.java

@@ -7,18 +7,28 @@
 
 import static org.assertj.core.api.Assertions.assertThat;
 
-import io.opentelemetry.common.ComponentLoader;
-import io.opentelemetry.sdk.autoconfigure.spi.internal.ComponentProvider;
+import io.opentelemetry.api.common.Attributes;
+import io.opentelemetry.sdk.autoconfigure.AutoConfiguredOpenTelemetrySdk;
+import io.opentelemetry.sdk.testing.assertj.OpenTelemetryAssertions;
+import io.opentelemetry.semconv.incubating.CloudIncubatingAttributes;
+import org.assertj.core.api.InstanceOfAssertFactory;
 import org.junit.jupiter.api.Test;
 
 class ResourceComponentProviderTest {
-
   @Test
-  @SuppressWarnings("rawtypes")
-  void providerIsLoaded() {
-    Iterable<ComponentProvider> providers =
-        ComponentLoader.forClassLoader(ResourceComponentProviderTest.class.getClassLoader())
-            .load(ComponentProvider.class);
-    assertThat(providers).extracting(ComponentProvider::getName).containsExactly("aws");
+  void endToEnd() {
+    assertThat(
+            AutoConfiguredOpenTelemetrySdk.builder()
+                .build()
+                .getOpenTelemetrySdk()
+                .getSdkTracerProvider())
+        .extracting("sharedState")
+        .extracting("resource")
+        .extracting(
+            "attributes",
+            new InstanceOfAssertFactory<>(Attributes.class, OpenTelemetryAssertions::assertThat))
+        .containsEntry(
+            CloudIncubatingAttributes.CLOUD_PROVIDER,
+            CloudIncubatingAttributes.CloudProviderIncubatingValues.AWS);
   }
 }

aws-resources/src/test/resources/declarative-config.yaml

@@ -0,0 +1,10 @@
+file_format: "1.0-rc.1"
+resource:
+  detection/development:
+    detectors:
+      - aws:
+tracer_provider:
+  processors:
+    - simple:
+        exporter:
+          console:

azure-resources/build.gradle.kts

@@ -29,10 +29,22 @@ dependencies {
   testImplementation("io.opentelemetry:opentelemetry-sdk-extension-autoconfigure")
   testImplementation("io.opentelemetry:opentelemetry-api-incubator")
   testImplementation("io.opentelemetry:opentelemetry-sdk-testing")
+  testImplementation("io.opentelemetry:opentelemetry-exporter-logging")
+  testImplementation("io.opentelemetry:opentelemetry-sdk-extension-incubator")
 
   testImplementation("com.google.guava:guava")
 
   testImplementation("org.junit.jupiter:junit-jupiter-api")
   testImplementation("org.assertj:assertj-core")
   testImplementation("com.linecorp.armeria:armeria-junit5")
 }
+
+tasks {
+  withType<Test>().configureEach {
+    environment(
+      "WEBSITE_SITE_NAME" to "my-function",
+      "FUNCTIONS_EXTENSION_VERSION" to "1.2.3"
+    )
+    jvmArgs("-Dotel.experimental.config.file=${project.projectDir.resolve("src/test/resources/declarative-config.yaml")}")
+  }
+}

azure-resources/src/test/java/io/opentelemetry/contrib/azure/resource/ResourceComponentProviderTest.java

@@ -7,18 +7,29 @@
 
 import static org.assertj.core.api.Assertions.assertThat;
 
-import io.opentelemetry.common.ComponentLoader;
-import io.opentelemetry.sdk.autoconfigure.spi.internal.ComponentProvider;
+import io.opentelemetry.api.common.Attributes;
+import io.opentelemetry.sdk.autoconfigure.AutoConfiguredOpenTelemetrySdk;
+import io.opentelemetry.sdk.testing.assertj.OpenTelemetryAssertions;
+import io.opentelemetry.semconv.incubating.CloudIncubatingAttributes;
+import org.assertj.core.api.InstanceOfAssertFactory;
 import org.junit.jupiter.api.Test;
 
 class ResourceComponentProviderTest {
 
   @Test
-  @SuppressWarnings("rawtypes")
-  void providerIsLoaded() {
-    Iterable<ComponentProvider> providers =
-        ComponentLoader.forClassLoader(ResourceComponentProviderTest.class.getClassLoader())
-            .load(ComponentProvider.class);
-    assertThat(providers).extracting(ComponentProvider::getName).containsExactly("azure");
+  void endToEnd() {
+    assertThat(
+            AutoConfiguredOpenTelemetrySdk.builder()
+                .build()
+                .getOpenTelemetrySdk()
+                .getSdkTracerProvider())
+        .extracting("sharedState")
+        .extracting("resource")
+        .extracting(
+            "attributes",
+            new InstanceOfAssertFactory<>(Attributes.class, OpenTelemetryAssertions::assertThat))
+        .containsEntry(
+            CloudIncubatingAttributes.CLOUD_PROVIDER,
+            CloudIncubatingAttributes.CloudProviderIncubatingValues.AZURE);
   }
 }

azure-resources/src/test/resources/declarative-config.yaml

@@ -0,0 +1,10 @@
+file_format: "1.0-rc.1"
+resource:
+  detection/development:
+    detectors:
+      - azure:
+tracer_provider:
+  processors:
+    - simple:
+        exporter:
+          console:

cloudfoundry-resources/build.gradle.kts

@@ -23,4 +23,35 @@ dependencies {
   testImplementation("io.opentelemetry:opentelemetry-api-incubator")
   testImplementation("io.opentelemetry:opentelemetry-sdk-testing")
   testImplementation("io.opentelemetry:opentelemetry-sdk-extension-autoconfigure-spi")
+  testImplementation("io.opentelemetry:opentelemetry-exporter-logging")
+  testImplementation("io.opentelemetry:opentelemetry-sdk-extension-incubator")
+}
+
+tasks {
+  withType<Test>().configureEach {
+    environment(
+      "VCAP_APPLICATION" to """
+        {
+          "application_id": "0193a038-e615-7e5e-92ca-f4bcd7ba0a25",
+          "application_name": "cf-app-name",
+          "application_uris": [
+            "testapp.example.com"
+          ],
+          "cf_api": "https://api.cf.example.com",
+          "limits": {
+            "fds": 256
+          },
+          "instance_index": 1,
+          "organization_id": "0193a375-8d8e-7e0c-a832-01ce9ded40dc",
+          "organization_name": "cf-org-name",
+          "process_id": "0193a4e3-8fd3-71b9-9fe3-5640c53bf1e2",
+          "process_type": "web",
+          "space_id": "0193a7e7-da17-7ea4-8940-b1e07b401b16",
+          "space_name": "cf-space-name",
+          "users": null
+        }
+      """.trimIndent(),
+    )
+    jvmArgs("-Dotel.experimental.config.file=${project.projectDir.resolve("src/test/resources/declarative-config.yaml")}")
+  }
 }

cloudfoundry-resources/src/test/java/io/opentelemetry/contrib/cloudfoundry/resources/ResourceComponentProviderTest.java

@@ -7,18 +7,25 @@
 
 import static org.assertj.core.api.Assertions.assertThat;
 
-import io.opentelemetry.common.ComponentLoader;
-import io.opentelemetry.sdk.autoconfigure.spi.internal.ComponentProvider;
+import io.opentelemetry.api.common.Attributes;
+import io.opentelemetry.sdk.autoconfigure.AutoConfiguredOpenTelemetrySdk;
+import io.opentelemetry.sdk.testing.assertj.OpenTelemetryAssertions;
+import org.assertj.core.api.InstanceOfAssertFactory;
 import org.junit.jupiter.api.Test;
 
 class ResourceComponentProviderTest {
-
   @Test
-  @SuppressWarnings("rawtypes")
-  void providerIsLoaded() {
-    Iterable<ComponentProvider> providers =
-        ComponentLoader.forClassLoader(ResourceComponentProviderTest.class.getClassLoader())
-            .load(ComponentProvider.class);
-    assertThat(providers).extracting(ComponentProvider::getName).containsExactly("cloud_foundry");
+  void endToEnd() {
+    assertThat(
+            AutoConfiguredOpenTelemetrySdk.builder()
+                .build()
+                .getOpenTelemetrySdk()
+                .getSdkTracerProvider())
+        .extracting("sharedState")
+        .extracting("resource")
+        .extracting(
+            "attributes",
+            new InstanceOfAssertFactory<>(Attributes.class, OpenTelemetryAssertions::assertThat))
+        .containsEntry("cloudfoundry.app.name", "cf-app-name");
   }
 }

cloudfoundry-resources/src/test/resources/declarative-config.yaml

@@ -0,0 +1,10 @@
+file_format: "1.0-rc.1"
+resource:
+  detection/development:
+    detectors:
+      - cloud_foundry:
+tracer_provider:
+  processors:
+    - simple:
+        exporter:
+          console:

maven-extension/build.gradle.kts

@@ -33,7 +33,10 @@ dependencies {
   compileOnly("org.apache.maven:maven-core:3.5.0") // do not auto-update, support older mvn versions
   compileOnly("org.slf4j:slf4j-api")
 
+  testImplementation("io.opentelemetry:opentelemetry-sdk-testing")
   testImplementation("io.opentelemetry:opentelemetry-api-incubator")
+  testImplementation("io.opentelemetry:opentelemetry-exporter-logging")
+  testImplementation("io.opentelemetry:opentelemetry-sdk-extension-incubator")
   testImplementation("org.apache.maven:maven-core:3.5.0")
   testImplementation("org.slf4j:slf4j-simple")
 }