♻️ refacto(jq): isolate json conversion filter

pkg/output/filter/jq.go

@@ -6,7 +6,6 @@ package filter
 
 import (
 	"context"
-	"encoding/json"
 	"fmt"
 	"iter"
 
@@ -21,7 +20,7 @@ type JQ struct {
 func NewJQ(s string) (JQ, error) {
 	query, err := gojq.Parse(s)
 	if err != nil {
-		return JQ{}, fmt.Errorf("parse jq filter: %w", err)
+		return JQ{}, fmt.Errorf("invalid jq filter: %w", err)
 	}
 	return JQ{query: query}, nil
 }
@@ -33,18 +32,7 @@ func (j JQ) Filter(ctx context.Context, seq iter.Seq[result.Result]) iter.Seq[re
 				_ = yield(v)
 				return
 			}
-			buf, err := json.Marshal(v.Ok)
-			if err != nil {
-				_ = yield(result.Result{Error: fmt.Errorf("jq to JSON: %w", err)})
-				return
-			}
-			var raw any
-			err = json.Unmarshal(buf, &raw)
-			if err != nil {
-				_ = yield(result.Result{Error: fmt.Errorf("jq from JSON: %w", err)})
-				return
-			}
-			iter := j.query.RunWithContext(ctx, raw)
+			iter := j.query.RunWithContext(ctx, v.Ok)
 			for {
 				v, ok := iter.Next()
 				if !ok {

pkg/output/filter/json.go

@@ -0,0 +1,43 @@
+/*
+SPDX-FileCopyrightText: 2026 Outscale SAS <opensource@outscale.com>
+SPDX-License-Identifier: BSD-3-Clause
+*/
+package filter
+
+import (
+	"context"
+	"encoding/json"
+	"fmt"
+	"iter"
+
+	"github.com/outscale/octl/pkg/output/result"
+)
+
+type JSON struct{}
+
+func (j JSON) Filter(ctx context.Context, seq iter.Seq[result.Result]) iter.Seq[result.Result] {
+	return func(yield func(result.Result) bool) {
+		for v := range seq {
+			if v.Error != nil {
+				_ = yield(v)
+				return
+			}
+			buf, err := json.Marshal(v.Ok)
+			if err != nil {
+				_ = yield(result.Result{Error: fmt.Errorf("to JSON: %w", err)})
+				return
+			}
+			var raw any
+			err = json.Unmarshal(buf, &raw)
+			if err != nil {
+				_ = yield(result.Result{Error: fmt.Errorf("from JSON: %w", err)})
+				return
+			}
+			if !yield(result.Result{Ok: raw}) {
+				return
+			}
+		}
+	}
+}
+
+var _ Interface = JSON{}

pkg/output/flags.go

@@ -45,6 +45,9 @@ func NewFromFlags(fs *pflag.FlagSet, out, contentField string, cols config.Colum
 		}
 		filters = append(filters, jqf)
 	}
+	if len(filters) > 0 {
+		filters = slices.Insert(filters, 0, filter.Interface(filter.JSON{}))
+	}
 
 	var fmter format.Interface
 	switch out {