fix: add interaction references to the interaction, not the pact

Appraisals

@@ -7,7 +7,7 @@ appraise "rack-2" do
 end
 
 appraise "activesupport" do
-  gem "activesupport", "~> 5.1"
+  gem "activesupport", "~> 6.1"
   if RUBY_VERSION >= "3.4"
     gem "csv"
     gem "mutex_m"

lib/pact/consumer/grpc_interaction_builder.rb

@@ -148,7 +148,9 @@ def execute(&block)
         end
 
         @references.each do |group, name, value|
-          PactFfi.add_interaction_reference(pact_handle, group, name, value)
+          next if PactFfi.add_interaction_reference(message_pact, group, name, value)
+
+          raise InteractionBuilderError.new("could not add reference #{group}/#{name}")
         end
 
         result = PactFfi::PluginConsumer.interaction_contents(message_pact, 0, GRPC_CONTENT_TYPE, interaction_json)

lib/pact/consumer/http_interaction_builder.rb

@@ -116,7 +116,9 @@ def execute(&block)
         raise InteractionBuilderError.new("interaction is designed to be used one-time only") if defined?(@used)
 
         @references.each do |group, name, value|
-          PactFfi.add_interaction_reference(pact_handle, group, name, value)
+          next if PactFfi.add_interaction_reference(pact_interaction, group, name, value)
+
+          raise InteractionBuilderError.new("could not add reference #{group}/#{name}")
         end
 
         mock_server = MockServer.create_for_http!(

lib/pact/consumer/message_interaction_builder.rb

@@ -141,7 +141,9 @@ def execute(&block)
         message_pact = PactFfi::MessageConsumer.new_message_interaction(pact_handle, @description)
 
         @references.each do |group, name, value|
-          PactFfi.add_interaction_reference(pact_handle, group, name, value)
+          next if PactFfi.add_interaction_reference(message_pact, group, name, value)
+
+          raise InteractionBuilderError.new("could not add reference #{group}/#{name}")
         end
 
         configure_interaction!(message_pact)

lib/pact/consumer/plugin_async_message_interaction_builder.rb

@@ -111,7 +111,9 @@ def execute(&block)
         interaction = PactFfi::AsyncMessageConsumer.new(pact_handle, @description)
 
         @references.each do |group, name, value|
-          PactFfi.add_interaction_reference(pact_handle, group, name, value)
+          next if PactFfi.add_interaction_reference(interaction, group, name, value)
+
+          raise InteractionBuilderError.new("could not add reference #{group}/#{name}")
         end
 
         @provider_state_meta&.each_pair do |provider_state, meta|

lib/pact/consumer/plugin_http_interaction_builder.rb

@@ -129,7 +129,9 @@ def execute(&block)
         interaction = PactFfi.new_interaction(pact_handle, @description)
 
         @references.each do |group, name, value|
-          PactFfi.add_interaction_reference(pact_handle, group, name, value)
+          next if PactFfi.add_interaction_reference(interaction, group, name, value)
+
+          raise InteractionBuilderError.new("could not add reference #{group}/#{name}")
         end
 
         @provider_state_meta&.each_pair do |provider_state, meta|

lib/pact/consumer/plugin_sync_message_interaction_builder.rb

@@ -128,7 +128,9 @@ def execute(&block)
         message_pact = PactFfi::SyncMessageConsumer.new_interaction(pact_handle, @description)
 
         @references.each do |group, name, value|
-          PactFfi.add_interaction_reference(pact_handle, group, name, value)
+          next if PactFfi.add_interaction_reference(message_pact, group, name, value)
+
+          raise InteractionBuilderError.new("could not add reference #{group}/#{name}")
         end
 
         @provider_state_meta&.each_pair do |provider_state, meta|

pact.gemspec

@@ -48,12 +48,8 @@ Gem::Specification.new do |gem|
   # For Kafka support
   unless RUBY_PLATFORM =~ /win32|x64-mingw32|x64-mingw-ucrt/
     # windows does not support librdkafka
-    gem.add_development_dependency 'sbmt-kafka_consumer', '>= 2.0.1'
-    gem.add_development_dependency 'sbmt-kafka_producer', '>= 1.0'
-  end
-  if ENV['X_PACT_DEVELOPMENT_RDKAFKA'] == 'true'
-    # darwin-arm64 prebuilt gems available from 0.20.0
-    gem.add_development_dependency 'karafka-rdkafka', '>= 0.20.0'
+    gem.add_development_dependency 'sbmt-kafka_consumer', '>= 3.0.0'
+    gem.add_development_dependency 'sbmt-kafka_producer', '>= 3.0.0'
   end
   # For gRPC support
   gem.add_development_dependency 'gruf', '>= 2.18'

spec/lib/consumer/message_interaction_builder_spec.rb

@@ -61,5 +61,22 @@
         subject.reference('group', 'name', '')
       end.to raise_error(described_class::InteractionBuilderError, /value is required/)
     end
+
+    it 'writes the reference to the interaction in the pact file' do
+      Dir.mktmpdir do |dir|
+        config = Pact::Consumer::PactConfig::Message.new(
+          consumer_name: 'reference-consumer', provider_name: 'reference-provider', opts: {pact_dir: dir}
+        )
+        config.new_interaction('a referenced message')
+          .with_json_contents(id: 1)
+          .reference('AsyncAPI', 'operationId', 'publishThing')
+          .execute { |_payload, _meta| }
+
+        pact = JSON.parse(File.read(File.join(dir, 'reference-consumer-reference-provider.json')))
+        expect(pact['interactions'].first.dig('comments', 'references')).to eq(
+          'AsyncAPI' => {'operationId' => 'publishThing'}
+        )
+      end
+    end
   end
 end