Add a SetInputFromHeader request mutator

Author: azimux

CHANGELOG.md

@@ -1,3 +1,7 @@
+## [0.0.18] - 2025-03-29
+
+- Implement SetInputsFromHeader request mutator and MoveAttributeToHeader response mutator
+
 ## [0.0.17] - 2025-03-29
 
 - Implement SetInputsFromCookie request mutator

Gemfile.lock

@@ -1,7 +1,7 @@
 PATH
   remote: .
   specs:
-    foobara-http-command-connector (0.0.17)
+    foobara-http-command-connector (0.0.18)
       foobara (~> 0.0.88)
 
 GEM

spec/foobara/command_connectors_http/set_input_from_header_spec.rb

@@ -0,0 +1,44 @@
+RSpec.describe Foobara::CommandConnectors::Http::SetInputFromHeader do
+  let(:command_class) do
+    stub_class(:SomeCommand, Foobara::Command) do
+      inputs foo: :string, bar: :string
+      result :duck
+
+      def execute
+        inputs
+      end
+    end
+  end
+
+  let(:request_mutator) do
+    described_class.for(:foo, "foo_header")
+  end
+
+  let(:command_connector) { Foobara::CommandConnectors::Http.new }
+  let(:response) { command_connector.run(path:, query_string:, headers:) }
+  let(:query_string) { "bar=barvalue" }
+  let(:path) { "/run/#{command_class.full_command_name}" }
+  let(:headers) do
+    { "foo_header" => "foovalue" }
+  end
+
+  before do
+    command_connector.connect(command_class, request_mutators: request_mutator)
+  end
+
+  it "moves the header to an input" do
+    expect(response.status).to eq(200)
+    expect(JSON.parse(response.body)).to eq("bar" => "barvalue", "foo" => "foovalue")
+  end
+
+  it "makes changes in the manifest" do
+    manifest = command_connector.foobara_manifest
+
+    expect(manifest[:command][:SomeCommand][:inputs_type]).to eq(
+      type: :attributes,
+      element_type_declarations: {
+        bar: { type: :string }
+      }
+    )
+  end
+end

src/http/request_mutators/set_input_from_header.rb

@@ -0,0 +1,42 @@
+module Foobara
+  module CommandConnectors
+    class Http < CommandConnector
+      class SetInputFromHeader < RequestMutator
+        class << self
+          attr_accessor :attribute_name, :header_name
+
+          def for(attribute_name, header_name = attribute_name)
+            subclass = Class.new(self)
+
+            header_name = header_name.to_s if header_name.is_a?(::Symbol)
+
+            subclass.attribute_name = attribute_name
+            subclass.header_name = header_name
+
+            subclass
+          end
+        end
+
+        attr_writer :attribute_name, :header_name
+
+        def inputs_type_from(inputs_type)
+          new_declaration = TypeDeclarations::Attributes.reject(inputs_type.declaration_data, attribute_name)
+          Domain.current.foobara_type_from_declaration(new_declaration)
+        end
+
+        def mutate(request)
+          header_value = request.headers[header_name]
+          request.inputs[attribute_name] = header_value
+        end
+
+        def attribute_name
+          @attribute_name ||= self.class.attribute_name
+        end
+
+        def header_name
+          @header_name ||= self.class.header_name
+        end
+      end
+    end
+  end
+end

version.rb

@@ -1,6 +1,6 @@
 module Foobara
   module HttpCommandConnector
-    VERSION = "0.0.17".freeze
+    VERSION = "0.0.18".freeze
 
     local_ruby_version = File.read("#{__dir__}/.ruby-version").chomp
     local_ruby_version_minor = local_ruby_version[/\A(\d+\.\d+)\.\d+\z/, 1]