chore: add tests to ExecuteWithClient for pipelines cmds

cmd/conduit/api/client.go

@@ -25,8 +25,8 @@ import (
 )
 
 type Client struct {
-	conn *grpc.ClientConn
-	apiv1.PipelineServiceClient
+	conn                  *grpc.ClientConn
+	PipelineServiceClient PipelineService
 	apiv1.ProcessorServiceClient
 	apiv1.ConnectorServiceClient
 	healthgrpc.HealthClient

cmd/conduit/api/pipeline_service.go

@@ -0,0 +1,31 @@
+// Copyright © 2025 Meroxa, Inc.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package api
+
+import (
+	"context"
+
+	apiv1 "github.com/conduitio/conduit/proto/api/v1"
+	"google.golang.org/grpc"
+)
+
+//go:generate mockgen -destination=mock/pipeline_service.go -package=mock . PipelineService
+
+// PipelineService defines the methods of the PipelineServiceClient that are currently used by the CLI.
+type PipelineService interface {
+	ListPipelines(ctx context.Context, in *apiv1.ListPipelinesRequest, opts ...grpc.CallOption) (*apiv1.ListPipelinesResponse, error)
+	GetPipeline(ctx context.Context, in *apiv1.GetPipelineRequest, opts ...grpc.CallOption) (*apiv1.GetPipelineResponse, error)
+	GetDLQ(ctx context.Context, in *apiv1.GetDLQRequest, opts ...grpc.CallOption) (*apiv1.GetDLQResponse, error)
+}

cmd/conduit/internal/print_utils.go

@@ -162,7 +162,6 @@ func DisplayConfigParams(cfg map[string]*configv1.Parameter) {
 		table.Body.Cells = append(table.Body.Cells, r)
 	}
 
-	table.SetStyle(simpletable.StyleDefault)
 	fmt.Println(table.String())
 }
 

cmd/conduit/root/connectorplugins/list.go

@@ -98,6 +98,5 @@ func displayConnectorPlugins(connectorPlugins []*apiv1.ConnectorPluginSpecificat
 
 		table.Body.Cells = append(table.Body.Cells, r)
 	}
-	table.SetStyle(simpletable.StyleDefault)
 	fmt.Println(table.String())
 }

cmd/conduit/root/connectors/list.go

@@ -103,9 +103,7 @@ func displayConnectors(connectors []*apiv1.Connector) {
 			{Align: simpletable.AlignLeft, Text: internal.PrintTime(c.CreatedAt)},
 			{Align: simpletable.AlignLeft, Text: internal.PrintTime(c.UpdatedAt)},
 		}
-
 		table.Body.Cells = append(table.Body.Cells, r)
 	}
-	table.SetStyle(simpletable.StyleDefault)
 	fmt.Println(table.String())
 }

cmd/conduit/root/pipelines/list.go

@@ -31,9 +31,12 @@ var (
 	_ cecdysis.CommandWithExecuteWithClient = (*ListCommand)(nil)
 	_ ecdysis.CommandWithAliases            = (*ListCommand)(nil)
 	_ ecdysis.CommandWithDocs               = (*ListCommand)(nil)
+	_ ecdysis.CommandWithOutput             = (*ListCommand)(nil)
 )
 
