Don't list all channels when making a kots release

Author: divolgin

cli/cmd/channel_ls.go

@@ -17,7 +17,7 @@ func (r *runners) InitChannelList(parent *cobra.Command) {
 }
 
 func (r *runners) channelList(cmd *cobra.Command, args []string) error {
-	channels, err := r.api.ListChannels(r.appID, r.appType, r.appSlug)
+	channels, err := r.api.ListChannels(r.appID, r.appType, r.appSlug, "")
 	if err != nil {
 		return err
 	}

cli/cmd/root.go

@@ -1,12 +1,13 @@
 package cmd
 
 import (
-	"github.com/pkg/errors"
 	"io"
 	"os"
 	"path/filepath"
 	"text/tabwriter"
 
+	"github.com/pkg/errors"
+
 	"github.com/replicatedhq/replicated/pkg/kotsclient"
 	"github.com/replicatedhq/replicated/pkg/shipclient"
 
@@ -46,6 +47,11 @@ func init() {
 	if enterpriseOriginFromEnv != "" {
 		enterpriseOrigin = enterpriseOriginFromEnv
 	}
+
+	graphqlOriginFromEnv := os.Getenv("REPLICATED_GRAPHQL_ORIGIN")
+	if graphqlOriginFromEnv != "" {
+		graphqlOrigin = graphqlOriginFromEnv
+	}
 }
 
 // RootCmd represents the base command when called without any subcommands

client/channel.go

@@ -2,13 +2,14 @@ package client
 
 import (
 	"fmt"
+
 	"github.com/pkg/errors"
 
 	channels "github.com/replicatedhq/replicated/gen/go/v1"
 	"github.com/replicatedhq/replicated/pkg/types"
 )
 
-func (c *Client) ListChannels(appID string, appType string, appSlug string) ([]types.Channel, error) {
+func (c *Client) ListChannels(appID string, appType string, appSlug string, channelName string) ([]types.Channel, error) {
 
 	if appType == "platform" {
 		platformChannels, err := c.PlatformClient.ListChannels(appID)
@@ -33,7 +34,7 @@ func (c *Client) ListChannels(appID string, appType string, appSlug string) ([]t
 	} else if appType == "ship" {
 		return c.ShipClient.ListChannels(appID)
 	} else if appType == "kots" {
-		return c.KotsHTTPClient.ListChannels(appID, appSlug)
+		return c.KotsHTTPClient.ListChannels(appID, appSlug, channelName)
 	}
 
 	return nil, errors.New("unknown app type")
@@ -71,7 +72,7 @@ func (c *Client) CreateChannel(appID string, appType string, appSlug string, nam
 		if err := c.PlatformClient.CreateChannel(appID, name, description); err != nil {
 			return nil, err
 		}
-		return c.ListChannels(appID, appType, appSlug)
+		return c.ListChannels(appID, appType, appSlug, name)
 	} else if appType == "ship" {
 		if _, err := c.ShipClient.CreateChannel(appID, name, description); err != nil {
 			return nil, err
@@ -81,14 +82,14 @@ func (c *Client) CreateChannel(appID string, appType string, appSlug string, nam
 		if _, err := c.KotsClient.CreateChannel(appID, name, description); err != nil {
 			return nil, err
 		}
-		return c.KotsHTTPClient.ListChannels(appID, appSlug)
+		return c.KotsHTTPClient.ListChannels(appID, appSlug, name)
 	}
 
 	return nil, errors.New("unknown app type")
 }
 
 func (c *Client) GetOrCreateChannelByName(appID string, appType string, appSlug string, name string, description string, createIfAbsent bool) (*types.Channel, error) {
-	allChannels, err := c.ListChannels(appID, appType, appSlug)
+	allChannels, err := c.ListChannels(appID, appType, appSlug, name)
 	if err != nil {
 		return nil, err
 	}

pkg/kotsclient/channel.go

@@ -2,12 +2,14 @@ package kotsclient
 
 import (
 	"fmt"
+	"net/http"
+	"net/url"
+	"os"
+
 	"github.com/pkg/errors"
 	channels "github.com/replicatedhq/replicated/gen/go/v1"
 	"github.com/replicatedhq/replicated/pkg/graphql"
 	"github.com/replicatedhq/replicated/pkg/types"
-	"net/http"
-	"os"
 )
 
 type GraphQLResponseGetChannel struct {
@@ -94,9 +96,13 @@ type ListChannelsResponse struct {
 	Channels []*KotsChannel `json:"channels"`
 }
 
-func (c *VendorV3Client) ListChannels(appID string, appSlug string) ([]types.Channel, error) {
+func (c *VendorV3Client) ListChannels(appID string, appSlug string, channelName string) ([]types.Channel, error) {
 	var response = ListChannelsResponse{}
-	url := fmt.Sprintf("/v3/app/%s/channels", appID)
+
+	v := url.Values{}
+	v.Set("channelName", channelName)
+
+	url := fmt.Sprintf("/v3/app/%s/channels?%s", appID, v.Encode())
 	err := c.DoJSON("GET", url, http.StatusOK, nil, &response)
 	if err != nil {
 		return nil, errors.Wrap(err, "list channels")