Pin LS command emits custom JSON to handle streaming case

ipfs · Oct 7, 2019 · 69bb578 · 69bb578
1 parent f1cd629
commit 69bb578
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/core/commands/pin.go b/core/commands/pin.go
@@ -2,6 +2,7 @@ package commands
 
 import (
 	"context"
+	"encoding/json"
 	"fmt"
 	"io"
 	"os"
@@ -367,6 +368,17 @@ Example:
 	},
 	Type: &PinLsOutputWrapper{},
 	Encoders: cmds.EncoderMap{
+		cmds.JSON: cmds.MakeTypedEncoder(func(req *cmds.Request, w io.Writer, out *PinLsOutputWrapper) error {
+			stream, _ := req.Options[pinStreamOptionName].(bool)
+
+			enc := json.NewEncoder(w)
+
+			if stream {
+				return enc.Encode(out.PinLsObject)
+			}
+
+			return enc.Encode(out.PinLsList)
+		}),
 		cmds.Text: cmds.MakeTypedEncoder(func(req *cmds.Request, w io.Writer, out *PinLsOutputWrapper) error {
 			quiet, _ := req.Options[pinQuietOptionName].(bool)
 			stream, _ := req.Options[pinStreamOptionName].(bool)