1 files changed, 38 insertions, 0 deletions
diff --git a/lib/error_tracking/collector/sentry_request_parser.rb b/lib/error_tracking/collector/sentry_request_parser.rb
new file mode 100644
index 00000000000..29e4cc8976f
--- /dev/null
+++ b/lib/error_tracking/collector/sentry_request_parser.rb
@@ -0,0 +1,38 @@
+# frozen_string_literal: true
+
+module ErrorTracking
+  module Collector
+    class SentryRequestParser
+      def self.parse(request)
+        # Request body can be "" or "gzip".
+        # If later then body was compressed with Zlib.gzip
+        encoding = request.headers['Content-Encoding']
+
+        body = if encoding == 'gzip'
+                 Zlib.gunzip(request.body.read)
+               else
+                 request.body.read
+               end
+
+        # Request body contains 3 json objects merged together in one StringIO.
+        # We need to separate and parse them into array of hash objects.
+        json_objects = []
+        parser = Yajl::Parser.new
+
+        parser.parse(body) do |json_object|
+          json_objects << json_object
+        end
+
+        # The request contains 3 objects: sentry metadata, type data and event data.
+        # We need only last two. Type to decide what to do with the request.
+        # And event data as it contains all information about the exception.
+        _, type, event = json_objects
+
+        {
+          request_type: type['type'],
+          event: event
+        }
+      end
+    end
+  end
+end