Skip to content

Commit

Permalink
(#202) pass federations properly down from choria playbooks
Browse files Browse the repository at this point in the history
  • Loading branch information
vjanelle committed Dec 11, 2024
1 parent 71bc741 commit 1932da5
Show file tree
Hide file tree
Showing 7 changed files with 8 additions and 10 deletions.
6 changes: 3 additions & 3 deletions lib/mcollective/ddl/discoveryddl.rb
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,7 @@ module DDL
# :timeout => 2
#
# discovery do
# capabilities [:classes, :facts, :identity, :agents, :compound]
# capabilities [:classes, :facts, :identity, :agents, :compound, :federations]
# end
class DiscoveryDDL < Base
def discovery_interface
Expand All @@ -25,10 +25,10 @@ def capabilities(*caps)
raise "Discovery plugin capabilities can't be empty" if caps.empty?

caps.each do |cap|
if [:classes, :facts, :identity, :agents, :compound].include?(cap)
if [:classes, :facts, :identity, :agents, :compound, :federations].include?(cap)
@entities[:discovery][:capabilities] << cap
else
raise "%s is not a valid capability, valid capabilities are :classes, :facts, :identity, :agents and :compound" % cap
raise "%s is not a valid capability, valid capabilities are :classes, :facts, :identity, :agents, :compound, and :federations" % cap
end
end
end
Expand Down
4 changes: 1 addition & 3 deletions lib/mcollective/discovery/delegate.rb
Original file line number Diff line number Diff line change
Expand Up @@ -39,9 +39,7 @@ def self.discover(filter, timeout, limit, client)
cmd << "-S" << c.first["expr"]
end

unless @config.federations.empty?
cmd << "--federations" << @config.federations.join(",")
end
cmd << "--federations" << @config.federations.join(",") unless @config.federations.empty?

client.options.fetch(:discovery_options, []).each do |opt|
cmd << "--do" << opt
Expand Down
2 changes: 1 addition & 1 deletion lib/mcollective/discovery/external.ddl
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@ metadata :name => "external",
:timeout => 2

discovery do
capabilities [:classes, :facts, :identity, :agents, :compound]
capabilities [:classes, :facts, :identity, :agents, :compound, :federations]
end


1 change: 0 additions & 1 deletion lib/mcollective/rpc.rb
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,6 @@ def rpcoptions

Helpers.add_simplerpc_options(parser, opts)
end

end

# Wrapper to create clients, supposed to be used as
Expand Down
2 changes: 1 addition & 1 deletion lib/mcollective/util.rb
Original file line number Diff line number Diff line change
Expand Up @@ -217,7 +217,7 @@ def self.default_options
:discovery_method => nil,
:discovery_options => Config.instance.default_discovery_options,
:filter => empty_filter,
:federations => []
:federations => Config.instance.federations
}
end

Expand Down
2 changes: 1 addition & 1 deletion lib/mcollective/util/choria.rb
Original file line number Diff line number Diff line change
Expand Up @@ -97,7 +97,7 @@ def federated?
#
# @return [Array<String>]
def federation_collectives
if (@config.federations.length > 0)
if !@config.federations.empty?
@config.federations
elsif (override_networks = env_fetch("CHORIA_FED_COLLECTIVE", nil))
override_networks.split(",").map(&:strip).reject(&:empty?)
Expand Down
1 change: 1 addition & 0 deletions lib/mcollective/util/playbook/nodes/mcollective_nodes.rb
Original file line number Diff line number Diff line change
Expand Up @@ -9,6 +9,7 @@ def initialize
@facts = []
@classes = []
@identity = []
@federations = []
@compound = nil
end

Expand Down

0 comments on commit 1932da5

Please sign in to comment.