Function async_wrapper

backend/common/audit/schemas/logger_decorator.py:485–594

(*args, **kwargs)

    def decorator(func: Callable) -> Callable:
        @functools.wraps(func)
        async def async_wrapper(*args, **kwargs):
            start_time = time.time()
            status = OperationStatus.SUCCESS
            error_message = None
            request = None
            resource_id = None
            resource_name = None
            remark = None
            oid = -1
            opt_type_ref = None
            resource_info_list = None
            result = None

            try:
                # Get current request
                request = RequestContext.get_request()
                func_signature = inspect.signature(func)
                bound_args = func_signature.bind(*args, **kwargs)
                bound_args.apply_defaults()
                unified_kwargs = dict(bound_args.arguments)

                # Step 1: Attempt to extract the resource ID from the parameters
                if config.resource_id_expr:
                    resource_id = SystemLogger.extract_from_function_params(
                        config.resource_id_expr,
                        unified_kwargs,
                        kwargs
                    )
                if config.remark_expr:
                    remark = SystemLogger.extract_from_function_params(
                        config.remark_expr,
                        unified_kwargs,
                        kwargs
                    )

                if config.operation_type == OperationType.LOGIN:
                    input_account_dec = SystemLogger.extract_from_function_params(
                        "form_data.username",
                        args,
                        kwargs
                    )
                    from common.utils.crypto import sqlbot_decrypt
                    input_account = await sqlbot_decrypt(input_account_dec)
                    with Session(engine) as session:
                        userInfo = get_user_by_account(session=session, account=input_account)
                        if userInfo is not None:
                            resource_id = userInfo.id
                            resource_name = userInfo.name
                            oid = userInfo.oid
                        else:
                            resource_id = -1
                            oid = -1
                            resource_name = input_account
                if config.operation_type == OperationType.DELETE:
                    with Session(engine) as session:
                        resource_info_list = get_resource_name_by_id_and_module(session, resource_id, config.module)

                if config.operation_type == OperationType.CREATE_OR_UPDATE: