from internal.post_request_filters import convert_analytics_groups_to_graphql
from internal.pre_request_filters import make_clientid_param, async_source, make_user_id_param, \
  make_email_param, decode_alliance_workspace_id_params
from management.alliance import *
from management.logs import event_log
from management.packages import get_product_packages, get_current_package
from management.pre_request_filters import make_allianceid_param
from management.users import update_current_user, get_current_user, get_stripe_invoices, update_billing_info, \
  get_billing_info, get_stripe_payment_method, create_stripe_subscription, retry_stripe_subscription, \
  cancel_stripe_subscription, update_payment_method, setup_payment_intent, get_stripe_invoice, retry_stripe_invoice, \
  cancel_stripe_subscription_schedule
from management.workspace import create_workspace, update_workspace, delete_workspace, get_workspaces, get_workspace, \
  check_workspace_channel_access, get_workspace_totalprofiles
from management.progress import check_process_subscription_access

log = logging.getLogger().getChild('management')


def make_management_endpoints(DP_URL):
    return {
      "management/create_alliance": {
        "pre_filters": [make_clientid_param],
        "rights_check": ['max_alliance_count'],
        "url": DP_URL + "initialize_new_user",
        "query": create_alliance},
      "management/update_alliance": {
        "pre_filters": [make_allianceid_param],
        "query": update_alliance},
      "management/delete_alliance": {
        "url": DP_URL + "async_notify",
        "pre_filters": [async_source, make_user_id_param, make_allianceid_param, make_clientid_param],
        "query": delete_alliance},
      "management/delete_alliance_collections": {
        "url": DP_URL + "async_notify",
        "pre_filters": [async_source, make_user_id_param, make_allianceid_param, make_clientid_param],
        "query": delete_alliance_collections},
      "management/invite_alliance_member": {
        "pre_filters": [make_allianceid_param],
        "url": DP_URL + "async_notify",
        "query": invite_alliance_member},
      "management/alliance_invitation_reply": {
        "pre_filters": [make_allianceid_param],
        "query": alliance_invitation_reply},
      "management/remove_alliance_member": {
        "url": DP_URL + "async_notify",
        "pre_filters": [async_source, decode_alliance_workspace_id_params, make_user_id_param, make_allianceid_param,
                        make_clientid_param],
        "query": remove_alliance_member},
      "management/get_alliance_analytics": {
        "url": DP_URL + "get_grouped_analytics",
        "pre_filters": [decode_alliance_workspace_id_params, make_allianceid_param],
        "query": get_alliance_analytics,
        "post_filters": [convert_analytics_groups_to_graphql]},
      "management/get_alliances": {
        "query": get_alliances},
      "management/get_alliance": {
        "pre_filters": [make_allianceid_param],
        "query": get_alliance},
      "management/get_alliance_members": {
        "pre_filters": [make_allianceid_param],
        "query": get_alliance_members},
      "management/get_alliance_segments": {
        "pre_filters": [make_allianceid_param],
        "query": get_alliance_segments},
      "management/get_alliance_collections": {
        "pre_filters": [make_allianceid_param],
        "query": get_alliance_collections},
      "management/get_alliance_totalProfiles": {
        "pre_filters": [make_allianceid_param],
        "query": get_alliance_totalprofiles},
      "management/merge_profiles_into_alliance": {
        "url": DP_URL + "async_notify",
        "method": "POST",
        "pre_filters": [async_source, make_user_id_param, make_allianceid_param, make_clientid_param],
        "query": merge_profiles_into_alliance},
      "management/get_alliance_collection_event_log": {
        "pre_filters": [make_allianceid_param],
        "query": get_alliance_collection_event_log},
      "management/send_alliance": {
        "pre_filters": [],
        "query": send_alliance},
      "management/event_log": {
        "pre_filters": [decode_alliance_workspace_id_params, make_allianceid_param, make_clientid_param, make_email_param],
        "query": event_log},
      "management/check_alliance_channel_access": {
        "query": check_alliance_channel_access
      },
      "management/check_workspace_channel_access": {
        "query": check_workspace_channel_access
      },
      "management/check_progress_subscription_access": {
        "query": check_process_subscription_access
      },
      "management/update_current_user": {
        "query": update_current_user
      },
      "management/get_current_user": {
        "query": get_current_user
      },
      "management/create_workspace": {
        "pre_filters": [make_clientid_param],
        "rights_check": ['max_workspace_count'],
        "url": DP_URL + "initialize_new_user",
        "query": create_workspace},
      "management/update_workspace": {
        "pre_filters": [make_clientid_param],
        "query": update_workspace},
      "management/delete_workspace": {
        "url": DP_URL + "async_notify",
        "pre_filters": [async_source, make_user_id_param, make_clientid_param],
        "query": delete_workspace},
      "management/get_workspaces": {
        "query": get_workspaces},
      "management/get_workspace": {
        "pre_filters": [make_clientid_param],
        "query": get_workspace},
      "management/get_workspace_total_profiles": {
        "pre_filters": [decode_alliance_workspace_id_params, make_clientid_param],
        "query": get_workspace_totalprofiles},
      "management/get_product_packages": {
        "pre_filters": [make_clientid_param],
        "query": get_product_packages},
      "management/get_current_package": {
        "pre_filters": [make_clientid_param],
        "query": get_current_package},
      "management/get_stripe_invoices": {
        "pre_filters": [make_clientid_param],
        "query": get_stripe_invoices},
      "management/update_billing_info": {
        "pre_filters": [make_clientid_param],
        "query": update_billing_info},
      "management/get_billing_info": {
        "pre_filters": [make_clientid_param],
        "query": get_billing_info},
      "management/get_payment_method": {
        "pre_filters": [make_clientid_param],
        "query": get_stripe_payment_method},
      "management/create_stripe_subscription": {
        "pre_filters": [make_clientid_param],
        "query": create_stripe_subscription},
      "management/retry_stripe_subscription": {
        "pre_filters": [make_clientid_param],
        "query": retry_stripe_subscription},
      "management/cancel_stripe_subscription": {
        "pre_filters": [make_clientid_param],
        "query": cancel_stripe_subscription},
      "management/cancel_stripe_subscription_schedule": {
        "pre_filters": [make_clientid_param],
        "query": cancel_stripe_subscription_schedule},
      "management/update_payment_method": {
        "pre_filters": [make_clientid_param],
        "query": update_payment_method},
      "management/setup_intent": {
        "pre_filters": [make_clientid_param],
        "query": setup_payment_intent},
      "management/get_stripe_invoice": {
        "pre_filters": [make_clientid_param],
        "query": get_stripe_invoice},
      "management/retry_stripe_invoice": {
        "pre_filters": [make_clientid_param],
        "query": retry_stripe_invoice},
    }