main.go

package main

import (
	"context"
	"github.com/digital-ai/community-release-k8s-integration/k8s/cmd"
	"github.com/digital-ai/community-release-k8s-integration/task/server"
	"github.com/digital-ai/release-integration-sdk-go/runner"
	"github.com/digital-ai/release-integration-sdk-go/task"
	"github.com/digital-ai/release-integration-sdk-go/task/command"
	"os"
)

var PluginVersion = os.Getenv("VERSION")
var BuildDate = os.Getenv("BUILD_DATE")

func prepareCommandFactory(input task.InputContext) (command.CommandFactory, error) {
	k8sServer, err := server.DeserializeKubernetesServer(input.Task.Properties)
	if err != nil {
		return nil, err
	}
	return cmd.NewK8sCommandFactory(*k8sServer, task.DefaultResponseResultField, task.SecureResponseResultField)
}

var commandRunner = runner.NewCommandRunner(prepareCommandFactory)

func main() {
	context.Background()
	runner.Execute(PluginVersion, BuildDate, commandRunner)
}