Skip to content
Closed
Show file tree
Hide file tree
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Next Next commit
added implementation, unit test, gradle dependencies
  • Loading branch information
tonzhan2 committed Oct 19, 2023
commit c3d3d72bb8d26eb1e4e39ef7cca58dda2db4ba6c
1 change: 1 addition & 0 deletions gradle/libs.versions.toml
Original file line number Diff line number Diff line change
Expand Up @@ -25,6 +25,7 @@ opentelemetry-api = { module = "io.opentelemetry:opentelemetry-api" }
opentelemetry-sdk = { module = "io.opentelemetry:opentelemetry-sdk" }
opentelemetry-exporter-zipkin = { module = "io.opentelemetry:opentelemetry-exporter-zipkin" }
opentelemetry-exporter-logging = { module = "io.opentelemetry:opentelemetry-exporter-logging" }
opentelemetry-apievents = { module = "io.opentelemetry:opentelemetry-api-events" }
zipkin-sender-okhttp3 = { module = "io.zipkin.reporter2:zipkin-sender-okhttp3", version.ref = "zipkin-reporter"}

#Test tools
Expand Down
3 changes: 3 additions & 0 deletions instrumentation/build.gradle.kts
Original file line number Diff line number Diff line change
Expand Up @@ -70,6 +70,9 @@ dependencies {
implementation(libs.opentelemetry.exporter.logging)
implementation(libs.opentelemetry.instrumentation.api)
implementation(libs.opentelemetry.semconv)
implementation(libs.opentelemetry.apievents)

implementation("io.opentelemetry:opentelemetry-api-events")

testImplementation(libs.bundles.mockito)
testImplementation(libs.bundles.junit)
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,51 @@
/*
* Copyright The OpenTelemetry Authors
* SPDX-License-Identifier: Apache-2.0
*/

package io.opentelemetry.android.emitter;

import io.opentelemetry.api.common.AttributeKey;
import io.opentelemetry.api.common.Attributes;
import io.opentelemetry.api.common.AttributesBuilder;
import io.opentelemetry.api.events.EventEmitter;
import java.util.Map;

class EventEmitterWithData {

private static final String EVENT_DATA = "event.data";

private final EventEmitter delegate;

EventEmitterWithData(EventEmitter delegate) {
this.delegate = delegate;
}

public void emit(String eventName, Attributes attributes, Map<String, Object> data) {
Attributes dataAsAttribute = convertRichDataObjectIntoAttributes(data);
Attributes eventAttrs =
attributes.toBuilder().put(EVENT_DATA, dataAsAttribute.toString()).build();
delegate.emit(eventName, eventAttrs);
}

public Attributes convertRichDataObjectIntoAttributes(Map<String, Object> data) {
AttributesBuilder builder = Attributes.builder();
for (String key : data.keySet()) {
Object val = data.get(key);
if (val != null) {
if (val instanceof String) {
builder.put(AttributeKey.stringKey(key), (String) val);
} else if (val instanceof Long) {
builder.put(AttributeKey.longKey(key), (Long) val);
} else if (val instanceof Double) {
builder.put(AttributeKey.doubleKey(key), (Double) val);
} else if (val instanceof Boolean) {
builder.put(AttributeKey.booleanKey(key), (Boolean) val);
} else {
builder.put(AttributeKey.stringKey(key), val.toString());
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

}
}
}
return builder.build();
}
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,32 @@
package io.opentelemetry.android.emitter;

import org.junit.Test;

import java.util.HashMap;
import java.util.Map;

import io.opentelemetry.api.common.AttributeKey;
import io.opentelemetry.api.common.Attributes;
import static org.junit.jupiter.api.Assertions.assertEquals;

public class EventEmitterWithDataTest {

@Test
public void testConvertRichDataObjectIntoAttributes() {
Map<String, Object> data = new HashMap<>();
data.put("stringKey", "key");
data.put("longKey", 123L);
data.put("doubleKey", 12.3);
data.put("booleanKey", true);

EventEmitterWithData emitter = new EventEmitterWithData(null);

Attributes attributes = emitter.convertRichDataObjectIntoAttributes(data);

assertEquals(attributes.size(), data.size());
assertEquals(data.get("stringKey"), attributes.get(AttributeKey.stringKey("stringKey")));
assertEquals(data.get("longKey"), attributes.get(AttributeKey.longKey("longKey")));
assertEquals(data.get("doubleKey"), attributes.get(AttributeKey.doubleKey("doubleKey")));
assertEquals(data.get("booleanKey"), attributes.get(AttributeKey.booleanKey("booleanKey")));
}
}