infisical/k8-operator/internal/util/helpers.go

package util

import (
	"fmt"
	"strconv"
	"strings"
	"time"
)

func ConvertIntervalToDuration(resyncInterval *string) (time.Duration, error) {

	if resyncInterval == nil || *resyncInterval == "" {
		return 0, nil
	}

	length := len(*resyncInterval)
	if length < 2 {
		return 0, fmt.Errorf("invalid format")
	}

	unit := (*resyncInterval)[length-1:]
	numberPart := (*resyncInterval)[:length-1]

	number, err := strconv.Atoi(numberPart)
	if err != nil {
		return 0, err
	}

	switch unit {
	case "s":
		if number < 5 {
			return 0, fmt.Errorf("resync interval must be at least 5 seconds")
		}
		return time.Duration(number) * time.Second, nil
	case "m":
		return time.Duration(number) * time.Minute, nil
	case "h":
		return time.Duration(number) * time.Hour, nil
	case "d":
		return time.Duration(number) * 24 * time.Hour, nil
	case "w":
		return time.Duration(number) * 7 * 24 * time.Hour, nil
	default:
		return 0, fmt.Errorf("invalid time unit")
	}
}

func AppendAPIEndpoint(address string) string {
	if strings.HasSuffix(address, "/api") {
		return address
	}
	if address[len(address)-1] == '/' {
		return address + "api"
	}
	return address + "/api"
}

func IsNamespaceScopedError(err error, isNamespaceScoped bool) bool {
	return isNamespaceScoped && err != nil && strings.Contains(err.Error(), "unknown namespace for the cache")
}