main.go

// Copyright (c) JFrog Ltd. (2025)
//
// 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 main

import (
	"context"
	"flag"
	"jfrog-credential-provider/internal/logger"
	"jfrog-credential-provider/internal/provider"
	"log"
	"os"
	"strconv"
	"time"
)

var Version string

func main() {
	if Version == "" {
		Version = "unknown"
	}

	// Create a subcommand for add-provider-config
	addProviderConfigCmd := flag.NewFlagSet("add-provider-config", flag.ExitOnError)
	dryRun := addProviderConfigCmd.Bool("dry-run", false, "Perform a dry run without making changes")
	generateConfig := addProviderConfigCmd.Bool("generateConfig", false, "Generate jfrog provider config from environment variables")
	isYaml := addProviderConfigCmd.Bool("yaml", false, "Generate config in YAML format")
	providerHome := addProviderConfigCmd.String("provider-home", "", "Provider home directory")
	providerConfig := addProviderConfigCmd.String("provider-config", "", "Provider config file name")

	// Create a subcommand for watch-kubelet
	watchKubeletCmd := flag.NewFlagSet("watch-kubelet", flag.ExitOnError)
	watchIsYaml := watchKubeletCmd.Bool("yaml", false, "Config is in YAML format")
	watchProviderHome := watchKubeletCmd.String("provider-home", "", "Provider home directory")
	watchProviderConfig := watchKubeletCmd.String("provider-config", "", "Provider config file name")
	watchTimeout := watchKubeletCmd.Int("timeout", 60, "Timeout in seconds to watch kubelet health")

	switch {
	case len(os.Args) > 1 && os.Args[1] == "add-provider-config":
		// Parse flags for the subcommand
		addProviderConfigCmd.Parse(os.Args[2:])

		resolvedProviderHome, resolvedProviderConfig := provider.ProcessProviderConfigEnvs(*providerHome, *providerConfig)

		if *generateConfig {
			provider.CreateProviderConfigFromEnv(*isYaml, resolvedProviderHome, resolvedProviderConfig)
		} else {
			provider.MergeConfig(*dryRun, *isYaml, resolvedProviderHome, resolvedProviderConfig)
		}
		return

	case len(os.Args) > 1 && os.Args[1] == "watch-kubelet":
		watchKubeletCmd.Parse(os.Args[2:])
		resolvedHome, resolvedConfig := provider.ProcessProviderConfigEnvs(*watchProviderHome, *watchProviderConfig)
		logs, err := logger.NewLogger()
		if err != nil {
			log.Fatalf("Failed to initialize logger: %v", err)
		}
		provider.WatchKubelet(*watchIsYaml, resolvedHome, resolvedConfig, *watchTimeout, logs)
		return

	default:
		httpTimeout := 30 * time.Second
		if v := os.Getenv("http_timeout_seconds"); v != "" {
			if n, err := strconv.Atoi(v); err == nil && n > 0 {
				httpTimeout = time.Duration(n) * time.Second
			}
		}
		ctx, cancel := context.WithTimeout(context.Background(), httpTimeout)
		defer cancel()
		provider.StartProvider(ctx, Version)
	}
}