fix

Author: Gwynbleidd0241

internal/api/seqapi/v1/grpc/search_test.go

@@ -83,11 +83,11 @@ func TestSearch(t *testing.T) {
 			req: &seqapi.SearchRequest{
 				Limit: 10,
 			},
-			cfg: test.SetCfgDefaults(config.SeqAPI{
+			cfg: config.SeqAPI{
 				SeqAPIOptions: &config.SeqAPIOptions{
 					MaxSearchLimit: 5,
 				},
-			}),
+			},
 			apiErr: true,
 		},
 		{

internal/api/seqapi/v1/http/search_test.go

@@ -288,22 +288,22 @@ func TestServeSearch(t *testing.T) {
 			name:       "err_search_limit_max",
 			reqBody:    formatReqBody(10, 0, false, "", nil, ""),
 			wantStatus: http.StatusBadRequest,
-			cfg: test.SetCfgDefaults(config.SeqAPI{
+			cfg: config.SeqAPI{
 				SeqAPIOptions: &config.SeqAPIOptions{
 					MaxSearchLimit: 5,
 				},
-			}),
+			},
 		},
 		{
 			name:       "err_aggs_limit_max",
 			reqBody:    formatReqBody(3, 0, false, "", aggregationQueries{{}, {}, {}}, ""),
 			wantStatus: http.StatusBadRequest,
-			cfg: test.SetCfgDefaults(config.SeqAPI{
+			cfg: config.SeqAPI{
 				SeqAPIOptions: &config.SeqAPIOptions{
 					MaxSearchLimit:            5,
 					MaxAggregationsPerRequest: 2,
 				},
-			}),
+			},
 		}, {
 			name:       "err_offset_too_high",
 			reqBody:    formatReqBody(3, 11, false, "", nil, ""),

internal/api/seqapi/v1/http/start_async_search.go

@@ -42,6 +42,7 @@ func (a *API) serveStartAsyncSearch(w http.ResponseWriter, r *http.Request) {
 		wr.Error(fmt.Errorf("failed to parse search request: %w", err), http.StatusBadRequest)
 		return
 	}
+
 	parsedRetention, err := time.ParseDuration(httpReq.Retention)
 	if err != nil {
 		wr.Error(fmt.Errorf("failed to parse retention: %w", err), http.StatusBadRequest)

internal/pkg/service/async_searches/service.go

@@ -185,9 +185,7 @@ func (s *Service) GetAsyncSearchesList(
 
 	for _, as := range resp.Searches {
 		as.OwnerName = ownerNameByID[as.SearchId]
-		if trimmedQuery, ok := s.trimQueryToLimit(as.Request.Query, s.cfg.ListQueryLengthLimit); ok {
-			as.Request.Query = trimmedQuery + "..."
-		}
+		as.Request.Query = s.trimQueryToLimit(as.Request.Query, s.cfg.ListQueryLengthLimit)
 	}
 
 	return resp, nil
@@ -219,13 +217,13 @@ func (s *Service) deleteExpiredAsyncSearches(ctx context.Context) {
 	}
 }
 
-func (s *Service) trimQueryToLimit(query string, limit int) (string, bool) {
+func (s *Service) trimQueryToLimit(query string, limit int) string {
 	count := 0
 	for i := range query {
 		if count == limit {
-			return query[:i], true
+			return query[:i] + "..."
 		}
 		count++
 	}
-	return query, false
+	return query
 }