sqlinstance.go

package generators

import (
	"context"
	"fmt"
	"strings"

	sql_cnrm_cloud_google_com_v1beta1 "github.com/nais/liberator/pkg/apis/sql.cnrm.cloud.google.com/v1beta1"
	"k8s.io/apimachinery/pkg/api/errors"
	"sigs.k8s.io/controller-runtime/pkg/client"
)

func prepareSqlInstance(ctx context.Context, kube client.Client, key client.ObjectKey, o *Options) error {
	sqlinstance := &sql_cnrm_cloud_google_com_v1beta1.SQLInstance{}
	err := kube.Get(ctx, key, sqlinstance)
	if err != nil {
		if !errors.IsNotFound(err) {
			return fmt.Errorf("NAISERATOR-7093: query existing sqlinstance: %s", err)
		}
		o.SqlInstance.exists = false
	} else {
		o.SqlInstance.exists = true
		o.SqlInstance.hasPrivateIpInSharedVpc = hasPrivateIpInSharedVpc(sqlinstance, o)
	}
	return nil
}

func hasPrivateIpInSharedVpc(sqlinstance *sql_cnrm_cloud_google_com_v1beta1.SQLInstance, o *Options) bool {
	privateNetworkRef := sqlinstance.Spec.Settings.IpConfiguration.PrivateNetworkRef
	if privateNetworkRef == nil {
		return false
	}
	return strings.Contains(privateNetworkRef.External, o.GetGoogleProjectID())
}