@@ -30,24 +30,24 @@ def __init__(self, config, *args, **kwargs):
30
30
def process (self , context , data ):
31
31
# apply default filters
32
32
provider_filters = self .attribute_filters .get ("" , {})
33
- self ._apply_requester_filters (data .attributes , provider_filters , data .requester )
33
+ target_provider = data .auth_info .issuer
34
+ self ._apply_requester_filters (data .attributes , provider_filters , data .requester , context , target_provider )
34
35
35
36
# apply target provider specific filters
36
- target_provider = data .auth_info .issuer
37
37
provider_filters = self .attribute_filters .get (target_provider , {})
38
- self ._apply_requester_filters (data .attributes , provider_filters , data .requester )
38
+ self ._apply_requester_filters (data .attributes , provider_filters , data .requester , context , target_provider )
39
39
return super ().process (context , data )
40
40
41
- def _apply_requester_filters (self , attributes , provider_filters , requester ):
41
+ def _apply_requester_filters (self , attributes , provider_filters , requester , context , target_provider ):
42
42
# apply default requester filters
43
43
default_requester_filters = provider_filters .get ("" , {})
44
- self ._apply_filters (attributes , default_requester_filters )
44
+ self ._apply_filters (attributes , default_requester_filters , context , target_provider )
45
45
46
46
# apply requester specific filters
47
47
requester_filters = provider_filters .get (requester , {})
48
- self ._apply_filters (attributes , requester_filters )
48
+ self ._apply_filters (attributes , requester_filters , context , target_provider )
49
49
50
- def _apply_filters (self , attributes , attribute_filters ):
50
+ def _apply_filters (self , attributes , attribute_filters , context , target_provider ):
51
51
for attribute_name , attribute_filters in attribute_filters .items ():
52
52
if type (attribute_filters ) == str :
53
53
# convert simple notation to filter list
0 commit comments