Compare commits
1 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
4e1f1d6426 |
103
frontend/src/lib/components/UploadQueue.svelte
Normal file
103
frontend/src/lib/components/UploadQueue.svelte
Normal file
@@ -0,0 +1,103 @@
|
|||||||
|
<script lang="ts">
|
||||||
|
import { queueItems, isProcessing, retryItem, removeItem, clearCompleted } from '$lib/upload-queue';
|
||||||
|
import type { QueueItem } from '$lib/upload-queue';
|
||||||
|
|
||||||
|
function formatSize(bytes: number): string {
|
||||||
|
if (bytes < 1024) return `${bytes} B`;
|
||||||
|
if (bytes < 1024 * 1024) return `${(bytes / 1024).toFixed(1)} KB`;
|
||||||
|
return `${(bytes / (1024 * 1024)).toFixed(1)} MB`;
|
||||||
|
}
|
||||||
|
|
||||||
|
function statusLabel(status: QueueItem['status']): string {
|
||||||
|
switch (status) {
|
||||||
|
case 'pending': return 'Wartend';
|
||||||
|
case 'uploading': return 'Wird hochgeladen';
|
||||||
|
case 'done': return 'Fertig';
|
||||||
|
case 'error': return 'Fehler';
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
function statusColor(status: QueueItem['status']): string {
|
||||||
|
switch (status) {
|
||||||
|
case 'pending': return 'text-gray-500';
|
||||||
|
case 'uploading': return 'text-blue-600';
|
||||||
|
case 'done': return 'text-green-600';
|
||||||
|
case 'error': return 'text-red-600';
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
let items = $derived($queueItems);
|
||||||
|
let hasCompleted = $derived(items.some((i) => i.status === 'done'));
|
||||||
|
</script>
|
||||||
|
|
||||||
|
{#if items.length > 0}
|
||||||
|
<div class="mt-4 rounded-lg border border-gray-200 bg-white">
|
||||||
|
<div class="flex items-center justify-between border-b border-gray-100 px-4 py-3">
|
||||||
|
<h3 class="text-sm font-semibold text-gray-900">
|
||||||
|
Upload-Warteschlange
|
||||||
|
{#if $isProcessing}
|
||||||
|
<span class="ml-2 inline-block h-2 w-2 animate-pulse rounded-full bg-blue-500"></span>
|
||||||
|
{/if}
|
||||||
|
</h3>
|
||||||
|
{#if hasCompleted}
|
||||||
|
<button
|
||||||
|
onclick={() => clearCompleted()}
|
||||||
|
class="text-xs text-gray-500 hover:text-gray-700"
|
||||||
|
>
|
||||||
|
Fertige entfernen
|
||||||
|
</button>
|
||||||
|
{/if}
|
||||||
|
</div>
|
||||||
|
|
||||||
|
<ul class="divide-y divide-gray-100">
|
||||||
|
{#each items as item (item.id)}
|
||||||
|
<li class="px-4 py-3">
|
||||||
|
<div class="flex items-center justify-between">
|
||||||
|
<div class="min-w-0 flex-1">
|
||||||
|
<p class="truncate text-sm font-medium text-gray-900">{item.fileName}</p>
|
||||||
|
<p class="text-xs text-gray-500">{formatSize(item.fileSize)}</p>
|
||||||
|
</div>
|
||||||
|
<div class="ml-3 flex items-center gap-2">
|
||||||
|
<span class="text-xs font-medium {statusColor(item.status)}">
|
||||||
|
{statusLabel(item.status)}
|
||||||
|
</span>
|
||||||
|
{#if item.status === 'error'}
|
||||||
|
<button
|
||||||
|
onclick={() => retryItem(item.id)}
|
||||||
|
class="rounded bg-red-100 px-2 py-0.5 text-xs text-red-700 hover:bg-red-200"
|
||||||
|
>
|
||||||
|
Erneut
|
||||||
|
</button>
|
||||||
|
{/if}
|
||||||
|
{#if item.status === 'done' || item.status === 'error'}
|
||||||
|
<button
|
||||||
|
onclick={() => removeItem(item.id)}
|
||||||
|
class="text-gray-400 hover:text-gray-600"
|
||||||
|
aria-label="Entfernen"
|
||||||
|
>
|
||||||
|
<svg class="h-4 w-4" fill="none" viewBox="0 0 24 24" stroke="currentColor">
|
||||||
|
<path stroke-linecap="round" stroke-linejoin="round" stroke-width="2" d="M6 18L18 6M6 6l12 12" />
|
||||||
|
</svg>
|
||||||
|
</button>
|
||||||
|
{/if}
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
|
||||||
|
{#if item.status === 'uploading'}
|
||||||
|
<div class="mt-2 h-1.5 w-full overflow-hidden rounded-full bg-gray-200">
|
||||||
|
<div
|
||||||
|
class="h-full rounded-full bg-blue-500 transition-all duration-300"
|
||||||
|
style="width: {item.progress}%"
|
||||||
|
></div>
|
||||||
|
</div>
|
||||||
|
<p class="mt-1 text-right text-xs text-gray-400">{item.progress}%</p>
|
||||||
|
{/if}
|
||||||
|
|
||||||
|
{#if item.error}
|
||||||
|
<p class="mt-1 text-xs text-red-500">{item.error}</p>
|
||||||
|
{/if}
|
||||||
|
</li>
|
||||||
|
{/each}
|
||||||
|
</ul>
|
||||||
|
</div>
|
||||||
|
{/if}
|
||||||
233
frontend/src/lib/upload-queue.ts
Normal file
233
frontend/src/lib/upload-queue.ts
Normal file
@@ -0,0 +1,233 @@
|
|||||||
|
import { openDB, type IDBPDatabase } from 'idb';
|
||||||
|
import { writable, get } from 'svelte/store';
|
||||||
|
import { getToken } from './auth';
|
||||||
|
|
||||||
|
export interface QueueItem {
|
||||||
|
id: string;
|
||||||
|
fileName: string;
|
||||||
|
fileSize: number;
|
||||||
|
mimeType: string;
|
||||||
|
caption: string;
|
||||||
|
hashtags: string;
|
||||||
|
status: 'pending' | 'uploading' | 'done' | 'error';
|
||||||
|
progress: number;
|
||||||
|
error?: string;
|
||||||
|
}
|
||||||
|
|
||||||
|
// Store does NOT hold file blobs — those stay in IndexedDB only
|
||||||
|
export const queueItems = writable<QueueItem[]>([]);
|
||||||
|
export const isProcessing = writable(false);
|
||||||
|
|
||||||
|
const DB_NAME = 'eventsnap-uploads';
|
||||||
|
const STORE_NAME = 'queue';
|
||||||
|
|
||||||
|
let db: IDBPDatabase | null = null;
|
||||||
|
|
||||||
|
async function getDb(): Promise<IDBPDatabase> {
|
||||||
|
if (db) return db;
|
||||||
|
db = await openDB(DB_NAME, 1, {
|
||||||
|
upgrade(database) {
|
||||||
|
if (!database.objectStoreNames.contains(STORE_NAME)) {
|
||||||
|
database.createObjectStore(STORE_NAME, { keyPath: 'id' });
|
||||||
|
}
|
||||||
|
}
|
||||||
|
});
|
||||||
|
return db;
|
||||||
|
}
|
||||||
|
|
||||||
|
export async function loadQueue(): Promise<void> {
|
||||||
|
const database = await getDb();
|
||||||
|
const all = await database.getAll(STORE_NAME);
|
||||||
|
const items: QueueItem[] = all.map((entry) => ({
|
||||||
|
id: entry.id,
|
||||||
|
fileName: entry.fileName,
|
||||||
|
fileSize: entry.fileSize,
|
||||||
|
mimeType: entry.mimeType,
|
||||||
|
caption: entry.caption ?? '',
|
||||||
|
hashtags: entry.hashtags ?? '',
|
||||||
|
status: entry.status === 'uploading' ? 'pending' : entry.status,
|
||||||
|
progress: entry.status === 'done' ? 100 : 0,
|
||||||
|
error: entry.error
|
||||||
|
}));
|
||||||
|
queueItems.set(items);
|
||||||
|
}
|
||||||
|
|
||||||
|
export async function addToQueue(
|
||||||
|
file: File,
|
||||||
|
caption: string,
|
||||||
|
hashtags: string
|
||||||
|
): Promise<void> {
|
||||||
|
const database = await getDb();
|
||||||
|
const id = crypto.randomUUID();
|
||||||
|
const entry = {
|
||||||
|
id,
|
||||||
|
fileName: file.name,
|
||||||
|
fileSize: file.size,
|
||||||
|
mimeType: file.type,
|
||||||
|
caption,
|
||||||
|
hashtags,
|
||||||
|
status: 'pending',
|
||||||
|
blob: file
|
||||||
|
};
|
||||||
|
await database.put(STORE_NAME, entry);
|
||||||
|
|
||||||
|
queueItems.update((items) => [
|
||||||
|
...items,
|
||||||
|
{
|
||||||
|
id,
|
||||||
|
fileName: file.name,
|
||||||
|
fileSize: file.size,
|
||||||
|
mimeType: file.type,
|
||||||
|
caption,
|
||||||
|
hashtags,
|
||||||
|
status: 'pending',
|
||||||
|
progress: 0
|
||||||
|
}
|
||||||
|
]);
|
||||||
|
|
||||||
|
processQueue();
|
||||||
|
}
|
||||||
|
|
||||||
|
export async function retryItem(id: string): Promise<void> {
|
||||||
|
const database = await getDb();
|
||||||
|
const entry = await database.get(STORE_NAME, id);
|
||||||
|
if (!entry) return;
|
||||||
|
|
||||||
|
entry.status = 'pending';
|
||||||
|
entry.error = undefined;
|
||||||
|
await database.put(STORE_NAME, entry);
|
||||||
|
|
||||||
|
queueItems.update((items) =>
|
||||||
|
items.map((item) =>
|
||||||
|
item.id === id ? { ...item, status: 'pending' as const, progress: 0, error: undefined } : item
|
||||||
|
)
|
||||||
|
);
|
||||||
|
|
||||||
|
processQueue();
|
||||||
|
}
|
||||||
|
|
||||||
|
export async function removeItem(id: string): Promise<void> {
|
||||||
|
const database = await getDb();
|
||||||
|
await database.delete(STORE_NAME, id);
|
||||||
|
queueItems.update((items) => items.filter((item) => item.id !== id));
|
||||||
|
}
|
||||||
|
|
||||||
|
export async function clearCompleted(): Promise<void> {
|
||||||
|
const database = await getDb();
|
||||||
|
const items = get(queueItems);
|
||||||
|
for (const item of items) {
|
||||||
|
if (item.status === 'done') {
|
||||||
|
await database.delete(STORE_NAME, item.id);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
queueItems.update((items) => items.filter((item) => item.status !== 'done'));
|
||||||
|
}
|
||||||
|
|
||||||
|
let processing = false;
|
||||||
|
|
||||||
|
async function processQueue(): Promise<void> {
|
||||||
|
if (processing) return;
|
||||||
|
processing = true;
|
||||||
|
isProcessing.set(true);
|
||||||
|
|
||||||
|
try {
|
||||||
|
while (true) {
|
||||||
|
const items = get(queueItems);
|
||||||
|
const next = items.find((item) => item.status === 'pending');
|
||||||
|
if (!next) break;
|
||||||
|
|
||||||
|
await uploadItem(next.id);
|
||||||
|
}
|
||||||
|
} finally {
|
||||||
|
processing = false;
|
||||||
|
isProcessing.set(false);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
async function uploadItem(id: string): Promise<void> {
|
||||||
|
const database = await getDb();
|
||||||
|
const entry = await database.get(STORE_NAME, id);
|
||||||
|
if (!entry || !entry.blob) {
|
||||||
|
// No blob — mark as error
|
||||||
|
updateItemStatus(id, 'error', 'Datei nicht gefunden.');
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
updateItemStatus(id, 'uploading');
|
||||||
|
|
||||||
|
const token = getToken();
|
||||||
|
if (!token) {
|
||||||
|
updateItemStatus(id, 'error', 'Nicht angemeldet.');
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
try {
|
||||||
|
const formData = new FormData();
|
||||||
|
formData.append('file', entry.blob, entry.fileName);
|
||||||
|
if (entry.caption) formData.append('caption', entry.caption);
|
||||||
|
if (entry.hashtags) formData.append('hashtags', entry.hashtags);
|
||||||
|
|
||||||
|
await new Promise<void>((resolve, reject) => {
|
||||||
|
const xhr = new XMLHttpRequest();
|
||||||
|
xhr.open('POST', '/api/v1/upload');
|
||||||
|
xhr.setRequestHeader('Authorization', `Bearer ${token}`);
|
||||||
|
|
||||||
|
xhr.upload.addEventListener('progress', (e) => {
|
||||||
|
if (e.lengthComputable) {
|
||||||
|
const pct = Math.round((e.loaded / e.total) * 100);
|
||||||
|
queueItems.update((items) =>
|
||||||
|
items.map((item) => (item.id === id ? { ...item, progress: pct } : item))
|
||||||
|
);
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
xhr.addEventListener('load', () => {
|
||||||
|
if (xhr.status >= 200 && xhr.status < 300) {
|
||||||
|
resolve();
|
||||||
|
} else {
|
||||||
|
try {
|
||||||
|
const body = JSON.parse(xhr.responseText);
|
||||||
|
reject(new Error(body.message || `HTTP ${xhr.status}`));
|
||||||
|
} catch {
|
||||||
|
reject(new Error(`HTTP ${xhr.status}`));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
xhr.addEventListener('error', () => reject(new Error('Netzwerkfehler')));
|
||||||
|
xhr.addEventListener('abort', () => reject(new Error('Abgebrochen')));
|
||||||
|
xhr.send(formData);
|
||||||
|
});
|
||||||
|
|
||||||
|
// Success — remove blob from IndexedDB, mark done
|
||||||
|
entry.status = 'done';
|
||||||
|
delete entry.blob;
|
||||||
|
await database.put(STORE_NAME, entry);
|
||||||
|
updateItemStatus(id, 'done');
|
||||||
|
} catch (e) {
|
||||||
|
const msg = e instanceof Error ? e.message : 'Upload fehlgeschlagen.';
|
||||||
|
entry.status = 'error';
|
||||||
|
entry.error = msg;
|
||||||
|
await database.put(STORE_NAME, entry);
|
||||||
|
updateItemStatus(id, 'error', msg);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
function updateItemStatus(
|
||||||
|
id: string,
|
||||||
|
status: QueueItem['status'],
|
||||||
|
error?: string
|
||||||
|
): void {
|
||||||
|
queueItems.update((items) =>
|
||||||
|
items.map((item) =>
|
||||||
|
item.id === id
|
||||||
|
? {
|
||||||
|
...item,
|
||||||
|
status,
|
||||||
|
progress: status === 'done' ? 100 : status === 'error' ? item.progress : item.progress,
|
||||||
|
error
|
||||||
|
}
|
||||||
|
: item
|
||||||
|
)
|
||||||
|
);
|
||||||
|
}
|
||||||
79
frontend/src/routes/upload/+page.svelte
Normal file
79
frontend/src/routes/upload/+page.svelte
Normal file
@@ -0,0 +1,79 @@
|
|||||||
|
<script lang="ts">
|
||||||
|
import { goto } from '$app/navigation';
|
||||||
|
import { getToken } from '$lib/auth';
|
||||||
|
import { addToQueue, loadQueue } from '$lib/upload-queue';
|
||||||
|
import UploadQueue from '$lib/components/UploadQueue.svelte';
|
||||||
|
import { onMount } from 'svelte';
|
||||||
|
|
||||||
|
let caption = $state('');
|
||||||
|
let hashtags = $state('');
|
||||||
|
let fileInput: HTMLInputElement;
|
||||||
|
|
||||||
|
onMount(() => {
|
||||||
|
if (!getToken()) {
|
||||||
|
goto('/join');
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
loadQueue();
|
||||||
|
});
|
||||||
|
|
||||||
|
async function handleFiles() {
|
||||||
|
const files = fileInput?.files;
|
||||||
|
if (!files || files.length === 0) return;
|
||||||
|
|
||||||
|
for (const file of files) {
|
||||||
|
await addToQueue(file, caption, hashtags);
|
||||||
|
}
|
||||||
|
|
||||||
|
// Reset form
|
||||||
|
caption = '';
|
||||||
|
hashtags = '';
|
||||||
|
if (fileInput) fileInput.value = '';
|
||||||
|
}
|
||||||
|
</script>
|
||||||
|
|
||||||
|
<div class="min-h-screen bg-gray-50 p-4">
|
||||||
|
<div class="mx-auto max-w-lg">
|
||||||
|
<div class="mb-6 flex items-center justify-between">
|
||||||
|
<h1 class="text-xl font-bold text-gray-900">Hochladen</h1>
|
||||||
|
<a href="/feed" class="text-sm text-blue-600 hover:underline">Zur Galerie</a>
|
||||||
|
</div>
|
||||||
|
|
||||||
|
<div class="rounded-lg border border-gray-200 bg-white p-4">
|
||||||
|
<label
|
||||||
|
class="flex cursor-pointer flex-col items-center justify-center rounded-lg border-2 border-dashed border-gray-300 bg-gray-50 p-8 transition hover:border-blue-400 hover:bg-blue-50"
|
||||||
|
>
|
||||||
|
<svg class="mb-2 h-10 w-10 text-gray-400" fill="none" viewBox="0 0 24 24" stroke="currentColor">
|
||||||
|
<path stroke-linecap="round" stroke-linejoin="round" stroke-width="1.5" d="M12 16V4m0 0l-4 4m4-4l4 4M4 20h16" />
|
||||||
|
</svg>
|
||||||
|
<span class="text-sm font-medium text-gray-600">Fotos oder Videos auswählen</span>
|
||||||
|
<span class="mt-1 text-xs text-gray-400">Mehrere Dateien möglich</span>
|
||||||
|
<input
|
||||||
|
bind:this={fileInput}
|
||||||
|
type="file"
|
||||||
|
accept="image/*,video/*"
|
||||||
|
multiple
|
||||||
|
class="hidden"
|
||||||
|
onchange={handleFiles}
|
||||||
|
/>
|
||||||
|
</label>
|
||||||
|
|
||||||
|
<div class="mt-4 space-y-3">
|
||||||
|
<input
|
||||||
|
type="text"
|
||||||
|
bind:value={caption}
|
||||||
|
placeholder="Beschreibung (optional, #hashtags möglich)"
|
||||||
|
class="w-full rounded-lg border border-gray-300 px-3 py-2 text-sm focus:border-blue-500 focus:outline-none focus:ring-1 focus:ring-blue-200"
|
||||||
|
/>
|
||||||
|
<input
|
||||||
|
type="text"
|
||||||
|
bind:value={hashtags}
|
||||||
|
placeholder="Hashtags (kommagetrennt, z.B. hochzeit, party)"
|
||||||
|
class="w-full rounded-lg border border-gray-300 px-3 py-2 text-sm focus:border-blue-500 focus:outline-none focus:ring-1 focus:ring-blue-200"
|
||||||
|
/>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
|
||||||
|
<UploadQueue />
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
Reference in New Issue
Block a user