innohub/tatort
7
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge pull request 'f105_umstellung_seaweedS3' (#32) from f105_umstellung_seaweedS3 into development
All checks were successful
InnoHub Processor/tatort/pipeline/head This commit looks good
Details

Browse Source 
Reviewed-on: #32
This commit was merged in pull request #32.
This commit is contained in:
jared
2025-09-04 15:17:38 +02:00
parent 92f5f8e5ed d007513e82
commit 0bbbe0064b
7 changed files with 28 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/routes/api/list/[vorgang]/+server.ts
View File

@@ -1,4 +1,4 @@
import { client } from '$lib/minio';
import { BUCKET, client } from '$lib/minio';
import {
deleteVorgangByToken,
getCrimesListByToken,
@@ -11,7 +11,7 @@ export async function DELETE({ params }) {
const object_list = await new Promise((resolve, reject) => {
const res = [];
const items_str = client.listObjects('tatort', vorgangToken, true);
const items_str = client.listObjects(BUCKET, vorgangToken, true);
items_str.on('data', (obj) => {
res.push(obj.name);
@@ -24,7 +24,7 @@ export async function DELETE({ params }) {
});
});
await client.removeObjects('tatort', object_list);
await client.removeObjects(BUCKET, object_list);
deleteVorgangByToken(vorgangToken);
return new Response(null, { status: 204 });

9
src/routes/api/list/[vorgang]/[tatort]/+server.ts
View File

@@ -40,10 +40,9 @@ export async function PUT({ params, request }) {
const vorgangToken = params.vorgang;
// prepare copy, incl. check if new name exists already
const crimeOldName = data['oldName'];
const crimeS3FullBucketPathOld = `/tatort/${vorgangToken}/${crimeOldName}`;
const crimeS3FullBucketPathOld = `/${BUCKET}/${vorgangToken}/${crimeOldName}`;
const crimeNewName = `${vorgangToken}/${data['newName']}`;
if (!crimeOldName || !crimeNewName) {
@@ -51,14 +50,14 @@ export async function PUT({ params, request }) {
}
try {
await client.statObject('tatort', crimeNewName);
await client.statObject(BUCKET, crimeNewName);
return json({ msg: 'Die Datei existiert bereits.' }, { status: 400 });
} catch (error) {
console.log(error, 'continue operation');
}
await client.copyObject('tatort', crimeNewName, crimeS3FullBucketPathOld);
await client.removeObject('tatort', `${vorgangToken}/${crimeOldName}`);
await client.copyObject(BUCKET, crimeNewName, crimeS3FullBucketPathOld);
await client.removeObject(BUCKET, `${vorgangToken}/${crimeOldName}`);
return json({ success: 'success' }, { status: 200 });
}