package provider

import (
	"context"
	"fmt"
	"log"
	"os"
	"os/exec"
	"strings"

	"git.front.kjuulh.io/kjuulh/char/pkg/schema"
	"golang.org/x/sync/errgroup"
)

type GitPluginProvider struct{}

func NewGitPluginProvider() *GitPluginProvider {
	return &GitPluginProvider{}
}

func (gpp *GitPluginProvider) FetchPlugins(ctx context.Context, registry string, plugins schema.CharSchemaPlugins) error {
	errgroup, ctx := errgroup.WithContext(ctx)
	baseDir := ".char/plugins"
	if os.Getenv("CHAR_DEV_MODE") == "true" {
		if err := os.RemoveAll(baseDir); err != nil {
			return err
		}
	}
	if err := os.MkdirAll(baseDir, 0755); err != nil {
		return err
	}

	for n, plugin := range plugins {
		n, plugin := n, plugin
		errgroup.Go(func() error {
			log.Printf("fetching git plugin repo: %s", n)
			return gpp.FetchPlugin(
				ctx,
				registry,
				plugin,
				fmt.Sprintf(
					"%s/%s",
					strings.TrimRight(baseDir, "/"), n.Hash(),
				),
			)
		})
	}

	if err := errgroup.Wait(); err != nil {
		return err
	}

	return nil
}

func (gpp *GitPluginProvider) FetchPlugin(ctx context.Context, registry string, plugin *schema.CharSchemaPlugin, dest string) error {
	cloneUrl, err := plugin.Opts.GetCloneUrl(ctx, registry, &schema.CloneUrlOpt{
		Protocol: schema.GitProtocolSsh,
		SshUser:  "git",
	},
	)
	if err != nil {
		return err
	}

	output, err := exec.Command(
		"git",
		"clone",
		cloneUrl,
		dest,
	).CombinedOutput()
	if len(output) > 0 {
		log.Print(string(output))
	}
	if err != nil {
		return err
	}
	return nil
}