Fix cloud-sync cursor; update deploy and status

Handle named-server cursor behavior in cloud-sync: fetch the first batch before reading cursor.description so column names and signal columns are populated correctly, and iterate fetchmany() in a proper loop to avoid missing batches. Update .env.macbook to point DBC_HOST_PATH to the secret DBC location. Clarify docker-compose.macbook-base usage and environment file path in comments, and add status and Cloud Sync access URLs. Enhance status UI to show the DBC file name (shortened), color-code it (red for example.dbc), and retain the existing warning banner behavior for the example DBC.

Author: haoruizhou

universal-telemetry-software/cloud-sync/sync.py

@@ -237,7 +237,8 @@ def sync(self, progress_cb: Optional[Callable[[int, int], None]] = None) -> dict
             if total_rows == 0:
                 return {"rows_synced": 0, "batches": 0, "elapsed_s": 0.0}
 
-            # Use a named (server-side) cursor to avoid loading all rows into RAM
+            # Use a named (server-side) cursor to avoid loading all rows into RAM.
+            # description is not populated until after the first fetchmany() on named cursors.
             with local_conn.cursor("_cloud_sync") as read_cur:
                 if cursor is None:
                     read_cur.execute(
@@ -249,13 +250,15 @@ def sync(self, progress_cb: Optional[Callable[[int, int], None]] = None) -> dict
                         (cursor,),
                     )
 
-                col_names = [d.name for d in read_cur.description]
-                signal_cols = [c for c in col_names if c not in _FIXED_COLS]
+                col_names = None
+                signal_cols = None
 
-                while True:
-                    rows = read_cur.fetchmany(self.batch_size)
-                    if not rows:
-                        break
+                rows = read_cur.fetchmany(self.batch_size)
+                while rows:
+                    # description is available after the first fetch on named cursors
+                    if col_names is None:
+                        col_names = [d.name for d in read_cur.description]
+                        signal_cols = [c for c in col_names if c not in _FIXED_COLS]
 
                     # Collect signal names present in this batch (non-null columns vary)
                     batch_signal_names: Set[str] = set()
@@ -302,6 +305,7 @@ def sync(self, progress_cb: Optional[Callable[[int, int], None]] = None) -> dict
                         progress_cb(rows_synced, total_rows)
 
                     logger.info(f"Batch {batches}: {rows_synced}/{total_rows} rows synced")
+                    rows = read_cur.fetchmany(self.batch_size)
 
         finally:
             try:

universal-telemetry-software/deploy/.env.macbook

@@ -3,7 +3,7 @@
 
 REMOTE_IP=10.71.1.10
 TIMESCALE_TABLE=WFR26test
-DBC_HOST_PATH=./example.dbc
+DBC_HOST_PATH=../../secret-dbc/WFR25.dbc
 GRAFANA_ADMIN_PASSWORD=admin
 
 # Cloud Sync dashboard — http://localhost:8092

universal-telemetry-software/deploy/docker-compose.macbook-base.yml

@@ -1,12 +1,14 @@
 # MacBook base station — full local stack with TimescaleDB persistence
 # Use this for development and testing with full telemetry recording.
-# Run from universal-telemetry-software/:
-#   docker compose -f deploy/docker-compose.macbook-base.yml up -d --build
+# Run from repo root (data-acquisition/):
+#   docker compose -f universal-telemetry-software/deploy/docker-compose.macbook-base.yml --env-file universal-telemetry-software/deploy/.env.macbook up -d --build
 #
 # Access points:
 #   Pecan dashboard:  http://localhost:3000
+#   Status page:      http://localhost:8080
 #   Grafana:          http://localhost:8087
 #   TimescaleDB:      postgresql://wfr:wfr_password@localhost:5432/wfr
+#   Cloud Sync:       http://localhost:8092
 
 networks:
   datalink:

universal-telemetry-software/status/index.html

@@ -539,6 +539,10 @@ <h1>[DAQ_BASE_STATION]</h1>
                     <span class="metric-label">Write Errors</span>
                     <span class="metric-value" id="timescaleErrors">--</span>
                 </div>
+                <div class="metric" style="margin-top:8px; padding-top:8px; border-top:1px solid #222;">
+                    <span class="metric-label">DBC File</span>
+                    <span class="metric-value" id="dbcFileName" style="font-size:0.75rem; word-break:break-all;">--</span>
+                </div>
             </div>
         </div>
 
@@ -729,7 +733,13 @@ <h1>[DAQ_BASE_STATION]</h1>
 
             if (stats.dbc_file) {
                 const dbcWarning = document.getElementById('dbcWarningBanner');
-                if (stats.dbc_file.includes('example.dbc')) {
+                const dbcFileName = document.getElementById('dbcFileName');
+                const isExample = stats.dbc_file.includes('example.dbc');
+                // Show just the filename, not the full container path
+                const shortName = stats.dbc_file.split('/').pop();
+                dbcFileName.textContent = shortName;
+                dbcFileName.style.color = isExample ? '#f85149' : '#3fb950';
+                if (isExample) {
                     dbcWarning.style.display = 'block';
                 } else {
                     dbcWarning.style.display = 'none';