3 Commits
Author SHA1 Message Date
u80864958 b4e8baabdc fix: language change
/ publish (push) Successful in 1m19s
2026-01-23 14:41:52 +01:00
u80864958 ab3c8982e2 feat: lru cache 2026-01-23 14:32:51 +01:00
u80864958 df9e6e95cb feat: cache images 2026-01-23 13:50:40 +01:00
6 changed files with 229 additions and 130 deletions
+1
View File
@@ -30,6 +30,7 @@
"@inlang/paraglide-js": "^1.11.0", "@inlang/paraglide-js": "^1.11.0",
"@inlang/paraglide-sveltekit": "^0.16.1", "@inlang/paraglide-sveltekit": "^0.16.1",
"@ts-stack/markdown": "^1.5.0", "@ts-stack/markdown": "^1.5.0",
"lru-cache": "^11.2.4",
"mime-types": "^3.0.2", "mime-types": "^3.0.2",
"svelte-preprocess": "^6.0.2", "svelte-preprocess": "^6.0.2",
"webdav": "^5.8.0" "webdav": "^5.8.0"
+9
View File
@@ -20,6 +20,9 @@ importers:
'@ts-stack/markdown': '@ts-stack/markdown':
specifier: ^1.5.0 specifier: ^1.5.0
version: 1.5.0 version: 1.5.0
lru-cache:
specifier: ^11.2.4
version: 11.2.4
mime-types: mime-types:
specifier: ^3.0.2 specifier: ^3.0.2
version: 3.0.2 version: 3.0.2
@@ -1269,6 +1272,10 @@ packages:
resolution: {integrity: sha512-9hp3Vp2/hFQUiIwKo8XCeFVnrg8Pk3TYNPIR7tJADKi5YfcF7vEaK7avFHTlSy3kOKYaJQaalfEo6YuXdceBOQ==} resolution: {integrity: sha512-9hp3Vp2/hFQUiIwKo8XCeFVnrg8Pk3TYNPIR7tJADKi5YfcF7vEaK7avFHTlSy3kOKYaJQaalfEo6YuXdceBOQ==}
engines: {node: 14 || >=16.14} engines: {node: 14 || >=16.14}
lru-cache@11.2.4:
resolution: {integrity: sha512-B5Y16Jr9LB9dHVkh6ZevG+vAbOsNOYCX+sXvFWFu7B3Iz5mijW3zdbMyhsh8ANd2mSWBYdJgnqi+mL7/LrOPYg==}
engines: {node: 20 || >=22}
magic-string@0.30.10: magic-string@0.30.10:
resolution: {integrity: sha512-iIRwTIf0QKV3UAnYK4PU8uiEc4SRh5jX0mwpIwETPpHdhVM4f53RSwS/vXvN1JhGX+Cs7B8qIq3d6AH49O5fAQ==} resolution: {integrity: sha512-iIRwTIf0QKV3UAnYK4PU8uiEc4SRh5jX0mwpIwETPpHdhVM4f53RSwS/vXvN1JhGX+Cs7B8qIq3d6AH49O5fAQ==}
@@ -2988,6 +2995,8 @@ snapshots:
lru-cache@10.2.2: {} lru-cache@10.2.2: {}
lru-cache@11.2.4: {}
magic-string@0.30.10: magic-string@0.30.10:
dependencies: dependencies:
'@jridgewell/sourcemap-codec': 1.4.15 '@jridgewell/sourcemap-codec': 1.4.15
+50 -6
View File
@@ -1,5 +1,44 @@
const cache = new Map<string, { timestamp: number; data: any }>(); import { LRUCache } from "lru-cache";
// const cache = new Map<string, { timestamp: number; data: any }>();
const DEFAULT_TTL = 1000 * 60 * 15; // 15 minutes default TTL const DEFAULT_TTL = 1000 * 60 * 15; // 15 minutes default TTL
const MAX_CACHE_SIZE = 1000 * 1000 * 750; // 750 MB
const cache = new LRUCache({
max: 100,
// Maximum allowed size (in bytes)
maxSize: MAX_CACHE_SIZE,
// IMPORTANT: We must teach the cache how to calculate the size of an item.
// We check for your specific image structure, generic buffers, or fallback to JSON length.
sizeCalculation: (value) => {
// 1. Check if it's our specific image object { buffer: ArrayBuffer, ... }
if (value && typeof value === "object") {
const obj = value as Record<string, any>;
if (obj.buffer instanceof ArrayBuffer) {
return obj.buffer.byteLength;
}
}
// 2. Handle raw ArrayBuffers or Node.js Buffers
if (value instanceof ArrayBuffer) {
return value.byteLength;
}
if (Buffer.isBuffer(value)) {
return value.length;
}
// 3. Fallback for strings or JSON metadata
try {
const str = JSON.stringify(value);
return str ? str.length : 1;
} catch {
return 1;
}
},
ttl: DEFAULT_TTL,
});
/** /**
* Caches the result of a promise-returning function. * Caches the result of a promise-returning function.
@@ -7,17 +46,22 @@ const DEFAULT_TTL = 1000 * 60 * 15; // 15 minutes default TTL
* @param fetcher Function that returns a promise with the data to cache. * @param fetcher Function that returns a promise with the data to cache.
* @param ttl Time to live in milliseconds. Defaults to 15 minutes. * @param ttl Time to live in milliseconds. Defaults to 15 minutes.
*/ */
export async function withCache<T>(key: string, fetcher: () => Promise<T>, ttl = DEFAULT_TTL): Promise<T> { export async function withCache<T>(
const now = Date.now(); key: string,
fetcher: () => Promise<T>,
ttl = DEFAULT_TTL,
): Promise<T> {
const entry = cache.get(key); const entry = cache.get(key);
if (entry && (now - entry.timestamp < ttl)) { if (entry) {
return entry.data as T; return entry as T;
} }
try { try {
const data = await fetcher(); const data = await fetcher();
cache.set(key, { timestamp: now, data }); if (data) {
cache.set(key, data, { ttl: ttl });
}
return data; return data;
} catch (error) { } catch (error) {
console.error(`Error fetching data for key ${key}:`, error); console.error(`Error fetching data for key ${key}:`, error);
+20 -11
View File
@@ -1,10 +1,11 @@
<script lang="ts"> <script lang="ts">
import "../app.css"; import "../app.css";
import type { Snippet } from 'svelte'; import type { Snippet } from "svelte";
import { ParaglideJS } from '@inlang/paraglide-sveltekit'; import { ParaglideJS } from "@inlang/paraglide-sveltekit";
import { i18n } from '$lib/i18n'; import { i18n } from "$lib/i18n";
import { languageTag } from '$lib/paraglide/runtime'; import { languageTag } from "$lib/paraglide/runtime";
import * as m from '$lib/paraglide/messages'; import { page } from "$app/state";
import * as m from "$lib/paraglide/messages";
let { children }: { children?: Snippet } = $props(); let { children }: { children?: Snippet } = $props();
</script> </script>
@@ -15,22 +16,30 @@
</svelte:head> </svelte:head>
<ParaglideJS {i18n}> <ParaglideJS {i18n}>
<header class="fixed z-50 mix-blend-difference p-1 w-full flex justify-between items-start"> <header
<a href="/" class="text-white text-2xl">schreifuchs.ch</a> class="fixed z-50 mix-blend-difference p-1 w-full flex justify-between items-start"
>
<a href={i18n.resolveRoute("/")} class="text-white text-2xl"
>schreifuchs.ch</a
>
<nav class="flex gap-2 p-2"> <nav class="flex gap-2 p-2">
<a <a
href="/" href={i18n.resolveRoute(i18n.route(page.url.pathname), "de")}
hreflang="de" hreflang="de"
data-no-translate data-no-translate
class="text-white hover:underline {languageTag() === 'de' ? 'font-bold' : ''}" class="text-white hover:underline {languageTag() === 'de'
? 'font-bold'
: ''}"
> >
DE DE
</a> </a>
<a <a
href="/en" href={i18n.resolveRoute(i18n.route(page.url.pathname), "en")}
hreflang="en" hreflang="en"
data-no-translate data-no-translate
class="text-white hover:underline {languageTag() === 'en' ? 'font-bold' : ''}" class="text-white hover:underline {languageTag() === 'en'
? 'font-bold'
: ''}"
> >
EN EN
</a> </a>
+2 -1
View File
@@ -23,7 +23,7 @@
// Helper to resolve image source: Local override -> Nextcloud cover -> Placeholder (handled by ImageTile) // Helper to resolve image source: Local override -> Nextcloud cover -> Placeholder (handled by ImageTile)
const getTileImage = (page: { slug: string; coverImage: string | null }) => { const getTileImage = (page: { slug: string; coverImage: string | null }) => {
return staticImages[page.slug.toLowerCase()] || page.coverImage || ""; return page.coverImage || staticImages[page.slug.toLowerCase()] || "";
}; };
</script> </script>
@@ -47,3 +47,4 @@
</h2> </h2>
</ImageLinkTile> </ImageLinkTile>
</main> </main>
+74 -39
View File
@@ -1,8 +1,19 @@
// src/routes/assets/[...path]/+server.ts
import { client } from "$lib/server/nextcloud"; import { client } from "$lib/server/nextcloud";
import { error } from "@sveltejs/kit"; import { error } from "@sveltejs/kit";
import type { RequestHandler } from "./$types"; import type { RequestHandler } from "./$types";
import mime from "mime-types"; import mime from "mime-types";
import { env } from "$env/dynamic/private"; import { env } from "$env/dynamic/private";
import { withCache } from "$lib/server/cache";
const DEFAULT_TTL = 1000 * 60 * 15; // 15min
const EXTENDED_TTL = 1000 * 60 * 60 * 24 * 7; // 1 week
// Define what we are storing in the cache
type CachedAsset = {
buffer: ArrayBuffer;
contentType: string;
};
export const GET: RequestHandler = async ({ params, url }) => { export const GET: RequestHandler = async ({ params, url }) => {
const { path } = params; const { path } = params;
@@ -13,80 +24,91 @@ export const GET: RequestHandler = async ({ params, url }) => {
throw error(400, "Path is required"); throw error(400, "Path is required");
} }
// 1. Create a unique cache key for this specific asset variation
const cacheKey = `asset:${path}?w=${width ?? ""}&h=${height ?? ""}`;
const ttl = path.toString().includes("cover") ? DEFAULT_TTL : EXTENDED_TTL;
try { try {
let buffer: ArrayBuffer; // 2. Use withCache to wrap the fetching logic
let contentType: string; const cachedData = await withCache<CachedAsset>(
cacheKey,
async () => {
// --- START OF FETCH LOGIC ---
// This function only runs if the data is NOT in the cache
// Try both original path and hidden variant if applicable
const pathsToTry = [path]; const pathsToTry = [path];
if (!path.startsWith('_')) { if (!path.startsWith("_")) {
pathsToTry.push(`_${path}`); pathsToTry.push(`_${path}`);
} }
let response: Response | null = null;
let lastError: any = null; let lastError: any = null;
for (const currentPath of pathsToTry) { for (const currentPath of pathsToTry) {
try { try {
// A. Try Nextcloud Preview (Resizing)
if (width || height) { if (width || height) {
// Use Nextcloud Preview API const baseUrl = env.NEXTCLOUD_URL?.endsWith("/")
const baseUrl = env.NEXTCLOUD_URL?.endsWith("/") ? env.NEXTCLOUD_URL : `${env.NEXTCLOUD_URL}/`; ? env.NEXTCLOUD_URL
: `${env.NEXTCLOUD_URL}/`;
let fullPath = currentPath; let fullPath = currentPath;
if (env.NEXTCLOUD_BASE_DIR) { if (env.NEXTCLOUD_BASE_DIR) {
const baseDir = env.NEXTCLOUD_BASE_DIR.replace(/^\/+|\/+$/g, ""); const baseDir = env.NEXTCLOUD_BASE_DIR.replace(
/^\/+|\/+$/g,
"",
);
fullPath = baseDir ? `${baseDir}/${currentPath}` : currentPath; fullPath = baseDir ? `${baseDir}/${currentPath}` : currentPath;
} }
const isJpg = fullPath.match(/\.(jpg|jpeg)$/i); const isJpg = fullPath.match(/\.(jpg|jpeg)$/i);
const previewExtension = isJpg ? 'jpg' : 'png'; const previewExtension = isJpg ? "jpg" : "png";
const previewUrl = new URL(`${baseUrl}index.php/core/preview.${previewExtension}`); const previewUrl = new URL(
// Ensure leading slash for the file parameter `${baseUrl}index.php/core/preview.${previewExtension}`,
const fileParam = fullPath.startsWith('/') ? fullPath : `/${fullPath}`; );
const fileParam = fullPath.startsWith("/")
? fullPath
: `/${fullPath}`;
previewUrl.searchParams.set("file", fileParam); previewUrl.searchParams.set("file", fileParam);
if (width) previewUrl.searchParams.set("x", width); if (width) previewUrl.searchParams.set("x", width);
if (height) previewUrl.searchParams.set("y", height); if (height) previewUrl.searchParams.set("y", height);
previewUrl.searchParams.set("forceIcon", "0"); previewUrl.searchParams.set("forceIcon", "0");
const auth = Buffer.from(`${env.NEXTCLOUD_USER}:${env.NEXTCLOUD_PASSWORD}`).toString("base64"); const auth = Buffer.from(
`${env.NEXTCLOUD_USER}:${env.NEXTCLOUD_PASSWORD}`,
).toString("base64");
console.log(`Fetching preview: ${previewUrl.toString()} for file: ${fullPath}`); console.log(
`Fetching preview: ${previewUrl.toString()} for file: ${fullPath}`,
);
const ncResponse = await fetch(previewUrl.toString(), { const ncResponse = await fetch(previewUrl.toString(), {
headers: { headers: { Authorization: `Basic ${auth}` },
"Authorization": `Basic ${auth}`
}
}); });
if (ncResponse.ok) { if (ncResponse.ok) {
buffer = await ncResponse.arrayBuffer(); const buffer = await ncResponse.arrayBuffer();
contentType = ncResponse.headers.get("Content-Type") || "image/png"; const contentType =
ncResponse.headers.get("Content-Type") || "image/png";
return new Response(buffer, { // Return the raw data to be cached
headers: { return { buffer, contentType };
"Content-Type": contentType,
"Cache-Control": "public, max-age=86400",
"Vary": "Accept-Encoding"
}
});
} else { } else {
console.warn(`Nextcloud preview failed (${ncResponse.status}) for ${fullPath}.`); console.warn(
`Nextcloud preview failed (${ncResponse.status}) for ${fullPath}.`,
);
} }
} }
// Fetch original via WebDAV (Fallback or no resize requested) // B. Try WebDAV (Original)
console.log(`Fetching original file via WebDAV: /${currentPath}`); console.log(`Fetching original file via WebDAV: /${currentPath}`);
const data = await client.getFileContents("/" + currentPath); const data = await client.getFileContents("/" + currentPath);
buffer = data as ArrayBuffer; const buffer = data as ArrayBuffer;
contentType = mime.lookup(currentPath) || "application/octet-stream"; const contentType =
mime.lookup(currentPath) || "application/octet-stream";
return new Response(buffer, { // Return the raw data to be cached
headers: { return { buffer, contentType };
"Content-Type": contentType,
"Cache-Control": "public, max-age=86400",
"Vary": "Accept-Encoding"
}
});
} catch (e) { } catch (e) {
lastError = e; lastError = e;
continue; // Try next path variant continue; // Try next path variant
@@ -94,8 +116,21 @@ export const GET: RequestHandler = async ({ params, url }) => {
} }
throw lastError || new Error("Asset not found"); throw lastError || new Error("Asset not found");
// --- END OF FETCH LOGIC ---
},
ttl,
);
// 3. Construct a fresh Response using the cached data
return new Response(cachedData.buffer, {
headers: {
"Content-Type": cachedData.contentType,
"Cache-Control": "public, max-age=86400", // Browser cache
Vary: "Accept-Encoding",
},
});
} catch (e) { } catch (e) {
console.error(`Error fetching asset from Nextcloud: ${path}`, e); console.error(`Error fetching asset: ${path}`, e);
throw error(404, "Asset not found"); throw error(404, "Asset not found");
} }
}; };