Include queried facts as host vars in -A inventory
`-A` emitted hosts with empty vars, so `-F ipaddress,enc_role -A` lost the facts
it just queried. Ansible inventories are far more useful with the values inline.
- Extract factsByHost() (the {host: {fact: value}} builder) and share it between
-j and -A so the Ansible inventory attaches each host's queried fact(s) as
host vars, keyed by real fact name.
- Strengthen the Ansible test to assert host vars and add a multi-fact case.
This commit is contained in:
@@ -68,7 +68,7 @@ installed. To load ad-hoc in the current shell, e.g. zsh:
|
|||||||
./node-lookup -R -1 # node names only
|
./node-lookup -R -1 # node names only
|
||||||
./node-lookup -R -2 # values only
|
./node-lookup -R -2 # values only
|
||||||
./node-lookup -R -C # count occurrences
|
./node-lookup -R -C # count occurrences
|
||||||
./node-lookup -R -A # output as Ansible YAML inventory
|
./node-lookup -R -A # output as Ansible YAML inventory (queried facts become host vars)
|
||||||
./node-lookup -j # output as JSON { host → { fact → value } }
|
./node-lookup -j # output as JSON { host → { fact → value } }
|
||||||
./node-lookup --url http://host:8080/... # override PuppetDB URL for this invocation
|
./node-lookup --url http://host:8080/... # override PuppetDB URL for this invocation
|
||||||
echo -e "node1\nnode2" | ./node-lookup -R # pipe node names via stdin
|
echo -e "node1\nnode2" | ./node-lookup -R # pipe node names via stdin
|
||||||
@@ -116,7 +116,7 @@ Show the active configuration (after all overrides applied):
|
|||||||
- **Match value / `matchValue()`**: the value to match comes from `-m/--match` or, if that is empty, an optional positional argument. The positional fallback exists because pflag does not attach a space-separated value to a string flag grouped with a bool flag, so in `-pm k8s` the `k8s` arrives as a positional. `-m` still wins when both are given.
|
- **Match value / `matchValue()`**: the value to match comes from `-m/--match` or, if that is empty, an optional positional argument. The positional fallback exists because pflag does not attach a space-separated value to a string flag grouped with a bool flag, so in `-pm k8s` the `k8s` arrives as a positional. `-m` still wins when both are given.
|
||||||
- **`queryPuppetDB(url, query)`**: takes the URL as a parameter — never reads globals.
|
- **`queryPuppetDB(url, query)`**: takes the URL as a parameter — never reads globals.
|
||||||
- **`processResults()`**: iterates facts, returns sorted `"certname value"` strings. JSON string values are unquoted; other JSON types rendered as compact JSON.
|
- **`processResults()`**: iterates facts, returns sorted `"certname value"` strings. JSON string values are unquoted; other JSON types rendered as compact JSON.
|
||||||
- **Output modes**: JSON (`-j`), count (`-C`), Ansible YAML (`-A`), node-only (`-1`), value-only (`-2`), default (node + value).
|
- **Output modes**: JSON (`-j`), count (`-C`), Ansible YAML (`-A`), node-only (`-1`), value-only (`-2`), default (node + value). `-j` and `-A` share `factsByHost()`, so both attach the queried fact(s) per host — as an object under the host (`-j`) or as inventory host vars (`-A`).
|
||||||
- **Stdin support**: `stdinReader()` reads node names from stdin only when it is a real pipe/redirect carrying data (and no `-n` given). Terminals, `/dev/null`, and empty/closed pipes fall through to a normal query — so running without a TTY (e.g. invoked by an agent or CI) behaves like an interactive run instead of consuming empty input.
|
- **Stdin support**: `stdinReader()` reads node names from stdin only when it is a real pipe/redirect carrying data (and no `-n` given). Terminals, `/dev/null`, and empty/closed pipes fall through to a normal query — so running without a TTY (e.g. invoked by an agent or CI) behaves like an interactive run instead of consuming empty input.
|
||||||
- **SIGPIPE handling**: `signal.Ignore(syscall.SIGPIPE)` so pipes to `head` etc. work cleanly.
|
- **SIGPIPE handling**: `signal.Ignore(syscall.SIGPIPE)` so pipes to `head` etc. work cleanly.
|
||||||
|
|
||||||
|
|||||||
@@ -276,6 +276,31 @@ func matchValue(flagMatch string, args []string) string {
|
|||||||
return ""
|
return ""
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// factsByHost groups collected facts into {certname: {factname: value}}. Each
|
||||||
|
// value is keyed by the fact's real name, so multiple -F facts each appear
|
||||||
|
// under the host; it falls back to the -F string, the role fact (with -R), or
|
||||||
|
// "value" only when a result carries no name. Shared by the -j and -A outputs.
|
||||||
|
func factsByHost(collected []fact, factName, roleFact string, showRole bool) map[string]map[string]interface{} {
|
||||||
|
out := map[string]map[string]interface{}{}
|
||||||
|
for _, f := range collected {
|
||||||
|
if _, ok := out[f.Certname]; !ok {
|
||||||
|
out[f.Certname] = map[string]interface{}{}
|
||||||
|
}
|
||||||
|
key := f.Name
|
||||||
|
if key == "" {
|
||||||
|
if key = factName; key == "" {
|
||||||
|
if showRole {
|
||||||
|
key = roleFact
|
||||||
|
} else {
|
||||||
|
key = "value"
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
out[f.Certname][key] = valueAny(f.Value)
|
||||||
|
}
|
||||||
|
return out
|
||||||
|
}
|
||||||
|
|
||||||
func allFactsForNode(puppetDBURL, node string) ([]fact, error) {
|
func allFactsForNode(puppetDBURL, node string) ([]fact, error) {
|
||||||
query, _ := json.Marshal([]interface{}{"=", "certname", node})
|
query, _ := json.Marshal([]interface{}{"=", "certname", node})
|
||||||
return queryPuppetDB(puppetDBURL, string(query))
|
return queryPuppetDB(puppetDBURL, string(query))
|
||||||
@@ -346,30 +371,10 @@ func run(cfg config, nodeName, factName, match string, showRole, partial, invers
|
|||||||
|
|
||||||
switch {
|
switch {
|
||||||
case jsonMode:
|
case jsonMode:
|
||||||
hostFactMap := map[string]map[string]interface{}{}
|
|
||||||
for _, f := range collected {
|
|
||||||
if _, ok := hostFactMap[f.Certname]; !ok {
|
|
||||||
hostFactMap[f.Certname] = map[string]interface{}{}
|
|
||||||
}
|
|
||||||
// Key by the fact's actual name so multiple -F facts (e.g.
|
|
||||||
// ipaddress,enc_role) each appear under the host. Fall back to the
|
|
||||||
// computed key only if the result carries no name.
|
|
||||||
key := f.Name
|
|
||||||
if key == "" {
|
|
||||||
if key = factName; key == "" {
|
|
||||||
if showRole {
|
|
||||||
key = cfg.RoleFact
|
|
||||||
} else {
|
|
||||||
key = "value"
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
hostFactMap[f.Certname][key] = valueAny(f.Value)
|
|
||||||
}
|
|
||||||
enc := json.NewEncoder(os.Stdout)
|
enc := json.NewEncoder(os.Stdout)
|
||||||
enc.SetIndent("", " ")
|
enc.SetIndent("", " ")
|
||||||
enc.SetEscapeHTML(false)
|
enc.SetEscapeHTML(false)
|
||||||
_ = enc.Encode(hostFactMap)
|
_ = enc.Encode(factsByHost(collected, factName, cfg.RoleFact, showRole))
|
||||||
|
|
||||||
case count:
|
case count:
|
||||||
values := stdinLines
|
values := stdinLines
|
||||||
@@ -379,10 +384,11 @@ func run(cfg config, nodeName, factName, match string, showRole, partial, invers
|
|||||||
fmt.Println(strings.Join(countResults(values), "\n"))
|
fmt.Println(strings.Join(countResults(values), "\n"))
|
||||||
|
|
||||||
case ansible:
|
case ansible:
|
||||||
|
// Attach each host's queried fact(s) as inventory host vars, e.g.
|
||||||
|
// `-F ipaddress,enc_role -A` yields hosts with ipaddress + enc_role set.
|
||||||
hosts := map[string]interface{}{}
|
hosts := map[string]interface{}{}
|
||||||
for _, line := range returnData {
|
for host, vars := range factsByHost(collected, factName, cfg.RoleFact, showRole) {
|
||||||
host := strings.Fields(line)[0]
|
hosts[host] = vars
|
||||||
hosts[host] = map[string]interface{}{}
|
|
||||||
}
|
}
|
||||||
inventory := map[string]interface{}{
|
inventory := map[string]interface{}{
|
||||||
"all": map[string]interface{}{"hosts": hosts},
|
"all": map[string]interface{}{"hosts": hosts},
|
||||||
|
|||||||
@@ -9,6 +9,8 @@ import (
|
|||||||
"path/filepath"
|
"path/filepath"
|
||||||
"strings"
|
"strings"
|
||||||
"testing"
|
"testing"
|
||||||
|
|
||||||
|
"gopkg.in/yaml.v3"
|
||||||
)
|
)
|
||||||
|
|
||||||
// ---- helpers ----------------------------------------------------------------
|
// ---- helpers ----------------------------------------------------------------
|
||||||
@@ -772,6 +774,37 @@ func TestRun_Ansible(t *testing.T) {
|
|||||||
if !strings.Contains(out, "hosta:") || !strings.Contains(out, "hostb:") {
|
if !strings.Contains(out, "hosta:") || !strings.Contains(out, "hostb:") {
|
||||||
t.Fatalf("expected both hosts in inventory, got: %q", out)
|
t.Fatalf("expected both hosts in inventory, got: %q", out)
|
||||||
}
|
}
|
||||||
|
// The queried fact is attached as a host var.
|
||||||
|
if !strings.Contains(out, "enc_role: roles::db") || !strings.Contains(out, "enc_role: roles::web") {
|
||||||
|
t.Fatalf("expected fact host vars in inventory, got: %q", out)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestRun_Ansible_MultipleFacts(t *testing.T) {
|
||||||
|
// -F ipaddress,enc_role -A must include both facts as host vars.
|
||||||
|
facts := []fact{
|
||||||
|
{Certname: "hosta", Name: "ipaddress", Value: rawJSON("198.18.0.1")},
|
||||||
|
{Certname: "hosta", Name: "enc_role", Value: rawJSON("roles::dns")},
|
||||||
|
}
|
||||||
|
out := runToString(t, facts, func(a *runArgs) {
|
||||||
|
a.showRole = false
|
||||||
|
a.factName = "ipaddress,enc_role"
|
||||||
|
a.ansible = true
|
||||||
|
})
|
||||||
|
|
||||||
|
// Parse it back as YAML and assert the structure precisely.
|
||||||
|
var inv struct {
|
||||||
|
All struct {
|
||||||
|
Hosts map[string]map[string]interface{} `yaml:"hosts"`
|
||||||
|
} `yaml:"all"`
|
||||||
|
}
|
||||||
|
if err := yaml.Unmarshal([]byte(out), &inv); err != nil {
|
||||||
|
t.Fatalf("inventory is not valid YAML: %v (%s)", err, out)
|
||||||
|
}
|
||||||
|
host := inv.All.Hosts["hosta"]
|
||||||
|
if host["ipaddress"] != "198.18.0.1" || host["enc_role"] != "roles::dns" {
|
||||||
|
t.Fatalf("expected both facts as host vars, got: %v", host)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestRun_AllFacts_PrintsSortedByName(t *testing.T) {
|
func TestRun_AllFacts_PrintsSortedByName(t *testing.T) {
|
||||||
|
|||||||
Reference in New Issue
Block a user