[SR] Add session replay envelope and events

buildSrc/src/main/java/Config.kt

@@ -195,6 +195,7 @@ object Config {
         val jsonUnit = "net.javacrumbs.json-unit:json-unit:2.32.0"
         val hsqldb = "org.hsqldb:hsqldb:2.6.1"
         val javaFaker = "com.github.javafaker:javafaker:1.0.2"
+        val msgpack = "org.msgpack:msgpack-core:0.9.8"
     }
 
     object QualityPlugins {

sentry-android-core/src/main/java/io/sentry/android/core/DefaultAndroidEventProcessor.java

@@ -10,6 +10,7 @@
 import io.sentry.SentryBaseEvent;
 import io.sentry.SentryEvent;
 import io.sentry.SentryLevel;
+import io.sentry.SentryReplayEvent;
 import io.sentry.android.core.internal.util.AndroidMainThreadChecker;
 import io.sentry.android.core.performance.AppStartMetrics;
 import io.sentry.android.core.performance.TimeSpan;
@@ -256,4 +257,17 @@ private void setSideLoadedInfo(final @NotNull SentryBaseEvent event) {
 
     return transaction;
   }
+
+  @Override
+  public @NotNull SentryReplayEvent process(
+      final @NotNull SentryReplayEvent event, final @NotNull Hint hint) {
+    final boolean applyScopeData = shouldApplyScopeData(event, hint);
+    if (applyScopeData) {
+      processNonCachedEvent(event, hint);
+    }
+
+    setCommons(event, false, applyScopeData);
+
+    return event;
+  }
 }

sentry-android-core/src/test/java/io/sentry/android/core/SessionTrackingIntegrationTest.kt

@@ -15,6 +15,7 @@ import io.sentry.Sentry
 import io.sentry.SentryEnvelope
 import io.sentry.SentryEvent
 import io.sentry.SentryOptions
+import io.sentry.SentryReplayEvent
 import io.sentry.Session
 import io.sentry.TraceContext
 import io.sentry.UserFeedback
@@ -141,6 +142,14 @@ class SessionTrackingIntegrationTest {
             TODO("Not yet implemented")
         }
 
+        override fun captureReplayEvent(
+            event: SentryReplayEvent,
+            scope: IScope?,
+            hint: Hint?
+        ): SentryId {
+            TODO("Not yet implemented")
+        }
+
         override fun captureUserFeedback(userFeedback: UserFeedback) {
             TODO("Not yet implemented")
         }

sentry/build.gradle.kts

@@ -32,6 +32,7 @@ dependencies {
     testImplementation(Config.TestLibs.mockitoInline)
     testImplementation(Config.TestLibs.awaitility)
     testImplementation(Config.TestLibs.javaFaker)
+    testImplementation(Config.TestLibs.msgpack)
     testImplementation(projects.sentryTestSupport)
 }
 

sentry/src/main/java/io/sentry/DataCategory.java

