move contrib tracer helpers to common helpers;

serialize test event to msgpack

lib/datadog/ci/test_visibility/serializer/base.rb

@@ -0,0 +1,34 @@
+# frozen_string_literal: true
+
+module Datadog
+  module CI
+    module TestVisibility
+      module Serializer
+        class Base
+          attr_reader :trace, :span
+
+          def initialize(trace, span)
+            @trace = trace
+            @span = span
+          end
+
+          def runtime_id
+            @trace.runtime_id
+          end
+
+          # Used for serialization
+          # @return [Integer] in nanoseconds since Epoch
+          def time_nano(time)
+            time.to_i * 1000000000 + time.nsec
+          end
+
+          # Used for serialization
+          # @return [Integer] in nanoseconds since Epoch
+          def duration_nano(duration)
+            (duration * 1e9).to_i
+          end
+        end
+      end
+    end
+  end
+end

lib/datadog/ci/test_visibility/serializer/span.rb

@@ -0,0 +1,17 @@
+# frozen_string_literal: true
+
+require_relative "base"
+
+module Datadog
+  module CI
+    module TestVisibility
+      module Serializer
+        class Span < Base
+          def to_msgpack(packer = nil)
+            packer ||= MessagePack::Packer.new
+          end
+        end
+      end
+    end
+  end
+end

lib/datadog/ci/test_visibility/serializer/test.rb

@@ -0,0 +1,61 @@
+# frozen_string_literal: true
+
+require_relative "base"
+require_relative "../../ext/test"
+
+module Datadog
+  module CI
+    module TestVisibility
+      module Serializer
+        class Test < Base
+          def to_msgpack(packer = nil)
+            packer ||= MessagePack::Packer.new unless defined?(@packer)
+
+            packer.write_map_header(3)
+
+            packer.write("type")
+            packer.write("test")
+
+            packer.write("version")
+            packer.write(1)
+
+            packer.write("content")
+
+            packer.write_map_header(10)
+
+            packer.write("trace_id")
+            packer.write(@trace.id)
+
+            packer.write("span_id")
+            packer.write(@span.id)
+
+            packer.write("name")
+            packer.write("#{@span.get_tag(Ext::Test::TAG_FRAMEWORK)}.test")
+
+            packer.write("resource")
+            packer.write("#{@span.get_tag(Ext::Test::TAG_SUITE)}.#{@span.get_tag(Ext::Test::TAG_NAME)}")
+
+            packer.write("service")
+            packer.write(@span.service)
+
+            packer.write("type")
+            packer.write("test")
+
+            packer.write("start")
+            packer.write(time_nano(@span.start_time))
+
+            packer.write("duration")
+            packer.write(duration_nano(@span.duration))
+
+            packer.write("meta")
+            packer.write(@span.meta)
+
+            # metrics have the same value as meta
+            packer.write("metrics")
+            packer.write({})
+          end
+        end
+      end
+    end
+  end
+end

lib/datadog/ci/test_visibility/something_that_converts_traces.rb

@@ -0,0 +1,27 @@
+# frozen_string_literal: true
+
+require_relative "serializer/test"
+require_relative "serializer/span"
+
+module Datadog
+  module CI
+    module TestVisibility
+      module SomethingThatConvertsTraces
+        module_function
+
+        def convert(trace)
+          trace.spans.map { |span| convert_span(trace, span) }
+        end
+
+        def convert_span(trace, span)
+          case span.type
+          when Datadog::CI::Ext::AppTypes::TYPE_TEST
+            Serializer::Test.new(trace, span)
+          else
+            Serializer::Span.new(trace, span)
+          end
+        end
+      end
+    end
+  end
+end

lib/datadog/ci/test_visibility/transport.rb

@@ -1,5 +1,6 @@
 # frozen_string_literal: true
 
+require_relative "something_that_converts_traces"
 require "datadog/core/encoding"
 # use it to chunk payloads by size
 # require "datadog/core/chunker"
