Spaces:

vectorplasticity
/

social-server

Sleeping

App Files Files Community

vectorplasticity commited on Jun 26

Commit

a00f3fc

verified ·

1 Parent(s): b690638

Update server.js

Browse files

Files changed (1) hide show

server.js +97 -244

server.js CHANGED Viewed

@@ -14,13 +14,12 @@
  *
  * Deploy:
  *   1. Create Space → Docker SDK
- *   2. Push this file + Dockerfile.hf
- *   3. Set port to 7860 (already default)
- *   4. Your Space URL becomes the endpoint!
  *
- *   Read:  https://USER-REPO.hf.space/blobs.jsonl
- *   Write: https://USER-REPO.hf.space/submit
- *   Web:   https://USER-REPO.hf.space/
  */
 const http = require('http');
@@ -31,26 +30,19 @@ const urlMod = require('url');
 // ─── Configuration ───────────────────────────────────────────────────
 const PORT = parseInt(process.env.PORT) || 7860;
-// HuggingFace Spaces mounts a persistent volume at /data
-let DATA_DIR = '/data';
-let BLOBS_FILE = path.join(DATA_DIR, 'blobs.jsonl');
 // ─── Initialize ──────────────────────────────────────────────────────
-if (!fs.existsSync(DATA_DIR)) {
-  // Fallback to local ./data if /data doesn't exist (local dev)
-  DATA_DIR = path.join(__dirname, 'data');
-  BLOBS_FILE = path.join(DATA_DIR, 'blobs.jsonl');
-  console.warn('⚠️ /data volume not found — using local ./data instead');
-}
 if (!fs.existsSync(DATA_DIR)) {
   fs.mkdirSync(DATA_DIR, { recursive: true });
-  console.log(`📁 Created data directory: ${DATA_DIR}`);
-} else {
-  console.log(`📁 Using HuggingFace persistent volume: ${DATA_DIR}`);
 }
