From 8570bf7eb82ab4fce522d13201cb5a250803fd1c Mon Sep 17 00:00:00 2001 From: yumoqing Date: Tue, 14 Jan 2025 19:20:48 +0800 Subject: [PATCH 1/4] bugfix --- ahserver/websocketProcessor.py | 6 ------ 1 file changed, 6 deletions(-) diff --git a/ahserver/websocketProcessor.py b/ahserver/websocketProcessor.py index ec4be55..81c2a02 100644 --- a/ahserver/websocketProcessor.py +++ b/ahserver/websocketProcessor.py @@ -49,12 +49,6 @@ class XtermProcessor(PythonScriptProcessor): self.retResponse = ws return ws - async def get_login_info(self): - async with aiofiles.open(self.real_path, 'r', encoding='utf-8') as f: - txt = await f.read() - self.login_info = json.loads(txt) - # print(f'{self.login_info=}') - async def create_process(self, lgoin_info): # id = lenv['params_kw'].get('termid') host = login_info['host'] From 0be1a53af4143017305f5589c3b8ce1b50b28db5 Mon Sep 17 00:00:00 2001 From: yumoqing Date: Sun, 19 Jan 2025 20:46:39 +0800 Subject: [PATCH 2/4] bugfix --- ahserver/websocketProcessor.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/ahserver/websocketProcessor.py b/ahserver/websocketProcessor.py index 81c2a02..83e47bd 100644 --- a/ahserver/websocketProcessor.py +++ b/ahserver/websocketProcessor.py @@ -49,7 +49,7 @@ class XtermProcessor(PythonScriptProcessor): self.retResponse = ws return ws - async def create_process(self, lgoin_info): + async def create_process(self, login_info): # id = lenv['params_kw'].get('termid') host = login_info['host'] port = login_info.get('port', 22) From 6e40d7f5273e914d1fc299ccd3ec8ef17bec7991 Mon Sep 17 00:00:00 2001 From: yumoqing Date: Sun, 19 Jan 2025 21:39:00 +0800 Subject: [PATCH 3/4] bugfix --- ahserver/baseProcessor.py | 2 +- ahserver/websocketProcessor.py | 7 ++++++- 2 files changed, 7 insertions(+), 2 deletions(-) diff --git a/ahserver/baseProcessor.py b/ahserver/baseProcessor.py index bcf1f13..8a716d8 100644 --- a/ahserver/baseProcessor.py +++ b/ahserver/baseProcessor.py @@ -76,7 +76,7 @@ class BaseProcessor: kw = await self.run_ns['request2ns']() kw.update(params) self.run_ns['params_kw'] = kw - self.run_ns.update(kw) + # self.run_ns.update(kw) self.run_ns['ref_real_path'] = self.real_path self.run_ns['processor'] = self self.env_set = True diff --git a/ahserver/websocketProcessor.py b/ahserver/websocketProcessor.py index 83e47bd..353f777 100644 --- a/ahserver/websocketProcessor.py +++ b/ahserver/websocketProcessor.py @@ -38,7 +38,12 @@ class XtermProcessor(PythonScriptProcessor): # it must return a DictObject with sshnode information # parameters: nodeid # - login_info = super().path_call(request, params=params) + await self.set_run_env(request, params=params) + login_info = await super().path_call(request, params=params) + if login_info is None: + raise f'data error' + + debug(f'{login_info=}') ws = web.WebSocketResponse() await ws.prepare(request) await self.create_process(login_info) From 5af9ddb2e5799cae7568a04bf1af2b326f1e5820 Mon Sep 17 00:00:00 2001 From: yumoqing Date: Sun, 19 Jan 2025 21:47:18 +0800 Subject: [PATCH 4/4] bugfix --- ahserver/websocketProcessor.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/ahserver/websocketProcessor.py b/ahserver/websocketProcessor.py index 353f777..ec28b67 100644 --- a/ahserver/websocketProcessor.py +++ b/ahserver/websocketProcessor.py @@ -60,9 +60,11 @@ class XtermProcessor(PythonScriptProcessor): port = login_info.get('port', 22) username = login_info.get('username', 'root') password = login_info.get('password',None) + jumpers = login_info.get('jumpers', []) self.sshnode = SSHNode(host, username=username, password=password, - port=port) + port=port, + jumpers=jumpers) await self.sshnode.connect() self.p_obj = await self.sshnode._process('bash', term_type='vt100',