@@ -14,8 +15,8 @@ def initialize
 
         def send_traces(traces)
           # convert traces to events and construct payload
-          events = traces.map { |trace| PayloadEvents.convert_from_trace(trace) }
-          # payload = Payload.new(events)
+          events = traces.flat_map { |trace| SomethingThatConvertsTraces.convert(trace) }
+          payload = Payload.new(events)
           # @encoder.encode(payload)
         end
 
@@ -24,9 +25,30 @@ def send_traces(traces)
         # represents payload with some subset of serializable events to be sent to CI-APP intake
         class Payload
           def initialize(events)
+            @events = events
           end
 
-          def to_msgpack
+          def to_msgpack(packer)
+            packer ||= MessagePack::Packer.new
+
+            packer.write_map_header(3) # Set header with how many elements in the map
+            packer.write("version")
+            packer.write(1)
+
+            packer.write("metadata")
+            packer.write_map_header(3)
+
+            packer.write("runtime-id")
+            packer.write(@events.first.runtime_id)
+
+            packer.write("language")
+            packer.write("ruby")
+
+            packer.write("library_version")
+            packer.write(Datadog::CI::VERSION::STRING)
+
+            packer.write_array_header(@events.size)
+            packer.write(@events)
           end
         end
       end

spec/datadog/ci/contrib/cucumber/instrumentation_spec.rb

@@ -1,5 +1,3 @@
-require_relative "../support/spec_helper"
-
 require "stringio"
 require "cucumber"
 

spec/datadog/ci/contrib/cucumber/integration_spec.rb

@@ -1,5 +1,3 @@
-require_relative "../support/spec_helper"
-
 RSpec.describe Datadog::CI::Contrib::Cucumber::Integration do
   extend ConfigurationHelpers
 

spec/datadog/ci/contrib/cucumber/patcher_spec.rb

@@ -1,5 +1,3 @@
-require_relative "../support/spec_helper"
-
 RSpec.describe Datadog::CI::Contrib::Cucumber::Patcher do
   describe ".patch" do
     subject!(:patch) { described_class.patch }

spec/datadog/ci/contrib/minitest/instrumentation_spec.rb

@@ -2,8 +2,6 @@
 require "minitest"
 require "minitest/spec"
 
-require_relative "../support/spec_helper"
-
 RSpec.describe "Minitest hooks" do
   include_context "CI mode activated" do
     let(:integration_name) { :minitest }

spec/datadog/ci/contrib/minitest/integration_spec.rb

@@ -1,5 +1,3 @@
-require_relative "../support/spec_helper"
-
 RSpec.describe Datadog::CI::Contrib::Minitest::Integration do
   extend ConfigurationHelpers
 

spec/datadog/ci/contrib/minitest/patcher_spec.rb

@@ -1,5 +1,3 @@
-require_relative "../support/spec_helper"
-
 require "minitest"
 
 RSpec.describe Datadog::CI::Contrib::Minitest::Patcher do

spec/datadog/ci/contrib/rspec/instrumentation_spec.rb

@@ -1,7 +1,5 @@
 require "time"
 
-require_relative "../support/spec_helper"
-
 RSpec.describe "RSpec hooks" do
   include_context "CI mode activated" do
     let(:integration_name) { :rspec }

spec/datadog/ci/contrib/rspec/integration_spec.rb

@@ -1,5 +1,3 @@
-require_relative "../support/spec_helper"
-
 RSpec.describe Datadog::CI::Contrib::RSpec::Integration do
   extend ConfigurationHelpers
 

spec/datadog/ci/contrib/rspec/patcher_spec.rb

@@ -1,5 +1,3 @@
-require_relative "../support/spec_helper"
-
 RSpec.describe Datadog::CI::Contrib::RSpec::Patcher do
   describe ".patch" do
     subject!(:patch) { described_class.patch }