Update Data Request script to compute requesting issuer and have configurable depth

lib/data_pull.rb

@@ -162,14 +162,22 @@ def run(args:, config:)
       ActiveRecord::Base.connection.execute('SET statement_timeout = 0')
       uuids = args
 
+      requesting_issuers =
+        config.requesting_issuers.presence || compute_requesting_issuers(uuids)
+
       users, missing_uuids = uuids.map do |uuid|
         DataRequests::Deployed::LookupUserByUuid.new(uuid).call || uuid
       end.partition { |u| u.is_a?(User) }
 
-      shared_device_users = DataRequests::Deployed::LookupSharedDeviceUsers.new(users).call
+      shared_device_users =
+        if config.depth && config.depth > 0
+          DataRequests::Deployed::LookupSharedDeviceUsers.new(users, config.depth).call
+        else
+          users
+        end
 
       output = shared_device_users.map do |user|
-        DataRequests::Deployed::CreateUserReport.new(user, config.requesting_issuers).call
+        DataRequests::Deployed::CreateUserReport.new(user, requesting_issuers).call
       end
 
       if config.include_missing?
@@ -198,6 +206,24 @@ def run(args:, config:)
         json: output,
       )
     end
+
+    private
+
+    def compute_requesting_issuers(uuids)
+      service_providers = ServiceProviderIdentity.where(uuid: uuids).pluck(:service_provider)
+      return nil if service_providers.empty?
+      service_provider = service_providers.tally.max_by { |_sp, count| count }[0]
+
+      if service_providers.count > 1
+        warn "Multiple computed service providers: #{service_providers.join(', ')}"
+      end
+
+      warn "Computed service provider #{service_provider}"
+
+      [
+        service_provider,
+      ]
+    end
   end
 
   class ProfileSummary

lib/script_base.rb

@@ -33,6 +33,7 @@ def reason_arg?
     :show_help,
     :requesting_issuers,
     :deflate,
+    :depth,
     :reason,
     keyword_init: true,
   ) do
@@ -111,6 +112,12 @@ def option_parser
         config.requesting_issuers << issuer
       end
 
+      opts.on('--depth=DEPTH', <<-MSG) do |depth|
+        depth of connected devices (used for ig-request task)
+      MSG
+        config.depth = depth.to_i
+      end
+
       opts.on('--help') do
         config.show_help = true
       end

spec/lib/data_pull_spec.rb

@@ -319,6 +319,26 @@
         expect(result.subtask).to eq('ig-request')
         expect(result.uuids).to eq([user.uuid])
       end
+
+      context 'with SP UUID argument and no requesting issuer' do
+        let(:args) { [identity.uuid] }
+        let(:config) { ScriptBase::Config.new }
+
+        it 'runs the report with computed requesting issuer', aggregate_failures: true do
+          expect(result.table).to be_nil
+          expect(result.json.first.keys).to contain_exactly(
+            :user_id,
+            :login_uuid,
+            :requesting_issuer_uuid,
+            :email_addresses,
+            :mfa_configurations,
+            :user_events,
+          )
+
+          expect(result.subtask).to eq('ig-request')
+          expect(result.uuids).to eq([user.uuid])
+        end
+      end
     end
   end