' +
- '
' +
- '' + esc(catLabel) + ' ' +
- '
' +
- '
' + esc(preview) + (m.content && m.content.length > 120 ? '...' : '') + '
' +
+ var preview = (m.name || '').replace(/\n/g, ' ');
+ // Parse original and corrected from content
+ var parts = parseCorrection(m.content || '');
+ var date = m.created_at ? new Date(m.created_at).toLocaleDateString() : '';
+ return '
' +
+ '' +
+ '
' +
+ '
' +
+ '
Original (AI generated):
' +
+ '
' + esc(parts.original) + '
' +
+ '
' +
+ '
' +
+ '
Corrected to:
' +
+ '
' + esc(parts.corrected) + '
' +
+ '
' +
'
' +
- '
' +
'
';
}).join('');
- container.querySelectorAll('.correction-delete-btn').forEach(function(btn) {
- btn.addEventListener('click', function() { deleteMemory(parseInt(btn.dataset.id)); });
+
+ // Toggle expand/collapse
+ container.querySelectorAll('.correction-header').forEach(function(header) {
+ header.addEventListener('click', function(e) {
+ if (e.target.closest('.correction-delete-btn')) return;
+ var id = header.dataset.toggle;
+ var detail = document.getElementById('detail-' + id);
+ var arrow = document.getElementById('arrow-' + id);
+ if (detail) {
+ detail.classList.toggle('hidden');
+ if (arrow) arrow.style.transform = detail.classList.contains('hidden') ? '' : 'rotate(90deg)';
+ }
+ });
});
+
+ container.querySelectorAll('.correction-delete-btn').forEach(function(btn) {
+ btn.addEventListener('click', function(e) {
+ e.stopPropagation();
+ deleteMemory(parseInt(btn.dataset.id));
+ });
+ });
+ }
+
+ function parseCorrection(content) {
+ var original = '';
+ var corrected = '';
+ var idx = content.indexOf('\nCORRECTED TO: ');
+ if (idx !== -1) {
+ original = content.substring(0, idx).replace(/^ORIGINAL:\s*/i, '');
+ corrected = content.substring(idx + '\nCORRECTED TO: '.length);
+ } else {
+ original = content;
+ }
+ return { original: original.trim(), corrected: corrected.trim() };
}
// ── Save memory ──────────────────────────────────────────────────────────
diff --git a/server.js b/server.js
index 479aece..09af021 100644
--- a/server.js
+++ b/server.js
@@ -167,6 +167,7 @@ app.use('/api', require('./src/routes/logs'));
app.use('/api', require('./src/routes/encounters'));
app.use('/api', require('./src/routes/memories'));
app.use('/api', require('./src/routes/documents'));
+app.use('/api', require('./src/routes/audioBackups'));
app.use('/api', require('./src/routes/wellVisit'));
app.use('/api', require('./src/routes/sickVisit'));
app.use('/api/admin/learning', require('./src/routes/learningAI'));
diff --git a/src/db/database.js b/src/db/database.js
index 56a7257..ea25245 100644
--- a/src/db/database.js
+++ b/src/db/database.js
@@ -217,6 +217,23 @@ async function initDatabase() {
// Add idempotency_key for duplicate prevention
try { await client.query("ALTER TABLE saved_encounters ADD COLUMN IF NOT EXISTS idempotency_key TEXT"); } catch(e) {}
try { await client.query("CREATE UNIQUE INDEX IF NOT EXISTS idx_saved_enc_idemp ON saved_encounters(user_id, idempotency_key) WHERE idempotency_key IS NOT NULL"); } catch(e) {}
+ // Audio backups table — server-side, auto-deleted after 24 hours
+ try { await client.query(`
+ CREATE TABLE IF NOT EXISTS audio_backups (
+ id SERIAL PRIMARY KEY,
+ user_id INTEGER REFERENCES users(id) ON DELETE CASCADE,
+ module TEXT NOT NULL DEFAULT 'encounter',
+ mime_type TEXT DEFAULT 'audio/webm',
+ size_bytes INTEGER DEFAULT 0,
+ compressed_bytes INTEGER DEFAULT 0,
+ audio_data BYTEA NOT NULL,
+ created_at TIMESTAMPTZ DEFAULT NOW(),
+ expires_at TIMESTAMPTZ DEFAULT NOW() + INTERVAL '24 hours'
+ );
+ CREATE INDEX IF NOT EXISTS idx_audio_backups_user ON audio_backups(user_id);
+ CREATE INDEX IF NOT EXISTS idx_audio_backups_expires ON audio_backups(expires_at);
+ `); } catch(e) {}
+
// User documents table for S3 storage
try { await client.query(`
CREATE TABLE IF NOT EXISTS user_documents (
@@ -270,15 +287,19 @@ async function initDatabase() {
initDatabase();
-// Clean up expired saved encounters daily
-async function cleanupExpiredEncounters() {
+// Clean up expired saved encounters and audio backups
+async function cleanupExpired() {
try {
- var result = await pool.query('DELETE FROM saved_encounters WHERE expires_at < NOW()');
- if (result.rowCount > 0) console.log('[DB] Cleaned up ' + result.rowCount + ' expired encounters');
- } catch(e) { console.error('[DB] Cleanup error:', e.message); }
+ var enc = await pool.query('DELETE FROM saved_encounters WHERE expires_at < NOW()');
+ if (enc.rowCount > 0) console.log('[DB] Cleaned up ' + enc.rowCount + ' expired encounters');
+ } catch(e) { console.error('[DB] Encounter cleanup error:', e.message); }
+ try {
+ var audio = await pool.query('DELETE FROM audio_backups WHERE expires_at < NOW()');
+ if (audio.rowCount > 0) console.log('[DB] Cleaned up ' + audio.rowCount + ' expired audio backups');
+ } catch(e) { /* table may not exist yet */ }
}
-setInterval(cleanupExpiredEncounters, 6 * 60 * 60 * 1000); // every 6 hours
-setTimeout(cleanupExpiredEncounters, 10000); // also run 10s after startup
+setInterval(cleanupExpired, 60 * 60 * 1000); // every hour (audio backups are 24h)
+setTimeout(cleanupExpired, 10000); // also run 10s after startup
// Query helpers
var db = {
diff --git a/src/routes/audioBackups.js b/src/routes/audioBackups.js
new file mode 100644
index 0000000..a1c895c
--- /dev/null
+++ b/src/routes/audioBackups.js
@@ -0,0 +1,93 @@
+// ============================================================
+// AUDIO BACKUPS ROUTES — Server-side audio backup storage
+// Stores compressed audio in PostgreSQL, auto-deletes after 24h
+// ============================================================
+
+var express = require('express');
+var router = express.Router();
+var zlib = require('zlib');
+var multer = require('multer');
+var db = require('../db/database');
+var { authMiddleware } = require('../middleware/auth');
+
+// 25MB upload limit (same as transcribe)
+var upload = multer({ storage: multer.memoryStorage(), limits: { fileSize: 25 * 1024 * 1024 } });
+
+router.use(authMiddleware);
+
+// ── POST save audio backup (compressed) ──────────────────────────────────
+router.post('/audio-backups', upload.single('audio'), async function(req, res) {
+ try {
+ if (!req.file) return res.status(400).json({ error: 'No audio file' });
+
+ var module = req.body.module || 'encounter';
+ var originalSize = req.file.size;
+
+ // Gzip compress the audio data
+ var compressed = await new Promise(function(resolve, reject) {
+ zlib.gzip(req.file.buffer, { level: 6 }, function(err, result) {
+ if (err) reject(err); else resolve(result);
+ });
+ });
+
+ var result = await db.run(
+ 'INSERT INTO audio_backups (user_id, module, mime_type, size_bytes, compressed_bytes, audio_data) VALUES ($1,$2,$3,$4,$5,$6)',
+ [req.user.id, module, req.file.mimetype || 'audio/webm', originalSize, compressed.length, compressed]
+ );
+
+ var ratio = originalSize > 0 ? Math.round((1 - compressed.length / originalSize) * 100) : 0;
+ console.log('[AudioBackup] Saved ' + (originalSize / 1024).toFixed(0) + 'KB → ' + (compressed.length / 1024).toFixed(0) + 'KB (' + ratio + '% compression)');
+
+ res.json({ success: true, id: result.lastInsertRowid, originalSize: originalSize, compressedSize: compressed.length });
+ } catch (e) {
+ console.error('[AudioBackup] Save error:', e.message);
+ res.status(500).json({ error: e.message });
+ }
+});
+
+// ── GET list audio backups ───────────────────────────────────────────────
+router.get('/audio-backups', async function(req, res) {
+ try {
+ var rows = await db.all(
+ "SELECT id, module, mime_type, size_bytes, compressed_bytes, created_at, expires_at FROM audio_backups WHERE user_id = $1 AND expires_at > NOW() ORDER BY created_at DESC",
+ [req.user.id]
+ );
+ res.json({ success: true, backups: rows });
+ } catch (e) { res.status(500).json({ error: e.message }); }
+});
+
+// ── GET download audio backup (decompressed) ─────────────────────────────
+router.get('/audio-backups/:id/audio', async function(req, res) {
+ try {
+ var row = await db.get(
+ 'SELECT audio_data, mime_type, size_bytes FROM audio_backups WHERE id = $1 AND user_id = $2 AND expires_at > NOW()',
+ [req.params.id, req.user.id]
+ );
+ if (!row) return res.status(404).json({ error: 'Backup not found or expired' });
+
+ // Decompress
+ var decompressed = await new Promise(function(resolve, reject) {
+ zlib.gunzip(row.audio_data, function(err, result) {
+ if (err) reject(err); else resolve(result);
+ });
+ });
+
+ res.setHeader('Content-Type', row.mime_type || 'audio/webm');
+ res.setHeader('Content-Length', decompressed.length);
+ res.send(decompressed);
+ } catch (e) { res.status(500).json({ error: e.message }); }
+});
+
+// ── DELETE audio backup ──────────────────────────────────────────────────
+router.delete('/audio-backups/:id', async function(req, res) {
+ try {
+ var result = await db.run(
+ 'DELETE FROM audio_backups WHERE id = $1 AND user_id = $2',
+ [req.params.id, req.user.id]
+ );
+ if (result.changes === 0) return res.status(404).json({ error: 'Not found' });
+ res.json({ success: true });
+ } catch (e) { res.status(500).json({ error: e.message }); }
+});
+
+module.exports = router;