poc

Author: buenaflor

dart/lib/src/sentry_client.dart

@@ -16,6 +16,7 @@ import 'sentry_options.dart';
 import 'sentry_stack_trace_factory.dart';
 import 'transport/http_transport.dart';
 import 'transport/noop_transport.dart';
+import 'transport/spotlight_http_transport.dart';
 import 'utils/isolate_utils.dart';
 import 'version.dart';
 import 'sentry_envelope.dart';
@@ -49,6 +50,9 @@ class SentryClient {
       final rateLimiter = RateLimiter(options);
       options.transport = HttpTransport(options, rateLimiter);
     }
+    if (options.enableSpotlight) {
+      options.transport = SpotlightHttpTransport(options, options.transport);
+    }
     return SentryClient._(options);
   }
 

dart/lib/src/sentry_options.dart

@@ -374,6 +374,12 @@ class SentryOptions {
   /// Settings this to `false` will set the `level` to [SentryLevel.error].
   bool markAutomaticallyCollectedErrorsAsFatal = true;
 
+  /// Whether to enable Spotlight for local development.
+  bool enableSpotlight = false;
+
+  /// The Spotlight URL. Defaults to http://localhost:8969/stream
+  String spotlightUrl = 'http://localhost:8969/stream';
+
   SentryOptions({this.dsn, PlatformChecker? checker}) {
     if (checker != null) {
       platformChecker = checker;

dart/lib/src/transport/spotlight_http_transport.dart

@@ -0,0 +1,29 @@
+import 'package:http/http.dart';
+
+import '../../sentry.dart';
+
+/// Spotlight HTTP transport class that sends Sentry envelopes to both Sentry and Spotlight.
+class SpotlightHttpTransport extends Transport {
+  final SentryOptions _options;
+  final Transport _transport;
+
+  SpotlightHttpTransport(this._options, this._transport);
+
+  @override
+  Future<SentryId?> send(SentryEnvelope envelope) async {
+    await _sendToSpotlight(envelope);
+    return _transport.send(envelope);
+  }
+
+  Future<void> _sendToSpotlight(SentryEnvelope envelope) async {
+    final Uri spotlightUri = Uri.parse(_options.spotlightUrl);
+    final StreamedRequest spotlightRequest =
+        StreamedRequest('POST', spotlightUri);
+
+    try {
+      await _options.httpClient.send(spotlightRequest);
+    } catch (e) {
+      // Handle any exceptions.
+    }
+  }
+}