@@ -13,6 +13,7 @@ public enum DataCategory {
   Monitor("monitor"),
   Profile("profile"),
   Transaction("transaction"),
+  Replay("replay"),
   Security("security"),
   UserReport("user_report"),
   Unknown("unknown");

sentry/src/main/java/io/sentry/EventProcessor.java

@@ -32,4 +32,16 @@ default SentryEvent process(@NotNull SentryEvent event, @NotNull Hint hint) {
   default SentryTransaction process(@NotNull SentryTransaction transaction, @NotNull Hint hint) {
     return transaction;
   }
+
+  /**
+   * May mutate or drop a SentryEvent
+   *
+   * @param event the SentryEvent
+   * @param hint the Hint
+   * @return the event itself, a mutated SentryEvent or null
+   */
+  @Nullable
+  default SentryReplayEvent process(@NotNull SentryReplayEvent event, @NotNull Hint hint) {
+    return event;
+  }
 }

sentry/src/main/java/io/sentry/Hint.java

@@ -29,8 +29,8 @@ public final class Hint {
   private final @NotNull List<Attachment> attachments = new ArrayList<>();
   private @Nullable Attachment screenshot = null;
   private @Nullable Attachment viewHierarchy = null;
-
   private @Nullable Attachment threadDump = null;
+  private @Nullable ReplayRecording replayRecording = null;
 
   public static @NotNull Hint withAttachment(@Nullable Attachment attachment) {
     @NotNull final Hint hint = new Hint();
@@ -136,6 +136,15 @@ public void setThreadDump(final @Nullable Attachment threadDump) {
     return threadDump;
   }
 
+  @Nullable
+  public ReplayRecording getReplayRecording() {
+    return replayRecording;
+  }
+
+  public void setReplayRecording(final @Nullable ReplayRecording replayRecording) {
+    this.replayRecording = replayRecording;
+  }
+
   private boolean isCastablePrimitive(@Nullable Object hintValue, @NotNull Class<?> clazz) {
     Class<?> nonPrimitiveClass = PRIMITIVE_MAPPINGS.get(clazz.getCanonicalName());
     return hintValue != null

sentry/src/main/java/io/sentry/Hub.java

@@ -920,6 +920,28 @@ private IScope buildLocalScope(
     return sentryId;
   }
 
+  @Override
+  public @NotNull SentryId captureReplay(
+      final @NotNull SentryReplayEvent replay, final @Nullable Hint hint) {
+    SentryId sentryId = SentryId.EMPTY_ID;
+    if (!isEnabled()) {
+      options
+          .getLogger()
+          .log(
+              SentryLevel.WARNING,
+              "Instance is disabled and this 'captureReplay' call is a no-op.");
+    } else {
+      try {
+        StackItem item = stack.peek();
+        sentryId = item.getClient().captureReplayEvent(replay, item.getScope(), hint);
+      } catch (Throwable e) {
+        options.getLogger().log(SentryLevel.ERROR, "Error while capturing replay", e);
+      }
+    }
+    this.lastEventId = sentryId;
+    return sentryId;
+  }
+
   @ApiStatus.Internal
   @Override
   public @Nullable RateLimiter getRateLimiter() {

sentry/src/main/java/io/sentry/HubAdapter.java

@@ -262,6 +262,12 @@ public void reportFullyDisplayed() {
     return Sentry.captureCheckIn(checkIn);
   }
 
+  @Override
+  public @NotNull SentryId captureReplay(
+      final @NotNull SentryReplayEvent replay, final @Nullable Hint hint) {
+    return Sentry.getCurrentHub().captureReplay(replay, hint);
+  }
+
   @ApiStatus.Internal
   @Override
   public @Nullable RateLimiter getRateLimiter() {

sentry/src/main/java/io/sentry/IHub.java

@@ -572,6 +572,9 @@ TransactionContext continueTrace(
   @NotNull
   SentryId captureCheckIn(final @NotNull CheckIn checkIn);
 
+  @NotNull
+  SentryId captureReplay(@NotNull SentryReplayEvent replay, @Nullable Hint hint);
+
   @ApiStatus.Internal
   @Nullable
   RateLimiter getRateLimiter();

sentry/src/main/java/io/sentry/ISentryClient.java

@@ -147,6 +147,10 @@ public interface ISentryClient {
     return captureException(throwable, scope, null);
   }
 
+  @NotNull
+  SentryId captureReplayEvent(
+      @NotNull SentryReplayEvent event, @Nullable IScope scope, @Nullable Hint hint);
+
   /**
    * Captures a manually created user feedback and sends it to Sentry.
    *

sentry/src/main/java/io/sentry/JsonObjectWriter.java

@@ -52,6 +52,12 @@ public JsonObjectWriter value(final @Nullable String value) throws IOException {
     return this;
   }
 
+  @Override
+  public ObjectWriter jsonValue(@Nullable String value) throws IOException {
+    jsonWriter.jsonValue(value);
+    return this;
+  }
+
   @Override
   public JsonObjectWriter nullValue() throws IOException {
     jsonWriter.nullValue();
@@ -103,6 +109,11 @@ public JsonObjectWriter value(final @NotNull ILogger logger, final @Nullable Obj
     return this;
   }
 
+  @Override
+  public void setLenient(final boolean lenient) {
+    jsonWriter.setLenient(lenient);
+  }
+
   public void setIndent(final @NotNull String indent) {
     jsonWriter.setIndent(indent);
   }

sentry/src/main/java/io/sentry/JsonSerializer.java

@@ -29,6 +29,9 @@
 import io.sentry.protocol.User;
 import io.sentry.protocol.ViewHierarchy;
 import io.sentry.protocol.ViewHierarchyNode;
+import io.sentry.rrweb.RRWebEventType;
+import io.sentry.rrweb.RRWebMetaEvent;
+import io.sentry.rrweb.RRWebVideoEvent;
 import io.sentry.util.Objects;
 import java.io.BufferedOutputStream;
 import java.io.BufferedWriter;
@@ -89,6 +92,10 @@ public JsonSerializer(@NotNull SentryOptions options) {
     deserializersByClass.put(
         ProfileMeasurementValue.class, new ProfileMeasurementValue.Deserializer());
     deserializersByClass.put(Request.class, new Request.Deserializer());
+    deserializersByClass.put(ReplayRecording.class, new ReplayRecording.Deserializer());
+    deserializersByClass.put(RRWebEventType.class, new RRWebEventType.Deserializer());
+    deserializersByClass.put(RRWebMetaEvent.class, new RRWebMetaEvent.Deserializer());
+    deserializersByClass.put(RRWebVideoEvent.class, new RRWebVideoEvent.Deserializer());
     deserializersByClass.put(SdkInfo.class, new SdkInfo.Deserializer());
     deserializersByClass.put(SdkVersion.class, new SdkVersion.Deserializer());
     deserializersByClass.put(SentryEnvelopeHeader.class, new SentryEnvelopeHeader.Deserializer());
@@ -101,6 +108,7 @@ public JsonSerializer(@NotNull SentryOptions options) {
     deserializersByClass.put(SentryLockReason.class, new SentryLockReason.Deserializer());
     deserializersByClass.put(SentryPackage.class, new SentryPackage.Deserializer());
     deserializersByClass.put(SentryRuntime.class, new SentryRuntime.Deserializer());
+    deserializersByClass.put(SentryReplayEvent.class, new SentryReplayEvent.Deserializer());
     deserializersByClass.put(SentrySpan.class, new SentrySpan.Deserializer());
     deserializersByClass.put(SentryStackFrame.class, new SentryStackFrame.Deserializer());
     deserializersByClass.put(SentryStackTrace.class, new SentryStackTrace.Deserializer());

sentry/src/main/java/io/sentry/MainEventProcessor.java

@@ -149,6 +149,19 @@ private void processNonCachedEvent(final @NotNull SentryBaseEvent event) {
     return transaction;
   }
 
+  @Override
+  public @NotNull SentryReplayEvent process(@NotNull SentryReplayEvent event, @NotNull Hint hint) {
+    setCommons(event);
+    // TODO: maybe later it's needed to deobfuscate something (e.g. view hierarchy), for now the
+    // TODO: protocol does not support it
+    // setDebugMeta(event);
+
+    if (shouldApplyScopeData(event, hint)) {
+      processNonCachedEvent(event);
+    }
+    return event;
+  }
+
   private void setCommons(final @NotNull SentryBaseEvent event) {
     setPlatform(event);
   }

sentry/src/main/java/io/sentry/NoOpHub.java

@@ -218,6 +218,11 @@ public void reportFullyDisplayed() {}
     return SentryId.EMPTY_ID;
   }
 
+  @Override
+  public @NotNull SentryId captureReplay(@NotNull SentryReplayEvent replay, @Nullable Hint hint) {
+    return SentryId.EMPTY_ID;
+  }
+
   @Override
   public @Nullable RateLimiter getRateLimiter() {
     return null;

sentry/src/main/java/io/sentry/NoOpSentryClient.java

@@ -62,6 +62,12 @@ public SentryId captureEnvelope(@NotNull SentryEnvelope envelope, @Nullable Hint
     return SentryId.EMPTY_ID;
   }
 
+  @Override
+  public @NotNull SentryId captureReplayEvent(
+      @NotNull SentryReplayEvent event, @Nullable IScope scope, @Nullable Hint hint) {
+    return SentryId.EMPTY_ID;
+  }
+
   @Override
   public @Nullable RateLimiter getRateLimiter() {
     return null;

sentry/src/main/java/io/sentry/ObjectWriter.java

@@ -17,6 +17,8 @@ public interface ObjectWriter {
 
   ObjectWriter value(final @Nullable String value) throws IOException;
 
+  ObjectWriter jsonValue(final @Nullable String value) throws IOException;
+
   ObjectWriter nullValue() throws IOException;
 
   ObjectWriter value(final boolean value) throws IOException;
@@ -31,4 +33,6 @@ public interface ObjectWriter {
 
   ObjectWriter value(final @NotNull ILogger logger, final @Nullable Object object)
       throws IOException;
+
+  void setLenient(boolean lenient);
 }