test(hermes): add opt-in real CLI smoke and state.db fixture tests

- Rewrite test_hermes_cli_available_and_mocked into two opt-in smoke tests:
  * test_hermes_cli_available: fast hermes --version probe (skip if missing)
  * test_real_hermes_chat_smoke: real CLI invocation + backend-path call
    (opt-in via SKILLOPT_REAL_HERMES=1; uses -Q --max-turns 1 flags)
- Add tests/test_harvest_hermes.py with sanitized synthetic state.db fixture:
  * 6 core harvest tests (engine-session filtering, scope, since_iso, limit,
    digest content, missing db)
  * 7 schema-drift variants (no_title, no_tool_name, extra_columns,
    no_messages_table, no_sessions_table, schema_version_25, text_epochs)
- Fix harvest_hermes.py: graceful handling of missing tables/columns
  (_fetch_messages catches OperationalError for missing tool_name or table;
  harvest_hermes catches missing sessions table and missing title column)
- Register pytest 'slow' marker in pyproject.toml

Author: fgscaglioni

pyproject.toml

@@ -80,6 +80,9 @@ include = ["skillopt", "skillopt.*", "skillopt_sleep", "skillopt_sleep.*", "skil
 line-length = 120
 target-version = "py310"
 
+[tool.pytest.ini_options]
+markers = ["slow: opt-in tests that invoke the real Hermes CLI or network"]
+
 [tool.ruff.lint]
 select = ["E", "F", "I", "W"]
 ignore = ["E501"]

skillopt_sleep/harvest_hermes.py

@@ -38,17 +38,36 @@ def _filter_engine_sessions(sessions: List[Dict[str, Any]]) -> List[Dict[str, An
 
 
 def _fetch_messages(db_path: str, session_id: str) -> List[Dict[str, Any]]:
-    """Return all messages for a session, ordered by id."""
+    """Return all messages for a session, ordered by id.
+
+    Gracefully handles the ``tool_name`` column or whole ``messages`` table
+    being absent (schema drift).
+    """
     conn = sqlite3.connect(db_path)
     conn.row_factory = sqlite3.Row
     cursor = conn.cursor()
-    cursor.execute(
-        """SELECT role, content, tool_name, timestamp
-           FROM messages
-           WHERE session_id = ? AND role IN ('user', 'assistant')
-           ORDER BY id""",
-        (session_id,),
-    )
+    try:
+        try:
+            cursor.execute(
+                """SELECT role, content, tool_name, timestamp
+                   FROM messages
+                   WHERE session_id = ? AND role IN ('user', 'assistant')
+                   ORDER BY id""",
+                (session_id,),
+            )
+        except sqlite3.OperationalError:
+            # Column or table mismatch — retry without tool_name
+            cursor.execute(
+                """SELECT role, content, timestamp
+                   FROM messages
+                   WHERE session_id = ? AND role IN ('user', 'assistant')
+                   ORDER BY id""",
+                (session_id,),
+            )
+    except sqlite3.OperationalError:
+        # Table missing entirely
+        conn.close()
+        return []
     rows = [dict(r) for r in cursor.fetchall()]
     conn.close()
     return rows
@@ -202,13 +221,28 @@ def harvest_hermes(
             where += " AND ended_at >= ?"
             params.append(since_epoch)
 
-    cursor.execute(
-        f"""SELECT id, cwd, title, started_at, ended_at, model
-            FROM sessions
-            {where}
-            ORDER BY ended_at DESC""",
-        params,
-    )
+    try:
+        cursor.execute(
+            f"""SELECT id, cwd, title, started_at, ended_at, model
+                FROM sessions
+                {where}
+                ORDER BY ended_at DESC""",
+            params,
+        )
+    except sqlite3.OperationalError:
+        # Table missing or column mismatch (e.g. no 'title' column) —
+        # retry without title, or bail out if sessions table is absent.
+        try:
+            cursor.execute(
+                f"""SELECT id, cwd, started_at, ended_at, model
+                    FROM sessions
+                    {where}
+                    ORDER BY ended_at DESC""",
+                params,
+            )
+        except sqlite3.OperationalError:
+            conn.close()
+            return []
 
     sessions = [dict(r) for r in cursor.fetchall()]
     conn.close()