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

Use Library Size for Counter

Browse source
This commit is contained in:
speatzle 2024-05-05 17:15:05 +02:00
parent 595efd0c66
commit 4153e48eb3
1 changed files with 9 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
server/index.go
View file

@ -22,8 +22,6 @@ type IndexWorker struct {
Status *types.WorkerStatus Status *types.WorkerStatus
} }
var count = 123456789
type Task struct { type Task struct {
ID int `db:"id"` ID int `db:"id"`
Library int `db:"library"` Library int `db:"library"`
@ -36,10 +34,8 @@ type Task struct {
func handleIndex(w http.ResponseWriter, r *http.Request) { func handleIndex(w http.ResponseWriter, r *http.Request) {
data := IndexData{ data := IndexData{
Counter: splitInt(count),
Workers: []IndexWorker{}, Workers: []IndexWorker{},
} }
count++
func() { func() {
WorkersMutex.Lock() WorkersMutex.Lock()
defer WorkersMutex.Unlock() defer WorkersMutex.Unlock()
@ -66,6 +62,15 @@ func handleIndex(w http.ResponseWriter, r *http.Request) {
} }
}() }()
var size int
err := db.QueryRow(r.Context(), "SELECT SUM(size) AS size FROM files WHERE missing = $1", false).Scan(&size)
if err != nil {
slog.ErrorContext(r.Context(), "Query File Size Sum", "err", err)
http.Error(w, "Error Query File Size Sum: "+err.Error(), http.StatusInternalServerError)
return
}
data.Counter = splitInt(size)
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") 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 { if err != nil {
slog.ErrorContext(r.Context(), "Query Tasks", "err", err) slog.ErrorContext(r.Context(), "Query Tasks", "err", err)