Remove Concerns::Payloads

lib/temporal/activity/task_processor.rb

@@ -2,7 +2,6 @@
 require 'temporal/error_handler'
 require 'temporal/errors'
 require 'temporal/activity/context'
-require 'temporal/concerns/payloads'
 require 'temporal/connection/retryer'
 require 'temporal/connection'
 require 'temporal/metric_keys'

lib/temporal/connection/grpc.rb

@@ -15,7 +15,6 @@
 require 'temporal/connection/serializer/backfill'
 require 'temporal/connection/serializer/schedule'
 require 'temporal/connection/serializer/workflow_id_reuse_policy'
-require 'temporal/concerns/payloads'
 
 module Temporal
   module Connection

lib/temporal/connection/serializer/complete_workflow.rb

@@ -1,5 +1,4 @@
 require 'temporal/connection/serializer/base'
-require 'temporal/concerns/payloads'
 
 module Temporal
   module Connection

lib/temporal/connection/serializer/continue_as_new.rb

@@ -1,6 +1,5 @@
 require 'temporal/connection/serializer/base'
 require 'temporal/connection/serializer/retry_policy'
-require 'temporal/concerns/payloads'
 
 module Temporal
   module Connection

lib/temporal/connection/serializer/failure.rb

@@ -1,5 +1,4 @@
 require 'temporal/connection/serializer/base'
-require 'temporal/concerns/payloads'
 
 module Temporal
   module Connection

lib/temporal/connection/serializer/query_answer.rb

@@ -1,5 +1,4 @@
 require 'temporal/connection/serializer/base'
-require 'temporal/concerns/payloads'
 
 module Temporal
   module Connection

lib/temporal/connection/serializer/record_marker.rb

@@ -1,5 +1,4 @@
 require 'temporal/connection/serializer/base'
-require 'temporal/concerns/payloads'
 
 module Temporal
   module Connection

lib/temporal/connection/serializer/schedule_action.rb

@@ -1,5 +1,4 @@
 require "temporal/connection/serializer/base"
-require "temporal/concerns/payloads"
 
 module Temporal
   module Connection

lib/temporal/connection/serializer/schedule_activity.rb

@@ -1,6 +1,5 @@
 require 'temporal/connection/serializer/base'
 require 'temporal/connection/serializer/retry_policy'
-require 'temporal/concerns/payloads'
 
 module Temporal
   module Connection

lib/temporal/connection/serializer/signal_external_workflow.rb

@@ -1,5 +1,4 @@
 require 'temporal/connection/serializer/base'
-require 'temporal/concerns/payloads'
 
 module Temporal
   module Connection

lib/temporal/connection/serializer/start_child_workflow.rb

@@ -1,7 +1,6 @@
 require 'temporal/connection/serializer/base'
 require 'temporal/connection/serializer/retry_policy'
 require 'temporal/connection/serializer/workflow_id_reuse_policy'
-require 'temporal/concerns/payloads'
 
 module Temporal
   module Connection

lib/temporal/connection/serializer/upsert_search_attributes.rb

@@ -1,5 +1,4 @@
 require 'temporal/connection/serializer/base'
-require 'temporal/concerns/payloads'
 
 module Temporal
   module Connection

lib/temporal/metadata.rb

@@ -2,7 +2,6 @@
 require 'temporal/metadata/activity'
 require 'temporal/metadata/workflow'
 require 'temporal/metadata/workflow_task'
-require 'temporal/concerns/payloads'
 
 module Temporal
   module Metadata

lib/temporal/workflow/execution_info.rb

@@ -1,4 +1,3 @@
-require 'temporal/concerns/payloads'
 require 'temporal/workflow/status'
 
 module Temporal

lib/temporal/workflow/state_manager.rb

@@ -4,7 +4,6 @@
 require 'temporal/workflow/command_state_machine'
 require 'temporal/workflow/history/event_target'
 require 'temporal/workflow/history/size'
-require 'temporal/concerns/payloads'
 require 'temporal/workflow/errors'
 require 'temporal/workflow/sdk_flags'
 require 'temporal/workflow/signal'

spec/fabricators/grpc/activity_task_fabricator.rb

@@ -6,7 +6,7 @@
   activity_id { SecureRandom.uuid }
   task_token { |attrs| attrs[:task_token] || SecureRandom.uuid }
   activity_type { Fabricate(:api_activity_type) }
-  input { Temporal.configuration.converter.to_payloads(nil) }
+  input { TEST_CONVERTER.to_payloads(nil) }
   workflow_type { Fabricate(:api_workflow_type) }
   workflow_execution { Fabricate(:api_workflow_execution) }
   current_attempt_scheduled_time { Google::Protobuf::Timestamp.new.tap { |t| t.from_time(Time.now) } }
@@ -15,7 +15,7 @@
   current_attempt_scheduled_time { Google::Protobuf::Timestamp.new.tap { |t| t.from_time(Time.now) } }
   header do |attrs|
     fields = (attrs[:headers] || {}).each_with_object({}) do |(field, value), h|
-      h[field] = Temporal.configuration.converter.to_payload(value)
+      h[field] = TEST_CONVERTER.to_payload(value)
     end
     Temporalio::Api::Common::V1::Header.new(fields: fields)
   end

spec/fabricators/grpc/application_failure_fabricator.rb

@@ -1,5 +1,3 @@
-require 'temporal/concerns/payloads'
-
 # Simulates Temporal::Connection::Serializer::Failure
 Fabricator(:api_application_failure, from: Temporalio::Api::Failure::V1::Failure) do
   transient :error_class, :backtrace

spec/fabricators/grpc/history_event_fabricator.rb

@@ -1,5 +1,4 @@
 require 'securerandom'
-require 'temporal/concerns/payloads'
 
 Fabricator(:api_history_event, from: Temporalio::Api::History::V1::HistoryEvent) do
   event_id { 1 }

spec/fabricators/grpc/memo_fabricator.rb

@@ -1,7 +1,7 @@
 Fabricator(:memo, from: Temporalio::Api::Common::V1::Memo) do
   fields do
     Google::Protobuf::Map.new(:string, :message, Temporalio::Api::Common::V1::Payload).tap do |m|
-      m['foo'] = Temporal.configuration.converter.to_payload('bar')
+      m['foo'] = TEST_CONVERTER.to_payload('bar')
     end
   end
 end

spec/fabricators/grpc/search_attributes_fabricator.rb

@@ -1,7 +1,7 @@
 Fabricator(:search_attributes, from: Temporalio::Api::Common::V1::SearchAttributes) do
   indexed_fields do
     Google::Protobuf::Map.new(:string, :message, Temporalio::Api::Common::V1::Payload).tap do |m|
-      m['foo'] = Temporal.configuration.converter.to_payload('bar')
+      m['foo'] = TEST_CONVERTER.to_payload('bar')
     end
   end
 end

spec/fabricators/grpc/workflow_query_fabricator.rb

@@ -1,4 +1,4 @@
 Fabricator(:api_workflow_query, from: Temporalio::Api::Query::V1::WorkflowQuery) do
   query_type { 'state' }
-  query_args { Temporal.configuration.converter.to_payloads(['']) }
+  query_args { TEST_CONVERTER.to_payloads(['']) }
 end

spec/unit/lib/temporal/connection/serializer/query_answer_spec.rb

@@ -1,6 +1,5 @@
 require 'temporal/connection/serializer/query_failure'
 require 'temporal/workflow/query_result'
-require 'temporal/concerns/payloads'
 
 describe Temporal::Connection::Serializer::QueryAnswer do
   let(:converter) do