Telemetry

.github/workflows/ci.yml

@@ -32,7 +32,7 @@ jobs:
         restore-keys: |
           ${{ runner.os }}-deps-${{ matrix.flutter_version }}-
     - name: Enable pana
-      run: flutter pub global activate pana 0.21.12
+      run: flutter pub global activate pana
     - name: Show Flutter environment
       run: |
         which flutter

.gitignore

@@ -6,6 +6,4 @@ local.properties
 
 **/.DS_Store
 
-rollbar_payloads.db
-# rollbar_payloads.db-journal
-# rollbar_payloads copy- backup.db
+**/*.db

build_tools/run-pana

@@ -12,7 +12,7 @@ function run-pana-checks {
         PUB_CACHE=$HOME/.pub-cache
     fi
 
-    flutter pub global activate pana 0.21.12
+    flutter pub global activate pana
 
     mkdir -p pana-report
 

rollbar_common/lib/rollbar_common.dart

@@ -3,10 +3,23 @@ library rollbar_common;
 export 'src/extension/function.dart';
 export 'src/extension/object.dart';
 export 'src/extension/collection.dart';
+export 'src/extension/string.dart';
+export 'src/extension/mirror.dart';
 export 'src/extension/math.dart';
 export 'src/extension/date_time.dart';
 export 'src/extension/environment.dart';
 
-export 'src/extension/tuple.dart';
+export 'src/identifiable.dart';
+export 'src/serializable.dart';
+export 'src/persistable.dart';
+
+export 'src/zipped.dart';
+export 'src/table_set.dart';
+export 'src/data/payload_record.dart';
+export 'src/data/breadcrumb_record.dart';
+
+export 'src/http.dart';
+export 'src/level.dart';
+export 'src/tuple.dart';
 
 export 'src/connectivity_monitor.dart';

rollbar_common/lib/src/data/breadcrumb_record.dart

@@ -0,0 +1,121 @@
+import 'package:meta/meta.dart';
+import '../../rollbar_common.dart'
+    show
+        Persistable,
+        PersistableFor,
+        SerializableFor,
+        UUID,
+        uuidGen,
+        Datatype,
+        JsonMap;
+
+@sealed
+@immutable
+class BreadcrumbRecord implements Persistable<UUID> {
+  @override
+  final UUID id;
+  final String breadcrumb;
+  final DateTime timestamp;
+
+  static Map<String, Datatype> get persistingKeyTypes => {
+        'id': Datatype.uuid,
+        'breadcrumb': Datatype.text,
+        'timestamp': Datatype.integer,
+      };
+
+  BreadcrumbRecord({
+    UUID? id,
+    required this.breadcrumb,
+    DateTime? timestamp,
+  })  : id = id ?? uuidGen.v4obj(),
+        timestamp = timestamp ?? DateTime.now().toUtc();
+
+  BreadcrumbRecord copyWith({
+    UUID? id,
+    String? breadcrumb,
+    DateTime? timestamp,
+  }) =>
+      BreadcrumbRecord(
+          id: id ?? this.id,
+          breadcrumb: breadcrumb ?? this.breadcrumb,
+          timestamp: timestamp ?? this.timestamp);
+
+  @override
+  factory BreadcrumbRecord.fromMap(JsonMap map) => BreadcrumbRecord(
+        id: map.id,
+        breadcrumb: map.breadcrumb,
+        timestamp: map.timestamp,
+      );
+
+  @override
+  JsonMap toMap() => {
+        'id': id.toBytes(),
+        'breadcrumb': breadcrumb,
+        'timestamp': timestamp.microsecondsSinceEpoch,
+      };
+
+  /// Compares this [BreadcrumbRecord] to another [BreadcrumbRecord].
+  ///
+  /// Comparison is timestamp-based.
+  ///
+  /// If [other] is not a [BreadcrumbRecord] instance, an [ArgumentError] is
+  /// thrown.
+  ///
+  /// Returns a value like a [Comparator] when comparing this to [other]. That
+  /// is, it returns a negative integer if this is ordered before [other], a
+  /// positive integer if this is ordered after [other], and zero if this and
+  /// [other] are ordered together.
+  ///
+  /// The [other] argument must be a value that is comparable to this object.
+  @override
+  int compareTo(other) {
+    if (other is! BreadcrumbRecord) {
+      throw ArgumentError('Cannot compare between different types.', other);
+    }
+
+    return timestamp.compareTo(other.timestamp);
+  }
+
+  @override
+  String toString() => 'Record('
+      'id: ${id.uuid}, '
+      'breadcrumb: $breadcrumb, '
+      'timestamp: $timestamp)';
+
+  @override
+  bool operator ==(Object other) =>
+      identical(this, other) ||
+      (other is BreadcrumbRecord &&
+          other.id == id &&
+          other.breadcrumb == breadcrumb &&
+          other.timestamp == timestamp);
+
+  @override
+  int get hashCode => Object.hash(id, breadcrumb, timestamp);
+}
+
+@sealed
+class SerializableBreadcrumbRecord implements SerializableFor {
+  const SerializableBreadcrumbRecord();
+
+  @override
+  BreadcrumbRecord fromMap(JsonMap map) => BreadcrumbRecord.fromMap(map);
+}
+
+@sealed
+class PersistableBreadcrumbRecord implements PersistableFor {
+  const PersistableBreadcrumbRecord();
+
+  @override
+  Map<String, Datatype> get persistingKeyTypes =>
+      BreadcrumbRecord.persistingKeyTypes;
+}
+
+extension BreadcrumbRecordAttributes on JsonMap {
+  UUID get id => UUID.fromList(this['id'].whereType<int>().toList());
+  String get breadcrumb => this['breadcrumb'];
+  DateTime get timestamp => DateTime.fromMicrosecondsSinceEpoch(
+        this['timestamp'],
+        isUtc: true,
+      );
+}

rollbar_common/lib/src/data/payload_record.dart

@@ -0,0 +1,141 @@
+import 'package:meta/meta.dart';
+import '../../rollbar_common.dart'
+    show
+        Persistable,
+        PersistableFor,
+        SerializableFor,
+        UUID,
+        uuidGen,
+        Datatype,
+        JsonMap;
+
+@sealed
+@immutable
+class PayloadRecord implements Persistable<UUID> {
+  @override
+  final UUID id;
+  final String accessToken;
+  final String endpoint;
+  final String payload;
+  final DateTime timestamp;
+
+  static Map<String, Datatype> get persistingKeyTypes => {
+        'id': Datatype.uuid,
+        'accessToken': Datatype.text,
+        'endpoint': Datatype.text,
+        'payload': Datatype.text,
+        'timestamp': Datatype.integer,
+      };
+
+  PayloadRecord({
+    UUID? id,
+    required this.accessToken,
+    required this.endpoint,
+    required this.payload,
+    DateTime? timestamp,
+  })  : id = id ?? uuidGen.v4obj(),
+        timestamp = timestamp ?? DateTime.now().toUtc();
+
+  PayloadRecord copyWith({
+    UUID? id,
+    String? accessToken,
+    String? endpoint,
+    String? payload,
+    DateTime? timestamp,
+  }) =>
+      PayloadRecord(
+          id: id ?? this.id,
+          accessToken: accessToken ?? this.accessToken,
+          endpoint: endpoint ?? this.endpoint,
+          payload: payload ?? this.payload,
+          timestamp: timestamp ?? this.timestamp);
+
+  @override
+  factory PayloadRecord.fromMap(JsonMap map) => PayloadRecord(
+      id: map.id,
+      accessToken: map.accessToken,
+      endpoint: map.endpoint,
+      payload: map.payload,
+      timestamp: map.timestamp);
+
+  @override
+  JsonMap toMap() => {
+        'id': id.toBytes(),
+        'accessToken': accessToken,
+        'endpoint': endpoint,
+        'payload': payload,
+        'timestamp': timestamp.microsecondsSinceEpoch,
+      };
+
+  /// Compares this [PayloadRecord] to another [PayloadRecord].
+  ///
+  /// Comparison is timestamp-based.
+  ///
+  /// If [other] is not a [PayloadRecord] instance, an [ArgumentError] is
+  /// thrown.
+  ///
+  /// Returns a value like a [Comparator] when comparing this to [other]. That
+  /// is, it returns a negative integer if this is ordered before [other], a
+  /// positive integer if this is ordered after [other], and zero if this and
+  /// [other] are ordered together.
+  ///
+  /// The [other] argument must be a value that is comparable to this object.
+  @override
+  int compareTo(other) {
+    if (other is! PayloadRecord) {
+      throw ArgumentError('Cannot compare between different types.', other);
+    }
+
+    return timestamp.compareTo(other.timestamp);
+  }
+
+  @override
+  String toString() => 'Record('
+      'id: ${id.uuid}, '
+      'accessToken: $accessToken, '
+      'endpoint: $endpoint, '
+      'payload: $payload, '
+      'timestamp: $timestamp)';
+
+  @override
+  bool operator ==(Object other) =>
+      identical(this, other) ||
+      (other is PayloadRecord &&
+          other.id == id &&
+          other.accessToken == accessToken &&
+          other.endpoint == endpoint &&
+          other.payload == payload &&
+          other.timestamp == timestamp);
+
+  @override
+  int get hashCode =>
+      Object.hash(id, accessToken, endpoint, payload, timestamp);
+}
+
+@sealed
+class SerializablePayloadRecord implements SerializableFor {
+  const SerializablePayloadRecord();
+
+  @override
+  PayloadRecord fromMap(JsonMap map) => PayloadRecord.fromMap(map);
+}
+
+@sealed
+class PersistablePayloadRecord implements PersistableFor {
+  const PersistablePayloadRecord();
+
+  @override
+  Map<String, Datatype> get persistingKeyTypes =>
+      PayloadRecord.persistingKeyTypes;
+}
+
+extension PayloadRecordAttributes on JsonMap {
+  UUID get id => UUID.fromList(this['id'].whereType<int>().toList());
+  String get accessToken => this['accessToken'];
+  String get endpoint => this['endpoint'];
+  String get payload => this['payload'];
+  DateTime get timestamp => DateTime.fromMicrosecondsSinceEpoch(
+        this['timestamp'],
+        isUtc: true,
+      );
+}