feat:#26 added new api route

This commit is contained in:
Elmar Kresse
2024-02-04 00:54:59 +01:00
parent 57ef3c2f70
commit 4878499650
4 changed files with 66 additions and 10 deletions

View File

@@ -21,9 +21,7 @@ func main() {
// (the isGoRun check is to enable it only during development) // (the isGoRun check is to enable it only during development)
Automigrate: isGoRun, Automigrate: isGoRun,
}) })
service.AddRoutes(app) service.AddRoutes(app)
service.AddSchedules(app) service.AddSchedules(app)
if err := app.Start(); err != nil { if err := app.Start(); err != nil {

View File

@@ -294,8 +294,14 @@ func AddRoutes(app *pocketbase.PocketBase) {
Method: http.MethodGet, Method: http.MethodGet,
Path: "/api/courses", Path: "/api/courses",
Handler: func(c echo.Context) error { Handler: func(c echo.Context) error {
courses := events.GetAllCourses(app) semester := c.QueryParam("semester")
return c.JSON(200, courses) if semester == "" {
courses := events.GetAllCourses(app)
return c.JSON(200, courses)
} else {
courses := events.GetAllCoursesForSemester(app, semester)
return c.JSON(200, courses)
}
}, },
Middlewares: []echo.MiddlewareFunc{ Middlewares: []echo.MiddlewareFunc{
apis.ActivityLogger(app), apis.ActivityLogger(app),
@@ -307,14 +313,21 @@ func AddRoutes(app *pocketbase.PocketBase) {
return nil return nil
}) })
// api end point to get all courses for a specific semester with courses that have events
app.OnBeforeServe().Add(func(e *core.ServeEvent) error { app.OnBeforeServe().Add(func(e *core.ServeEvent) error {
_, err := e.Router.AddRoute(echo.Route{ _, err := e.Router.AddRoute(echo.Route{
Method: http.MethodGet, Method: http.MethodGet,
Path: "/api/courses", Path: "/api/courses/events",
Handler: func(c echo.Context) error { Handler: func(c echo.Context) error {
semester := c.QueryParam("semester") semester := c.QueryParam("semester")
courses := events.GetAllCoursesForSemester(app, semester) courses, err := events.GetAllCoursesForSemesterWithEvents(app, semester)
return c.JSON(200, courses)
if err != nil {
slog.Error("Failed to get courses for semester with events: %v", err)
return c.JSON(http.StatusBadRequest, "Failed to get courses for semester with events")
} else {
return c.JSON(200, courses)
}
}, },
Middlewares: []echo.MiddlewareFunc{ Middlewares: []echo.MiddlewareFunc{
apis.ActivityLogger(app), apis.ActivityLogger(app),

View File

@@ -82,13 +82,13 @@ func GetAllCourses(app *pocketbase.PocketBase) []string {
return courseArray return courseArray
} }
func GetAllCoursesForSemester(app *pocketbase.PocketBase, semester string) interface{} { func GetAllCoursesForSemester(app *pocketbase.PocketBase, semester string) []string {
var courses []struct { var courses []struct {
CourseShortcut string `db:"course" json:"course"` CourseShortcut string `db:"course" json:"course"`
} }
// get all rooms from event records in the events collection // get all courses for a specific semester
err := app.Dao().DB().Select("course").From("groups").Where(dbx.NewExp("semester = {:semester}", dbx.Params{"semester": semester})).All(&courses) err := app.Dao().DB().Select("course").From("groups").Where(dbx.NewExp("semester = {:semester}", dbx.Params{"semester": semester})).All(&courses)
if err != nil { if err != nil {
slog.Error("Error while getting groups from database: ", err) slog.Error("Error while getting groups from database: ", err)
@@ -104,3 +104,25 @@ func GetAllCoursesForSemester(app *pocketbase.PocketBase, semester string) inter
return courseArray return courseArray
} }
func GetAllCoursesForSemesterWithEvents(app *pocketbase.PocketBase, semester string) ([]string, error) {
var courses []struct {
CourseShortcut string `db:"course" json:"course"`
}
// get all courses from events distinct for a specific semester
err := app.Dao().DB().Select("course").From("events").Where(dbx.NewExp("semester = {:semester}", dbx.Params{"semester": semester})).Distinct(true).All(&courses)
if err != nil {
slog.Error("Error while getting groups from database: ", err)
return nil, err
}
var courseArray []string
for _, course := range courses {
courseArray = append(courseArray, course.CourseShortcut)
}
return courseArray, nil
}

View File

@@ -3,12 +3,35 @@ package events
import ( import (
"github.com/pocketbase/pocketbase" "github.com/pocketbase/pocketbase"
"htwkalender/service/db" "htwkalender/service/db"
"htwkalender/service/functions"
) )
func GetAllCourses(app *pocketbase.PocketBase) []string { func GetAllCourses(app *pocketbase.PocketBase) []string {
return db.GetAllCourses(app) return db.GetAllCourses(app)
} }
func GetAllCoursesForSemester(app *pocketbase.PocketBase, semester string) interface{} { func GetAllCoursesForSemester(app *pocketbase.PocketBase, semester string) []string {
return db.GetAllCoursesForSemester(app, semester) return db.GetAllCoursesForSemester(app, semester)
} }
func GetAllCoursesForSemesterWithEvents(app *pocketbase.PocketBase, semester string) ([]string, error) {
courses, err := db.GetAllCoursesForSemesterWithEvents(app, semester)
if err != nil {
return nil, err
} else {
// remove empty courses
courses = removeEmptyCourses(courses)
return courses, nil
}
}
func removeEmptyCourses(courses []string) []string {
var filteredCourses []string
for index, course := range courses {
if functions.OnlyWhitespace(course) || len(course) == 0 {
filteredCourses = append(courses[:index], courses[index+1:]...)
}
}
return filteredCourses
}