Spaces:

somratpro
/

HuggingClaw

Running

App Files Files Community

somratpro commited on 13 days ago

Commit

ea9c8a5

1 Parent(s): d9dfa01

feat: add Hugging Face backup configuration and support for global app routing

Browse files

Files changed (2) hide show

health-server.js +25 -15
workspace-sync.py +6 -0

health-server.js CHANGED Viewed

@@ -13,11 +13,14 @@ const SPACE_HOST = process.env.SPACE_HOST || "";
 const TELEGRAM_ENABLED = !!process.env.TELEGRAM_BOT_TOKEN;
 const WHATSAPP_ENABLED = /^true$/i.test(process.env.WHATSAPP_ENABLED || "");
 const WHATSAPP_STATUS_FILE = "/tmp/huggingclaw-wa-status.json";
 const DASHBOARD_BASE = "/dashboard";
 const DASHBOARD_STATUS_PATH = `${DASHBOARD_BASE}/status`;
 const DASHBOARD_HEALTH_PATH = `${DASHBOARD_BASE}/health`;
 const DASHBOARD_UPTIMEROBOT_PATH = `${DASHBOARD_BASE}/uptimerobot/setup`;
 const DASHBOARD_APP_BASE = `${DASHBOARD_BASE}/app`;
 function parseRequestUrl(url) {
   try {
@@ -36,10 +39,11 @@ function isDashboardScopedPath(pathname, suffix) {
 }
 function isDashboardAppRoute(pathname) {
-  return (
-    pathname === DASHBOARD_APP_BASE ||
-    pathname.startsWith(`${DASHBOARD_APP_BASE}/`)
-  );
 }
 function isLocalRoute(pathname) {
@@ -59,6 +63,10 @@ function stripDashboardAppPrefix(path) {
   if (path.startsWith(`${DASHBOARD_APP_BASE}/`)) {
     return path.slice(DASHBOARD_APP_BASE.length) || "/";
   }
   return path;
 }
@@ -89,6 +97,12 @@ function readSyncStatus() {
       return JSON.parse(fs.readFileSync("/tmp/sync-status.json", "utf8"));
     }
   } catch {}
   return { status: "unknown", message: "No sync data yet" };
 }
@@ -142,9 +156,7 @@ function renderSyncBadge(syncData) {
 }
 function renderDashboard(initialData) {
-  const controlUiHref = SPACE_HOST
-    ? `https://${SPACE_HOST}`
-    : `${DASHBOARD_APP_BASE}/`;
   return `
 <!DOCTYPE html>
 <html lang="en">
@@ -504,11 +516,11 @@ function renderDashboard(initialData) {
             </div>
             <div class="stat-card">
                 <span class="stat-label">WhatsApp</span>
-                <span id="wa-status">${renderChannelBadge(initialData.whatsapp, "Ready to pair")}</span>
             </div>
             <div class="stat-card">
                 <span class="stat-label">Telegram</span>
-                <span id="tg-status">${renderChannelBadge(initialData.telegram, "Configured")}</span>
             </div>
             <a href="${controlUiHref}" id="control-ui-link" class="stat-btn">Open Control UI</a>
         </div>
@@ -692,6 +704,7 @@ function renderDashboard(initialData) {
         updateStats();
         setInterval(updateStats, 10000);
         restoreMonitorUiState();
         document.getElementById('uptimerobot-btn').addEventListener('click', setupUptimeRobot);
         document.getElementById('uptimerobot-toggle').addEventListener('click', toggleMonitorSetup);
     </script>
@@ -939,10 +952,7 @@ const server = http.createServer((req, res) => {
     return;
   }
-  if (
-    pathname === "/uptimerobot/setup" ||
-    pathname === DASHBOARD_UPTIMEROBOT_PATH
-  ) {
     if (req.method !== "POST") {
       res.writeHead(405, { "Content-Type": "application/json" });
       res.end(JSON.stringify({ message: "Method not allowed" }));
@@ -1001,7 +1011,7 @@ const server = http.createServer((req, res) => {
     return;
   }
-  if (isDashboardAppRoute(pathname)) {
     const proxyPath =
       stripDashboardAppPrefix(pathname) + (parsedUrl.search || "");
     proxyHttp(req, res, proxyPath);
@@ -1018,7 +1028,7 @@ server.on("upgrade", (req, socket, head) => {
     return;
   }
-  if (isDashboardAppRoute(pathname)) {
     const parsedUrl = parseRequestUrl(req.url || "/");
     const proxyPath =
       stripDashboardAppPrefix(pathname) + (parsedUrl.search || "");

 const TELEGRAM_ENABLED = !!process.env.TELEGRAM_BOT_TOKEN;
 const WHATSAPP_ENABLED = /^true$/i.test(process.env.WHATSAPP_ENABLED || "");
 const WHATSAPP_STATUS_FILE = "/tmp/huggingclaw-wa-status.json";
+const HF_BACKUP_ENABLED = !!(process.env.HF_USERNAME && process.env.HF_TOKEN);
+const SYNC_INTERVAL = process.env.SYNC_INTERVAL || "600";
 const DASHBOARD_BASE = "/dashboard";
 const DASHBOARD_STATUS_PATH = `${DASHBOARD_BASE}/status`;
 const DASHBOARD_HEALTH_PATH = `${DASHBOARD_BASE}/health`;
 const DASHBOARD_UPTIMEROBOT_PATH = `${DASHBOARD_BASE}/uptimerobot/setup`;
 const DASHBOARD_APP_BASE = `${DASHBOARD_BASE}/app`;
+const APP_BASE = "/app";
 function parseRequestUrl(url) {
   try {
 }
 function isDashboardAppRoute(pathname) {
+  return pathname === DASHBOARD_APP_BASE || pathname.startsWith(`${DASHBOARD_APP_BASE}/`);
+}
+function isAppRoute(pathname) {
+  return pathname === APP_BASE || pathname.startsWith(`${APP_BASE}/`);
 }
 function isLocalRoute(pathname) {
   if (path.startsWith(`${DASHBOARD_APP_BASE}/`)) {
     return path.slice(DASHBOARD_APP_BASE.length) || "/";
   }
+  if (path === APP_BASE) return "/";
+  if (path.startsWith(`${APP_BASE}/`)) {
+    return path.slice(APP_BASE.length) || "/";
+  }
   return path;
 }
       return JSON.parse(fs.readFileSync("/tmp/sync-status.json", "utf8"));
     }
   } catch {}
+  if (HF_BACKUP_ENABLED) {
+    return {
+      status: "configured",
+      message: `Backup is enabled. Waiting for the next sync window (${SYNC_INTERVAL}s).`,
+    };
+  }
   return { status: "unknown", message: "No sync data yet" };
 }
 }
 function renderDashboard(initialData) {
+  const controlUiHref = `${DASHBOARD_APP_BASE}/`;
   return `
 <!DOCTYPE html>
 <html lang="en">
             </div>
             <div class="stat-card">
                 <span class="stat-label">WhatsApp</span>
+                <span id="wa-status">${renderChannelBadge(initialData.whatsapp, 'Ready to pair')}</span>
             </div>
             <div class="stat-card">
                 <span class="stat-label">Telegram</span>
+                <span id="tg-status">${renderChannelBadge(initialData.telegram, 'Configured')}</span>
             </div>
             <a href="${controlUiHref}" id="control-ui-link" class="stat-btn">Open Control UI</a>
         </div>
         updateStats();
         setInterval(updateStats, 10000);
         restoreMonitorUiState();
+        document.getElementById('control-ui-link').setAttribute('href', getDashboardBase() + '/app/');
         document.getElementById('uptimerobot-btn').addEventListener('click', setupUptimeRobot);
         document.getElementById('uptimerobot-toggle').addEventListener('click', toggleMonitorSetup);
     </script>
     return;
   }
+  if (pathname === "/uptimerobot/setup" || pathname === DASHBOARD_UPTIMEROBOT_PATH) {
     if (req.method !== "POST") {
       res.writeHead(405, { "Content-Type": "application/json" });
       res.end(JSON.stringify({ message: "Method not allowed" }));
     return;
   }
+  if (isDashboardAppRoute(pathname) || isAppRoute(pathname)) {
     const proxyPath =
       stripDashboardAppPrefix(pathname) + (parsedUrl.search || "");
     proxyHttp(req, res, proxyPath);
     return;
   }
+  if (isDashboardAppRoute(pathname) || isAppRoute(pathname)) {
     const parsedUrl = parseRequestUrl(req.url || "/");
     const proxyPath =
       stripDashboardAppPrefix(pathname) + (parsedUrl.search || "");

workspace-sync.py CHANGED Viewed

@@ -195,6 +195,12 @@ def main():
         print("📁 Workspace sync: no git repo and no HF credentials, skipping.")
         return
     # Give the gateway a short head start before the first sync probe.
     time.sleep(INITIAL_DELAY)

         print("📁 Workspace sync: no git repo and no HF credentials, skipping.")
         return
+    # Give the gateway a short head start before the first sync probe.
+    if use_hf_hub:
+        write_sync_status("configured", f"Backup enabled. Waiting for next sync in {INTERVAL}s.")
+    else:
+        write_sync_status("configured", f"Git sync enabled. Waiting for next sync in {INTERVAL}s.")
     # Give the gateway a short head start before the first sync probe.
     time.sleep(INITIAL_DELAY)