From 197c6041d9ef16cb649c9d9ef98e102b762565e6 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Johannes=20B=C3=BClow?= <johannes.buelow@jmbit.de>
Date: Sun, 15 Jun 2025 21:13:49 +0200
Subject: [PATCH] added more functions to db abstraction

---
 server/internal/database/file.go                     | 10 ++++++++++
 server/internal/database/processingJob.go            |  9 +++++++++
 server/internal/database/queries-processing_jobs.sql |  2 ++
 3 files changed, 21 insertions(+)

diff --git a/server/internal/database/file.go b/server/internal/database/file.go
index 4646dbf..49dfa39 100644
--- a/server/internal/database/file.go
+++ b/server/internal/database/file.go
@@ -70,3 +70,13 @@ func GetFileMime(fileID pgtype.UUID) (string, error) {
 	}
 	return mimeType, nil
 }
+
+func GetFileProperties(fileID pgtype.UUID) (sqlc.FileProperty, error) {
+  query := sqlc.New(pool)
+  fileProperties, err := query.GetFileProperties(context.Background(), fileID)
+  if err != nil {
+    slog.Error("Error in GetFileProperties", "file-uuid", fileID, "error", err)
+  }
+  return fileProperties, err
+
+}
diff --git a/server/internal/database/processingJob.go b/server/internal/database/processingJob.go
index e0f33af..e43aeea 100644
--- a/server/internal/database/processingJob.go
+++ b/server/internal/database/processingJob.go
@@ -70,3 +70,12 @@ func AddProcessingJobMessage(jobid int64, message string) error {
 	}
 	return err
 }
+
+func ALlProcessingJobs() ([]sqlc.ProcessingJob, error) {
+	query := sqlc.New(pool)
+  jobs, err := query.GetAllJobs(context.Background())
+  if err != nil {
+    slog.Error("Unable to retrieve processing jobs", "error", err)
+  }
+  return jobs, err
+}
diff --git a/server/internal/database/queries-processing_jobs.sql b/server/internal/database/queries-processing_jobs.sql
index 30009ec..a10fd9a 100644
--- a/server/internal/database/queries-processing_jobs.sql
+++ b/server/internal/database/queries-processing_jobs.sql
@@ -32,3 +32,5 @@ SET completed = NOW(),
   error = $1
 WHERE id = $2;
 
+-- name: GetAllJobs :many
+SELECT * FROM processing_jobs;