speatzle/morffix
1
0
Fork 0
Code Issues Pull requests Projects Releases 2 Packages Wiki Activity Actions

Add Task Index Backend

Browse source
This commit is contained in:
Samuel Lorch 2024-05-05 01:29:46 +02:00
parent fe0c712447
commit 8ae77f802d
1 changed files with 27 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

28
server/index.go
View file

@ -7,12 +7,14 @@ import (
"git.lastassault.de/speatzle/morffix/constants" "git.lastassault.de/speatzle/morffix/constants"
"git.lastassault.de/speatzle/morffix/types" "git.lastassault.de/speatzle/morffix/types"
"github.com/jackc/pgx/v5"
) )
type IndexData struct { type IndexData struct {
Counter []int Counter []int
Workers []IndexWorker Workers []IndexWorker
Tasks []Task
} }
type IndexWorker struct { type IndexWorker struct {
@ -22,6 +24,15 @@ type IndexWorker struct {
var count = 123456789 var count = 123456789
type Task struct {
ID int `db:"id"`
Library int `db:"library"`
Worker *string `db:"worker"`
Type int `db:"type"`
Status int `db:"status"`
File string `db:"file"`
}
func handleIndex(w http.ResponseWriter, r *http.Request) { func handleIndex(w http.ResponseWriter, r *http.Request) {
data := IndexData{ data := IndexData{
@ -54,8 +65,23 @@ func handleIndex(w http.ResponseWriter, r *http.Request) {
} }
} }
}() }()
rows, err := db.Query(r.Context(), "SELECT t.id AS id, l.id AS library, t.worker_id AS worker, t.type AS type, t.status AS status, f.path AS file FROM tasks t INNER JOIN files f ON f.id = t.file_id INNER JOIN libraries l ON l.id = f.library_id")
if err != nil {
slog.ErrorContext(r.Context(), "Query Tasks", "err", err)
http.Error(w, "Error Query Tasks: "+err.Error(), http.StatusInternalServerError)
return
}
tasks, err := pgx.CollectRows[Task](rows, pgx.RowToStructByName[Task])
if err != nil {
slog.ErrorContext(r.Context(), "Executing index Template", "err", err)
http.Error(w, "Error Query Tasks: "+err.Error(), http.StatusInternalServerError)
return
}
data.Tasks = tasks
buf := bytes.Buffer{} buf := bytes.Buffer{}
err := templates.ExecuteTemplate(&buf, constants.INDEX_TEMPLATE_NAME, data) err = templates.ExecuteTemplate(&buf, constants.INDEX_TEMPLATE_NAME, data)
if err != nil { if err != nil {
slog.ErrorContext(r.Context(), "Executing index Template", "err", err) slog.ErrorContext(r.Context(), "Executing index Template", "err", err)
http.Error(w, "Error Executing Template: "+err.Error(), http.StatusInternalServerError) http.Error(w, "Error Executing Template: "+err.Error(), http.StatusInternalServerError)