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;