Class: Train::Transports::Azure::Connection
- Inherits:
-
BaseConnection
- Object
- BaseConnection
- Train::Transports::Azure::Connection
- Defined in:
- lib/train/transports/azure.rb
Constant Summary collapse
- DEFAULT_FILE =
::File.join(Dir.home, ".azure", "credentials")
Instance Attribute Summary collapse
-
#options ⇒ Object
readonly
Returns the value of attribute options.
Instance Method Summary collapse
- #azure_client(klass = ::Azure::Resources::Profiles::Latest::Mgmt::Client, opts = {}) ⇒ Object
- #connect ⇒ Object
-
#get_api_version(resource_type, options) ⇒ Object
Returns the api version for the specified resource type.
-
#initialize(options) ⇒ Connection
constructor
A new instance of Connection.
- #msi_auth? ⇒ Boolean
- #platform ⇒ Object
- #unique_identifier ⇒ Object
- #uri ⇒ Object
Constructor Details
#initialize(options) ⇒ Connection
Returns a new instance of Connection.
35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 |
# File 'lib/train/transports/azure.rb', line 35 def initialize() @apis = {} # Override for any cli options # azure://subscription_id [:subscription_id] = [:host] || [:subscription_id] super() @cache_enabled[:api_call] = true @cache[:api_call] = {} if @options[:client_secret].nil? && @options[:client_id].nil? [:credentials_file] = DEFAULT_FILE if [:credentials_file].nil? @options.merge!(Helpers::Azure::FileCredentials.parse(@options)) end @options[:msi_port] = @options[:msi_port].to_i unless @options[:msi_port].nil? # additional platform details release = Gem.loaded_specs["azure_mgmt_resources"].version @platform_details = { release: "azure_mgmt_resources-v#{release}" } connect end |
Instance Attribute Details
#options ⇒ Object (readonly)
Returns the value of attribute options.
31 32 33 |
# File 'lib/train/transports/azure.rb', line 31 def @options end |
Instance Method Details
#azure_client(klass = ::Azure::Resources::Profiles::Latest::Mgmt::Client, opts = {}) ⇒ Object
64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 |
# File 'lib/train/transports/azure.rb', line 64 def azure_client(klass = ::Azure::Resources::Profiles::Latest::Mgmt::Client, opts = {}) if cache_enabled?(:api_call) return @cache[:api_call][klass.to_s.to_sym] unless @cache[:api_call][klass.to_s.to_sym].nil? end if klass == ::Azure::Resources::Profiles::Latest::Mgmt::Client @credentials[:base_url] = MsRestAzure::AzureEnvironments::AzureCloud.resource_manager_endpoint_url elsif klass == ::Azure::GraphRbac::Profiles::Latest::Client client = GraphRbac.client(@credentials) elsif klass == ::Azure::KeyVault::Profiles::Latest::Mgmt::Client client = Vault.client(opts[:vault_name], @credentials) end client ||= klass.new(@credentials) # Cache if enabled @cache[:api_call][klass.to_s.to_sym] ||= client if cache_enabled?(:api_call) client end |
#connect ⇒ Object
85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 |
# File 'lib/train/transports/azure.rb', line 85 def connect if msi_auth? # this needs set for azure cloud to authenticate ENV["MSI_VM"] = "true" provider = ::MsRestAzure::MSITokenProvider.new(@options[:msi_port]) else provider = ::MsRestAzure::ApplicationTokenProvider.new( @options[:tenant_id], @options[:client_id], @options[:client_secret] ) end @credentials = { credentials: ::MsRest::TokenCredentials.new(provider), subscription_id: @options[:subscription_id], tenant_id: @options[:tenant_id], } @credentials[:client_id] = @options[:client_id] unless @options[:client_id].nil? @credentials[:client_secret] = @options[:client_secret] unless @options[:client_secret].nil? end |
#get_api_version(resource_type, options) ⇒ Object
Returns the api version for the specified resource type
If an api version has been specified in the options then the apis version table is updated with that value and it is returned
However if it is not specified, or multiple types are being interrogated then this method will interrogate Azure for each of the types versions and pick the latest one. This is added to the apis table so that it can be retrieved quickly again of another one of those resources is encountered again in the resource collection.
129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 |
# File 'lib/train/transports/azure.rb', line 129 def get_api_version(resource_type, ) # if an api version has been set in the options, add to the apis hashtable with # the resource type if [:apiversion] @apis[resource_type] = [:apiversion] else # only attempt to get the api version from Azure if the resource type # is not present in the apis hashtable unless @apis.key?(resource_type) # determine the namespace for the resource type namespace, type = resource_type.split(%r{/}) client = azure_client(::Azure::Resources::Profiles::Latest::Mgmt::Client) provider = client.providers.get(namespace) # get the latest API version for the type # assuming that this is the first one in the list api_versions = (provider.resource_types.find { |v| v.resource_type == type }).api_versions @apis[resource_type] = api_versions[0] end end # return the api version for the type @apis[resource_type] end |
#msi_auth? ⇒ Boolean
160 161 162 |
# File 'lib/train/transports/azure.rb', line 160 def msi_auth? @options[:client_id].nil? && @options[:client_secret].nil? && port_open?(@options[:msi_port]) end |
#platform ⇒ Object
60 61 62 |
# File 'lib/train/transports/azure.rb', line 60 def platform force_platform!("azure", @platform_details) end |
#unique_identifier ⇒ Object
156 157 158 |
# File 'lib/train/transports/azure.rb', line 156 def unique_identifier [:subscription_id] || [:tenant_id] end |
#uri ⇒ Object
107 108 109 |
# File 'lib/train/transports/azure.rb', line 107 def uri "azure://#{@options[:subscription_id]}" end |