IBCornelsen/online-energieausweis
1
0
Fork 0
Code Issues 272 Pull Requests Actions Packages Projects 1 Releases Wiki Activity

Datenbank Umstellung

Browse Source
This commit is contained in:
Moritz Utcke
2023-12-09 10:40:39 +05:30
parent 2a995a1e8a
commit 9a6f5218d0
18 changed files with 242 additions and 106 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
src/pages/api/building/images.json.ts
View File

@@ -4,22 +4,36 @@ import {
error,
success,
} from "src/lib/APIResponse";
import { db } from "src/lib/shared";
import { db, prisma } from "src/lib/shared";
export const get: APIRoute = async ({ request }) => {
const body = Object.fromEntries(new URLSearchParams(request.url.split("?")[1]))
export const get: APIRoute = async ({ url }) => {
const body = url.searchParams
const uid = body.get("uid")
if (!body.uid) {
if (!body.has("uid") || !uid) {
return error(["Missing 'uid' in request body."])
}
const gebaeude = await db("gebaeude").where({ uid: body.uid }).first();
const gebaeude = await prisma.gebaeudeStammdaten.findUnique({
where: {
uid: uid
}
})
if (!gebaeude) {
return MissingEntityError("gebaeude")
}
const images = await db("gebaeude_bilder").where({ gebaeude_id: gebaeude.id }).select("uid", "kategorie");
const images = await prisma.gebaeudeBilder.findMany({
where: {
gebaeude_stammdaten_id: gebaeude.id
},
select: {
uid: true,
kategorie: true
}
})
return success(images);
};

27
src/pages/api/image.jpg.ts
View File

@@ -3,26 +3,27 @@ import {
MissingEntityError,
error,
} from "src/lib/APIResponse";
import { z } from "zod";
import * as path from "path";
import * as fs from "fs";
import { db } from "src/lib/shared";
import { prisma } from "src/lib/shared";
const ImageUploadChecker = z.object({
data: z.string(),
name: z.string(),
gebaeude_uid: z.string().optional(),
kategorie: z.string(),
});
export const get: APIRoute = async ({ url }) => {
const body = url.searchParams
const uid = body.get("uid")
export const get: APIRoute = async ({ request }) => {
const body = Object.fromEntries(new URLSearchParams(request.url.split("?")[1]))
if (!body.uid) {
if (!body.has("uid") || !uid) {
return error(["Missing 'uid' in request body."])
}
const image = await db("gebaeude_bilder").where({ uid: body.uid }).select("uid", "kategorie").first();
const image = await prisma.gebaeudeBilder.findUnique({
where: {
uid
},
select: {
uid: true,
kategorie: true
}
})
if (!image) {
return MissingEntityError("image")

53
src/pages/api/image.json.ts
View File

@@ -9,7 +9,7 @@ import * as jimp from "jimp";
import { z } from "zod";
import * as path from "path";
import * as fs from "fs";
import { db } from "src/lib/shared";
import { db, prisma } from "src/lib/shared";
const ImageUploadChecker = z.object({
data: z.string(),
@@ -18,14 +18,23 @@ const ImageUploadChecker = z.object({
kategorie: z.string(),
});
export const get: APIRoute = async ({ request }) => {
const body = Object.fromEntries(new URLSearchParams(request.url.split("?")[1]))
export const get: APIRoute = async ({ url }) => {
const body = url.searchParams
const uid = body.get("uid")
if (!body.uid) {
if (!body.has("uid") || !uid) {
return error(["Missing 'uid' in request body."])
}
const image = await db("gebaeude_bilder").where({ uid: body.uid }).select("uid", "kategorie").first();
const image = await prisma.gebaeudeBilder.findUnique({
where: {
uid
},
select: {
uid: true,
kategorie: true
}
})
if (!image) {
return MissingEntityError("image")
@@ -68,30 +77,44 @@ export const put: APIRoute = async ({ request }) => {
let gebaeude;
if (!body.gebaeude_uid) {
gebaeude = await db("gebaeude").insert({}).returning(["uid", "id"]);
gebaeude = await prisma.gebaeudeStammdaten.create({
data: {},
select: {
uid: true,
id: true
}
})
if (!gebaeude) {
return ActionFailedError();
}
} else {
gebaeude = await db("gebaeude")
.select("*")
.where("uid", body.gebaeude_uid);
gebaeude = await prisma.gebaeudeStammdaten.findUnique({
where: {
uid: body.gebaeude_uid
}
})
if (!gebaeude) {
return MissingEntityError("gebaeude");
}
}
const result = await db("gebaeude_bilder")
.insert({ gebaeude_id: gebaeude[0].id, kategorie: body.kategorie })
.returning(["uid"]);
const result = await prisma.gebaeudeBilder.create({
data: {
gebaeude_stammdaten_id: gebaeude.id,
kategorie: body.kategorie
},
select: {
uid: true
}
})
if (!result) {
return ActionFailedError();
}
const location = path.join("/persistent/uploads", `${result[0].uid}.jpg`);
const location = path.join("/persistent/uploads", `${result.uid}.jpg`);
const buffer = await jimpResult.getBufferAsync(jimp.MIME_JPEG)
@@ -102,7 +125,7 @@ export const put: APIRoute = async ({ request }) => {
}
return success({
uid: result[0].uid,
gebaeude_uid: gebaeude[0].uid,
uid: result.uid,
gebaeude_uid: gebaeude.uid,
});
};