fix: Fixed tests

Author: praveen5959

src/main/java/com/parseable/temporal/ParseableEmitter.java

@@ -33,7 +33,7 @@
  * <p>Call {@link #close()} (or let {@link ParseablePlugin#close()} do it) to flush and shut down
  * both providers before your JVM exits.
  */
-public final class ParseableEmitter implements AutoCloseable {
+public class ParseableEmitter implements AutoCloseable {
 
   static final String INSTRUMENTATION_SCOPE = "temporal-parseable";
 

src/main/java/com/parseable/temporal/exporters/SanitizingSpanExporter.java

@@ -54,6 +54,7 @@ public CompletableResultCode shutdown() {
   private SpanData sanitizeSpan(SpanData span) {
     Attributes original = span.getAttributes();
     AttributesBuilder builder = Attributes.builder();
+    boolean[] changed = { false };
 
     original.forEach((key, value) -> {
       String type = key.getType().name(); // STRING, BOOLEAN, LONG, DOUBLE, STRING_ARRAY, ...
@@ -62,43 +63,43 @@ private SpanData sanitizeSpan(SpanData span) {
         case "BOOLEAN":
         case "LONG":
         case "DOUBLE":
-          // Primitive — safe to pass through
           putUnchecked(builder, key, value);
           break;
         case "STRING_ARRAY":
-          // Flatten array to comma-joined string
           @SuppressWarnings("unchecked")
           List<String> strings = (List<String>) value;
           builder.put(key.getKey(), String.join(", ", strings));
+          changed[0] = true;
           break;
         case "BOOLEAN_ARRAY":
           @SuppressWarnings("unchecked")
           List<Boolean> booleans = (List<Boolean>) value;
           builder.put(key.getKey(), joinToString(booleans));
+          changed[0] = true;
           break;
         case "LONG_ARRAY":
           @SuppressWarnings("unchecked")
           List<Long> longs = (List<Long>) value;
           builder.put(key.getKey(), joinToString(longs));
+          changed[0] = true;
           break;
         case "DOUBLE_ARRAY":
           @SuppressWarnings("unchecked")
           List<Double> doubles = (List<Double>) value;
           builder.put(key.getKey(), joinToString(doubles));
+          changed[0] = true;
           break;
         default:
           // Unknown / map type — drop silently
+          changed[0] = true;
           break;
       }
     });
 
-    Attributes sanitizedAttrs = builder.build();
-
-    // Only wrap if attributes actually changed
-    if (sanitizedAttrs.size() == original.size()) {
+    if (!changed[0]) {
       return span;
     }
-    return new SanitizedSpanData(span, sanitizedAttrs);
+    return new SanitizedSpanData(span, builder.build());
   }
 
   @SuppressWarnings("unchecked")

src/test/java/com/parseable/temporal/ParseableInterceptorTest.java

@@ -7,9 +7,10 @@
 import io.temporal.activity.ActivityOptions;
 import io.temporal.client.WorkflowClient;
 import io.temporal.client.WorkflowOptions;
+import io.temporal.testing.TestEnvironmentOptions;
 import io.temporal.testing.TestWorkflowEnvironment;
 import io.temporal.worker.Worker;
-import io.temporal.worker.WorkerOptions;
+import io.temporal.worker.WorkerFactoryOptions;
 import io.temporal.workflow.Workflow;
 import io.temporal.workflow.WorkflowInterface;
 import io.temporal.workflow.WorkflowMethod;
@@ -43,15 +44,16 @@ class ParseableInterceptorTest {
 
   @BeforeEach
   void setUp() {
-    testEnv = TestWorkflowEnvironment.newInstance();
-    client = testEnv.getWorkflowClient();
     spy = new SpyEmitter();
-
-    Worker worker = testEnv.newWorker(
-        "test-queue",
-        WorkerOptions.newBuilder()
-            .setInterceptors(new ParseableWorkerInterceptor(spy))
+    testEnv = TestWorkflowEnvironment.newInstance(
+        TestEnvironmentOptions.newBuilder()
+            .setWorkerFactoryOptions(WorkerFactoryOptions.newBuilder()
+                .setWorkerInterceptors(new ParseableWorkerInterceptor(spy))
+                .build())
             .build());
+    client = testEnv.getWorkflowClient();
+
+    Worker worker = testEnv.newWorker("test-queue");
     worker.registerWorkflowImplementationTypes(HelloWorkflowImpl.class);
     worker.registerActivitiesImplementations(new HelloActivitiesImpl());
     testEnv.start();

src/test/java/com/parseable/temporal/SanitizingSpanExporterTest.java

@@ -136,6 +136,9 @@ static class StubSpanData implements SpanData {
     @Override public InstrumentationScopeInfo getInstrumentationScopeInfo() {
       return InstrumentationScopeInfo.create("test");
     }
+    @Override public io.opentelemetry.sdk.common.InstrumentationLibraryInfo getInstrumentationLibraryInfo() {
+      return io.opentelemetry.sdk.common.InstrumentationLibraryInfo.create("test", null);
+    }
     @Override public Resource getResource() { return Resource.empty(); }
   }
 }