from internal.post_request_filters import convert_collections_to_graphql
from internal.pre_request_filters import make_clientid_param, make_user_id_param, decode_alliance_workspace_id_params, \
    async_source, make_email_param
from internal.queries import http_query
from management.pre_request_filters import make_allianceid_param


def make_klaviyo_endpoints(DP_URL):
    return {
        "dataprocessor/get_klaviyo_status": {"url": DP_URL + "get_klaviyo_status",
                                             "method": "POST",
                                             "pre_filters": [make_allianceid_param, make_clientid_param],
                                             "query": http_query
                                             },
        "dataprocessor/update_klaviyo_status": {"url": DP_URL + "update_klaviyo_status",
                                                "method": "POST",
                                                "pre_filters": [make_clientid_param, make_user_id_param],
                                                "query": http_query
                                                },
        "dataprocessor/list_klaviyo_lists": {"url": DP_URL + "list_klaviyo_lists",
                                             "method": "POST",
                                             "pre_filters": [make_user_id_param, make_clientid_param],
                                             "query": http_query
                                             },
        "dataprocessor/klaviyo_import": {"url": DP_URL + "async_notify",
                                         "method": "POST",
                                         "rights_check": ['max_unique_fan_count'],
                                         "pre_filters": [async_source, make_user_id_param,
                                                         decode_alliance_workspace_id_params, make_clientid_param],
                                         "query": http_query,
                                         "post_filters": [convert_collections_to_graphql]
                                         },
        "dataprocessor/klaviyo_export": {"url": DP_URL + "async_notify",
                                         "method": "POST",
                                         "pre_filters": [async_source, make_email_param, make_user_id_param,
                                                         decode_alliance_workspace_id_params, make_allianceid_param,
                                                         make_clientid_param],
                                         "query": http_query,
                                         "post_filters": [convert_collections_to_graphql]
                                         }
    }