hansjone/oclaw
1
0
Fork 0
mirror of https://github.com/hansjone/oclaw.git synced 2026-10-08 23:33:16 +08:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix(netx-bridge): use OCLAW_OPS_AI_SHARED_TOKEN for alarm WSS auth

Browse source 
Co-authored-by: Cursor <cursoragent@cursor.com>
This commit is contained in:
oliver 2026-06-22 11:22:39 +08:00
parent 7210293f42
commit eaeb9fd33d
3 changed files with 4 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

4
_local/system.env.example
View file

@ -317,10 +317,8 @@ OCLAW_WS_RATE_LIMIT_USER_PER_WINDOW=360
OCLAW_WS_SEND_QUEUE_MAX_MESSAGES=256
OCLAW_WS_SEND_QUEUE_MAX_BYTES=
OCLAW_WS_EVENT_REPLAY_MAX=256
# netx -> oclaw AP 分析接口共享 token（可选；设置后可用 Bearer 直接访问 /admin/api/ops-ai/analyze-sync）
# netx -> oclaw AP 分析接口共享 token（可选；设置后可用 Bearer 直接访问 /admin/api/ops-ai/analyze-sync，亦用于 /ws/netx-bridge 告警 WSS）
OCLAW_OPS_AI_SHARED_TOKEN=
# netx -> oclaw 告警 WSS（/ws/netx-bridge）独立 token，与 OPS_AI 分开
OCLAW_NETX_BRIDGE_TOKEN=
# -----------------------------------------------------------------------------
# 十五、模型请求：工具 JSON、Replay 策略、Agent 消息回放

2
interfaces/ws/netx_bridge.py
View file

@ -11,7 +11,7 @@ from svc.persistence.assistant_store import get_assistant_store
def _bridge_token_expected() -> str:
return str(os.getenv("OCLAW_NETX_BRIDGE_TOKEN") or "").strip()
return str(os.getenv("OCLAW_OPS_AI_SHARED_TOKEN") or "").strip()
def _verify_bridge_token(token: str) -> bool:

4
tests/test_netx_bridge_whatsapp_outbound.py
View file

@ -13,8 +13,8 @@ from svc.persistence.assistant_store import reset_assistant_store_singleton
class NetxBridgeTests(unittest.TestCase):
def setUp(self) -> None:
os.environ["OCLAW_NETX_BRIDGE_TOKEN"] = "test-bridge-token"
os.environ.pop("OCLAW_OPS_AI_SHARED_TOKEN", None)
os.environ["OCLAW_OPS_AI_SHARED_TOKEN"] = "test-bridge-token"
os.environ.pop("OCLAW_NETX_BRIDGE_TOKEN", None)
os.environ["AIA_WHATSAPP_ACCOUNT_ID"] = "wa-default"
reset_assistant_store_singleton()
self.client = TestClient(create_app())