Add kolide_snap_upgradeable table and new data_table exec parser

ee/allowedcmd/cmd_linux.go

@@ -140,6 +140,10 @@ func Rpm(ctx context.Context, arg ...string) (*exec.Cmd, error) {
 	return nil, errors.New("rpm not found")
 }
 
+func Snap(ctx context.Context, arg ...string) (*exec.Cmd, error) {
+	return validatedCommand(ctx, "/usr/bin/snap", arg...)
+}
+
 func Systemctl(ctx context.Context, arg ...string) (*exec.Cmd, error) {
 	return validatedCommand(ctx, "/usr/bin/systemctl", arg...)
 }

ee/tables/execparsers/data_table/parser.go

@@ -0,0 +1,92 @@
+package data_table
+
+import (
+	"bufio"
+	"io"
+	"strings"
+)
+
+// data_table is a general parser for an input of data which conforms to columns and rows styled output.
+// Parser options
+// skipLines - The number of initial lines of data to skip. By default no lines are skipped. This can be useful if consistent undesired output/garbage is printed before the data to parse.
+// headers - The set of headers. If left blank, the parser assumes the headers are in the first line of data and splits the line to set them.
+// delimiter - The splitting string. If left blank, the parser assumes the delimiter is whitespace and uses `strings.Fields()` split method.
+type parser struct {
+	skipLines uint
+	headers   []string
+	delimiter string
+}
+
+func Parser(skipLines uint, headers []string, delimiter string) parser {
+	return parser{skipLines: skipLines, headers: headers, delimiter: delimiter}
+}
+
+func (p parser) Parse(reader io.Reader) (any, error) {
+	return p.parseLines(reader)
+}
+
+// parseLines scans a reader line by line and splits it into fields based on a delimiter.
+// The line fields are paired with a header, which is defined by an input array, or the first line of data.
+// If no delimiter is provided, it's assumed that fields are separated by whitespace.
+// The first N lines of data can be skipped in case garbage is sent before the data.
+func (p parser) parseLines(reader io.Reader) ([]map[string]string, error) {
+	results := make([]map[string]string, 0)
+	scanner := bufio.NewScanner(reader)
+
+	// Skip first N lines due to provided headers or otherwise.
+	// This would likely only ever be 1 or 0, but we may want more.
+	for p.skipLines > 0 {
+		p.skipLines--
+		// Early exit if the scanner skipped past all data.
+		if !scanner.Scan() {
+			return results, nil // <-- Do we want to error here?
+		}
+	}
+
+	headerCount := len(p.headers)
+
+	for scanner.Scan() {
+		line := scanner.Text()
+
+		// headers weren't provided, so retrieve them from the first available line.
+		if headerCount == 0 {
+			p.headers = p.lineSplit(line, headerCount)
+			headerCount = len(p.headers)
+			continue
+		}
+
+		row := make(map[string]string)
+		fields := p.lineSplit(line, headerCount)
+		// It's possible we don't have the same number of fields to headers, so use
+		// min here to avoid a possible array out-of-bounds exception.
+		min := min(headerCount, len(fields))
+
+		// For each header, add the corresponding line field to the result row.
+		// Duplicate headers overwrite the set value. <-- Perhaps this should be different?
+		for c := 0; c < min; c++ {
+			row[strings.TrimSpace(p.headers[c])] = strings.TrimSpace(fields[c])
+		}
+
+		results = append(results, row)
+	}
+
+	return results, nil
+}
+
+// Switch to the appropriate function to return the current line's fields.
+// Delimiter often might be a comma or similar single character.
+func (p parser) lineSplit(line string, headerCount int) []string {
+	switch p.delimiter {
+	case "":
+		// Delimiter wasn't provided, assume whitespace separated fields.
+		return strings.Fields(line)
+	default:
+		// If we have a count of the headers, split the current line to N fields.
+		// Otherwise assume headers weren't provided and split the initial line to set them.
+		if headerCount > 0 {
+			return strings.SplitN(line, p.delimiter, headerCount)
+		} else {
+			return strings.Split(line, p.delimiter)
+		}
+	}
+}

ee/tables/execparsers/data_table/parser_test.go

