SentryContextStorage.java

package io.sentry.opentelemetry;

import io.opentelemetry.context.Context;
import io.opentelemetry.context.ContextStorage;
import io.opentelemetry.context.Scope;
import org.jetbrains.annotations.ApiStatus;
import org.jetbrains.annotations.NotNull;

@ApiStatus.Internal
public final class SentryContextStorage implements ContextStorage {
  private final @NotNull ContextStorage contextStorage;

  public SentryContextStorage(final @NotNull ContextStorage contextStorage) {
    this.contextStorage = contextStorage;
  }

  @Override
  public Scope attach(Context toAttach) {
    // TODO [POTEL] do we need to fork here as well?
    // scenario: Context is propagated from thread A to thread B without changes
    // OTEL likely also dosn't fork in that case so we probably also don't have to
    // or maybe shouldn't even to better align with OTEL
    // but since OTEL Context is immutable it doesn't have the same consequence for OTEL as for us

    // TODO [POTEL] sometimes context has already gone through forking but is still an
    // ArrayBaseContext
    // most likely due to OTEL bridging between agent and app

    // incoming non sentry wrapped context that already has scopes in it
    if (toAttach instanceof SentryContextWrapper) {
      return contextStorage.attach(toAttach);
    } else {
      return contextStorage.attach(SentryContextWrapper.wrap(toAttach));
    }
  }

  @Override
  public Context current() {
    return contextStorage.current();
  }

  @Override
  public Context root() {
    return SentryContextWrapper.wrap(ContextStorage.super.root());
  }
}