package main

import (
	"fmt"
	"path"

	"src.opensuse.org/autogits/common"
)

const (
	ListenAddr = "[::1]:8001"

	GitAuthor = "GiteaBot - AutoStaging"
	PrReview  = "pr-review"
)

func processPullRequestOpened(h *common.RequestHandler) error {
	req := h.Data.(*common.PullRequestAction)

	// requests against project are not handled here
	if req.Repository.Name == common.DefaultGitPrj {
		return nil
	}

	// create PrjGit branch for buidling the pull request
	branchName := fmt.Sprintf("PR_%s#%d", req.Repository.Name, req.Pull_Request.Number)
	commitMsg := fmt.Sprintf(`auto-created for %s

This commit was autocreated by %s
referencing

PullRequest: %s#%d`, req.Repository.Name, GitAuthor, req.Repository.Name, req.Pull_Request.Number)

	prjGit := h.CreateRepositoryIfNotExist(*req.Repository.Owner, common.DefaultGitPrj)
	if h.HasError() {
		return h.Error
	}

	h.GitExec("", "clone", "--depth", "1", prjGit.SSHURL, common.DefaultGitPrj)
	h.GitExec(common.DefaultGitPrj, "checkout", "-B", branchName, prjGit.DefaultBranch)
	h.GitExec(common.DefaultGitPrj, "submodule", "update", "--init", "--checkout", "--depth", "1", req.Repository.Name)
	h.GitExec(path.Join(common.DefaultGitPrj, req.Repository.Name), "fetch", "--depth", "1", "origin", req.Pull_Request.Head.Sha)
	h.GitExec(path.Join(common.DefaultGitPrj, req.Repository.Name), "checkout", req.Pull_Request.Head.Sha)
	h.GitExec(common.DefaultGitPrj, "commit", "-a", "-m", commitMsg)
	h.GitExec(common.DefaultGitPrj, "push", "-f", "origin", branchName)

	PR := h.CreatePullRequest(prjGit, branchName, prjGit.DefaultBranch,
		fmt.Sprintf("Forwarded PR: %s", req.Repository.Name),
		fmt.Sprintf(`This is a forwarded pull request by %s
referencing the following pull request:

PullRequest: %s#%d
`, GitAuthor, req.Repository.Name, req.Pull_Request.Number),
	)

	if h.HasError() {
		return h.Error
	}

	// request build review
	h.RequestReviews(PR, common.Bot_BuildReview)

	return nil
}

func processPullRequest(h *common.RequestHandler) error {
	req := h.Data.(*common.PullRequestAction)

	switch req.Action {
	case "opened":
		return processPullRequestOpened(h)
	}

	return fmt.Errorf("Unhandled pull request action: %s", req.Action)
}

func main() {
	var defs common.ListenDefinitions

	defs.Url = PrReview
	defs.GitAuthor = GitAuthor

	defs.Handlers = make(map[string]common.RequestProcessor)
	defs.Handlers[common.RequestType_PR] = processPullRequest

	common.RequireGiteaSecretToken()
	common.RequireObsSecretToken()
	common.StartServerWithAddress(defs, ListenAddr)
}