Commit 61abfa7e authored by Jorge Moratinos's avatar Jorge Moratinos
Browse files

New tests insisde event_filter features

parent 2cc7d8e4
Loading
Loading
Loading
Loading
Loading
+486 −37

File changed.

Preview size limit exceeded, changes collapsed.

+29 −2
Original line number Diff line number Diff line
@@ -32,7 +32,7 @@ def create_service_security_body(notification_destination, aef_id=None, api_id=N
    return data


def create_service_security_from_discover_response(notification_destination, discover_response):
def create_service_security_from_discover_response(notification_destination, discover_response, legacy=True):
    data = {
        "notificationDestination": notification_destination,
        "supportedFeatures": "fffffff",
@@ -43,6 +43,7 @@ def create_service_security_from_discover_response(notification_destination, dis
        },
        "requestTestNotification": True
    }
    api_ids=list()
    service_api_descriptions = discover_response.json()['serviceAPIDescriptions']
    for service_api_description in service_api_descriptions:
        for aef_profile in service_api_description['aefProfiles']:
@@ -53,7 +54,33 @@ def create_service_security_from_discover_response(notification_destination, dis
                "aefId": aef_profile['aefId'],
                "apiId": service_api_description['apiId']
            })
            api_ids.append(service_api_description['apiId'])
    if legacy:
        return data
    else:
        return data, api_ids


def update_service_security_with_discover_response(security_body, discover_response, legacy=True):
    api_ids = list()
    service_api_descriptions = discover_response.json()['serviceAPIDescriptions']
    for service_api_description in service_api_descriptions:
        for aef_profile in service_api_description['aefProfiles']:
            security_body['securityInfo'].append({
                "authenticationInfo": "authenticationInfo",
                "authorizationInfo": "authorizationInfo",
                "prefSecurityMethods": ["PSK", "PKI", "OAUTH"],
                "aefId": aef_profile['aefId'],
                "apiId": service_api_description['apiId']
            })

    for security_info in security_body['securityInfo']:
        api_ids.append(security_info['apiId'])

    if legacy:
        return security_body
    else:
        return security_body, api_ids


def create_security_notification_body(api_invoker_id, api_ids, cause="OVERLIMIT_USAGE", aef_id=None):