repository_admin.go

package web

import (
	"fmt"
	"net/http"
	"strconv"

	"github.com/gorilla/mux"
	"github.com/gorilla/schema"

	"github.com/francoishill/leeroyci/database"
)

type repositoryAdminForm struct {
	Name string `schema:"name"`
	URL  string `schema:"url"`

	ClosePR   bool   `schema:"close_pr"`
	StatusPR  bool   `schema:"status_pr"`
	AccessKey string `schema:"access_key"`
}

func (r repositoryAdminForm) create(request *http.Request) (*database.Repository, error) {
	err := request.ParseForm()

	if err != nil {
		return nil, err
	}

	decoder := schema.NewDecoder()
	form := new(repositoryAdminForm)

	err = decoder.Decode(form, request.PostForm)

	if err != nil {
		return nil, err
	}

	repo, err := database.CreateRepository(
		form.Name,
		form.URL,
		form.AccessKey,
		form.ClosePR,
		form.StatusPR,
	)

	return repo, err
}

func (r repositoryAdminForm) update(request *http.Request, rid int64) error {
	err := request.ParseForm()

	if err != nil {
		return err
	}

	decoder := schema.NewDecoder()
	form := new(repositoryAdminForm)

	err = decoder.Decode(form, request.PostForm)

	if err != nil {
		return err
	}

	repo, err := database.GetRepositoryByID(rid)

	if err != nil {
		return err
	}

	_, err = repo.Update(
		form.Name,
		form.URL,
		form.AccessKey,
		form.ClosePR,
		form.StatusPR,
	)

	return err
}

func viewAdminListRepositories(w http.ResponseWriter, r *http.Request) {
	template := "repository/admin/list.html"
	ctx := make(responseContext)

	ctx["repositories"] = database.ListRepositories()

	render(w, r, template, ctx)
}

func viewAdminCreateRepository(w http.ResponseWriter, r *http.Request) {
	template := "repository/admin/create.html"
	ctx := make(responseContext)

	if r.Method == "POST" {
		repo, err := repositoryAdminForm{}.create(r)

		if err != nil {
			ctx["error"] = err.Error()
		} else {
			uri := fmt.Sprintf("/admin/repository/%d", repo.ID)
			http.Redirect(w, r, uri, 302)
			return
		}
	}

	render(w, r, template, ctx)
}

func viewAdminUpdateRepository(w http.ResponseWriter, r *http.Request) {
	template := "repository/admin/update.html"
	ctx := make(responseContext)

	vars := mux.Vars(r)
	rid, _ := strconv.Atoi(vars["rid"])

	if r.Method == "POST" {
		err := repositoryAdminForm{}.update(r, int64(rid))

		if err == nil {
			ctx["message"] = "Update successful."
		} else {
			ctx["error"] = err.Error()
		}
	}

	repo, err := database.GetRepositoryByID(int64(rid))

	if err != nil {
		ctx["error"] = err.Error()
	} else {
		ctx["repository"] = repo
	}

	render(w, r, template, ctx)
}

func viewAdminDeleteRepository(w http.ResponseWriter, r *http.Request) {
	vars := mux.Vars(r)
	rid, _ := strconv.Atoi(vars["rid"])

	repo, err := database.GetRepositoryByID(int64(rid))

	if err == nil {
		repo.Delete()
	}

	http.Redirect(w, r, "/admin/repositories", 302)
}