-
Notifications
You must be signed in to change notification settings - Fork 0
/
restcontroller.go
119 lines (103 loc) · 3.57 KB
/
restcontroller.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
package controller
import (
"encoding/json"
"github.com/go-chi/chi"
"github.com/unrolled/render"
"issue-tracker/model"
"issue-tracker/repo"
"issue-tracker/service"
"issue-tracker/utils"
"log"
"net/http"
)
type RestController struct {
*render.Render
TicketRepo repo.TicketRepository
TicketService service.TicketService
}
func newJsonRender() *render.Render {
return render.New(render.Options{
//IndentJSON: true,
})
}
func NewRestController(ticketRepo repo.TicketRepository, ticketService service.TicketService) *RestController {
return &RestController{
newJsonRender(),
ticketRepo,
ticketService,
}
}
func (c *RestController) Routes() *chi.Mux {
router := chi.NewRouter()
router.Get("/ticket", c.GetAllTickets)
router.Get("/ticket/{ticketID}", c.GetTicket)
router.Post("/ticket", c.PostTicket)
router.Delete("/ticket/{ticketID}", c.DeleteTicket)
return router
}
func (c *RestController) GetAllTickets(w http.ResponseWriter, r *http.Request) {
tickets := c.TicketService.GetAllTickets()
_ = c.JSON(w, http.StatusOK, tickets)
}
func (c *RestController) GetTicket(w http.ResponseWriter, r *http.Request) {
ticketID := chi.URLParam(r, "ticketID")
if ticketID == "" { // This should not happen due to the GetAll endpoint
log.Println("Received a get ticket request with no ticketID.")
c.Error(w, http.StatusBadRequest, "The path parameter 'ticketID' is missing", nil)
return
}
ticket := c.TicketService.GetTicket(ticketID)
if (ticket == model.Ticket{}) {
log.Printf("Unable to find ticket with ID '%s'.\n", ticketID)
c.Error(w, http.StatusNotFound, "Ticket not found", nil)
return
}
_ = c.JSON(w, http.StatusOK, ticket)
}
func (c *RestController) PostTicket(w http.ResponseWriter, r *http.Request) {
var ticket model.Ticket
err := json.NewDecoder(r.Body).Decode(&ticket)
if err != nil {
log.Printf("Unable to parse PostTicket requet body, error: %s\n", err.Error())
c.Error(w, http.StatusBadRequest, "Unable to read the request body because it is invalid, empty or malformed", nil)
return
}
if errs := ticket.Validate(); len(errs) > 0 {
log.Printf("There is something wrong with the request body, errors: %s", utils.ErrorsToString(errs))
c.Error(w, http.StatusBadRequest, "There is something wrong with the request body", errs)
return
}
createdTicket, err := c.TicketService.AddTicket(ticket)
if err != nil {
c.Error(w, http.StatusInternalServerError, "Unable to create ticket due to an unexpected server error", nil)
return
}
_ = c.JSON(w, http.StatusCreated, createdTicket)
}
func (c *RestController) DeleteTicket(w http.ResponseWriter, r *http.Request) {
ticketID := chi.URLParam(r, "ticketID")
if ticketID == "" {
log.Println("Received a delete ticket request with no ticketID.")
c.Error(w, http.StatusBadRequest, "The path parameter 'ticketID' is missing", nil)
return
}
ticket := c.TicketService.GetTicket(ticketID)
if (ticket == model.Ticket{}) {
log.Printf("Unable to find ticket with ID '%s'.\n", ticketID)
c.Error(w, http.StatusNotFound, "Ticket not found", nil)
return
}
if err := c.TicketService.RemoveTicket(ticket.ID); err != nil {
log.Printf("Unable to delete ticket with ID '%s'.\n", ticketID)
c.Error(w, http.StatusInternalServerError, "Unable to delete ticket due to an unexpected server error", nil)
return
}
w.WriteHeader(http.StatusOK)
}
func (c *RestController) Error(w http.ResponseWriter, status int, message string, errors []error) {
var errorMessages []string
for _, err := range errors {
errorMessages = append(errorMessages, err.Error())
}
_ = c.JSON(w, status, model.Error{status, message, errorMessages})
}