package app

import (
	"bytes"
	"encoding/json"
	"fmt"
	"text/template"

	"git.ctrlz.es/mgdelacroix/campaigner/model"

	jira "gopkg.in/andygrunwald/go-jira.v1"
)

func (a *App) InitJiraClient() error {
	tp := jira.BasicAuthTransport{
		Username: a.Campaign.Jira.Username,
		Password: a.Campaign.Jira.Token,
	}

	client, err := jira.NewClient(tp.Client(), a.Campaign.Jira.Url)
	if err != nil {
		return err
	}

	a.jiraClient = client
	return nil
}

func (a *App) GetJiraIssueFromTicket(ticket *model.Ticket) (*jira.Issue, error) {
	summaryTmpl, err := template.New("").Parse(a.Campaign.Summary)
	if err != nil {
		return nil, err
	}

	var summaryBytes bytes.Buffer
	if err := summaryTmpl.Execute(&summaryBytes, ticket.Data); err != nil {
		return nil, err
	}
	summary := summaryBytes.String()

	descriptionTemplate, err := template.ParseFiles(a.Campaign.IssueTemplate)
	if err != nil {
		return nil, err
	}

	var descriptionBytes bytes.Buffer
	if err := descriptionTemplate.Execute(&descriptionBytes, ticket.Data); err != nil {
		return nil, err
	}
	description := descriptionBytes.String()

	data := map[string]string{
		"Description": description,
		"Summary":     summary,
		"Project":     a.Campaign.Jira.Project,
		"Issue Type":  a.Campaign.Jira.IssueType,
		"Epic Link":   a.Campaign.Jira.Epic,
	}

	createMetaInfo, _, err := a.jiraClient.Issue.GetCreateMeta(a.Campaign.Jira.Project)
	if err != nil {
		return nil, err
	}

	project := createMetaInfo.GetProjectWithKey(a.Campaign.Jira.Project)
	if project == nil {
		return nil, fmt.Errorf("Error retrieving project with key %s", a.Campaign.Jira.Project)
	}

	issueType := project.GetIssueTypeWithName(a.Campaign.Jira.IssueType)
	if issueType == nil {
		return nil, fmt.Errorf("Error retrieving issue type with name Story")
	}

	issue, err := jira.InitIssueWithMetaAndFields(project, issueType, data)
	if err != nil {
		return nil, err
	}

	return issue, nil
}

func (a *App) PublishInJira(ticket *model.Ticket, dryRun bool) (*jira.Issue, error) {
	issue, err := a.GetJiraIssueFromTicket(ticket)
	if err != nil {
		return nil, err
	}

	if dryRun {
		b, _ := json.MarshalIndent(issue, "", "  ")
		fmt.Println(string(b))
		return issue, nil
	}

	newIssue, _, err := a.jiraClient.Issue.Create(issue)
	if err != nil {
		return nil, err
	}

	return newIssue, nil
}

func (a *App) GetIssue(issueNo string) (*jira.Issue, error) {
	issue, _, err := a.jiraClient.Issue.Get(issueNo, nil)
	if err != nil {
		return nil, err
	}
	return issue, nil
}

func (a *App) PublishNextInJira(dryRun bool) (bool, error) {
	ticket := a.Campaign.NextJiraUnpublishedTicket()
	if ticket == nil {
		return false, nil
	}

	issue, err := a.PublishInJira(ticket, dryRun)
	if err != nil {
		return false, err
	}

	if dryRun {
		return true, nil
	}

	issue, _, err = a.jiraClient.Issue.Get(issue.Key, nil)
	if err != nil {
		return false, err
	}

	ticket.JiraLink = fmt.Sprintf("%s/browse/%s", a.Campaign.Jira.Url, issue.Key)
	ticket.Summary = issue.Fields.Summary
	ticket.Description = issue.Fields.Description
	ticket.JiraStatus = issue.Fields.Status.Name
	if err := a.Save(); err != nil {
		return false, err
	}
	return true, nil
}

func (a *App) PublishAllInJira(dryRun bool) (int, error) {
	count := 0
	for {
		next, err := a.PublishNextInJira(dryRun)
		if err != nil {
			return count, err
		}
		if !next {
			break
		}
		count++
	}
	return count, nil
}

func (a *App) PublishBatchInJira(batch int, dryRun bool) error {
	for i := 1; i <= batch; i++ {
		next, err := a.PublishNextInJira(dryRun)
		if err != nil {
			return err
		}
		if !next {
			return nil
		}
	}
	return nil
}