132 lines
3.8 KiB
TypeScript
132 lines
3.8 KiB
TypeScript
import { Readable } from 'stream';
|
|
import { BUCKET, client } from '$lib/minio';
|
|
import { fail, error } from '@sveltejs/kit';
|
|
import { v4 as uuidv4 } from 'uuid';
|
|
|
|
import { db } from '$lib/server/dbService';
|
|
import { getVorgangByName, vorgangNameExists } from '$lib/server/vorgangService';
|
|
|
|
const isRequiredFieldValid = (value: unknown) => {
|
|
if (value == null) return false;
|
|
|
|
if (typeof value === 'string' || value instanceof String) return value.trim() !== '';
|
|
|
|
return true;
|
|
};
|
|
|
|
export const actions = {
|
|
url: async ({ request }: { request: Request }) => {
|
|
const data = await request.formData();
|
|
const vorgangName: string | null = data.get('vorgang') as string;
|
|
const crimeName: string | null = data.get('name') as string;
|
|
const type: string | null = data.get('type') as string;
|
|
const vorgangPIN: string | null = data.get('vorgangPIN') as string;
|
|
const fileName: string | null = data.get('fileName') as string;
|
|
|
|
const vorgangExists = vorgangNameExists(vorgangName);
|
|
let vorgangToken;
|
|
|
|
if (!vorgangExists) {
|
|
vorgangToken = uuidv4();
|
|
const insertSQLStatement = `INSERT INTO cases (token, name, pin) VALUES (?, ?, ?)`;
|
|
const statement = db.prepare(insertSQLStatement);
|
|
statement.run(vorgangToken, vorgangName, vorgangPIN);
|
|
} else {
|
|
const vorgang = getVorgangByName(vorgangName);
|
|
vorgangToken = vorgang.token;
|
|
if (vorgang && vorgang.pin != vorgangPIN) {
|
|
const updateSQLStmt = `UPDATE cases SET pin = ? WHERE token = ?`;
|
|
const statement = db.prepare(updateSQLStmt);
|
|
statement.run(vorgangPIN, vorgangToken);
|
|
}
|
|
}
|
|
|
|
let objectName = `${vorgangToken}/${crimeName}`;
|
|
switch (type) {
|
|
case 'image/png':
|
|
if (!objectName.endsWith('.png')) objectName += '.png';
|
|
break;
|
|
case '':
|
|
if (fileName?.toString().endsWith('.glb') && !objectName.endsWith('.glb'))
|
|
objectName += '.glb';
|
|
}
|
|
|
|
const url = await client.presignedPutObject(BUCKET, objectName);
|
|
|
|
return { url };
|
|
},
|
|
validate: async ({ request }: { request: Request }) => {
|
|
const requestData = await request.formData();
|
|
const data = Object.fromEntries(requestData);
|
|
const vorgang = data.vorgang;
|
|
const name = data.name;
|
|
const vorgangPIN = data.vorgangPIN;
|
|
let success = true;
|
|
const err = {};
|
|
if (isRequiredFieldValid(vorgang)) {
|
|
err.vorgang = null;
|
|
} else {
|
|
err.vorgang = 'Das Feld Vorgang darf nicht leer bleiben.';
|
|
success = false;
|
|
}
|
|
|
|
if (isRequiredFieldValid(name)) {
|
|
err.name = null;
|
|
} else {
|
|
err.name = 'Das Feld Name darf nicht leer bleiben.';
|
|
success = false;
|
|
}
|
|
|
|
if (isRequiredFieldValid(vorgangPIN)) {
|
|
err.vorgangPIN = null;
|
|
} else {
|
|
err.vorgangPIN = 'Das Feld Zugangspasswort darf nicht leer bleiben.';
|
|
success = false;
|
|
}
|
|
|
|
if (success) return { success };
|
|
|
|
return fail(400, err);
|
|
},
|
|
|
|
upload: async ({ request }: { request: Request }) => {
|
|
const requestData = await request.formData();
|
|
const data = Object.fromEntries(requestData);
|
|
const vorgang = data.vorgang;
|
|
const name = data.name;
|
|
|
|
const url = await client.presignedPutObject(BUCKET, `${vorgang}/${name}`, 60);
|
|
|
|
return { url };
|
|
},
|
|
upload3: async ({ request }: { request: Request }) => {
|
|
const requestData = await request.formData();
|
|
const data = Object.fromEntries(requestData);
|
|
const name = data.name;
|
|
const stream = data.file.stream();
|
|
const metaData = { 'Content-Type': 'model-gtlf-binary', 'X-VorgangsNr': '4711' };
|
|
const result = new Promise((resolve, reject) => {
|
|
client.putObject(BUCKET, name, Readable.from(stream), metaData, function (err, etag) {
|
|
if (err) return reject(err);
|
|
resolve(etag);
|
|
});
|
|
});
|
|
let etag = null;
|
|
let error = null;
|
|
try {
|
|
etag = await result;
|
|
} catch (err) {
|
|
error = err;
|
|
console.log('Error:', err);
|
|
}
|
|
|
|
return { etag, error };
|
|
}
|
|
};
|
|
|
|
|
|
export const load: PageServerLoad = async (event) => {
|
|
if (!event.locals.user) {
|
|
error(404, 'Not found')
|
|
}
|
|
}; |