# frozen_string_literal: true require 'addressable/uri' require 'bolt/error' module Bolt class Target attr_reader :uri, :options attr_writer :inventory # Satisfies the Puppet datatypes API def self.from_asserted_hash(hash) new(hash['uri'], hash['options']) end def initialize(uri, options = nil) @uri = uri @uri_obj = parse(uri) @options = options || {} @options.freeze if @options['user'] @user = @options['user'] end if @options['password'] @password = @options['password'] end if @options['port'] @port = @options['port'] end if @options['protocol'] @protocol = @options['protocol'] end end def update_conf(conf) @protocol = conf[:transport] t_conf = conf[:transports][protocol.to_sym] # Override url methods @user = t_conf['user'] @password = t_conf['password'] @port = t_conf['port'] url_keys = %w[user password port] @options = t_conf.reject { |k, _| url_keys.include?(k) }.merge(@options) self end def parse(string) if string =~ %r{^[^:]+://} Addressable::URI.parse(string) else # Initialize with an empty scheme to ensure we parse the hostname correctly Addressable::URI.parse("//#{string}") end end private :parse def select_impl(task, additional_features = []) available_features = features + additional_features suitable_impl = task.implementations.find { |impl| Set.new(impl['requirements']).subset?(available_features) } return suitable_impl['path'] if suitable_impl end def features if @inventory @inventory.features(self) else Set.new end end def eql?(other) self.class.equal?(other.class) && @uri == other.uri end alias == eql? def hash @uri.hash ^ @options.hash end def to_s "Target('#{@uri}', #{@options})" end def host @uri_obj.hostname end # name is currently just uri but should be used instead to identify the # Target ouside the transport or uri options. def name uri end def port @uri_obj.port || @port end def protocol @uri_obj.scheme || @protocol end def user Addressable::URI.unencode_component( @uri_obj.user || @user ) end def password Addressable::URI.unencode_component( @uri_obj.password || @password ) end end end