Use DirectEventSubmitter by default in tests

lib/src/analytics/analytics.dart

@@ -8,16 +8,16 @@ import 'package:wiredash/src/core/version.dart';
 import 'package:wiredash/src/core/wiredash_widget.dart';
 
 // Required
+// TODO send events every 30 seconds to the server (or 5min?)
 // TODO drop event if server responds 400 (code 2200) MISSING TEST
 // TODO keep events if server responds 400 (code 2201) MISSING TEST
 // TODO keep events for any other server error MISSING TEST
 // TODO ignore corrupt events on disk (users might edit it on web)
-// TODO Write documentation
 // TODO export analytics
+// TODO Write documentation
 
 // Important
 // TODO send events to server on app close
-// TODO send events every 30 seconds to the server (or 5min?)
 // TODO drop event when API credentials are obviously wrong
 // TODO allow resetting of the analyticsId
 // TODO send events directly on web

lib/src/analytics/event_submitter.dart

@@ -7,28 +7,28 @@ import 'package:wiredash/src/core/network/send_events_request.dart';
 ///
 /// Implementations are
 /// - [DirectEventSubmitter] for immediate submission of events (usually web)
-/// - [PendingEventSubmitter] for batching events within a certain time frame (usually mobile)
+/// - [DebounceEventSubmitter] for batching events within a certain time frame (usually mobile)
 abstract class EventSubmitter {
   /// Submits all pending events in [SharedPreferences] to the backend
   Future<void> submitEvents();
 }
 
-class DirectEventSubmitter extends PendingEventSubmitter {
+class DirectEventSubmitter extends DebounceEventSubmitter {
   DirectEventSubmitter({
     required super.eventStore,
     required super.api,
     required super.projectId,
   }) : super(throttleDuration: Duration.zero);
 }
 
-class PendingEventSubmitter implements EventSubmitter {
+class DebounceEventSubmitter implements EventSubmitter {
   final AnalyticsEventStore eventStore;
   final WiredashApi api;
   final String Function() projectId;
 
   final Duration throttleDuration;
 
-  PendingEventSubmitter({
+  DebounceEventSubmitter({
     required this.eventStore,
     required this.api,
     required this.projectId,

lib/src/core/services/services.dart

@@ -187,7 +187,7 @@ void registerProdWiredashServices(WiredashServices sl) {
       );
     }
 
-    return PendingEventSubmitter(
+    return DebounceEventSubmitter(
       api: sl.api,
       eventStore: sl.eventStore,
       projectId: () => sl.wiredashWidget.projectId,

test/util/robot.dart

@@ -15,6 +15,7 @@ import 'package:wiredash/src/_feedback.dart';
 import 'package:wiredash/src/_ps.dart';
 import 'package:wiredash/src/_wiredash_internal.dart';
 import 'package:wiredash/src/_wiredash_ui.dart';
+import 'package:wiredash/src/analytics/event_submitter.dart';
 import 'package:wiredash/src/core/wiredash_widget.dart';
 
 // ignore: unused_import
@@ -146,11 +147,13 @@ class WiredashTestRobot {
     FutureOr<void> Function()? afterPump,
     List<LocalizationsDelegate> appLocalizationsDelegates = const [],
     bool useDirectFeedbackSubmitter = true,
+    bool useDirectEventSubmitter = true,
     bool wrapWithWiredash = true,
   }) async {
     setupMocks();
     WiredashServices.debugServicesCreator = () => createMockServices(
           useDirectFeedbackSubmitter: useDirectFeedbackSubmitter,
+          useDirectEventSubmitter: useDirectEventSubmitter,
         );
     addTearDown(() => WiredashServices.debugServicesCreator = null);
 
@@ -634,27 +637,50 @@ class WiredashMockServices {
   MockWiredashApi get mockApi => services.api as MockWiredashApi;
 }
 
-WiredashServices createMockServices({bool useDirectFeedbackSubmitter = false}) {
+WiredashServices createMockServices({
+  bool useDirectFeedbackSubmitter = false,
+  bool useDirectEventSubmitter = false,
+}) {
   return WiredashServices.setup((services) {
     registerProdWiredashServices(services);
 
     // Don't do actual http calls
-    services.inject<WiredashApi>((_) {
-      // depend on the widget (secret/project)
-      services.wiredashWidget;
-      return MockWiredashApi.fake();
-    });
+    services.inject<WiredashApi>(
+      (_) {
+        // depend on the widget (secret/project)
+        services.wiredashWidget;
+        return MockWiredashApi.fake();
+      },
+    );
 
     // Let the widget behave as in production
     services.inject<TestDetector>((_) => _OverlookFakeAsync());
 
     if (useDirectFeedbackSubmitter) {
       // replace submitter, because for testing we always want to submit directly
       services.inject<FeedbackSubmitter>(
-        (locator) => DirectFeedbackSubmitter(services.api),
+        (_) => DirectFeedbackSubmitter(services.api),
+      );
+    } else {
+      assert(
+        services.feedbackSubmitter.runtimeType == RetryingFeedbackSubmitter,
+      );
+    }
+
+    if (useDirectEventSubmitter) {
+      services.inject<EventSubmitter>(
+        (_) {
+          print('create direct submitter');
+          return DirectEventSubmitter(
+            projectId: () => services.wiredashWidget.projectId,
+            eventStore: services.eventStore,
+            api: services.api,
+          );
+        },
+        dispose: (submitter) => print('dispose ${submitter.instanceName}'),
       );
     } else {
-      assert(services.feedbackSubmitter is RetryingFeedbackSubmitter);
+      assert(services.eventSubmitter.runtimeType == DebounceEventSubmitter);
     }
   });
 }