address review comments

Signed-off-by: Mattia Lavacca <[email protected]>

Author: mlavacca

pkg/i2gw/providers/common/utils.go

@@ -19,6 +19,7 @@ package common
 import (
 	"fmt"
 	"regexp"
+	"strings"
 
 	networkingv1 "k8s.io/api/networking/v1"
 	networkingv1beta1 "k8s.io/api/networking/v1beta1"
@@ -102,11 +103,7 @@ func NameFromHost(host string) string {
 }
 
 func RouteName(ingressName, host string) string {
-	routeName := ingressName
-	if host != "" {
-		routeName = fmt.Sprintf("%s-%s", ingressName, NameFromHost(host))
-	}
-	return routeName
+	return strings.TrimSuffix(fmt.Sprintf("%s-%s", ingressName, NameFromHost(host)))
 }
 
 func ToBackendRef(ib networkingv1.IngressBackend, path *field.Path) (*gatewayv1.BackendRef, *field.Error) {

pkg/i2gw/providers/kong/consts.go

@@ -20,7 +20,6 @@ import (
 	"fmt"
 
 	"k8s.io/apimachinery/pkg/runtime/schema"
-	gatewayv1beta1 "sigs.k8s.io/gateway-api/apis/v1beta1"
 )
 
 const (
@@ -32,19 +31,19 @@ const (
 )
 
 const (
-	v1beta1Version string = "v1beta1"
+	v1beta1Version = "v1beta1"
 
-	kongResourcesGroup gatewayv1beta1.Group = "configuration.konghq.com"
+	kongResourcesGroup = "configuration.konghq.com"
 
-	kongPluginKind gatewayv1beta1.Kind = "KongPlugin"
-	tcpIngressKind gatewayv1beta1.Kind = "TCPIngress"
+	kongPluginKind = "KongPlugin"
+	tcpIngressKind = "TCPIngress"
 )
 
 var (
 	tcpIngressGVK = schema.GroupVersionKind{
-		Group:   string(kongResourcesGroup),
+		Group:   kongResourcesGroup,
 		Version: v1beta1Version,
-		Kind:    string(tcpIngressKind),
+		Kind:    tcpIngressKind,
 	}
 )
 

pkg/i2gw/providers/kong/converter_test.go

@@ -138,8 +138,8 @@ func Test_ToGateway(t *testing.T) {
 									{
 										Type: gatewayv1.HTTPRouteFilterExtensionRef,
 										ExtensionRef: &gatewayv1.LocalObjectReference{
-											Group: kongResourcesGroup,
-											Kind:  kongPluginKind,
+											Group: gatewayv1.Group(kongResourcesGroup),
+											Kind:  gatewayv1.Kind(kongPluginKind),
 											Name:  gatewayv1.ObjectName("plugin1"),
 										},
 									},

pkg/i2gw/providers/kong/kong.go

@@ -34,7 +34,6 @@ func init() {
 
 // Provider implements the i2gw.Provider interface.
 type Provider struct {
-	conf    *i2gw.ProviderConf
 	storage storage
 
 	*resourceReader
@@ -44,8 +43,6 @@ type Provider struct {
 // NewProvider constructs and returns the kong implementation of i2gw.Provider.
 func NewProvider(conf *i2gw.ProviderConf) i2gw.Provider {
 	return &Provider{
-		conf: conf,
-
 		resourceReader: newResourceReader(conf),
 		converter:      newConverter(),
 	}
@@ -54,7 +51,7 @@ func NewProvider(conf *i2gw.ProviderConf) i2gw.Provider {
 // ToGatewayAPI converts the received i2gw.InputResources to i2gw.GatewayResources
 // including the kong specific features.
 func (p *Provider) ToGatewayAPI(_ i2gw.InputResources) (i2gw.GatewayResources, field.ErrorList) {
-	return p.convert(p.storage)
+	return p.converter.convert(p.storage)
 }
 
 func (p *Provider) ReadResourcesFromCluster(ctx context.Context) error {

pkg/i2gw/providers/kong/plugins.go

@@ -61,8 +61,8 @@ func parsePluginsAnnotation(annotations map[string]string) []gatewayv1.HTTPRoute
 				filters = append(filters, gatewayv1.HTTPRouteFilter{
 					Type: gatewayv1.HTTPRouteFilterExtensionRef,
 					ExtensionRef: &gatewayv1.LocalObjectReference{
-						Group: kongResourcesGroup,
-						Kind:  kongPluginKind,
+						Group: gatewayv1.Group(kongResourcesGroup),
+						Kind:  gatewayv1.Kind(kongPluginKind),
 						Name:  gatewayv1.ObjectName(v),
 					},
 				})

pkg/i2gw/providers/kong/resource_reader.go

@@ -47,7 +47,7 @@ func newResourceReader(conf *i2gw.ProviderConf) *resourceReader {
 // -----------------------------------------------------------------------------
 
 func (r *resourceReader) readResourcesFromCluster(ctx context.Context) (*storage, error) {
-	st := newStorage()
+	st := newResourceStorage()
 
 	ingresses, err := common.ReadIngressesFromCluster(ctx, r.conf.Client, KongIngressClass)
 	if err != nil {
@@ -65,7 +65,7 @@ func (r *resourceReader) readResourcesFromCluster(ctx context.Context) (*storage
 }
 
 func (r *resourceReader) readResourcesFromFile(filename string) (*storage, error) {
-	st := newStorage()
+	st := newResourceStorage()
 
 	ingresses, err := common.ReadIngressesFromFile(filename, r.conf.Namespace, KongIngressClass)
 	if err != nil {

pkg/i2gw/providers/kong/storage.go

@@ -27,7 +27,7 @@ type storage struct {
 	TCPIngresses []kongv1beta1.TCPIngress
 }
 
-func newStorage() *storage {
+func newResourceStorage() *storage {
 	return &storage{
 		Ingresses:    map[types.NamespacedName]*networkingv1.Ingress{},
 		TCPIngresses: []kongv1beta1.TCPIngress{},