diff --git a/server/internal/database/capa.go b/server/internal/database/capa.go new file mode 100644 index 0000000..a3ceb94 --- /dev/null +++ b/server/internal/database/capa.go @@ -0,0 +1,44 @@ +package database + +import ( + "context" + "encoding/json" + "log/slog" + + "git.jmbit.de/jmb/scanfile/server/internal/sqlc" + "github.com/jackc/pgx/v5/pgtype" +) + +func InsertFileCapa(params sqlc.InsertFileCapaParams) error { + query := sqlc.New(pool) + err := query.InsertFileCapa(context.Background(), params) + if err != nil { + slog.Error("Error from Query in InsertFileCapa", "file-uuid", params.FileID.String(), "error", err) + } + return err +} + +func GetFileCapa(fileID string) (CapaResult, error) { + var pgUUID pgtype.UUID + err := pgUUID.Scan(fileID) + if err != nil { + slog.Error("Unable to convert string to UUID", "file-uuid", fileID, "error", err) + } + var r CapaResult + var data CapaData + query := sqlc.New(pool) + rawResult, err := query.GetFileCapa(context.Background(), pgUUID) + if err != nil { + slog.Error("Error from Query in GetFileCapa", "file-uuid", fileID, "error", err) + } + r.ID = rawResult.ID + r.FileID = rawResult.FileID + err = json.Unmarshal(rawResult.Data, &data) + if err != nil { + slog.Error("Error in GetFileCapa", "file-uuid", fileID, "error", err) + return r, err + } + r.Data = data + + return r, nil +} diff --git a/server/internal/database/file.go b/server/internal/database/file.go index 27548bf..27b22fa 100644 --- a/server/internal/database/file.go +++ b/server/internal/database/file.go @@ -111,30 +111,3 @@ func GetFileDiec(fileID pgtype.UUID) (Diec, error){ return r, nil } -func InsertFileCapa(params sqlc.InsertFileCapaParams) error { - query := sqlc.New(pool) - err := query.InsertFileCapa(context.Background(), params) - if err != nil { - slog.Error("Error from Query in InsertFileCapa", "file-uuid", params.FileID.String(), "error", err) - } - return err -} - -func GetFileCapa(fileID pgtype.UUID) (CapaResult, error) { - var r CapaResult - var data CapaData - query := sqlc.New(pool) - rawResult, err := query.GetFileCapa(context.Background(), fileID) - if err != nil { - slog.Error("Error from Query in GetFileCapa", "file-uuid", fileID.String(), "error", err) - } - r.ID = rawResult.ID - r.FileID = rawResult.FileID - err = json.Unmarshal(rawResult.Data, &data) - if err != nil { - slog.Error("Error in GetFileCapa", "file-uuid", fileID.String(), "error", err) - return r, err - } - - return r, nil -}