@@ -0,0 +1,203 @@
+package data_table
+
+import (
+	"bytes"
+	_ "embed"
+	"testing"
+
+	"github.com/stretchr/testify/require"
+)
+
+//go:embed test-data/test.csv
+var csv []byte
+
+//go:embed test-data/top.txt
+var top []byte
+
+//go:embed test-data/snap.txt
+var snap []byte
+
+func TestParse(t *testing.T) {
+	t.Parallel()
+
+	var tests = []struct {
+		name      string
+		input     []byte
+		skipLines uint
+		headers   []string
+		delimiter string
+		expected  []map[string]string
+	}{
+		{
+			name:     "empty input",
+			expected: make([]map[string]string, 0),
+		},
+		{
+			name:  "snap",
+			input: snap,
+			expected: []map[string]string{
+				{
+					"Name":      "core22",
+					"Version":   "20240111",
+					"Rev":       "1122",
+					"Size":      "77MB",
+					"Publisher": "canonical**",
+					"Notes":     "base",
+				},
+			},
+		},
+		{
+			name:      "csv",
+			input:     csv,
+			headers:   []string{"name", "age", "date", "street", "city", "state", "zip"},
+			delimiter: ",",
+			expected: []map[string]string{
+				{
+					"name":   "Sara Walton",
+					"age":    "19",
+					"date":   "07/10/2010",
+					"street": "Tagka Manor",
+					"city":   "Kedevwir",
+					"state":  "WV",
+					"zip":    "40036",
+				},
+				{
+					"name":   "Martin Powers",
+					"age":    "23",
+					"date":   "06/23/1942",
+					"street": "Eror Parkway",
+					"city":   "Masuzose",
+					"state":  "ID",
+					"zip":    "92375",
+				},
+				{
+					"name":   "Sara Porter",
+					"age":    "53",
+					"date":   "01/12/1942",
+					"street": "Ipsuj Path",
+					"city":   "Kikvitud",
+					"state":  "GA",
+					"zip":    "26070",
+				},
+				{
+					"name":   "Jayden Riley",
+					"age":    "41",
+					"date":   "11/30/2008",
+					"street": "Rahef Point",
+					"city":   "Sirunu",
+					"state":  "UT",
+					"zip":    "21076",
+				},
+				{
+					"name":   "Genevieve Greene",
+					"age":    "58",
+					"date":   "04/07/1976",
+					"street": "Camguf Terrace",
+					"city":   "Cunule",
+					"state":  "KS",
+					"zip":    "40733",
+				},
+			},
+		},
+		{
+			name:      "top",
+			input:     top,
+			skipLines: 11,
+			expected: []map[string]string{
+				{
+					"PID":  "3210",
+					"#TH":  "29",
+					"MEM":  "2552M",
+					"PGRP": "3210",
+					"PPID": "1",
+					"UID":  "501",
+				},
+				{
+					"PID":  "4933",
+					"#TH":  "19/1",
+					"MEM":  "1266M",
+					"PGRP": "4930",
+					"PPID": "4930",
+					"UID":  "501",
+				},
+				{
+					"PID":  "400",
+					"#TH":  "20",
+					"MEM":  "1021M",
+					"PGRP": "400",
+					"PPID": "1",
+					"UID":  "88",
+				},
+				{
+					"PID":  "67777",
+					"#TH":  "5",
+					"MEM":  "824M",
+					"PGRP": "4930",
+					"PPID": "67536",
+					"UID":  "501",
+				},
+				{
+					"PID":  "1265",
+					"#TH":  "26",
+					"MEM":  "631M",
+					"PGRP": "1258",
+					"PPID": "1258",
+					"UID":  "501",
+				},
+				{
+					"PID":  "87436",
+					"#TH":  "25",
+					"MEM":  "511M",
+					"PGRP": "84083",
+					"PPID": "84083",
+					"UID":  "501",
+				},
+				{
+					"PID":  "67534",
+					"#TH":  "21",
+					"MEM":  "420M",
+					"PGRP": "4930",
+					"PPID": "4930",
+					"UID":  "501",
+				},
+				{
+					"PID":  "3189",
+					"#TH":  "37",
+					"MEM":  "403M",
+					"PGRP": "3189",
+					"PPID": "1",
+					"UID":  "501",
+				},
+				{
+					"PID":  "579",
+					"#TH":  "23",
+					"MEM":  "352M",
+					"PGRP": "579",
+					"PPID": "1",
+					"UID":  "0",
+				},
+				{
+					"PID":  "4936",
+					"#TH":  "22",
+					"MEM":  "312M",
+					"PGRP": "4930",
+					"PPID": "4930",
+					"UID":  "501",
+				},
+			},
+		},
+	}
+
+	for _, tt := range tests {
+		tt := tt
+		t.Run(tt.name, func(t *testing.T) {
+			t.Parallel()
+
+			p := Parser(tt.skipLines, tt.headers, tt.delimiter)
+			result, err := p.Parse(bytes.NewReader(tt.input))
+
+			require.NoError(t, err, "unexpected error parsing input")
+			require.ElementsMatch(t, tt.expected, result)
+		})
+	}
+}

