Skip to content

feat(ecoseek): Phase 2 — direct hermes.ecoseek.org + legacy broker fallback #6

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
alrobles merged 1 commit into from
May 24, 2026
Merged

feat(ecoseek): Phase 2 — direct hermes.ecoseek.org + legacy broker fallback #6

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
68 changes: 44 additions & 24 deletions plugins/ecoseek/__init__.py
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
"""ecoseek — Hermes plugin for EcoSeek ecological intelligence.
"""ecoseek — Hermes plugin for EcoSeek DiDAL Phase 2.

Provides tools for the dual-agent architecture:

Expand All @@ -10,22 +10,26 @@
``eco_analyze`` — structured interface to EcoAgent MCP server (GBIF, SDM, diversity)
``ku_hpc`` — KU HPC cluster operations via Slurm (submit, status, cancel, output)

The remote Hermes has access to DeepSeek v4 Pro, KU HPC cluster (A100/MI210),
and advanced ecological tools.
Communication goes directly to hermes.ecoseek.org (preferred) with fallback
to the legacy broker at broker.ecoseek.org.

Activation is handled by the Hermes plugin system — enable with:
hermes plugins enable ecoseek

Optional env vars (set in ~/.hermes/.env):
ECOSEEK_BROKER_URL - Broker endpoint (default: https://broker.ecoseek.org)
ECOSEEK_BROKER_KEY - Broker session key for authenticated requests
ECOSEEK_MODEL - Model name on remote Hermes (default: openclaw/main)
ECOSEEK_TIMEOUT - Request timeout in seconds (default: 300)
DIDAL_MAX_TURNS - Max dialogue turns (default: 20)
DIDAL_STUCK_THRESHOLD - Repeated errors before stopping (default: 3)
ECOAGENT_URL - EcoAgent MCP server URL (default: http://localhost:8000)
ECOAGENT_TIMEOUT - EcoAgent request timeout (default: 120)
KU_HPC_TIMEOUT - Slurm command timeout (default: 30)
Env vars (set in ~/.hermes/.env):
HERMES_REMOTE_URL - Remote Hermes endpoint (default: https://hermes.ecoseek.org)
HERMES_ECOSEEK_API_KEY - API key for hermes.ecoseek.org
HERMES_REMOTE_MODEL - Model name on remote (default: hermes)
HERMES_REMOTE_TIMEOUT - Request timeout in seconds (default: 300)
DIDAL_MAX_TURNS - Max dialogue turns (default: 20)
DIDAL_STUCK_THRESHOLD - Repeated errors before stopping (default: 3)
ECOAGENT_URL - EcoAgent MCP server URL (default: http://localhost:8000)
ECOAGENT_TIMEOUT - EcoAgent request timeout (default: 120)
KU_HPC_TIMEOUT - Slurm command timeout (default: 30)

Legacy (fallback):
ECOSEEK_BROKER_URL - Broker endpoint
ECOSEEK_BROKER_KEY - Broker session key
"""
from __future__ import annotations

Expand All @@ -42,15 +46,29 @@
# Configuration
# ---------------------------------------------------------------------------

_BROKER_URL = os.environ.get("ECOSEEK_BROKER_URL", "https://broker.ecoseek.org").rstrip("/")
# Primary: direct connection to hermes.ecoseek.org
_REMOTE_URL = os.environ.get("HERMES_REMOTE_URL", "https://hermes.ecoseek.org").rstrip("/")
_API_KEY = os.environ.get("HERMES_ECOSEEK_API_KEY", "")
_MODEL = os.environ.get("HERMES_REMOTE_MODEL", "hermes")
_TIMEOUT = int(os.environ.get("HERMES_REMOTE_TIMEOUT", "300"))

# Legacy fallback (broker)
_BROKER_URL = os.environ.get("ECOSEEK_BROKER_URL", "").rstrip("/")
_BROKER_KEY = os.environ.get("ECOSEEK_BROKER_KEY", "")
_MODEL = os.environ.get("ECOSEEK_MODEL", "openclaw/main")
_TIMEOUT = int(os.environ.get("ECOSEEK_TIMEOUT", "300"))


def _is_configured() -> bool:
"""Return True when the remote broker is reachable (URL + key present)."""
return bool(_BROKER_URL and _BROKER_KEY)
"""Return True when we can reach a remote Hermes (direct or via broker)."""
return bool((_REMOTE_URL and _API_KEY) or (_BROKER_URL and _BROKER_KEY))


def _get_remote_endpoint() -> tuple[str, str]:
"""Return (url, auth_header) for the best available remote Hermes."""
if _REMOTE_URL and _API_KEY:
return _REMOTE_URL, f"Bearer {_API_KEY}"
if _BROKER_URL and _BROKER_KEY:
return _BROKER_URL, f"Bearer {_BROKER_KEY}"
return "", ""


# ---------------------------------------------------------------------------
Expand Down Expand Up @@ -90,13 +108,15 @@ def escalate_remote(
if not _is_configured():
return json.dumps({
"success": False,
"error": "ecoseek_not_configured",
"error": "hermes_not_configured",
"message": (
"Remote escalation is not configured. Set ECOSEEK_BROKER_URL "
"and ECOSEEK_BROKER_KEY in ~/.hermes/.env to enable."
"Remote escalation is not configured. Set HERMES_ECOSEEK_API_KEY "
"in ~/.hermes/.env to enable (or legacy ECOSEEK_BROKER_URL + ECOSEEK_BROKER_KEY)."
),
})

base_url, auth = _get_remote_endpoint()

messages = []
if context:
messages.append({"role": "system", "content": context})
Expand All @@ -117,11 +137,11 @@ def escalate_remote(
"Content-Type": "application/json",
"Accept": "application/json",
}
if _BROKER_KEY:
headers["Authorization"] = f"Bearer {_BROKER_KEY}"
if auth:
headers["Authorization"] = auth

req = urllib.request.Request(
f"{_BROKER_URL}/v1/chat/completions",
f"{base_url}/v1/chat/completions",
data=body,
headers=headers,
method="POST",
Expand Down
40 changes: 29 additions & 11 deletions plugins/ecoseek/didal.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -29,10 +29,24 @@
# Configuration
# ---------------------------------------------------------------------------

_BROKER_URL = os.environ.get("ECOSEEK_BROKER_URL", "https://broker.ecoseek.org").rstrip("/")
# Primary: direct connection to hermes.ecoseek.org
_REMOTE_URL = os.environ.get("HERMES_REMOTE_URL", "https://hermes.ecoseek.org").rstrip("/")
_API_KEY = os.environ.get("HERMES_ECOSEEK_API_KEY", "")
_MODEL = os.environ.get("HERMES_REMOTE_MODEL", "hermes")
_TIMEOUT = int(os.environ.get("HERMES_REMOTE_TIMEOUT", "300"))

# Legacy fallback (broker)
_BROKER_URL = os.environ.get("ECOSEEK_BROKER_URL", "").rstrip("/")
_BROKER_KEY = os.environ.get("ECOSEEK_BROKER_KEY", "")
_MODEL = os.environ.get("ECOSEEK_MODEL", "openclaw/main")
_TIMEOUT = int(os.environ.get("ECOSEEK_TIMEOUT", "300"))


def _get_remote_endpoint() -> tuple[str, str]:
"""Return (url, auth_header) for the best available remote Hermes."""
if _REMOTE_URL and _API_KEY:
return _REMOTE_URL, f"Bearer {_API_KEY}"
if _BROKER_URL and _BROKER_KEY:
return _BROKER_URL, f"Bearer {_BROKER_KEY}"
return "", ""
_MAX_TURNS = int(os.environ.get("DIDAL_MAX_TURNS", "20"))
_STUCK_THRESHOLD = int(os.environ.get("DIDAL_STUCK_THRESHOLD", "3"))

Expand Down Expand Up @@ -87,7 +101,11 @@ def detect_stuck_loop(history: list[dict]) -> bool:
# ---------------------------------------------------------------------------

def _send_to_beta(system_prompt: str, messages: list[dict]) -> dict:
"""Send a request to Beta (Hermes remote) via the broker."""
"""Send a request to Beta (Hermes remote) via hermes.ecoseek.org."""
base_url, auth = _get_remote_endpoint()
if not base_url:
raise RuntimeError("No remote endpoint configured")

api_messages = []
if system_prompt:
api_messages.append({"role": "system", "content": system_prompt})
Expand All @@ -104,11 +122,11 @@ def _send_to_beta(system_prompt: str, messages: list[dict]) -> dict:
"Content-Type": "application/json",
"Accept": "application/json",
}
if _BROKER_KEY:
headers["Authorization"] = f"Bearer {_BROKER_KEY}"
if auth:
headers["Authorization"] = auth

req = urllib.request.Request(
f"{_BROKER_URL}/v1/chat/completions",
f"{base_url}/v1/chat/completions",
data=body,
headers=headers,
method="POST",
Expand Down Expand Up @@ -176,13 +194,13 @@ def dialectical_exchange(
str
JSON with the dialogue history and final result.
"""
if not _BROKER_URL or not _BROKER_KEY:
if not ((_REMOTE_URL and _API_KEY) or (_BROKER_URL and _BROKER_KEY)):
return json.dumps({
"success": False,
"error": "didal_not_configured",
"error": "hermes_not_configured",
"message": (
"DiDAL requires ECOSEEK_BROKER_URL and ECOSEEK_BROKER_KEY. "
"Set them in ~/.hermes/.env to enable dialectical exchange."
"DiDAL requires HERMES_ECOSEEK_API_KEY (or legacy ECOSEEK_BROKER_URL "
"+ ECOSEEK_BROKER_KEY). Set in ~/.hermes/.env to enable."
),
})

Expand Down
5 changes: 2 additions & 3 deletions plugins/ecoseek/plugin.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,8 +1,7 @@
name: ecoseek
version: "0.3.0"
version: "0.5.0"
description: >
EcoSeek ecological intelligence plugin — dual-agent architecture with
DiDAL (Dialectical Dual-Agent Loop) for iterative task refinement.
EcoSeek DiDAL Phase 2 — dual-agent architecture via hermes.ecoseek.org.
Alpha tools: escalate_remote (one-shot), dialectical_exchange (debate loop).
Beta tools: eco_analyze (EcoAgent MCP wrapper), ku_hpc (Slurm HPC wrapper).
Enable via `hermes plugins enable ecoseek`.
Expand Down