-type ListCommand struct{}
+type ListCommand struct {
+	output ecdysis.Output
+}
 
 func (c *ListCommand) Docs() ecdysis.Docs {
 	return ecdysis.Docs{
@@ -45,6 +48,10 @@ be configured via --pipelines.path at the time of running Conduit.`,
 	}
 }
 
+func (c *ListCommand) Output(output ecdysis.Output) {
+	c.output = output
+}
+
 func (c *ListCommand) Aliases() []string { return []string{"ls"} }
 
 func (c *ListCommand) Usage() string { return "list" }
@@ -59,14 +66,14 @@ func (c *ListCommand) ExecuteWithClient(ctx context.Context, client *api.Client)
 		return resp.Pipelines[i].Id < resp.Pipelines[j].Id
 	})
 
-	displayPipelines(resp.Pipelines)
+	c.output.Stdout(getPipelinesTable(resp.Pipelines))
 
 	return nil
 }
 
-func displayPipelines(pipelines []*apiv1.Pipeline) {
+func getPipelinesTable(pipelines []*apiv1.Pipeline) string {
 	if len(pipelines) == 0 {
-		return
+		return ""
 	}
 
 	table := simpletable.New()
@@ -90,6 +97,5 @@ func displayPipelines(pipelines []*apiv1.Pipeline) {
 
 		table.Body.Cells = append(table.Body.Cells, r)
 	}
-	table.SetStyle(simpletable.StyleDefault)
-	fmt.Println(table.String())
+	return table.String()
 }

cmd/conduit/root/pipelines/list_test.go

@@ -0,0 +1,107 @@
+// Copyright © 2025 Meroxa, Inc.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package pipelines
+
+import (
+	"bytes"
+	"context"
+	"strings"
+	"testing"
+
+	"github.com/conduitio/ecdysis"
+	"github.com/matryer/is"
+	"go.uber.org/mock/gomock"
+
+	"github.com/conduitio/conduit/cmd/conduit/api"
+	"github.com/conduitio/conduit/cmd/conduit/api/mock"
+	apiv1 "github.com/conduitio/conduit/proto/api/v1"
+)
+
+func TestListCommandExecuteWithClient_WithPipelines(t *testing.T) {
+	is := is.New(t)
+
+	buf := new(bytes.Buffer)
+	out := &ecdysis.DefaultOutput{}
+	out.Output(buf, nil)
+
+	ctx := context.Background()
+	ctrl := gomock.NewController(t)
+	defer ctrl.Finish()
+
+	mockService := mock.NewMockPipelineService(ctrl)
+
+	mockService.EXPECT().ListPipelines(gomock.Any(), gomock.Any()).Return(&apiv1.ListPipelinesResponse{
+		Pipelines: []*apiv1.Pipeline{
+			{Id: "1", State: &apiv1.Pipeline_State{Status: apiv1.Pipeline_STATUS_RUNNING}},
+			{Id: "2", State: &apiv1.Pipeline_State{Status: apiv1.Pipeline_STATUS_STOPPED}},
+			{Id: "3", State: &apiv1.Pipeline_State{Status: apiv1.Pipeline_STATUS_RECOVERING}},
+			{Id: "4", State: &apiv1.Pipeline_State{Status: apiv1.Pipeline_STATUS_DEGRADED}},
+		},
+	}, nil)
+
+	client := &api.Client{
+		PipelineServiceClient: mockService,
+	}
+
+	cmd := &ListCommand{}
+	cmd.Output(out)
+
+	err := cmd.ExecuteWithClient(ctx, client)
+	is.NoErr(err)
+
+	output := buf.String()
+	is.True(len(output) > 0)
+	is.True(strings.Contains(output, "ID"))
+	is.True(strings.Contains(output, "CREATED"))
+	is.True(strings.Contains(output, "LAST_UPDATED"))
+
+	is.True(strings.Contains(output, "1"))
+	is.True(strings.Contains(output, "running"))
+	is.True(strings.Contains(output, "2"))
+	is.True(strings.Contains(output, "stopped"))
+	is.True(strings.Contains(output, "3"))
+	is.True(strings.Contains(output, "recovering"))
+	is.True(strings.Contains(output, "4"))
+	is.True(strings.Contains(output, "degraded"))
+}
+
+func TestListCommandExecuteWithClient_EmptyResponse(t *testing.T) {
+	is := is.New(t)
+
+	buf := new(bytes.Buffer)
+	out := &ecdysis.DefaultOutput{}
+	out.Output(buf, nil)
+
+	ctx := context.Background()
+	ctrl := gomock.NewController(t)
+	defer ctrl.Finish()
+
+	mockService := mock.NewMockPipelineService(ctrl)
+
+	mockService.EXPECT().ListPipelines(gomock.Any(), gomock.Any()).Return(&apiv1.ListPipelinesResponse{}, nil)
+
+	client := &api.Client{
+		PipelineServiceClient: mockService,
+	}
+
+	cmd := &ListCommand{}
+	cmd.Output(out)
+
+	err := cmd.ExecuteWithClient(ctx, client)
+	is.NoErr(err)
+
+	output := buf.String()
+	is.True(len(output) == 0)
+}

cmd/conduit/root/processorplugins/list.go

@@ -98,6 +98,5 @@ func displayProcessorPlugins(processorPlugins []*apiv1.ProcessorPluginSpecificat
 
 		table.Body.Cells = append(table.Body.Cells, r)
 	}
-	table.SetStyle(simpletable.StyleDefault)
 	fmt.Println(table.String())
 }

cmd/conduit/root/processors/list.go

@@ -94,6 +94,5 @@ func displayProcessors(processors []*apiv1.Processor) {
 
 		table.Body.Cells = append(table.Body.Cells, r)
 	}
-	table.SetStyle(simpletable.StyleDefault)
 	fmt.Println(table.String())
 }

cmd/conduit/root/root_test.go

@@ -65,7 +65,6 @@ func TestRootCommandExecuteWithVersionFlag(t *testing.T) {
 	is := is.New(t)
 
 	buf := new(bytes.Buffer)
-
 	out := &ecdysis.DefaultOutput{}
 	out.Output(buf, nil)