Compare commits
9 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
8b8d99e162 | ||
|
|
103a07b7ac | ||
|
|
a20a21d251 | ||
|
|
ee7ce526f3 | ||
|
|
a938f41e94 | ||
|
|
1d09705adb | ||
|
|
4ee558b340 | ||
|
|
ad44a65087 | ||
|
|
e3870de7d5 |
@@ -41,7 +41,7 @@ func NewAPI(host string, port int, logger *logging.Logger) (*API, error) {
|
|||||||
|
|
||||||
v1.POST("/database/open", apiHandler.OpenDatabase)
|
v1.POST("/database/open", apiHandler.OpenDatabase)
|
||||||
v1.POST("/members/add", apiHandler.AddNewMember)
|
v1.POST("/members/add", apiHandler.AddNewMember)
|
||||||
v1.POST("/members/edit", apiHandler.EditMember)
|
v1.POST("/members/edit", apiHandler.UpdateMember)
|
||||||
v1.POST("/members/delete", apiHandler.DeleteMember)
|
v1.POST("/members/delete", apiHandler.DeleteMember)
|
||||||
v1.POST("/members/import/csv", apiHandler.ImportCSV)
|
v1.POST("/members/import/csv", apiHandler.ImportCSV)
|
||||||
|
|
||||||
|
|||||||
@@ -15,22 +15,23 @@ func (a *APIHandler) StartNewEvent(c *gin.Context) {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
name := c.Query("name")
|
var event models.Event
|
||||||
if name == "" {
|
err := c.BindJSON(&event)
|
||||||
a.logger.Error("StartNewEvent", "missing query 'name'")
|
if err != nil {
|
||||||
|
a.logger.Error("StartNewEvent", err)
|
||||||
c.JSON(http.StatusInternalServerError, nil)
|
c.JSON(http.StatusInternalServerError, nil)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
if err := a.DbHandler.StartNewEvent(name); err != nil {
|
if err := a.DbHandler.StartNewEvent(&event); err != nil {
|
||||||
a.logger.Error("StartNewEvent", err)
|
a.logger.Error("StartNewEvent", err)
|
||||||
c.JSON(http.StatusBadRequest, gin.H{"message": err.Error()})
|
c.JSON(http.StatusBadRequest, gin.H{"message": err.Error()})
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
c.JSON(http.StatusOK, gin.H{
|
c.JSON(http.StatusOK, gin.H{
|
||||||
"message": "New Event added " + name,
|
"message": "New Event added " + event.Name,
|
||||||
|
"data": event,
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -65,6 +66,36 @@ func (a *APIHandler) GetEvent(c *gin.Context) {
|
|||||||
c.JSON(http.StatusOK, events)
|
c.JSON(http.StatusOK, events)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (a *APIHandler) UpdateEvent(c *gin.Context) {
|
||||||
|
if !a.DBHandlerIsInitialized() {
|
||||||
|
a.logger.Error("UpdateEvent", "database handler is not initialized")
|
||||||
|
c.JSON(http.StatusInternalServerError, nil)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
var events []models.Event
|
||||||
|
err := c.BindJSON(&events)
|
||||||
|
if err != nil {
|
||||||
|
a.logger.Error("UpdateEvent", err)
|
||||||
|
c.JSON(http.StatusInternalServerError, nil)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
for _, event := range events {
|
||||||
|
err = a.DbHandler.UpdateEvent(event.Id, event)
|
||||||
|
if err != nil {
|
||||||
|
a.logger.Error("UpdateEvent", err)
|
||||||
|
c.JSON(http.StatusBadRequest, gin.H{
|
||||||
|
"message": err.Error(),
|
||||||
|
})
|
||||||
|
return
|
||||||
|
}
|
||||||
|
}
|
||||||
|
c.JSON(http.StatusOK, gin.H{
|
||||||
|
"message": "event(s) updated",
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
func (a *APIHandler) DeleteEvent(c *gin.Context) {
|
func (a *APIHandler) DeleteEvent(c *gin.Context) {
|
||||||
if !a.DBHandlerIsInitialized() {
|
if !a.DBHandlerIsInitialized() {
|
||||||
a.logger.Error("DeleteEvent", "database handler is not initialized")
|
a.logger.Error("DeleteEvent", "database handler is not initialized")
|
||||||
@@ -146,7 +177,7 @@ func (a *APIHandler) DeleteAttendee(c *gin.Context) {
|
|||||||
|
|
||||||
err = a.DbHandler.DeleteAttendeesFromEvent(event)
|
err = a.DbHandler.DeleteAttendeesFromEvent(event)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
a.logger.Error("DeleteAttendeesFromEvent", err)
|
a.logger.Error("DeleteAttendee", err)
|
||||||
c.JSON(http.StatusInternalServerError, gin.H{
|
c.JSON(http.StatusInternalServerError, gin.H{
|
||||||
"message": err.Error(),
|
"message": err.Error(),
|
||||||
})
|
})
|
||||||
|
|||||||
@@ -93,41 +93,23 @@ func (a *APIHandler) GetMember(c *gin.Context) {
|
|||||||
c.JSON(http.StatusOK, members)
|
c.JSON(http.StatusOK, members)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (a *APIHandler) EditMember(c *gin.Context) {
|
func (a *APIHandler) UpdateMember(c *gin.Context) {
|
||||||
if !a.DBHandlerIsInitialized() {
|
if !a.DBHandlerIsInitialized() {
|
||||||
a.logger.Error("EditMember", "database handler is not initialized")
|
a.logger.Error("EditMember", "database handler is not initialized")
|
||||||
c.JSON(http.StatusInternalServerError, nil)
|
c.JSON(http.StatusInternalServerError, nil)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
var i int
|
var members []models.Member
|
||||||
var err error
|
err := c.BindJSON(&members)
|
||||||
|
|
||||||
id := c.Query("id")
|
|
||||||
if id != "" {
|
|
||||||
i, err = strconv.Atoi(id)
|
|
||||||
if err != nil {
|
|
||||||
a.logger.Error("EditMember", err)
|
|
||||||
c.JSON(http.StatusInternalServerError, nil)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
a.logger.Error("EditMember", err)
|
|
||||||
c.JSON(http.StatusBadRequest, gin.H{
|
|
||||||
"message": "query parameter 'id' missing",
|
|
||||||
})
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
var member models.Member
|
|
||||||
err = c.BindJSON(&member)
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
a.logger.Error("EditMember", err)
|
a.logger.Error("EditMember", err)
|
||||||
c.JSON(http.StatusInternalServerError, nil)
|
c.JSON(http.StatusInternalServerError, nil)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
err = a.DbHandler.UpdateMember(i, member)
|
for _, member := range members {
|
||||||
|
err = a.DbHandler.UpdateMember(member.Id, member)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
a.logger.Error("EditMember", err)
|
a.logger.Error("EditMember", err)
|
||||||
c.JSON(http.StatusBadRequest, gin.H{
|
c.JSON(http.StatusBadRequest, gin.H{
|
||||||
@@ -135,8 +117,9 @@ func (a *APIHandler) EditMember(c *gin.Context) {
|
|||||||
})
|
})
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
}
|
||||||
c.JSON(http.StatusOK, gin.H{
|
c.JSON(http.StatusOK, gin.H{
|
||||||
"message": "member updated",
|
"message": "member(s) updated",
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -16,24 +16,25 @@ func (a *APIHandler) AddNewResponsible(c *gin.Context) {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
var responsible models.Person
|
var responsibles []models.Person
|
||||||
err := c.BindJSON(&responsible)
|
err := c.BindJSON(&responsibles)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
a.logger.Error("AddNewResponsible", err)
|
a.logger.Error("AddNewResponsible", err)
|
||||||
c.JSON(http.StatusInternalServerError, nil)
|
c.JSON(http.StatusInternalServerError, nil)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
err = a.DbHandler.AddNewResponsible(responsible)
|
err = a.DbHandler.AddNewResponsible(responsibles...)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
c.JSON(http.StatusBadRequest, gin.H{
|
c.JSON(http.StatusBadRequest, gin.H{
|
||||||
"message": err.Error(),
|
"message": err.Error(),
|
||||||
})
|
})
|
||||||
return
|
return
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
c.JSON(http.StatusOK, gin.H{
|
c.JSON(http.StatusOK, gin.H{
|
||||||
"message": "responsible added",
|
"message": "responsible(s) added",
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -8,19 +8,17 @@ import (
|
|||||||
"gitea.tecamino.com/paadi/memberDB/models"
|
"gitea.tecamino.com/paadi/memberDB/models"
|
||||||
)
|
)
|
||||||
|
|
||||||
func (dh *DatabaseHandler) StartNewEvent(name string) error {
|
func (dh *DatabaseHandler) StartNewEvent(event *models.Event) error {
|
||||||
if !dh.DatabaseOpened() {
|
if !dh.DatabaseOpened() {
|
||||||
return errors.New("database not opened")
|
return errors.New("database not opened")
|
||||||
}
|
}
|
||||||
|
|
||||||
if nil == dh.database.Exists(&models.Event{}, "name", name, false) {
|
if nil == dh.database.Exists(&models.Event{}, "name", event.Name, false) {
|
||||||
return errors.New("event with name: " + name + " exists already")
|
return errors.New("event with name: " + event.Name + " exists already")
|
||||||
}
|
}
|
||||||
|
|
||||||
return dh.database.AddNewColum(&models.Event{
|
event.Date = time.Now().Format("2006-01-02 15:04:05")
|
||||||
Name: name,
|
return dh.database.AddNewColum(&event)
|
||||||
Date: time.Now().Format("2006-01-02 15:04:05"),
|
|
||||||
})
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func (dh *DatabaseHandler) GetEvent(id uint) (event []models.Event, err error) {
|
func (dh *DatabaseHandler) GetEvent(id uint) (event []models.Event, err error) {
|
||||||
@@ -39,6 +37,13 @@ func (dh *DatabaseHandler) GetEvent(id uint) (event []models.Event, err error) {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (dh *DatabaseHandler) UpdateEvent(id int, event models.Event) (err error) {
|
||||||
|
if !dh.DatabaseOpened() {
|
||||||
|
return errors.New("database not opened")
|
||||||
|
}
|
||||||
|
return dh.database.UpdateValuesById(&event, uint(event.Id))
|
||||||
|
}
|
||||||
|
|
||||||
func (dh *DatabaseHandler) DeleteEvent(ids ...uint) error {
|
func (dh *DatabaseHandler) DeleteEvent(ids ...uint) error {
|
||||||
if !dh.DatabaseOpened() {
|
if !dh.DatabaseOpened() {
|
||||||
return errors.New("database not opened")
|
return errors.New("database not opened")
|
||||||
@@ -74,7 +79,7 @@ next:
|
|||||||
|
|
||||||
event.Count = len(event.Attendees)
|
event.Count = len(event.Attendees)
|
||||||
|
|
||||||
return dh.database.UpdateValuesById(&event, uint(event.Id))
|
return dh.database.UpdateValuesById(&event, uint(newEvent.Id))
|
||||||
}
|
}
|
||||||
|
|
||||||
func (dh *DatabaseHandler) DeleteAttendeesFromEvent(newEvent models.Event) error {
|
func (dh *DatabaseHandler) DeleteAttendeesFromEvent(newEvent models.Event) error {
|
||||||
@@ -83,7 +88,7 @@ func (dh *DatabaseHandler) DeleteAttendeesFromEvent(newEvent models.Event) error
|
|||||||
}
|
}
|
||||||
|
|
||||||
var event models.Event
|
var event models.Event
|
||||||
dh.database.GetById(&event, uint(event.Id))
|
dh.database.GetById(&event, uint(newEvent.Id))
|
||||||
|
|
||||||
next:
|
next:
|
||||||
for _, newAttendee := range newEvent.Attendees {
|
for _, newAttendee := range newEvent.Attendees {
|
||||||
@@ -95,5 +100,5 @@ next:
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
event.Count = len(event.Attendees)
|
event.Count = len(event.Attendees)
|
||||||
return dh.database.UpdateValuesById(&event, uint(event.Id))
|
return dh.database.UpdateValuesById(&event, uint(newEvent.Id))
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -10,11 +10,10 @@ func (dh *DatabaseHandler) AddNewResponsible(responsibles ...models.Person) erro
|
|||||||
if !dh.DatabaseOpened() {
|
if !dh.DatabaseOpened() {
|
||||||
return errors.New("database not opened")
|
return errors.New("database not opened")
|
||||||
}
|
}
|
||||||
if !dh.DatabaseOpened() {
|
|
||||||
return errors.New("database not opened")
|
|
||||||
}
|
|
||||||
for _, responsible := range responsibles {
|
|
||||||
|
|
||||||
|
for _, responsible := range responsibles {
|
||||||
|
// set id to 0 so new uniq id is created
|
||||||
|
responsible.Id = 0
|
||||||
exists, err := dh.responsibleExists(responsible)
|
exists, err := dh.responsibleExists(responsible)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
|
|||||||
@@ -44,7 +44,7 @@ func TestErrors(t *testing.T) {
|
|||||||
|
|
||||||
v1.POST("/database/open", apiHandler.OpenDatabase)
|
v1.POST("/database/open", apiHandler.OpenDatabase)
|
||||||
v1.POST("/members/add", apiHandler.AddNewMember)
|
v1.POST("/members/add", apiHandler.AddNewMember)
|
||||||
v1.POST("/members/edit", apiHandler.EditMember)
|
v1.POST("/members/edit", apiHandler.UpdateMember)
|
||||||
v1.POST("/members/delete", apiHandler.DeleteMember)
|
v1.POST("/members/delete", apiHandler.DeleteMember)
|
||||||
v1.POST("/members/import/csv", apiHandler.ImportCSV)
|
v1.POST("/members/import/csv", apiHandler.ImportCSV)
|
||||||
|
|
||||||
@@ -129,19 +129,20 @@ func TestMemberDB(t *testing.T) {
|
|||||||
|
|
||||||
v1 := r.Group("v1")
|
v1 := r.Group("v1")
|
||||||
v1.GET("/events", apiHandler.GetEvent)
|
v1.GET("/events", apiHandler.GetEvent)
|
||||||
v1.GET("/events/new", apiHandler.StartNewEvent)
|
|
||||||
v1.GET("/events/delete", apiHandler.DeleteEvent)
|
|
||||||
v1.GET("/members", apiHandler.GetMember)
|
v1.GET("/members", apiHandler.GetMember)
|
||||||
v1.GET("/responsible", apiHandler.GetResponsible)
|
v1.GET("/responsible", apiHandler.GetResponsible)
|
||||||
|
|
||||||
v1.POST("/database/open", apiHandler.OpenDatabase)
|
v1.POST("/database/open", apiHandler.OpenDatabase)
|
||||||
v1.POST("/members/add", apiHandler.AddNewMember)
|
v1.POST("/members/add", apiHandler.AddNewMember)
|
||||||
v1.POST("/members/edit", apiHandler.EditMember)
|
v1.POST("/members/edit", apiHandler.UpdateMember)
|
||||||
v1.POST("/members/delete", apiHandler.DeleteMember)
|
v1.POST("/members/delete", apiHandler.DeleteMember)
|
||||||
v1.POST("/members/import/csv", apiHandler.ImportCSV)
|
v1.POST("/members/import/csv", apiHandler.ImportCSV)
|
||||||
|
|
||||||
|
v1.POST("/events/new", apiHandler.StartNewEvent)
|
||||||
v1.POST("/events/attendees/add", apiHandler.AddNewAttendees)
|
v1.POST("/events/attendees/add", apiHandler.AddNewAttendees)
|
||||||
v1.POST("/events/attendees/delete", apiHandler.DeleteAttendee)
|
v1.POST("/events/attendees/delete", apiHandler.DeleteAttendee)
|
||||||
|
v1.POST("/events/edit", apiHandler.UpdateEvent)
|
||||||
|
v1.POST("/events/delete", apiHandler.DeleteEvent)
|
||||||
|
|
||||||
v1.POST("/responsible/add", apiHandler.AddNewResponsible)
|
v1.POST("/responsible/add", apiHandler.AddNewResponsible)
|
||||||
v1.POST("/responsible/delete", apiHandler.DeleteResponsible)
|
v1.POST("/responsible/delete", apiHandler.DeleteResponsible)
|
||||||
|
|||||||
Reference in New Issue
Block a user