chore(flutter): handle gzip encoding

Author: abhaysood

android/measure/src/main/java/sh/measure/android/exporter/AttachmentExporter.kt

@@ -134,6 +134,7 @@ internal class DefaultAttachmentExporter(
             val response = httpClient.uploadFile(
                 url = attachment.url,
                 contentType = attachment.contentType,
+                contentEncoding = attachment.contentEncoding,
                 headers = attachment.headers,
                 fileSize = file.length(),
             ) { sink ->

android/measure/src/main/java/sh/measure/android/exporter/AttachmentPacket.kt

@@ -28,4 +28,9 @@ internal data class AttachmentPacket(
 
         else -> "application/octet-stream"
     }
+
+    val contentEncoding: String? = when (type) {
+        AttachmentType.LAYOUT_SNAPSHOT_JSON -> "gzip"
+        else -> null
+    }
 }

android/measure/src/main/java/sh/measure/android/exporter/HttpUrlConnectionClient.kt

@@ -22,6 +22,7 @@ internal interface HttpClient {
     fun uploadFile(
         url: String,
         contentType: String,
+        contentEncoding: String?,
         headers: Map<String, String>,
         fileSize: Long,
         fileWriter: (BufferedSink) -> Unit,
@@ -89,13 +90,15 @@ internal class HttpUrlConnectionClient(private val logger: Logger) : HttpClient
     override fun uploadFile(
         url: String,
         contentType: String,
+        contentEncoding: String?,
         headers: Map<String, String>,
         fileSize: Long,
         fileWriter: (BufferedSink) -> Unit,
     ): HttpResponse {
         var connection: HttpURLConnection? = null
         return try {
-            connection = createFileUploadConnection(url, contentType, headers, fileSize)
+            connection =
+                createFileUploadConnection(url, contentType, contentEncoding, headers, fileSize)
             logger.log(LogLevel.Debug, "Uploading file to: $url")
             connection.outputStream.sink().buffer().use { sink ->
                 fileWriter(sink)
@@ -144,6 +147,7 @@ internal class HttpUrlConnectionClient(private val logger: Logger) : HttpClient
     private fun createFileUploadConnection(
         url: String,
         contentType: String,
+        contentEncoding: String?,
         headers: Map<String, String>,
         fileSize: Long,
     ): HttpURLConnection = (URL(url).openConnection() as HttpURLConnection).apply {
@@ -156,6 +160,7 @@ internal class HttpUrlConnectionClient(private val logger: Logger) : HttpClient
             setChunkedStreamingMode(0)
         }
         setRequestProperty("Content-Type", contentType)
+        contentEncoding?.let { setRequestProperty("Content-Encoding", contentEncoding) }
         headers.forEach { (key, value) ->
             setRequestProperty(key, value)
         }

flutter/example/android/app/src/main/AndroidManifest.xml

@@ -25,10 +25,10 @@
 
         <meta-data
             android:name="sh.measure.android.API_KEY"
-            android:value="msrsh_" />
+            android:value="msrsh_8456989a9cd452c7a4864d37a1f3cf9b4f8a45395203c19cb5b6d8252c6970fd_95a8744f" />
 
         <meta-data android:name="sh.measure.android.API_URL"
-            android:value="http://localhost:8080" />
+            android:value="https://staging-ingest.measure.sh" />
 
         <meta-data
             android:name="flutterEmbedding"

flutter/example/android/app/src/main/kotlin/sh/measure/android/flutter/SampleApp.kt

@@ -1,9 +1,13 @@
 package sh.measure.android.flutter
 
 import android.app.Application
+import sh.measure.android.Measure
+import sh.measure.android.config.MeasureConfig
 
 class SampleApp : Application() {
     override fun onCreate() {
         super.onCreate()
+
+        Measure.init(this, MeasureConfig(enableLogging = true))
     }
 }

flutter/example/lib/main.dart

@@ -21,7 +21,7 @@ Future<void> main() async {
       layoutSnapshotWidgetTypes: msrWidgetsForLayoutSnapshot,
     ),
     clientInfo: ClientInfo(
-      apiKey: "msrsh_0c89033fc9ca86c29ba0300452d65ee441a60aac5adc7c5ee2d5057ebcbb4133_2d215ff0",
+      apiKey: "msrsh_8456989a9cd452c7a4864d37a1f3cf9b4f8a45395203c19cb5b6d8252c6970fd_95a8744f",
       apiUrl: "https://staging-ingest.measure.sh",
     ),
   );

flutter/packages/measure_flutter/lib/src/bug_report/attachment_processing.dart

@@ -116,7 +116,7 @@ Future<FileProcessingResult> writeJsonToFileInIsolate(WriteLayoutSnapshotParams
     params.snapshot,
     params.fileName,
     params.rootPath,
-    params.compress,
+    compress: params.compress,
   );
 }
 

flutter/packages/measure_flutter/lib/src/isolate/file_processing_isolate.dart

@@ -131,8 +131,7 @@ class FileProcessingIsolate {
       _sendPort = await completer.future.timeout(
         _initTimeout,
         onTimeout: () {
-          throw TimeoutException(
-              'Failed to initialize file processing isolate');
+          throw TimeoutException('Failed to initialize file processing isolate');
         },
       );
 
@@ -228,9 +227,9 @@ class FileProcessingIsolate {
   Future<FileProcessingResult> processLayoutSnapshotWrite(
     LayoutSnapshot snapshot,
     String fileName,
-    String rootPath,
-    bool compress,
-  ) async {
+    String rootPath, {
+    bool compress = true,
+  }) async {
     if (!_isInitialized || _sendPort == null) {
       return const FileProcessingResult(
         error: 'Isolate not initialized',
@@ -340,8 +339,7 @@ class FileProcessingIsolate {
   }
 
   /// Handle JSON write in isolate
-  static Future<void> _handleJsonWrite(
-      LayoutSnapshotWriteRequest request) async {
+  static Future<void> _handleJsonWrite(LayoutSnapshotWriteRequest request) async {
     try {
       final result = await writeJsonToFileInIsolateWorker(
         request.snapshot,

flutter/packages/measure_flutter/test/utils/fake_file_processing_isolate.dart

@@ -21,8 +21,9 @@ class FakeFileProcessingIsolate implements FileProcessingIsolate {
   Future<FileProcessingResult> processLayoutSnapshotWrite(
     LayoutSnapshot snapshot,
     String fileName,
-    String rootPath,
-  ) async {
+    String rootPath, {
+    bool compress = true,
+  }) async {
     if (shouldThrowException) {
       throw Exception('Test exception');
     }