mirror of https://github.com/jumpserver/jumpserver
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
140 lines
3.4 KiB
140 lines
3.4 KiB
# -*- coding: utf-8 -*-
|
|
#
|
|
import uuid
|
|
from inspect import signature
|
|
from functools import wraps
|
|
from werkzeug.local import LocalProxy
|
|
from contextlib import contextmanager
|
|
|
|
from common.local import thread_local
|
|
from .models import Organization
|
|
|
|
|
|
def get_org_from_request(request):
|
|
oid = request.META.get("HTTP_X_JMS_ORG")
|
|
if not oid:
|
|
oid = request.session.get("oid")
|
|
request_params_oid = request.GET.get("oid")
|
|
if request_params_oid:
|
|
oid = request.GET.get("oid")
|
|
|
|
if not oid:
|
|
oid = Organization.DEFAULT_ID
|
|
if oid.lower() == "default":
|
|
oid = Organization.DEFAULT_ID
|
|
elif oid.lower() == "root":
|
|
oid = Organization.ROOT_ID
|
|
org = Organization.get_instance(oid, True)
|
|
return org
|
|
|
|
|
|
def set_current_org(org):
|
|
if isinstance(org, (str, uuid.UUID)):
|
|
org = Organization.get_instance(org)
|
|
setattr(thread_local, 'current_org_id', org.id)
|
|
|
|
|
|
def set_to_default_org():
|
|
set_current_org(Organization.default())
|
|
|
|
|
|
def set_to_root_org():
|
|
set_current_org(Organization.root())
|
|
|
|
|
|
def _find(attr):
|
|
return getattr(thread_local, attr, None)
|
|
|
|
|
|
def get_current_org():
|
|
org_id = get_current_org_id()
|
|
if org_id is None:
|
|
return None
|
|
org = Organization.get_instance(org_id)
|
|
return org
|
|
|
|
|
|
def get_current_org_id():
|
|
org_id = _find('current_org_id')
|
|
return org_id
|
|
|
|
|
|
def get_current_org_id_for_serializer():
|
|
org_id = get_current_org_id()
|
|
if org_id == Organization.DEFAULT_ID:
|
|
org_id = ''
|
|
return org_id
|
|
|
|
|
|
@contextmanager
|
|
def tmp_to_root_org():
|
|
ori_org = get_current_org()
|
|
set_to_root_org()
|
|
yield
|
|
if ori_org is not None:
|
|
set_current_org(ori_org)
|
|
|
|
|
|
@contextmanager
|
|
def tmp_to_org(org):
|
|
ori_org = get_current_org()
|
|
set_current_org(org)
|
|
yield
|
|
if ori_org is not None:
|
|
set_current_org(ori_org)
|
|
|
|
|
|
def get_org_filters():
|
|
kwargs = {}
|
|
|
|
_current_org = get_current_org()
|
|
if _current_org is None:
|
|
return kwargs
|
|
|
|
if _current_org.is_real():
|
|
kwargs['org_id'] = _current_org.id
|
|
elif _current_org.is_default():
|
|
kwargs["org_id"] = ''
|
|
return kwargs
|
|
|
|
|
|
def filter_org_queryset(queryset):
|
|
kwargs = get_org_filters()
|
|
|
|
#
|
|
# lines = traceback.format_stack()
|
|
# print(">>>>>>>>>>>>>>>>>>>>>>>>>>>>")
|
|
# for line in lines[-10:-1]:
|
|
# print(line)
|
|
# print("<<<<<<<<<<<<<<<<<<<<<<<<<<<<")
|
|
queryset = queryset.filter(**kwargs)
|
|
return queryset
|
|
|
|
|
|
def org_aware_func(org_arg_name):
|
|
"""
|
|
:param org_arg_name: 函数中包含org_id的对象是哪个参数
|
|
:return:
|
|
"""
|
|
def decorate(func):
|
|
@wraps(func)
|
|
def wrapper(*args, **kwargs):
|
|
sig = signature(func)
|
|
values = sig.bind(*args, **kwargs)
|
|
org_aware_resource = values.arguments.get(org_arg_name)
|
|
if not org_aware_resource:
|
|
return func(*args, **kwargs)
|
|
if hasattr(org_aware_resource, '__getitem__'):
|
|
org_aware_resource = org_aware_resource[0]
|
|
if not hasattr(org_aware_resource, "org_id"):
|
|
print("Error: {} not has org_id attr".format(org_aware_resource))
|
|
return func(*args, **kwargs)
|
|
with tmp_to_org(org_aware_resource.org_id):
|
|
# print("Current org id: {}".format(org_aware_resource.org_id))
|
|
return func(*args, **kwargs)
|
|
return wrapper
|
|
return decorate
|
|
|
|
|
|
current_org = LocalProxy(get_current_org)
|