feat: Add configurable result limit and fix display

- Implements a `--limit` flag for `run` and `results` commands to control the number of results returned.
- Allows setting a default limit in the configuration file. A limit of 0 fetches all results, which is the new default.
- Fixes a display issue where the "Waiting for job..." message was not printed on a new line.

Author: magifd2

cmd/common.go

@@ -26,6 +26,7 @@ func addCommonFlags(fs *flag.FlagSet, cfg *splunk.Config) {
 	fs.BoolVar(&cfg.Insecure, "insecure", cfg.Insecure, "Skip TLS certificate verification")
 	fs.DurationVar(&cfg.HTTPTimeout, "http-timeout", cfg.HTTPTimeout, "Timeout for individual HTTP requests (e.g., '5s', '1m')")
 	fs.BoolVar(&cfg.Debug, "debug", false, "Enable verbose debug logging")
+	fs.IntVar(&cfg.Limit, "limit", cfg.Limit, "Maximum number of results to return (0 for all)")
 }
 
 // getChoiceFromTTY reads a single line of input from the terminal, bypassing stdin.

cmd/results.go

@@ -45,7 +45,7 @@ func resultsCmd(args []string, baseCfg splunk.Config) error {
 	}
 
 	client.Log.Println("Fetching results...")
-	results, err := client.Results(*sid)
+	results, err := client.Results(*sid, baseCfg.Limit)
 	if err != nil {
 		return err
 	}

cmd/run.go

@@ -50,7 +50,7 @@ func runCmd(args []string, baseCfg splunk.Config) error {
 	if err != nil {
 		return err
 	}
-	client.Log.Printf("Job started with SID: %s", sid)
+	client.Log.Printf("Job started with SID: %s\n", sid)
 
 	ctx, cancel := context.WithTimeout(context.Background(), *timeout)
 	defer cancel()
@@ -95,7 +95,7 @@ func runCmd(args []string, baseCfg splunk.Config) error {
 	}
 
 	client.Log.Println("Fetching results...")
-	results, err := client.Results(sid)
+	results, err := client.Results(sid, baseCfg.Limit)
 	if err != nil {
 		return err
 	}

splunk/client.go

@@ -292,20 +292,22 @@ func (c *Client) WaitForJob(ctx context.Context, sid string) error {
 }
 
 // Results fetches the results of a completed search job.
-func (c *Client) Results(sid string) (string, error) {
+func (c *Client) Results(sid string, limit int) (string, error) {
 	endpoint, err := c.createAPIURL("search", "jobs", sid, "results")
 	if err != nil {
 		return "", err
 	}
 	c.Log.Debugf(`Request: GET %s
-`, endpoint)
+`,
+			 endpoint)
 
 	req, err := http.NewRequest("GET", endpoint, nil)
 	if err != nil {
 		return "", err
 	}
 	q := req.URL.Query()
 	q.Add("output_mode", "json")
+	q.Add("count", fmt.Sprintf("%d", limit))
 	req.URL.RawQuery = q.Encode()
 
 	resp, err := c.doRequest(req)

splunk/config.go

@@ -19,6 +19,7 @@ type Config struct {
 	Owner       string        `json:"owner"`
 	Insecure    bool          `json:"insecure"`
 	HTTPTimeout time.Duration `json:"httpTimeout"`
+	Limit       int           `json:"limit"`
 	Debug       bool          `json:"-"` // Exclude from JSON marshalling
 }
 
@@ -55,6 +56,7 @@ func LoadConfigFromFile(customConfigPath string) (Config, string, error) {
 		Owner       string `json:"owner"`
 		Insecure    bool   `json:"insecure"`
 		HTTPTimeout string `json:"httpTimeout"`
+		Limit       int    `json:"limit"`
 	}
 	var helper configHelper
 	if err := json.NewDecoder(file).Decode(&helper); err != nil {
@@ -68,6 +70,7 @@ func LoadConfigFromFile(customConfigPath string) (Config, string, error) {
 	cfg.App = strings.TrimSpace(helper.App)
 	cfg.Owner = strings.TrimSpace(helper.Owner)
 	cfg.Insecure = helper.Insecure
+	cfg.Limit = helper.Limit
 	if helper.HTTPTimeout != "" {
 		parsedDuration, err := time.ParseDuration(helper.HTTPTimeout)
 		if err != nil {