A new episode file has arrived in Seafile.
+| Source | ${escapeHtml(sourceLabel)} |
| Host | ${escapeHtml(hostName)} |
| Episode | ${escapeHtml(episodeName)} |
| Passage | ${escapeHtml(passage)} |
| Audio File | ${escapeHtml(filename)} |
| Info File | ${escapeHtml(infoFile)} |
Description:
${escapeHtml(description).replace(/\n/g, '
')}
This notification was sent because a file was uploaded to the Nuggets Seafile library.
', + }), + }) + if (error) console.error('[nuggets-notify] send error:', error) + } catch (err) { + console.error('[nuggets-notify] send exception:', err) + } +} diff --git a/server/nuggets-seafile-watcher.js b/server/nuggets-seafile-watcher.js new file mode 100644 index 0000000..d8dcdf0 --- /dev/null +++ b/server/nuggets-seafile-watcher.js @@ -0,0 +1,93 @@ +import { readFile, writeFile } from 'node:fs/promises' +import { sendNuggetsUploadNotification } from './email.js' +import { + SEAFILE_URL, + SEAFILE_TOKEN, + SEAFILE_NUGGETS_REPO_ID, + SEAFILE_EPISODE_UPLOAD_DIR, + SEAFILE_EPISODE_INFO_DIR, + SEAFILE_POLL_INTERVAL_MS, + NUGGETS_SEAFILE_SEEN_FILE, + NUGGETS_NOTIFY_EMAIL, +} from './config.js' + +async function loadSeen() { + try { + return JSON.parse(await readFile(NUGGETS_SEAFILE_SEEN_FILE, 'utf8')) + } catch { + return { files: [] } + } +} + +async function saveSeen(data) { + await writeFile(NUGGETS_SEAFILE_SEEN_FILE, JSON.stringify(data, null, 2), 'utf8') +} + +// Called by the upload route after a successful portal upload so the poller +// doesn't also fire a notification for the same file. +export async function markSeafileFileSeen(filename) { + const data = await loadSeen() + if (!data.files.includes(filename)) { + data.files.push(filename) + await saveSeen(data) + } +} + +async function listSeafileDir(dir) { + if (!SEAFILE_URL || !SEAFILE_TOKEN || !SEAFILE_NUGGETS_REPO_ID) return [] + try { + const url = `${SEAFILE_URL}/api/v2.1/repos/${SEAFILE_NUGGETS_REPO_ID}/dir/?p=${encodeURIComponent(dir)}` + const res = await fetch(url, { + headers: { Authorization: `Token ${SEAFILE_TOKEN}` }, + signal: AbortSignal.timeout(10_000), + }) + if (!res.ok) return [] + const data = await res.json() + return (data.dirent ?? []).filter(e => e.type === 'file').map(e => e.name) + } catch { + return [] + } +} + +async function poll() { + if (!SEAFILE_URL || !SEAFILE_TOKEN || !SEAFILE_NUGGETS_REPO_ID) return + + const [uploadFiles, seen] = await Promise.all([ + listSeafileDir(SEAFILE_EPISODE_UPLOAD_DIR), + loadSeen(), + ]) + + const seenSet = new Set(seen.files) + const newFiles = uploadFiles.filter(f => !seenSet.has(f)) + + if (newFiles.length === 0) return + + for (const filename of newFiles) { + console.log(`[nuggets-watcher] new direct upload detected: ${filename}`) + await sendNuggetsUploadNotification({ + to: NUGGETS_NOTIFY_EMAIL, + source: 'direct', + filename, + }) + seenSet.add(filename) + } + + seen.files = [...seenSet] + await saveSeen(seen) +} + +export function startNuggetsSeafileWatcher() { + if (!SEAFILE_URL || !SEAFILE_TOKEN || !SEAFILE_NUGGETS_REPO_ID) { + console.log('[nuggets-watcher] Seafile not configured — watcher disabled.') + return + } + // Initial poll after 2 min (let the server settle), then every 15 min + setTimeout(() => { + poll().catch(err => console.error('[nuggets-watcher] poll error:', err)) + setInterval(() => { + poll().catch(err => console.error('[nuggets-watcher] poll error:', err)) + }, SEAFILE_POLL_INTERVAL_MS) + }, 2 * 60 * 1000) + + console.log(`[nuggets-watcher] started — polling every ${SEAFILE_POLL_INTERVAL_MS / 60000} min`) +} diff --git a/server/routes/nuggets-host-upload.js b/server/routes/nuggets-host-upload.js index ab50f25..fb642b1 100644 --- a/server/routes/nuggets-host-upload.js +++ b/server/routes/nuggets-host-upload.js @@ -6,8 +6,11 @@ import rateLimit from 'express-rate-limit' import { createHash, timingSafeEqual } from 'node:crypto' import { parseCookies, cookieSecureFlag } from '../helpers.js' import { requireAdminAuth } from '../auth.js' +import { sendNuggetsUploadNotification } from '../email.js' +import { markSeafileFileSeen } from '../nuggets-seafile-watcher.js' import { NUGGETS_UPLOAD_HOSTS_FILE, + NUGGETS_NOTIFY_EMAIL, SEAFILE_URL, SEAFILE_TOKEN, SEAFILE_NUGGETS_REPO_ID, @@ -241,6 +244,22 @@ export function register(app) { await uploadToSeafile(infoLink, infoBuffer, infoFilename, SEAFILE_EPISODE_INFO_DIR) console.log(`[nuggets-upload] ${session?.hostName ?? 'unknown'} uploaded "${episodeName}" (${originalName})`) + + // Mark audio file as seen so the Seafile watcher doesn't double-notify + await markSeafileFileSeen(originalName) + + // Send admin notification (fire-and-forget) + sendNuggetsUploadNotification({ + to: NUGGETS_NOTIFY_EMAIL, + source: 'portal', + hostName: session?.hostName ?? '', + episodeName, + passage, + description, + filename: originalName, + infoFile: infoFilename, + }).catch(err => console.error('[nuggets-upload] notify error:', err)) + res.json({ ok: true, episodeName, filename: originalName, infoFile: infoFilename }) } catch (err) { await unlink(tempPath).catch(() => {})