Sha256: 02714ed20f2b1a3b47fac92e0028b32dfbf48ec803573eab9d1e1fc89d1c9e60

Contents?: true

Size: 1.41 KB

Versions: 5

Compression:

Stored size: 1.41 KB

Contents

# frozen_string_literal: true

require_relative "includes"
require_relative "logging"

class AwsAssumeRole::Runner < Dry::Struct
    include AwsAssumeRole::Logging
    constructor_type :schema
    attribute :command, Dry::Types["coercible.array"].of(Dry::Types["strict.string"]).default([])
    attribute :exit_on_error, Dry::Types["strict.bool"].default(true)
    attribute :expected_exit_code, Dry::Types["strict.int"].default(0)
    attribute :environment, Dry::Types["strict.hash"].default({})
    attribute :credentials, Dry::Types["object"].optional

    def initialize(options)
        super(options)
        command_to_exec = command.join(" ")
        process_credentials unless credentials.blank?
        system environment, command_to_exec
        exit_status = $CHILD_STATUS.exitstatus
        process_error(exit_status) if exit_status != expected_exit_code
    end

    private

    def process_credentials
        cred_env = {
            "AWS_ACCESS_KEY_ID" => credentials.credentials.access_key_id,
            "AWS_SECRET_ACCESS_KEY" => credentials.credentials.secret_access_key,
            "AWS_SESSION_TOKEN" => credentials.credentials.session_token,
        }
        @environment = environment.merge cred_env
    end

    def process_error(exit_status)
        logger.error "#{command} failed with #{exit_status}"
        exit exit_status if exit_on_error
        raise "#{command} failed with #{exit_status}"
    end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version Path
aws_assume_role-1.0.4 lib/aws_assume_role/runner.rb
aws_assume_role-1.0.3 lib/aws_assume_role/runner.rb
aws_assume_role-1.0.2 lib/aws_assume_role/runner.rb
aws_assume_role-1.0.1 lib/aws_assume_role/runner.rb
aws_assume_role-1.0.0 lib/aws_assume_role/runner.rb