ee/tables/execparsers/data_table/test-data/snap.txt

@@ -0,0 +1,2 @@
+Name    Version   Rev   Size  Publisher    Notes
+core22  20240111  1122  77MB  canonical**  base

ee/tables/execparsers/data_table/test-data/test.csv

@@ -0,0 +1,5 @@
+Sara Walton,19,07/10/2010,Tagka Manor,Kedevwir,WV,40036
+Martin Powers,23,06/23/1942,Eror Parkway,Masuzose,ID,92375
+Sara Porter,53,01/12/1942,Ipsuj Path,Kikvitud,GA,26070
+Jayden Riley,41,11/30/2008,Rahef Point,Sirunu,UT,21076
+Genevieve Greene,58,04/07/1976,Camguf Terrace,Cunule,KS,40733

ee/tables/execparsers/data_table/test-data/top.txt

@@ -0,0 +1,22 @@
+Processes: 720 total, 3 running, 717 sleeping, 3841 threads 
+2024/03/11 12:18:30
+Load Avg: 1.79, 1.52, 1.67 
+CPU usage: 13.43% user, 10.55% sys, 76.0% idle 
+SharedLibs: 810M resident, 151M data, 106M linkedit.
+MemRegions: 586100 total, 10G resident, 533M private, 5265M shared.
+PhysMem: 30G used (2057M wired, 2316M compressor), 1124M unused.
+VM: 321T vsize, 4773M framework vsize, 0(0) swapins, 0(0) swapouts.
+Networks: packets: 27837831/21G in, 15638815/5658M out.
+Disks: 30011035/222G read, 15760164/231G written.
+
+PID    #TH    MEM   PGRP  PPID  UID
+3210   29     2552M 3210  1     501
+4933   19/1   1266M 4930  4930  501
+400    20     1021M 400   1     88 
+67777  5      824M  4930  67536 501
+1265   26     631M  1258  1258  501
+87436  25     511M  84083 84083 501
+67534  21     420M  4930  4930  501
+3189   37     403M  3189  1     501
+579    23     352M  579   1     0  
+4936   22     312M  4930  4930  501

pkg/osquery/table/platform_tables_linux.go

@@ -12,6 +12,7 @@ import (
 	"github.com/kolide/launcher/ee/tables/cryptsetup"
 	"github.com/kolide/launcher/ee/tables/dataflattentable"
 	"github.com/kolide/launcher/ee/tables/execparsers/apt"
+	"github.com/kolide/launcher/ee/tables/execparsers/data_table"
 	"github.com/kolide/launcher/ee/tables/execparsers/dnf"
 	"github.com/kolide/launcher/ee/tables/execparsers/dpkg"
 	"github.com/kolide/launcher/ee/tables/execparsers/flatpak/remote_ls/upgradeable"
@@ -66,6 +67,7 @@ func platformSpecificTables(slogger *slog.Logger, currentOsquerydBinaryPath stri
 		dataflattentable.NewExecAndParseTable(slogger, "kolide_pacman_version_info", pacman_info.Parser, allowedcmd.Pacman, []string{"-Qi"}, dataflattentable.WithIncludeStderr()),
 		dataflattentable.NewExecAndParseTable(slogger, "kolide_pacman_upgradeable", pacman_upgradeable.Parser, allowedcmd.Pacman, []string{"-Qu"}, dataflattentable.WithIncludeStderr()),
 		dataflattentable.NewExecAndParseTable(slogger, "kolide_rpm_version_info", rpm.Parser, allowedcmd.Rpm, []string{"-qai"}, dataflattentable.WithIncludeStderr()),
+		dataflattentable.NewExecAndParseTable(slogger, "kolide_snap_upgradeable", data_table.Parser(0, nil, ""), allowedcmd.Snap, []string{"refresh", "--list"}, dataflattentable.WithIncludeStderr()),
 		dataflattentable.NewExecAndParseTable(slogger, "kolide_carbonblack_repcli_status", repcli.Parser, allowedcmd.Repcli, []string{"status"}, dataflattentable.WithIncludeStderr()),
 		dataflattentable.TablePluginExec(slogger, "kolide_nftables", dataflattentable.JsonType, allowedcmd.Nftables, []string{"-jat", "list", "ruleset"}), // -j (json) -a (show object handles) -t (terse, omit set contents)
 		zfs.ZfsPropertiesPlugin(slogger),