add issues endpoints
This commit is contained in:
@@ -1,72 +1,134 @@
|
|||||||
package handler
|
package handler
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"encoding/json"
|
"context"
|
||||||
"fmt"
|
|
||||||
"net/http"
|
"net/http"
|
||||||
|
|
||||||
"github.com/LazyBachelor/LazyPM/internal/models"
|
"github.com/LazyBachelor/LazyPM/internal/models"
|
||||||
"github.com/LazyBachelor/LazyPM/internal/service"
|
"github.com/go-chi/chi/v5"
|
||||||
)
|
)
|
||||||
|
|
||||||
func IssuesRoutes(svc *service.Services) []Route {
|
type IssueForm struct {
|
||||||
return []Route{
|
Title string `form:"title" validate:"required,max=255"`
|
||||||
{Pattern: "/issues", Handler: GetAllIssues(svc)},
|
Description string `form:"description" validate:"required,max=2000"`
|
||||||
{Pattern: "POST /create-issue", Handler: CreateIssue(svc)},
|
Status models.Status `form:"status" validate:"required,oneof=open in_progress closed"`
|
||||||
|
IssueType models.IssueType `form:"issue_type" validate:"required,oneof=task bug feature chore"`
|
||||||
|
Priority int `form:"priority" validate:"gte=0,lte=4"`
|
||||||
|
}
|
||||||
|
|
||||||
|
func (f *IssueForm) ToIssue() models.Issue {
|
||||||
|
return models.Issue{
|
||||||
|
Title: f.Title,
|
||||||
|
Description: f.Description,
|
||||||
|
Status: f.Status,
|
||||||
|
IssueType: f.IssueType,
|
||||||
|
Priority: f.Priority,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func CreateIssue(svc *service.Services) http.HandlerFunc {
|
func CreateIssue(w http.ResponseWriter, r *http.Request) {
|
||||||
return func(w http.ResponseWriter, r *http.Request) {
|
svc := Services(r)
|
||||||
if r.Method != http.MethodPost {
|
hx := HTMX(r)
|
||||||
http.Error(w, "Method not allowed", http.StatusMethodNotAllowed)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
// 1. Parse Form instead of JSON
|
form, err := ParseForm[IssueForm](r)
|
||||||
if err := r.ParseForm(); err != nil {
|
if err != nil {
|
||||||
http.Error(w, "Failed to parse form", http.StatusBadRequest)
|
http.Error(w, "Failed to parse form", http.StatusBadRequest)
|
||||||
return
|
return
|
||||||
}
|
|
||||||
|
|
||||||
// 2. Map form values to your struct manually
|
|
||||||
// (Or use a library like 'gorilla/schema')
|
|
||||||
issue := models.Issue{
|
|
||||||
Title: r.FormValue("title"),
|
|
||||||
Description: r.FormValue("description"),
|
|
||||||
Status: models.Status(r.FormValue("status")),
|
|
||||||
IssueType: models.IssueType(r.FormValue("issue_type")),
|
|
||||||
}
|
|
||||||
|
|
||||||
err := svc.Beads.CreateIssue(r.Context(), &issue, "")
|
|
||||||
if err != nil {
|
|
||||||
http.Error(w, "Failed to create issue: "+err.Error(), http.StatusInternalServerError)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
// 3. HTMX usually expects HTML back, not JSON
|
|
||||||
w.Header().Set("Content-Type", "text/html")
|
|
||||||
fmt.Fprintf(w, "<p>Created issue: %s</p>", issue.Title)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if err := ValidateForm(form); err != nil {
|
||||||
|
w.WriteHeader(http.StatusUnprocessableEntity)
|
||||||
|
if hx.IsHxRequest() {
|
||||||
|
hx.WriteString("<div class='alert alert-error'>Please fix the form errors</div>")
|
||||||
|
} else {
|
||||||
|
hx.WriteJSON(map[string]interface{}{"error": err.Error()})
|
||||||
|
}
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
issue := form.ToIssue()
|
||||||
|
if err := svc.Beads.CreateIssue(r.Context(), &issue, ""); err != nil {
|
||||||
|
http.Error(w, "Failed to create issue: "+err.Error(), http.StatusInternalServerError)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
if hx.IsHxRequest() {
|
||||||
|
hx.WriteString("<div>Issue created successfully</div>")
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
hx.WriteJSON(map[string]any{
|
||||||
|
"title": issue.Title,
|
||||||
|
"status": issue.Status,
|
||||||
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
func GetAllIssues(svc *service.Services) http.HandlerFunc {
|
func ListIssues(w http.ResponseWriter, r *http.Request) {
|
||||||
return func(w http.ResponseWriter, r *http.Request) {
|
svc := Services(r)
|
||||||
issues, err := svc.Beads.AllIssues(r.Context())
|
hx := HTMX(r)
|
||||||
|
|
||||||
if err != nil {
|
issues, err := svc.Beads.AllIssues(r.Context())
|
||||||
http.Error(w, "Failed to retrieve issues", http.StatusInternalServerError)
|
if err != nil {
|
||||||
return
|
http.Error(w, "Failed to retrieve issues", http.StatusInternalServerError)
|
||||||
}
|
return
|
||||||
|
|
||||||
jsonData, err := json.Marshal(issues)
|
|
||||||
|
|
||||||
if err != nil {
|
|
||||||
http.Error(w, "Failed to marshal issues", http.StatusInternalServerError)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
w.Header().Set("Content-Type", "application/json")
|
|
||||||
w.Write(jsonData)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
hx.WriteJSON(issues)
|
||||||
|
}
|
||||||
|
|
||||||
|
func IssueCtx(next http.Handler) http.Handler {
|
||||||
|
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
||||||
|
svc := Services(r)
|
||||||
|
|
||||||
|
id := chi.URLParam(r, "id")
|
||||||
|
issue, err := svc.Beads.GetIssue(r.Context(), id)
|
||||||
|
if err != nil {
|
||||||
|
http.Error(w, "Issue not found", http.StatusNotFound)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
ctx := context.WithValue(r.Context(), "issue", issue)
|
||||||
|
next.ServeHTTP(w, r.WithContext(ctx))
|
||||||
|
})
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
func GetIssue(w http.ResponseWriter, r *http.Request) {
|
||||||
|
issue := r.Context().Value("issue").(*models.Issue)
|
||||||
|
hx := HTMX(r)
|
||||||
|
|
||||||
|
hx.WriteJSON(issue)
|
||||||
|
}
|
||||||
|
|
||||||
|
func UpdateIssue(w http.ResponseWriter, r *http.Request) {
|
||||||
|
issue := r.Context().Value("issue").(*models.Issue)
|
||||||
|
svc := Services(r)
|
||||||
|
hx := HTMX(r)
|
||||||
|
|
||||||
|
changes := make(map[string]any)
|
||||||
|
|
||||||
|
if err := svc.Beads.UpdateIssue(r.Context(), issue.ID, changes, ""); err != nil {
|
||||||
|
http.Error(w, "Failed to update issue", http.StatusInternalServerError)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
issue, err := svc.Beads.GetIssue(r.Context(), issue.ID)
|
||||||
|
if err != nil {
|
||||||
|
http.Error(w, "Failed to retrieve updated issue", http.StatusInternalServerError)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
hx.WriteJSON(issue)
|
||||||
|
}
|
||||||
|
|
||||||
|
func DeleteIssue(w http.ResponseWriter, r *http.Request) {
|
||||||
|
issue := r.Context().Value("issue").(*models.Issue)
|
||||||
|
|
||||||
|
svc := Services(r)
|
||||||
|
if err := svc.Beads.DeleteIssue(r.Context(), issue.ID); err != nil {
|
||||||
|
http.Error(w, "Failed to delete issue", http.StatusInternalServerError)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
w.WriteHeader(http.StatusNoContent)
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user