Unified list command
This commit is contained in:
parent
915fe7f9fe
commit
d5a00b7dc3
@ -1,65 +0,0 @@
|
||||
package cmd
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"log"
|
||||
"slices"
|
||||
|
||||
"github.com/Jaculabilis/intake/core"
|
||||
"github.com/spf13/cobra"
|
||||
)
|
||||
|
||||
var actionListCmd = &cobra.Command{
|
||||
Use: "list",
|
||||
Aliases: []string{"ls"},
|
||||
Short: "List actions on a source",
|
||||
Long: `List actions on a source.
|
||||
`,
|
||||
Run: func(cmd *cobra.Command, args []string) {
|
||||
actionList(stringArg(cmd, "source"), boolArg(cmd, "argv"))
|
||||
},
|
||||
}
|
||||
|
||||
func init() {
|
||||
actionCmd.AddCommand(actionListCmd)
|
||||
|
||||
actionListCmd.Flags().StringP("source", "s", "", "Source to list actions")
|
||||
actionListCmd.MarkFlagRequired("source")
|
||||
|
||||
actionListCmd.Flags().BoolP("argv", "a", false, "Include action command")
|
||||
}
|
||||
|
||||
func actionList(source string, argv bool) {
|
||||
if source == "" {
|
||||
log.Fatal("error: --source is empty")
|
||||
}
|
||||
|
||||
db := openAndMigrateDb()
|
||||
|
||||
actions, err := core.GetActionsForSource(db, source)
|
||||
if err != nil {
|
||||
log.Fatal(err)
|
||||
}
|
||||
slices.SortFunc(actions, actionSort)
|
||||
|
||||
if argv {
|
||||
actionArgv := make(map[string][]string)
|
||||
for _, name := range actions {
|
||||
argv, err := core.GetArgvForAction(db, source, name)
|
||||
if err != nil {
|
||||
log.Fatalf("error: could not get argv for source %s action %s: %v", source, name, err)
|
||||
}
|
||||
if argv != nil {
|
||||
actionArgv[name] = argv
|
||||
}
|
||||
}
|
||||
for _, name := range actions {
|
||||
fmt.Printf("%s %v\n", name, actionArgv[name])
|
||||
}
|
||||
|
||||
} else {
|
||||
for _, action := range actions {
|
||||
fmt.Println(action)
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -1,45 +0,0 @@
|
||||
package cmd
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"log"
|
||||
|
||||
"github.com/Jaculabilis/intake/core"
|
||||
"github.com/spf13/cobra"
|
||||
)
|
||||
|
||||
var channelListCmd = &cobra.Command{
|
||||
Use: "list",
|
||||
Aliases: []string{"ls"},
|
||||
Short: "List channels",
|
||||
Long: `List channels.
|
||||
`,
|
||||
Run: func(cmd *cobra.Command, args []string) {
|
||||
channelList(stringArg(cmd, "channel"))
|
||||
},
|
||||
}
|
||||
|
||||
func init() {
|
||||
channelCmd.AddCommand(channelListCmd)
|
||||
|
||||
channelListCmd.Flags().StringP("channel", "c", "", "List sources in a specific channel")
|
||||
}
|
||||
|
||||
func channelList(channel string) {
|
||||
db := openAndMigrateDb()
|
||||
|
||||
channelSources, err := core.GetSourcesInChannel(db)
|
||||
if err != nil {
|
||||
log.Fatalf("error: failed to get sources in channel: %v", err)
|
||||
}
|
||||
|
||||
if channel == "" {
|
||||
for channel := range channelSources {
|
||||
fmt.Println(channel)
|
||||
}
|
||||
} else {
|
||||
for _, source := range channelSources[channel] {
|
||||
fmt.Println(source)
|
||||
}
|
||||
}
|
||||
}
|
||||
134
cmd/list.go
Normal file
134
cmd/list.go
Normal file
@ -0,0 +1,134 @@
|
||||
package cmd
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"log"
|
||||
"slices"
|
||||
|
||||
"github.com/Jaculabilis/intake/core"
|
||||
"github.com/Jaculabilis/intake/web"
|
||||
"github.com/spf13/cobra"
|
||||
)
|
||||
|
||||
var listCmd = &cobra.Command{
|
||||
Use: "list",
|
||||
Aliases: []string{"ls"},
|
||||
Short: "List sources, channels, or actions",
|
||||
Long: `List sources, channels, or actions.
|
||||
`,
|
||||
Run: func(cmd *cobra.Command, args []string) {
|
||||
list(
|
||||
cmd,
|
||||
boolArg(cmd, "sources"),
|
||||
boolArg(cmd, "channels"),
|
||||
boolArg(cmd, "actions"),
|
||||
boolArg(cmd, "envs"),
|
||||
stringArg(cmd, "argv"),
|
||||
stringArg(cmd, "channel"),
|
||||
stringArg(cmd, "source"),
|
||||
)
|
||||
},
|
||||
}
|
||||
|
||||
type OptString struct {
|
||||
Value string
|
||||
}
|
||||
|
||||
func init() {
|
||||
rootCmd.AddCommand(listCmd)
|
||||
|
||||
listCmd.Flags().Bool("sources", false, "List sources")
|
||||
listCmd.Flags().Bool("channels", false, "List channels")
|
||||
listCmd.Flags().Bool("actions", false, "List actions for a source")
|
||||
listCmd.Flags().Bool("envs", false, "List environment variables for a source")
|
||||
listCmd.Flags().String("argv", "", "List command for a source action")
|
||||
listCmd.Flags().StringP("channel", "c", "", "List sources in a channel")
|
||||
listCmd.MarkFlagsMutuallyExclusive("channels", "sources", "actions", "envs", "channel", "argv")
|
||||
|
||||
listCmd.Flags().StringP("source", "s", "", "")
|
||||
}
|
||||
|
||||
func list(
|
||||
cmd *cobra.Command,
|
||||
sources bool,
|
||||
channels bool,
|
||||
actions bool,
|
||||
envs bool,
|
||||
argv string,
|
||||
channel string,
|
||||
source string,
|
||||
) {
|
||||
if sources {
|
||||
db := openAndMigrateDb()
|
||||
names, err := core.GetSources(db)
|
||||
if err != nil {
|
||||
log.Fatalf("error: failed to get sources: %v", err)
|
||||
}
|
||||
slices.Sort(names)
|
||||
for _, name := range names {
|
||||
fmt.Println(name)
|
||||
}
|
||||
} else if channels {
|
||||
db := openAndMigrateDb()
|
||||
channelSources, err := core.GetSourcesInChannel(db)
|
||||
if err != nil {
|
||||
log.Fatalf("error: failed to get sources in channel: %v", err)
|
||||
}
|
||||
for channel := range channelSources {
|
||||
if channel != "" {
|
||||
fmt.Println(channel)
|
||||
}
|
||||
}
|
||||
} else if actions {
|
||||
if source == "" {
|
||||
log.Fatal("error: --source is empty")
|
||||
}
|
||||
db := openAndMigrateDb()
|
||||
actions, err := core.GetActionsForSource(db, source)
|
||||
if err != nil {
|
||||
log.Fatal(err)
|
||||
}
|
||||
slices.SortFunc(actions, actionSort)
|
||||
for _, action := range actions {
|
||||
fmt.Println(action)
|
||||
}
|
||||
} else if envs {
|
||||
if source == "" {
|
||||
log.Fatal("error: --source is empty")
|
||||
}
|
||||
db := openAndMigrateDb()
|
||||
envs, err := core.GetEnvs(db, source)
|
||||
if err != nil {
|
||||
log.Fatalf("error: failed to get envs: %v", err)
|
||||
}
|
||||
slices.Sort(envs)
|
||||
for _, env := range envs {
|
||||
fmt.Println(env)
|
||||
}
|
||||
} else if argv != "" {
|
||||
if source == "" {
|
||||
log.Fatal("error: --source is empty")
|
||||
}
|
||||
db := openAndMigrateDb()
|
||||
argv, err := core.GetArgvForAction(db, source, argv)
|
||||
if err != nil {
|
||||
log.Fatalf("error: failed to get argv: %v", err)
|
||||
}
|
||||
quoted, err := web.Quote(argv)
|
||||
if err != nil {
|
||||
log.Fatalf("error: %v", err)
|
||||
}
|
||||
fmt.Println(quoted)
|
||||
} else if channel != "" {
|
||||
db := openAndMigrateDb()
|
||||
channelSources, err := core.GetSourcesInChannel(db)
|
||||
if err != nil {
|
||||
log.Fatalf("error: failed to get sources in channel: %v", err)
|
||||
}
|
||||
for _, source := range channelSources[channel] {
|
||||
fmt.Println(source)
|
||||
}
|
||||
} else {
|
||||
fmt.Print(cmd.UsageString())
|
||||
}
|
||||
}
|
||||
@ -1,56 +0,0 @@
|
||||
package cmd
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"log"
|
||||
"slices"
|
||||
|
||||
"github.com/Jaculabilis/intake/core"
|
||||
"github.com/spf13/cobra"
|
||||
)
|
||||
|
||||
var sourceListCmd = &cobra.Command{
|
||||
Use: "list",
|
||||
Aliases: []string{"ls"},
|
||||
Short: "List sources",
|
||||
Long: `Print the list of sources.
|
||||
`,
|
||||
Run: func(cmd *cobra.Command, args []string) {
|
||||
sourceList(boolArg(cmd, "actions"))
|
||||
},
|
||||
}
|
||||
|
||||
func init() {
|
||||
sourceCmd.AddCommand(sourceListCmd)
|
||||
|
||||
sourceListCmd.Flags().BoolP("actions", "a", false, "Include source actions")
|
||||
}
|
||||
|
||||
func sourceList(showActions bool) {
|
||||
db := openAndMigrateDb()
|
||||
|
||||
names, err := core.GetSources(db)
|
||||
if err != nil {
|
||||
log.Fatalf("error: failed to get sources: %v", err)
|
||||
}
|
||||
slices.Sort(names)
|
||||
|
||||
if showActions {
|
||||
sourceActions := make(map[string][]string)
|
||||
for _, name := range names {
|
||||
actions, err := core.GetActionsForSource(db, name)
|
||||
if err != nil {
|
||||
log.Fatalf("error: could not get actions for source %s: %v", name, err)
|
||||
}
|
||||
slices.SortFunc(actions, actionSort)
|
||||
sourceActions[name] = actions
|
||||
}
|
||||
for _, name := range names {
|
||||
fmt.Printf("%s %v\n", name, sourceActions[name])
|
||||
}
|
||||
} else {
|
||||
for _, name := range names {
|
||||
fmt.Println(name)
|
||||
}
|
||||
}
|
||||
}
|
||||
Loading…
Reference in New Issue
Block a user