github
/
jumpserver
mirror of https://github.com/jumpserver/jumpserver
1
0
Fork 0
Code Issues Releases Wiki Activity

fix: 修复bug

pull/5423/head
ibuler 2021-01-14 10:21:21 +08:00 committed by 老广
parent 62aeaf31c6
commit 3751b4158e
2 changed files with 5 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
apps/authentication/api/auth.py
View File

@ -54,12 +54,3 @@ class UserConnectionTokenApi(RootOrgViewMixin, APIView):
return Response(value) return Response(value)
else: else:
return Response({'user': value['user']}) return Response({'user': value['user']})
def get_permissions(self):
if self.request.query_params.get('user-only', None):
self.permission_classes = (AllowAny,)
return super().get_permissions()

4
apps/ops/ws.py
View File

@ -15,7 +15,11 @@ class CeleryLogWebsocket(JsonWebsocketConsumer):
disconnected = False disconnected = False
def connect(self): def connect(self):
user = self.scope["user"]
if user.is_authenticated and user.is_org_admin:
self.accept() self.accept()
else:
self.close()
def receive(self, text_data=None, bytes_data=None, **kwargs): def receive(self, text_data=None, bytes_data=None, **kwargs):
data = json.loads(text_data) data = json.loads(text_data)