2
0
mirror of https://github.com/xcat2/confluent.git synced 2026-09-05 12:37:56 +00:00

Fix web shell sessions

This commit is contained in:
Jarrod Johnson
2026-07-01 14:47:42 -04:00
parent 6bcf1b73ba
commit 57a4c840cb
3 changed files with 5 additions and 5 deletions
+2 -1
View File
@@ -767,8 +767,9 @@ class ConsoleSession(object):
@classmethod
async def create(cls, node, configmanager, username, datacallback=None,
skipreplay=False, direct=True, width=80, height=24):
skipreplay=False, direct=True, width=80, height=24, sessionid=None):
self = cls()
self.sessionid = sessionid
self.registered = False
self.tenant = configmanager.tenant
if not configmanager.is_node(node):
+1 -1
View File
@@ -548,7 +548,7 @@ async def wsock_handler(req):
auditlog.log(auditmsg)
datacallback = datacallback_bound(clientsessid, rsp)
if shellsession:
consession = shellserver.ShellSession(
consession = await shellserver.ShellSession.create(
node=node, configmanager=cfgmgr,
username=username, skipreplay=skipreplay,
datacallback=datacallback,
+2 -3
View File
@@ -124,10 +124,9 @@ class ShellSession(consoleserver.ConsoleSession):
@classmethod
async def create(cls, node, configmanager, username, datacallback=None,
skipreplay=False, sessionid=None, width=80, height=24):
self = await super().__init__(node, configmanager, username,
self = await super().create(node, configmanager, username,
datacallback, skipreplay,
width=width, height=height)
self.sessionid = sessionid
width=width, height=height, sessionid=sessionid)
return self