mirror of
https://github.com/jumpserver/jumpserver.git
synced 2025-09-19 01:45:27 +00:00
perf: command log risk choice (#9419)
Co-authored-by: feng <1304903146@qq.com>
This commit is contained in:
@@ -3,8 +3,6 @@ from django.conf import settings
|
||||
from django.utils.functional import LazyObject
|
||||
|
||||
from common.utils import get_logger
|
||||
from .command.serializers import SessionCommandSerializer
|
||||
|
||||
|
||||
logger = get_logger(__file__)
|
||||
|
||||
|
@@ -1,53 +0,0 @@
|
||||
# ~*~ coding: utf-8 ~*~
|
||||
from django.utils.translation import ugettext_lazy as _
|
||||
from rest_framework import serializers
|
||||
|
||||
from common.utils import pretty_string
|
||||
from .models import AbstractSessionCommand
|
||||
|
||||
__all__ = ['SessionCommandSerializer', 'InsecureCommandAlertSerializer']
|
||||
|
||||
|
||||
class SimpleSessionCommandSerializer(serializers.Serializer):
|
||||
""" 简单Session命令序列类, 用来提取公共字段 """
|
||||
user = serializers.CharField(label=_("User")) # 限制 64 字符,见 validate_user
|
||||
asset = serializers.CharField(max_length=128, label=_("Asset"))
|
||||
input = serializers.CharField(max_length=2048, label=_("Command"))
|
||||
session = serializers.CharField(max_length=36, label=_("Session ID"))
|
||||
risk_level = serializers.ChoiceField(
|
||||
required=False, label=_("Risk level"), choices=AbstractSessionCommand.RISK_LEVEL_CHOICES
|
||||
)
|
||||
org_id = serializers.CharField(
|
||||
max_length=36, required=False, default='', allow_null=True, allow_blank=True
|
||||
)
|
||||
|
||||
def validate_user(self, value):
|
||||
if len(value) > 64:
|
||||
value = value[:32] + value[-32:]
|
||||
return value
|
||||
|
||||
|
||||
class InsecureCommandAlertSerializer(SimpleSessionCommandSerializer):
|
||||
pass
|
||||
|
||||
|
||||
class SessionCommandSerializerMixin(serializers.Serializer):
|
||||
"""使用这个类作为基础Command Log Serializer类, 用来序列化"""
|
||||
id = serializers.UUIDField(read_only=True)
|
||||
# 限制 64 字符,不能直接迁移成 128 字符,命令表数据量会比较大
|
||||
account = serializers.CharField(label=_("Account "))
|
||||
output = serializers.CharField(max_length=2048, allow_blank=True, label=_("Output"))
|
||||
timestamp = serializers.IntegerField(label=_('Timestamp'))
|
||||
timestamp_display = serializers.DateTimeField(read_only=True, label=_('Datetime'))
|
||||
remote_addr = serializers.CharField(read_only=True, label=_('Remote Address'))
|
||||
|
||||
def validate_account(self, value):
|
||||
if len(value) > 64:
|
||||
value = pretty_string(value, 64)
|
||||
return value
|
||||
|
||||
|
||||
class SessionCommandSerializer(SessionCommandSerializerMixin, SimpleSessionCommandSerializer):
|
||||
""" 字段排序序列类 """
|
||||
pass
|
||||
|
Reference in New Issue
Block a user