package bitbucket

import (
	"encoding/json"
	"fmt"
	"github.com/hashicorp/terraform/helper/schema"
)

type Reviewer struct {
	DisplayName string `json:"display_name,omitempty"`
	UUID        string `json:"uuid,omitempty"`
	Username    string `json:"username,omitempty"`
	Type        string `json:"type,omitempty"`
}

type PaginatedReviewers struct {
	Values []Reviewer `json:"values,omitempty"`
}

func resourceDefaultReviewers() *schema.Resource {
	return &schema.Resource{
		Create: resourceDefaultReviewersCreate,
		Read:   resourceDefaultReviewersRead,
		Delete: resourceDefaultReviewersDelete,

		Schema: map[string]*schema.Schema{
			"username": {
				Type:     schema.TypeString,
				Required: true,
				ForceNew: true,
			},
			"repository": {
				Type:     schema.TypeString,
				Required: true,
				ForceNew: true,
			},
			"reviewers": {
				Type:     schema.TypeSet,
				Elem:     &schema.Schema{Type: schema.TypeString},
				Required: true,
				Set:      schema.HashString,
				ForceNew: true,
			},
		},
	}
}

func resourceDefaultReviewersCreate(d *schema.ResourceData, m interface{}) error {
	client := m.(*BitbucketClient)

	for _, user := range d.Get("reviewers").(*schema.Set).List() {
		reviewer_resp, err := client.PutOnly(fmt.Sprintf("2.0/repositories/%s/%s/default-reviewers/%s",
			d.Get("username").(string),
			d.Get("repository").(string),
			user,
		))

		if err != nil {
			return err
		}

		if reviewer_resp.StatusCode != 201 {
			return fmt.Errorf("Failed to create reviewer %s got code %d", user.(string), reviewer_resp.StatusCode)
		}

		defer reviewer_resp.Body.Close()
	}

	d.SetId(fmt.Sprintf("%s/%s/reviewers", d.Get("username").(string), d.Get("repository").(string)))
	return resourceDefaultReviewersRead(d, m)
}
func resourceDefaultReviewersRead(d *schema.ResourceData, m interface{}) error {
	client := m.(*BitbucketClient)

	reviewers_response, err := client.Get(fmt.Sprintf("2.0/repositories/%s/%s/default-reviewers",
		d.Get("username").(string),
		d.Get("repository").(string),
	))

	var reviewers PaginatedReviewers
	decoder := json.NewDecoder(reviewers_response.Body)
	err = decoder.Decode(&reviewers)
	if err != nil {
		return err
	}

	terraform_reviewers := make([]string, 0, len(reviewers.Values))

	for _, reviewer := range reviewers.Values {
		terraform_reviewers = append(terraform_reviewers, reviewer.Username)
	}

	d.Set("reviewers", terraform_reviewers)

	return nil
}
func resourceDefaultReviewersDelete(d *schema.ResourceData, m interface{}) error {
	client := m.(*BitbucketClient)

	for _, user := range d.Get("reviewers").(*schema.Set).List() {
		_, err := client.Delete(fmt.Sprintf("2.0/repositories/%s/%s/default-reviewers/%s",
			d.Get("username").(string),
			d.Get("repository").(string),
			user,
		))

		if err != nil {
			return err
		}
	}
	return nil
}