from management.workspace import check_workspace_channel_access
from management.alliance import check_alliance_channel_access


def check_process_subscription_access(endpoint, req, event):
    channel_id = req["channelId"]
    if channel_id.startswith("c") or channel_id.startswith("w"):  # workspace
        check_workspace_channel_access(endpoint, req, event)
    elif channel_id.startswith("a"):  # alliance
        check_alliance_channel_access(endpoint, req, event)
    else:
        raise RuntimeError("Unknown channelId format.")