-// ─── Helper: get message count ──────────────────────────────────────
 function getStats() {
   if (!fs.existsSync(BLOBS_FILE)) {
     return { messages: 0, size_bytes: 0, size_human: '0 B' };
@@ -83,176 +75,80 @@ function renderDashboard() {
         const idShort = entry.id ? entry.id.substring(0, 16) + '...' : '?';
         const time = entry.ts ? new Date(entry.ts).toLocaleString() : '?';
         const blobSize = entry.blob ? (entry.blob.length / 1024).toFixed(1) + ' KB' : '?';
-        return `<tr>
-          <td>${idShort}</td>
-          <td>${time}</td>
-          <td>${blobSize}</td>
-        </tr>`;
       } catch {
-        return `<tr><td colspan="3" style="color:var(--red)">⚠️ Malformed line</td></tr>`;
       }
     }).join('');
   }
   return `<!DOCTYPE html>
 <html lang="en">
-<head>
-<meta charset="UTF-8">
-<meta name="viewport" content="width=device-width,initial-scale=1">
 <title>🔐 SocialCrypt — HuggingFace Endpoint</title>
 <style>
-  :root {
-    --bg: #0d1117; --card: #161b22; --border: #30363d;
-    --text: #e6edf3; --dim: #8b949e; --accent: #58a6ff;
-    --green: #3fb950; --orange: #d29922; --red: #f85149;
-  }
-  * { box-sizing: border-box; margin: 0; padding: 0; }
-  body {
-    background: var(--bg); color: var(--text);
-    font-family: -apple-system, BlinkMacSystemFont, 'Segoe UI', system-ui, sans-serif;
-    line-height: 1.6; padding: 20px;
-  }
-  .container { max-width: 800px; margin: 0 auto; }
-  .hero {
-    text-align: center; padding: 40px 20px;
-    border-bottom: 1px solid var(--border); margin-bottom: 24px;
-  }
-  .hero h1 { font-size: 2.5rem; }
-  .hero h1 span { color: var(--accent); }
-  .hero p { color: var(--dim); margin-top: 8px; font-size: 1.1rem; }
-  .hero .hf-badge {
-    display: inline-block; margin-top: 12px;
-    padding: 4px 16px; border-radius: 999px;
-    background: rgba(255, 152, 0, 0.15); color: #ff9800;
-    font-size: 0.85rem; font-weight: 600;
-  }
-  .card {
-    background: var(--card); border: 1px solid var(--border);
-    border-radius: 12px; padding: 24px; margin-bottom: 16px;
-  }
-  .card h2 { font-size: 1.2rem; margin-bottom: 16px; }
-  .stat-grid {
-    display: grid; grid-template-columns: repeat(3, 1fr); gap: 12px;
-  }
-  .stat-box {
-    text-align: center; padding: 16px;
-    background: var(--bg); border: 1px solid var(--border);
-    border-radius: 8px;
-  }
-  .stat-box .num { font-size: 2rem; font-weight: 700; color: var(--accent); }
-  .stat-box .label { font-size: 0.82rem; color: var(--dim); margin-top: 4px; }
-  .endpoint-list { list-style: none; }
-  .endpoint-list li {
-    display: flex; align-items: center; gap: 8px;
-    padding: 12px; margin-bottom: 8px;
-    background: var(--bg); border: 1px solid var(--border);
-    border-radius: 8px; font-family: 'SF Mono', 'Fira Code', monospace;
-    font-size: 0.85rem; word-break: break-all;
-  }
-  .endpoint-list .method {
-    display: inline-block; padding: 2px 8px; border-radius: 4px;
-    font-size: 0.75rem; font-weight: 700; flex-shrink: 0;
-  }
-  .method.get { background: rgba(88, 166, 255, 0.15); color: var(--accent); }
-  .method.post { background: rgba(63, 185, 80, 0.15); color: var(--green); }
-  table { width: 100%; border-collapse: collapse; }
-  th {
-    text-align: left; padding: 10px 12px;
-    border-bottom: 2px solid var(--border);
-    color: var(--dim); font-size: 0.82rem; text-transform: uppercase;
-    letter-spacing: 0.05em;
-  }
-  td {
-    padding: 10px 12px; border-bottom: 1px solid var(--border);
-    font-size: 0.88rem; font-family: 'SF Mono', monospace;
-  }
-  tr:hover td { background: rgba(255,255,255,0.03); }
-  .footer {
-    text-align: center; padding: 24px;
-    color: var(--dim); font-size: 0.85rem;
-  }
-  .footer a { color: var(--accent); text-decoration: none; }
-  .tip {
-    background: rgba(88, 166, 255, 0.08);
-    border: 1px solid rgba(88, 166, 255, 0.2);
-    border-radius: 8px; padding: 16px; margin-top: 12px;
-    font-size: 0.9rem;
-  }
-  .tip code { background: var(--bg); padding: 2px 6px; border-radius: 4px; font-size: 0.82rem; }
-  @media (max-width: 600px) {
-    .hero { padding: 24px 12px; }
-    .hero h1 { font-size: 1.8rem; }
-    .stat-grid { grid-template-columns: 1fr; }
-  }
-</style>
-</head>
-<body>
-<div class="container">
 <div class="hero">
   <h1><span>🔐</span> SocialCrypt</h1>
-  <p>Encrypted blob store. Running on HuggingFace Spaces.</p>
-  <div class="hf-badge">🤗 Powered by HuggingFace Spaces</div>
 </div>
 <div class="card">
-  <h2>📊 Live Stats</h2>
-  <div class="stat-grid">
-    <div class="stat-box">
-      <div class="num">${stats.messages}</div>
-      <div class="label">Messages Stored</div>
-    </div>
-    <div class="stat-box">
-      <div class="num">${stats.size_human}</div>
-      <div class="label">Total Size</div>
-    </div>
-    <div class="stat-box">
-      <div class="num">/data</div>
-      <div class="label">Persistent Volume</div>
-    </div>
   </div>
 </div>
 <div class="card">
   <h2>📡 Endpoints</h2>
-  <p style="color:var(--dim);margin-bottom:12px;">Point your SocialCrypt client at these URLs.</p>
-  <ul class="endpoint-list">
-    <li><span class="method get">GET</span><span><strong>/blobs.jsonl</strong> — Fetch all stored blobs (JSONL format)</span></li>
-    <li><span class="method post">POST</span><span><strong>/submit</strong> — Submit a new blob <code>{"id":"...","blob":"..."}</code></span></li>
-    <li><span class="method get">GET</span><span><strong>/stats</strong> — JSON stats</span></li>
-    <li><span class="method get">GET</span><span><strong>/health</strong> — Health check</span></li>
   </ul>
-  <div class="tip">
-    💡 <strong>Client setup:</strong> In <code>social.html</code>, add these as your endpoint:<br><br>
-    <strong>Read URL:</strong> <code>https://${process.env.SPACE_ID || 'USER-REPO'}.hf.space/blobs.jsonl</code><br>
-    <strong>Submit URL:</strong> <code>https://${process.env.SPACE_ID || 'USER-REPO'}.hf.space/submit</code>
-  </div>
 </div>
 <div class="card">
-  <h2>📬 Recent Messages ${hasMessages ? `(last ${Math.min(stats.messages, 50)} of ${stats.messages})` : ''}</h2>
-  ${hasMessages ? `
-  <div style="overflow-x:auto;">
-  <table>
-    <thead><tr><th>Recipient ID</th><th>Timestamp</th><th>Blob Size</th></tr></thead>
-    <tbody>${messagesHtml}</tbody>
-  </table>
-  </div>
-  <p style="color:var(--dim);font-size:0.8rem;margin-top:8px;">🔒 Blobs are encrypted — the server cannot read them.</p>
-  ` : `<p style="text-align:center;padding:40px;color:var(--dim);">📭 No messages yet. Share this endpoint!</p>`}
-</div>
-<div class="card" style="text-align:center;">
-  <h2>🔐 Zero-Knowledge Architecture</h2>
-  <p style="color:var(--dim);font-size:0.9rem;">This server stores <strong>only encrypted blobs</strong>. Messages are encrypted in-browser with AES-256-GCM, and the AES key is wrapped with the recipient's RSA-2048 public key. The server never sees plaintext. Ever.</p>
-  <p style="color:var(--dim);font-size:0.85rem;margin-top:8px;">Data persists in the <code>/data</code> HuggingFace volume — survives restarts and sleeps.</p>
-</div>
-<div class="footer">
-  <a href="https://github.com/YOUR_USER/socialcrypt" target="_blank">SocialCrypt</a> — Encrypted Social Messaging
 </div>
-</div>
-</body>
-</html>`;
 }
 // ─── HTTP Server ─────────────────────────────────────────────────────
 const server = http.createServer((req, res) => {
-  // CORS
   res.setHeader('Access-Control-Allow-Origin', '*');
   res.setHeader('Access-Control-Allow-Methods', 'GET, POST, OPTIONS, HEAD');
   res.setHeader('Access-Control-Allow-Headers', 'Content-Type');
@@ -262,17 +158,16 @@ const server = http.createServer((req, res) => {
     return res.end();
   }
-  const parsed = urlMod.parse(req.url, true);
-  const pathname = parsed.pathname;
-  // ── GET / — Dashboard ─────────────────────────────────────────────
   if (req.method === 'GET' && pathname === '/') {
     res.writeHead(200, { 'Content-Type': 'text/html; charset=utf-8' });
     res.end(renderDashboard());
     return;
   }
-  // ── GET /blobs.jsonl — Stream blob store ──────────────────────────
   if (req.method === 'GET' && pathname === '/blobs.jsonl') {
     const stats = getStats();
     res.writeHead(200, {
@@ -281,16 +176,14 @@ const server = http.createServer((req, res) => {
       'X-Server': 'SocialCrypt-HF'
     });
     if (fs.existsSync(BLOBS_FILE)) {
-      const stream = fs.createReadStream(BLOBS_FILE);
-      stream.on('error', () => res.end());
-      stream.pipe(res);
     } else {
       res.end('');
     }
     return;
   }
-  // ── POST /submit — Append a new blob ──────────────────────────────
   if (req.method === 'POST' && pathname === '/submit') {
     let body = '';
     req.on('data', chunk => (body += chunk));
@@ -299,28 +192,19 @@ const server = http.createServer((req, res) => {
         const data = JSON.parse(body);
         if (!data.id || !data.blob) {
           res.writeHead(400, { 'Content-Type': 'application/json' });
-          return res.end(JSON.stringify({ error: 'Missing required fields: id, blob' }));
         }
         if (typeof data.id !== 'string' || typeof data.blob !== 'string') {
           res.writeHead(400, { 'Content-Type': 'application/json' });
           return res.end(JSON.stringify({ error: 'id and blob must be strings' }));
         }
-        const line = JSON.stringify({
-          id: data.id,
-          ts: Date.now(),
-          blob: data.blob
-        }) + '\n';
-        // Ensure directory exists
-        const dir = path.dirname(BLOBS_FILE);
-        if (!fs.existsSync(dir)) fs.mkdirSync(dir, { recursive: true });
         fs.appendFileSync(BLOBS_FILE, line, 'utf-8');
         const stats = getStats();
-        console.log(`📨 [${new Date().toISOString()}] Stored blob for ${data.id.substring(0,16)}... | Total: ${stats.messages}`);
         res.writeHead(201, { 'Content-Type': 'application/json' });
         res.end(JSON.stringify({ ok: true, total_messages: stats.messages }));
       } catch (e) {
@@ -331,29 +215,17 @@ const server = http.createServer((req, res) => {
     return;
   }
-  // ── GET /stats — JSON stats ───────────────────────────────────────
   if (req.method === 'GET' && pathname === '/stats') {
-    const stats = getStats();
     res.writeHead(200, { 'Content-Type': 'application/json' });
-    res.end(JSON.stringify({
-      ...stats,
-      data_dir: DATA_DIR,
-      store_file: BLOBS_FILE,
-      uptime_seconds: Math.floor(process.uptime()),
-      platform: 'huggingface_spaces'
-    }));
     return;
   }
-  // ── GET /health — Health check ────────────────────────────────────
   if (req.method === 'GET' && pathname === '/health') {
-    let writable = true;
-    try {
-      fs.accessSync(path.dirname(BLOBS_FILE), fs.constants.W_OK);
-    } catch {
-      writable = false;
-    }
     res.writeHead(writable ? 200 : 503, { 'Content-Type': 'application/json' });
     res.end(JSON.stringify({
       status: writable ? 'ok' : 'degraded',
@@ -365,54 +237,35 @@ const server = http.createServer((req, res) => {
     return;
   }
-  // ── 404 ───────────────────────────────────────────────────────────
   res.writeHead(404, { 'Content-Type': 'application/json' });
-  res.end(JSON.stringify({
-    error: 'Not found',
-    available: [
-      { path: '/',        method: 'GET',  desc: 'Web dashboard' },
-      { path: '/blobs.jsonl', method: 'GET',  desc: 'Fetch all blobs' },
-      { path: '/submit',  method: 'POST', desc: 'Submit a new blob' },
-      { path: '/stats',   method: 'GET',  desc: 'Server statistics' },
-      { path: '/health',  method: 'GET',  desc: 'Health check' }
-    ]
-  }));
 });
 // ─── Startup ─────────────────────────────────────────────────────────
 server.listen(PORT, '0.0.0.0', () => {
-  const spaceId = process.env.SPACE_ID || 'local-dev';
-  console.log(`┌───────��──────────────────────────────────────────┐`);
-  console.log(`│  🔐 SocialCrypt — HuggingFace Spaces Edition     │`);
-  console.log(`│  ───────────────────────────────────              │`);
-  console.log(`│                                                  │`);
-  console.log(`│  📡 Server:    http://0.0.0.0:${String(PORT).padEnd(5)}                    │`);
-  console.log(`│  💾 Volume:    ${String(DATA_DIR).padEnd(31)}│`);
-  console.log(`│                                                  │`);
-  console.log(`│  🌐 Dashboard: GET  /                            │`);
-  console.log(`│  📖 Read:      GET  /blobs.jsonl                 │`);
-  console.log(`│  ✏️  Write:     POST /submit { id, blob }         │`);
-  console.log(`│  📊 Stats:     GET  /stats                       │`);
-  console.log(`│  ❤️  Health:    GET  /health                      │`);
-  console.log(`│                                                  │`);
-  const stats = getStats();
-  console.log(`│  📬 ${String(stats.messages).padStart(5)} messages in store                 │`);
-  console.log(`└──────────────────────────────────────────────────┘`);
-  console.log(`🚀 Open http://localhost:${PORT} to see the dashboard.`);
 });
 // ─── Graceful Shutdown ──────────────────────────────────────────────
 function shutdown(signal) {
-  console.log(`\n🛑 ${signal} received — shutting down gracefully...`);
-  server.close(() => {
-    console.log('✅ Server closed. Data safely stored in persistent volume.');
-    process.exit(0);
-  });
-  setTimeout(() => {
-    console.error('⏰ Forced shutdown after timeout');
-    process.exit(1);
-  }, 5000);
 }
 process.on('SIGTERM', () => shutdown('SIGTERM'));
 process.on('SIGINT', () => shutdown('SIGINT'));

  *
  * Deploy:
  *   1. Create Space → Docker SDK
+ *   2. Push server_hf.js + Dockerfile.hf
+ *   3. Done! Your Space URL becomes the endpoint.
  *
+ *   Read:  https://USERNAME-SPACENAME.hf.space/blobs.jsonl
+ *   Write: https://USERNAME-SPACENAME.hf.space/submit
+ *   Web:   https://USERNAME-SPACENAME.hf.space/
  */
 const http = require('http');
 // ─── Configuration ───────────────────────────────────────────────────
 const PORT = parseInt(process.env.PORT) || 7860;
+// HuggingFace Spaces mounts persistent storage at /data
+// The Dockerfile does: RUN mkdir -p /data && chmod 777 /data
+// so it's always writable. Fallback to ./data for local dev.
+const DATA_DIR = fs.existsSync('/data') ? '/data' : path.join(__dirname, 'data');
+const BLOBS_FILE = path.join(DATA_DIR, 'blobs.jsonl');
 // ─── Initialize ──────────────────────────────────────────────────────
 if (!fs.existsSync(DATA_DIR)) {
   fs.mkdirSync(DATA_DIR, { recursive: true });
 }
+console.log(`📁 Data directory: ${DATA_DIR} (${DATA_DIR === '/data' ? 'HF persistent volume' : 'local'})`);
+// ─── Helper: get stats ──────────────────────────────────────────────
 function getStats() {
   if (!fs.existsSync(BLOBS_FILE)) {
     return { messages: 0, size_bytes: 0, size_human: '0 B' };
         const idShort = entry.id ? entry.id.substring(0, 16) + '...' : '?';
         const time = entry.ts ? new Date(entry.ts).toLocaleString() : '?';
         const blobSize = entry.blob ? (entry.blob.length / 1024).toFixed(1) + ' KB' : '?';
+        return `<tr><td>${idShort}</td><td>${time}</td><td>${blobSize}</td></tr>`;
       } catch {
+        return `<tr><td colspan="3" style="color:var(--red)">⚠️ Malformed</td></tr>`;
       }
     }).join('');
   }
   return `<!DOCTYPE html>
 <html lang="en">
+<head><meta charset="UTF-8"><meta name="viewport" content="width=device-width,initial-scale=1">
 <title>🔐 SocialCrypt — HuggingFace Endpoint</title>
 <style>
+:root{--bg:#0d1117;--card:#161b22;--border:#30363d;--text:#e6edf3;--dim:#8b949e;--accent:#58a6ff;--green:#3fb950;--red:#f85149}
+*{box-sizing:border-box;margin:0;padding:0}
+body{background:var(--bg);color:var(--text);font-family:-apple-system,BlinkMacSystemFont,'Segoe UI',system-ui,sans-serif;line-height:1.6;padding:20px}
+.container{max-width:800px;margin:0 auto}
+.hero{text-align:center;padding:40px 20px;border-bottom:1px solid var(--border);margin-bottom:24px}
+.hero h1{font-size:2.5rem}.hero h1 span{color:var(--accent)}
+.hero p{color:var(--dim);margin-top:8px}
+.hero .badge{display:inline-block;margin-top:12px;padding:4px 16px;border-radius:999px;background:rgba(255,152,0,0.15);color:#ff9800;font-size:0.85rem}
+.card{background:var(--card);border:1px solid var(--border);border-radius:12px;padding:24px;margin-bottom:16px}
+.card h2{font-size:1.2rem;margin-bottom:16px}
+.grid{display:grid;grid-template-columns:repeat(3,1fr);gap:12px}
+.box{text-align:center;padding:16px;background:var(--bg);border:1px solid var(--border);border-radius:8px}
+.box .num{font-size:2rem;font-weight:700;color:var(--accent)}
+.box .label{font-size:0.82rem;color:var(--dim);margin-top:4px}
+.list{list-style:none}
+.list li{display:flex;align-items:center;gap:8px;padding:12px;margin-bottom:8px;background:var(--bg);border:1px solid var(--border);border-radius:8px;font-family:'SF Mono','Fira Code',monospace;font-size:0.85rem;word-break:break-all}
+.m{display:inline-block;padding:2px 8px;border-radius:4px;font-size:0.75rem;font-weight:700;flex-shrink:0}
+.m.g{background:rgba(88,166,255,0.15);color:var(--accent)}
+.m.p{background:rgba(63,185,80,0.15);color:var(--green)}
+table{width:100%;border-collapse:collapse}
+th{text-align:left;padding:10px 12px;border-bottom:2px solid var(--border);color:var(--dim);font-size:0.82rem;text-transform:uppercase;letter-spacing:0.05em}
+td{padding:10px 12px;border-bottom:1px solid var(--border);font-size:0.88rem;font-family:'SF Mono',monospace}
+tr:hover td{background:rgba(255,255,255,0.03)}
+.footer{text-align:center;padding:24px;color:var(--dim);font-size:0.85rem}
+.footer a{color:var(--accent);text-decoration:none}
+.tip{background:rgba(88,166,255,0.08);border:1px solid rgba(88,166,255,0.2);border-radius:8px;padding:16px;margin:12px 0;font-size:0.9rem}
+.tip code{background:var(--bg);padding:2px 6px;border-radius:4px;font-size:0.82rem}
+@media(max-width:600px){.hero{padding:24px 12px}.hero h1{font-size:1.8rem}.grid{grid-template-columns:1fr}}
+</style></head>
+<body><div class="container">
 <div class="hero">
   <h1><span>🔐</span> SocialCrypt</h1>
+  <p>Encrypted blob store on HuggingFace Spaces</p>
+  <div class="badge">🤗 HF Spaces</div>
 </div>
 <div class="card">
+  <h2>📊 Stats</h2>
+  <div class="grid">
+    <div class="box"><div class="num">${stats.messages}</div><div class="label">Messages</div></div>
+    <div class="box"><div class="num">${stats.size_human}</div><div class="label">Total Size</div></div>
+    <div class="box"><div class="num">/data</div><div class="label">Persistent Volume</div></div>
   </div>
 </div>
 <div class="card">
   <h2>📡 Endpoints</h2>
+  <ul class="list">
+    <li><span class="m g">GET</span><span><strong>/blobs.jsonl</strong> — Fetch all blobs (JSONL)</span></li>
+    <li><span class="m p">POST</span><span><strong>/submit</strong> — Submit a blob <code>{"id":"...","blob":"..."}</code></span></li>
+    <li><span class="m g">GET</span><span><strong>/stats</strong> — JSON stats</span></li>
+    <li><span class="m g">GET</span><span><strong>/health</strong> — Health check</span></li>
   </ul>
 </div>
 <div class="card">
+  <h2>📬 Recent Messages ${hasMessages ? `(${Math.min(stats.messages,50)} of ${stats.messages})` : ''}</h2>
+  ${hasMessages ? `<div style="overflow-x:auto;"><table><thead><tr><th>Recipient ID</th><th>Time</th><th>Size</th></tr></thead><tbody>${messagesHtml}</tbody></table></div>` : '<p style="text-align:center;padding:40px;color:var(--dim)">📭 No messages yet</p>'}
 </div>
+<div class="footer"><a href="#">SocialCrypt</a> — Encrypted Social Messaging</div>
+</div></body></html>`;
 }
 // ─── HTTP Server ─────────────────────────────────────────────────────
 const server = http.createServer((req, res) => {
   res.setHeader('Access-Control-Allow-Origin', '*');
   res.setHeader('Access-Control-Allow-Methods', 'GET, POST, OPTIONS, HEAD');
   res.setHeader('Access-Control-Allow-Headers', 'Content-Type');
     return res.end();
   }
+  const pathname = urlMod.parse(req.url, true).pathname;
+  // GET / — Dashboard
   if (req.method === 'GET' && pathname === '/') {
     res.writeHead(200, { 'Content-Type': 'text/html; charset=utf-8' });
     res.end(renderDashboard());
     return;
   }
+  // GET /blobs.jsonl — Stream blob store
   if (req.method === 'GET' && pathname === '/blobs.jsonl') {
     const stats = getStats();
     res.writeHead(200, {
       'X-Server': 'SocialCrypt-HF'
     });
     if (fs.existsSync(BLOBS_FILE)) {
+      fs.createReadStream(BLOBS_FILE).on('error', () => res.end()).pipe(res);
     } else {
       res.end('');
     }
     return;
   }
+  // POST /submit — Append a new blob
   if (req.method === 'POST' && pathname === '/submit') {
     let body = '';
     req.on('data', chunk => (body += chunk));
         const data = JSON.parse(body);
         if (!data.id || !data.blob) {
           res.writeHead(400, { 'Content-Type': 'application/json' });
+          return res.end(JSON.stringify({ error: 'Missing id or blob' }));
         }
         if (typeof data.id !== 'string' || typeof data.blob !== 'string') {
           res.writeHead(400, { 'Content-Type': 'application/json' });
           return res.end(JSON.stringify({ error: 'id and blob must be strings' }));
         }
+        const line = JSON.stringify({ id: data.id, ts: Date.now(), blob: data.blob }) + '\n';
+        if (!fs.existsSync(path.dirname(BLOBS_FILE))) {
+          fs.mkdirSync(path.dirname(BLOBS_FILE), { recursive: true });
+        }
         fs.appendFileSync(BLOBS_FILE, line, 'utf-8');
         const stats = getStats();
+        console.log(`📨 [${new Date().toISOString()}] Stored for ${data.id.substring(0,16)}... Total: ${stats.messages}`);
         res.writeHead(201, { 'Content-Type': 'application/json' });
         res.end(JSON.stringify({ ok: true, total_messages: stats.messages }));
       } catch (e) {
     return;
   }
+  // GET /stats
   if (req.method === 'GET' && pathname === '/stats') {
     res.writeHead(200, { 'Content-Type': 'application/json' });
+    res.end(JSON.stringify({ ...getStats(), data_dir: DATA_DIR, uptime_seconds: Math.floor(process.uptime()) }));
     return;
   }
+  // GET /health
   if (req.method === 'GET' && pathname === '/health') {
+    let writable = false;
+    try { fs.accessSync(path.dirname(BLOBS_FILE), fs.constants.W_OK); writable = true; } catch {}
     res.writeHead(writable ? 200 : 503, { 'Content-Type': 'application/json' });
     res.end(JSON.stringify({
       status: writable ? 'ok' : 'degraded',
     return;
   }
+  // 404
   res.writeHead(404, { 'Content-Type': 'application/json' });
+  res.end(JSON.stringify({ error: 'Not found', endpoints: ['/','/blobs.jsonl','/submit','/stats','/health'] }));
 });
 // ─── Startup ─────────────────────────────────────────────────────────
 server.listen(PORT, '0.0.0.0', () => {
+  console.log(`┌──────────────────────────────────────┐`);
+  console.log(`│  🔐 SocialCrypt — HuggingFace Edition │`);
+  console.log(`│  ────────────────────────             │`);
+  console.log(`│  📡 http://0.0.0.0:${String(PORT).padEnd(5)}               │`);
+  console.log(`│  💾 Volume:  ${String(DATA_DIR).padEnd(21)}│`);
+  console.log(`│                                      │`);
+  console.log(`│  🌐 Dashboard: GET  /                 │`);
+  console.log(`│  📖 Read:      GET  /blobs.jsonl     │`);
+  console.log(`│  ✏️  Write:     POST /submit          │`);
+  console.log(`│  📊 Stats:     GET  /stats            │`);
+  console.log(`│  ❤️  Health:    GET  /health           │`);
+  console.log(`│                                      │`);
+  const s = getStats();
+  console.log(`│  📬 ${String(s.messages).padStart(5)} messages in store        │`);
+  console.log(`└──────────────────────────────────────┘`);
 });
 // ─── Graceful Shutdown ──────────────────────────────────────────────
 function shutdown(signal) {
+  console.log(`\n🛑 ${signal} received — shutting down...`);
+  server.close(() => { console.log('✅ Closed.'); process.exit(0); });
+  setTimeout(() => process.exit(1), 5000);
 }
 process.on('SIGTERM', () => shutdown('SIGTERM'));
 process.on('SIGINT', () => shutdown('SIGINT'));