Added format flag to convery output to JSON and slighly changed scanning logic

This commit is contained in:
David J. Allen 2024-05-10 13:41:08 -06:00
parent a2b841b401
commit b3ba75ea9a
No known key found for this signature in database
GPG key ID: 717C593FF60A2ACC
3 changed files with 52 additions and 26 deletions

View file

@ -1,7 +1,9 @@
package cmd package cmd
import ( import (
"encoding/json"
"fmt" "fmt"
"strings"
"github.com/OpenCHAMI/magellan/internal/db/sqlite" "github.com/OpenCHAMI/magellan/internal/db/sqlite"
@ -17,12 +19,19 @@ var listCmd = &cobra.Command{
if err != nil { if err != nil {
logrus.Errorf("failed toget probe results: %v\n", err) logrus.Errorf("failed toget probe results: %v\n", err)
} }
format = strings.ToLower(format)
if format == "json" {
b, _ := json.Marshal(probeResults)
fmt.Printf("%s\n", string(b))
} else {
for _, r := range probeResults { for _, r := range probeResults {
fmt.Printf("%s:%d (%s)\n", r.Host, r.Port, r.Protocol) fmt.Printf("%s:%d (%s)\n", r.Host, r.Port, r.Protocol)
} }
}
}, },
} }
func init() { func init() {
listCmd.Flags().StringVar(&format, "format", "", "set the output format")
rootCmd.AddCommand(listCmd) rootCmd.AddCommand(listCmd)
} }

View file

@ -15,6 +15,7 @@ import (
var ( var (
currentUser *user.User currentUser *user.User
accessToken string accessToken string
format string
timeout int timeout int
concurrency int concurrency int
ports []int ports []int

View file

@ -1,10 +1,12 @@
package cmd package cmd
import ( import (
"encoding/json"
"fmt" "fmt"
"net" "net"
"os" "os"
"path" "path"
"strings"
magellan "github.com/OpenCHAMI/magellan/internal" magellan "github.com/OpenCHAMI/magellan/internal"
"github.com/OpenCHAMI/magellan/internal/db/sqlite" "github.com/OpenCHAMI/magellan/internal/db/sqlite"
@ -26,43 +28,58 @@ var scanCmd = &cobra.Command{
Use: "scan", Use: "scan",
Short: "Scan for BMC nodes on a network", Short: "Scan for BMC nodes on a network",
Run: func(cmd *cobra.Command, args []string) { Run: func(cmd *cobra.Command, args []string) {
fmt.Printf("subnets in cmd: %v\n", subnets) var (
// set hosts to use for scanning hostsToScan []string
hostsToScan := []string{} portsToScan []int
)
// start by adding `--host` supplied to scan
if len(hosts) > 0 { if len(hosts) > 0 {
hostsToScan = hosts hostsToScan = hosts
} else {
for i, subnet := range subnets {
if len(subnet) <= 0 {
return
} }
// add hosts from `--subnets` and `--subnet-mask`
for i, subnet := range subnets {
// subnet string is empty so nothing to do here
if subnet == "" {
continue
}
// NOTE: should we check if subnet is valid here or is it done elsewhere (maybe in GenerateHosts)?
// no subnet masks supplied so add a default one for class C private networks
if len(subnetMasks) < i+1 { if len(subnetMasks) < i+1 {
subnetMasks = append(subnetMasks, net.IP{255, 255, 255, 0}) subnetMasks = append(subnetMasks, net.IP{255, 255, 255, 0})
} }
// generate a slice of all hosts to scan from subnets
hostsToScan = append(hostsToScan, magellan.GenerateHosts(subnet, &subnetMasks[i])...) hostsToScan = append(hostsToScan, magellan.GenerateHosts(subnet, &subnetMasks[i])...)
} }
}
// set ports to use for scanning // add ports to use for scanning
portsToScan := []int{}
if len(ports) > 0 { if len(ports) > 0 {
portsToScan = ports portsToScan = ports
} else { } else {
portsToScan = append(magellan.GetDefaultPorts(), ports...) // no ports supplied so only use defaults
portsToScan = magellan.GetDefaultPorts()
} }
// scan and store probe data in dbPath // scan and store scanned data in cache
if concurrency <= 0 { if concurrency <= 0 {
concurrency = mathutil.Clamp(len(hostsToScan), 1, 255) concurrency = mathutil.Clamp(len(hostsToScan), 1, 255)
} }
probeStates := magellan.ScanForAssets(hostsToScan, portsToScan, concurrency, timeout, disableProbing, verbose) probeStates := magellan.ScanForAssets(hostsToScan, portsToScan, concurrency, timeout, disableProbing, verbose)
if verbose { if verbose {
format = strings.ToLower(format)
if format == "json" {
b, _ := json.Marshal(probeStates)
fmt.Printf("%s\n", string(b))
} else {
for _, r := range probeStates { for _, r := range probeStates {
fmt.Printf("%s:%d (%s)\n", r.Host, r.Port, r.Protocol) fmt.Printf("%s:%d (%s)\n", r.Host, r.Port, r.Protocol)
} }
} }
}
// make the dbpath dir if needed // make the dbpath dir if needed
err := os.MkdirAll(path.Dir(dbpath), 0766) err := os.MkdirAll(path.Dir(dbpath), 0766)
@ -77,10 +94,9 @@ var scanCmd = &cobra.Command{
func init() { func init() {
scanCmd.Flags().StringSliceVar(&hosts, "host", []string{}, "set additional hosts to scan") scanCmd.Flags().StringSliceVar(&hosts, "host", []string{}, "set additional hosts to scan")
scanCmd.Flags().IntSliceVar(&ports, "port", []int{}, "set the ports to scan") scanCmd.Flags().IntSliceVar(&ports, "port", []int{}, "set the ports to scan")
// scanCmd.Flags().Uint8Var(&begin, "begin", 0, "set the starting point for range of IP addresses") scanCmd.Flags().StringVar(&format, "format", "", "set the output format")
// scanCmd.Flags().Uint8Var(&end, "end", 255, "set the ending point for range of IP addresses")
scanCmd.Flags().StringSliceVar(&subnets, "subnet", []string{}, "set additional subnets") scanCmd.Flags().StringSliceVar(&subnets, "subnet", []string{}, "set additional subnets")
scanCmd.Flags().IPSliceVar(&subnetMasks, "subnet-mask", []net.IP{}, "set the subnet masks to use for network") scanCmd.Flags().IPSliceVar(&subnetMasks, "subnet-mask", []net.IP{}, "set the subnet masks to use for network (must match number of subnets)")
scanCmd.Flags().BoolVar(&disableProbing, "disable-probing", false, "disable probing scanned results for BMC nodes") scanCmd.Flags().BoolVar(&disableProbing, "disable-probing", false, "disable probing scanned results for BMC nodes")
viper.BindPFlag("scan.hosts", scanCmd.Flags().Lookup("host")) viper.BindPFlag("scan.hosts", scanCmd.Flags().Lookup("host"))