from __future__ import absolute_import, division, print_function

import io
import logging
import os
import re
import sys

import six
from six.moves.urllib.parse import parse_qsl

import telnyx

TELNYX_LOG = os.environ.get("TELNYX_LOG")

logger = logging.getLogger("telnyx")

__all__ = ["io", "parse_qsl", "utf8", "log_info", "log_debug", "logfmt"]

# Special valid characters in telnyx id's objects. Format: `=/$#`
telnyx_valid_id_parts = "=-"


def utf8(value):
    if six.PY2 and isinstance(value, six.text_type):
        return value.encode("utf-8")
    else:
        return value


def is_appengine_dev():
    return "APPENGINE_RUNTIME" in os.environ and "Dev" in os.environ.get(
        "SERVER_SOFTWARE", ""
    )


def _console_log_level():
    if telnyx.log in ["debug", "info"]:
        return telnyx.log
    elif TELNYX_LOG in ["debug", "info"]:
        return TELNYX_LOG
    else:
        return None


# Rewrites reserved word keyword arguments
# This makes Message.create(to="", from_="", text="") possible
def rewrite_reserved_words(kwargs, reverse=False):
    reserved = [("from_", "from")]

    for i in reserved:
        if not reverse:
            original, replacement = i
        else:
            replacement, original = i

        if kwargs.get(original, None) is not None:
            kwargs[replacement] = kwargs.pop(original)

    return kwargs


def log_debug(message, **params):
    msg = logfmt(dict(message=message, **params))
    if _console_log_level() == "debug":
        print(msg, file=sys.stderr)
    logger.debug(msg)


def log_info(message, **params):
    msg = logfmt(dict(message=message, **params))
    if _console_log_level() in ["debug", "info"]:
        print(msg, file=sys.stderr)
    logger.info(msg)


def logfmt(props):
    def fmt(key, val):
        # Handle case where val is a bytes or bytesarray
        if six.PY3 and hasattr(val, "decode"):
            val = val.decode("utf-8")
        # Check if val is already a string to avoid re-encoding into
        # ascii. Since the code is sent through 2to3, we can't just
        # use unicode(val, encoding='utf8') since it will be
        # translated incorrectly.
        if not isinstance(val, six.string_types):
            val = six.text_type(val)
        if re.search(r"\s", val):
            val = repr(val)
        # key should already be a string
        if re.search(r"\s", key):
            key = repr(key)
        return "{key}={val}".format(key=key, val=val)

    return " ".join([fmt(key, val) for key, val in sorted(props.items())])


OBJECT_CLASSES = {}


def load_object_classes():
    # This is here to avoid a circular dependency
    from telnyx import api_resources

    global OBJECT_CLASSES

    OBJECT_CLASSES = {
        # business objects
        api_resources.APIKey.OBJECT_NAME: api_resources.APIKey,
        api_resources.AccessControlIP.OBJECT_NAME: api_resources.AccessControlIP,
        api_resources.AccessIPAddress.OBJECT_NAME: api_resources.AccessIPAddress,
        api_resources.AccessToken.OBJECT_NAME: api_resources.AccessToken,
        api_resources.Address.OBJECT_NAME: api_resources.Address,
        api_resources.AdvancedOptinoptout.OBJECT_NAME: api_resources.AdvancedOptinoptout,
        api_resources.AI.OBJECT_NAME: api_resources.AI,
        api_resources.AuthenticationProvider.OBJECT_NAME: api_resources.AuthenticationProvider,
        api_resources.Autorechargepreference.OBJECT_NAME: api_resources.Autorechargepreference,
        api_resources.AvailablePhoneNumber.OBJECT_NAME: api_resources.AvailablePhoneNumber,
        api_resources.Balance.OBJECT_NAME: api_resources.Balance,
        api_resources.Billing.OBJECT_NAME: api_resources.Billing,
        api_resources.BillingGroup.OBJECT_NAME: api_resources.BillingGroup,
        api_resources.Brand.OBJECT_NAME: api_resources.Brand,
        api_resources.Bucket.OBJECT_NAME: api_resources.Bucket,
        api_resources.BucketUsage.OBJECT_NAME: api_resources.BucketUsage,
        api_resources.BulkCreation.OBJECT_NAME: api_resources.BulkCreation,
        api_resources.BulkCredential.OBJECT_NAME: api_resources.BulkCredential,
        api_resources.BulkPhoneNumberCampaign.OBJECT_NAME: api_resources.BulkPhoneNumberCampaign,
        api_resources.BulkPhoneNumberOperation.OBJECT_NAME: api_resources.BulkPhoneNumberOperation,
        api_resources.BulkSoleProprietorCreation.OBJECT_NAME: api_resources.BulkSoleProprietorCreation,
        api_resources.BusinessIdentity.OBJECT_NAME: api_resources.BusinessIdentity,
        api_resources.Call.OBJECT_NAME: api_resources.Call,
        api_resources.CallControlApplication.OBJECT_NAME: api_resources.CallControlApplication,
        api_resources.CallInformation.OBJECT_NAME: api_resources.CallInformation,
        api_resources.CallRecording.OBJECT_NAME: api_resources.CallRecording,
        api_resources.Campaign.OBJECT_NAME: api_resources.Campaign,
        api_resources.CdrUsageReport.OBJECT_NAME: api_resources.CdrUsageReport,
        api_resources.Comment.OBJECT_NAME: api_resources.Comment,
        api_resources.Conference.OBJECT_NAME: api_resources.Conference,
        api_resources.Connection.OBJECT_NAME: api_resources.Connection,
        api_resources.CredentialConnection.OBJECT_NAME: api_resources.CredentialConnection,
        api_resources.CsvDownload.OBJECT_NAME: api_resources.CsvDownload,
        api_resources.CustomStorageCredential.OBJECT_NAME: api_resources.CustomStorageCredential,
        api_resources.CustomerServiceRecord.OBJECT_NAME: api_resources.CustomerServiceRecord,
        api_resources.Debugging.OBJECT_NAME: api_resources.Debugging,
        api_resources.DetailRecord.OBJECT_NAME: api_resources.DetailRecord,
        api_resources.DetailRecordsReport.OBJECT_NAME: api_resources.DetailRecordsReport,
        api_resources.DialogflowIntegration.OBJECT_NAME: api_resources.DialogflowIntegration,
        api_resources.Document.OBJECT_NAME: api_resources.Document,
        api_resources.Document.OBJECT_NAME: api_resources.DocumentLink,
        api_resources.DynamicEmergencyAddress.OBJECT_NAME: api_resources.DynamicEmergencyAddress,
        api_resources.DynamicEmergencyEndpoint.OBJECT_NAME: api_resources.DynamicEmergencyEndpoint,
        api_resources.Enum.OBJECT_NAME: api_resources.Enum,
        api_resources.Event.OBJECT_NAME: api_resources.Event,
        api_resources.ExternalConnection.OBJECT_NAME: api_resources.ExternalConnection,
        api_resources.Fax.OBJECT_NAME: api_resources.Fax,
        api_resources.FaxApplication.OBJECT_NAME: api_resources.FaxApplication,
        api_resources.FQDN.OBJECT_NAME: api_resources.FQDN,
        api_resources.FQDNConnection.OBJECT_NAME: api_resources.FQDNConnection,
        api_resources.IP.OBJECT_NAME: api_resources.IP,
        api_resources.IPAddress.OBJECT_NAME: api_resources.IPAddress,
        api_resources.IPConnection.OBJECT_NAME: api_resources.IPConnection,
        api_resources.IPRange.OBJECT_NAME: api_resources.IPRange,
        api_resources.InboundChannel.OBJECT_NAME: api_resources.InboundChannel,
        api_resources.InventoryCoverage.OBJECT_NAME: api_resources.InventoryCoverage,
        api_resources.InventoryLevel.OBJECT_NAME: api_resources.InventoryLevel,
        api_resources.ManagedAccount.OBJECT_NAME: api_resources.ManagedAccount,
        api_resources.MdrDetailReport.OBJECT_NAME: api_resources.MdrDetailReport,
        api_resources.MdrUsageReport.OBJECT_NAME: api_resources.MdrUsageReport,
        api_resources.Media.OBJECT_NAME: api_resources.Media,
        api_resources.MediaStorageApi.OBJECT_NAME: api_resources.MediaStorageApi,
        api_resources.Message.OBJECT_NAME: api_resources.Message,
        api_resources.MessagingHostedNumber.OBJECT_NAME: api_resources.MessagingHostedNumber,
        api_resources.MessagingHostedNumberOrder.OBJECT_NAME: api_resources.MessagingHostedNumberOrder,
        api_resources.MessagingPhoneNumber.OBJECT_NAME: api_resources.MessagingPhoneNumber,
        api_resources.MessagingProfile.OBJECT_NAME: api_resources.MessagingProfile,
        api_resources.MessagingTollfreeVerification.OBJECT_NAME: api_resources.MessagingTollfreeVerification,
        api_resources.MessagingUrlDomain.OBJECT_NAME: api_resources.MessagingUrlDomain,
        api_resources.MobileNetworkOperator.OBJECT_NAME: api_resources.MobileNetworkOperator,
        api_resources.Network.OBJECT_NAME: api_resources.Network,
        api_resources.Notification.OBJECT_NAME: api_resources.Notification,
        api_resources.NotificationChannel.OBJECT_NAME: api_resources.NotificationChannel,
        api_resources.NotificationEvent.OBJECT_NAME: api_resources.NotificationEvent,
        api_resources.NotificationEventCondition.OBJECT_NAME: api_resources.NotificationEventCondition,
        api_resources.NotificationProfile.OBJECT_NAME: api_resources.NotificationProfile,
        api_resources.NotificationSetting.OBJECT_NAME: api_resources.NotificationSetting,
        api_resources.NumberConfiguration.OBJECT_NAME: api_resources.NumberConfiguration,
        api_resources.NumberLookup.OBJECT_NAME: api_resources.NumberLookup,
        api_resources.NumberOrder.OBJECT_NAME: api_resources.NumberOrder,
        api_resources.NumberOrderPhoneNumber.OBJECT_NAME: api_resources.NumberOrderPhoneNumber,
        api_resources.NumberPortout.OBJECT_NAME: api_resources.NumberPortout,
        api_resources.NumberReservation.OBJECT_NAME: api_resources.NumberReservation,
        api_resources.NumbersFeature.OBJECT_NAME: api_resources.NumbersFeature,
        api_resources.OtaUpdate.OBJECT_NAME: api_resources.OtaUpdate,
        api_resources.OutboundVoiceProfile.OBJECT_NAME: api_resources.OutboundVoiceProfile,
        api_resources.PhoneNumber.OBJECT_NAME: api_resources.PhoneNumber,
        api_resources.PhoneNumber.OBJECT_NAME: api_resources.MessagingSettings,
        api_resources.PhoneNumber.OBJECT_NAME: api_resources.VoiceSettings,
        api_resources.PhoneNumberBlockOrder.OBJECT_NAME: api_resources.PhoneNumberBlockOrder,
        api_resources.PhoneNumberBlocksBackgroundJob.OBJECT_NAME: api_resources.PhoneNumberBlocksBackgroundJob,
        api_resources.PhoneNumberByProfile.OBJECT_NAME: api_resources.PhoneNumberByProfile,
        api_resources.PhoneNumberCampaign.OBJECT_NAME: api_resources.PhoneNumberCampaign,
        api_resources.PhoneNumberConfiguration.OBJECT_NAME: api_resources.PhoneNumberConfiguration,
        api_resources.PhoneNumberJob.OBJECT_NAME: api_resources.PhoneNumberJob,
        api_resources.PhoneNumberOrder.OBJECT_NAME: api_resources.PhoneNumberOrder,
        api_resources.PhoneNumberOrderDocument.OBJECT_NAME: api_resources.PhoneNumberOrderDocument,
        api_resources.PhoneNumberPorting.OBJECT_NAME: api_resources.PhoneNumberPorting,
        api_resources.PhoneNumberRegulatoryRequirement.OBJECT_NAME: api_resources.PhoneNumberRegulatoryRequirement,
        api_resources.PhoneNumberReservation.OBJECT_NAME: api_resources.PhoneNumberReservation,
        api_resources.PhoneNumberSearch.OBJECT_NAME: api_resources.PhoneNumberSearch,
        api_resources.PortOut.OBJECT_NAME: api_resources.PortOut,
        api_resources.PortabilityCheck.OBJECT_NAME: api_resources.PortabilityCheck,
        api_resources.PortingOrder.OBJECT_NAME: api_resources.PortingOrder,
        api_resources.PortingOrder.OBJECT_NAME: api_resources.PortingPhoneNumber,
        api_resources.PresignedObjectUrl.OBJECT_NAME: api_resources.PresignedObjectUrl,
        api_resources.PrivateWirelessGateway.OBJECT_NAME: api_resources.PrivateWirelessGateway,
        api_resources.PublicInternetGateway.OBJECT_NAME: api_resources.PublicInternetGateway,
        api_resources.PushCredential.OBJECT_NAME: api_resources.PushCredential,
        api_resources.Queue.OBJECT_NAME: api_resources.Queue,
        api_resources.Queue.OBJECT_NAME: api_resources.QueueCall,
        api_resources.QueueCommand.OBJECT_NAME: api_resources.QueueCommand,
        api_resources.RecordingsCommand.OBJECT_NAME: api_resources.RecordingsCommand,
        api_resources.Region.OBJECT_NAME: api_resources.Region,
        api_resources.RegisterCall.OBJECT_NAME: api_resources.RegisterCall,
        api_resources.Report.OBJECT_NAME: api_resources.Report,
        api_resources.Reporting.OBJECT_NAME: api_resources.Reporting,
        api_resources.Requirement.OBJECT_NAME: api_resources.Requirement,
        api_resources.RequirementType.OBJECT_NAME: api_resources.RequirementType,
        api_resources.Room.OBJECT_NAME: api_resources.Room,
        api_resources.RoomComposition.OBJECT_NAME: api_resources.RoomComposition,
        api_resources.RoomParticipant.OBJECT_NAME: api_resources.RoomParticipant,
        api_resources.RoomRecording.OBJECT_NAME: api_resources.RoomRecording,
        api_resources.RoomSession.OBJECT_NAME: api_resources.RoomSession,
        api_resources.RoomsClientToken.OBJECT_NAME: api_resources.RoomsClientToken,
        api_resources.SIMCard.OBJECT_NAME: api_resources.SIMCard,
        api_resources.SIMCardAction.OBJECT_NAME: api_resources.SIMCardAction,
        api_resources.SIMCardGroup.OBJECT_NAME: api_resources.SIMCardGroup,
        api_resources.SIMCardOrder.OBJECT_NAME: api_resources.SIMCardOrder,
        api_resources.SIMCardOrder.OBJECT_NAME: api_resources.SIMCardOrderPreview,
        api_resources.SharedCampaign.OBJECT_NAME: api_resources.SharedCampaign,
        api_resources.ShortCode.OBJECT_NAME: api_resources.ShortCode,
        api_resources.SslCertificate.OBJECT_NAME: api_resources.SslCertificate,
        api_resources.SubNumberOrder.OBJECT_NAME: api_resources.SubNumberOrder,
        api_resources.TelephonyCredential.OBJECT_NAME: api_resources.TelephonyCredential,
        api_resources.TexmlApplication.OBJECT_NAME: api_resources.TexmlApplication,
        api_resources.TexmlRestCommand.OBJECT_NAME: api_resources.TexmlRestCommand,
        api_resources.Verification.OBJECT_NAME: api_resources.Verification,
        api_resources.VerifiedCallsDisplayProfile.OBJECT_NAME: api_resources.VerifiedCallsDisplayProfile,
        api_resources.VerifiedNumber.OBJECT_NAME: api_resources.VerifiedNumber,
        api_resources.Verify.OBJECT_NAME: api_resources.Verify,
        api_resources.VerifyProfile.OBJECT_NAME: api_resources.VerifyProfile,
        api_resources.VirtualCrossConnect.OBJECT_NAME: api_resources.VirtualCrossConnect,
        api_resources.WdrDetailReport.OBJECT_NAME: api_resources.WdrDetailReport,
        api_resources.Webhook.OBJECT_NAME: api_resources.Webhook,
        api_resources.WebhookDeliveries.OBJECT_NAME: api_resources.WebhookDeliveries,
        api_resources.WireguardInterface.OBJECT_NAME: api_resources.WireguardInterface,
        api_resources.WirelessDetailRecordsReports.OBJECT_NAME: api_resources.WirelessDetailRecordsReports,
    }


def convert_to_telnyx_object(resp, api_key=None):
    global OBJECT_CLASSES

    if len(OBJECT_CLASSES) == 0:
        load_object_classes()
    types = OBJECT_CLASSES.copy()

    # If we get a TelnyxResponse, we'll want to return a
    # TelnyxObject with the last_response field filled out with
    # the raw API response information
    telnyx_response = None

    if isinstance(resp, telnyx.telnyx_response.TelnyxResponse):
        telnyx_response = resp
        resp = telnyx_response.data

    if isinstance(resp, list):
        return [convert_to_telnyx_object(i, api_key) for i in resp]
    elif isinstance(resp, dict) and not isinstance(
        resp, telnyx.telnyx_object.TelnyxObject
    ):
        resp = resp.copy()
        resp = rewrite_reserved_words(resp, reverse=True)
        data = resp.get("data", None)
        if data:
            if isinstance(data, list):
                return telnyx.api_resources.ListObject.construct_from(
                    resp, api_key, last_response=telnyx_response
                )

            record_type = data.get("record_type", None)
            if record_type:
                klass = types.get(record_type, telnyx.telnyx_object.TelnyxObject)
                return klass.construct_from(
                    data, api_key, last_response=telnyx_response
                )

        record_type = resp.get("record_type", None)
        if record_type:
            klass = types.get(record_type, telnyx.telnyx_object.TelnyxObject)
            return klass.construct_from(resp, api_key, last_response=telnyx_response)
        else:
            klass = telnyx.telnyx_object.TelnyxObject
            return klass.construct_from(resp, api_key, last_response=telnyx_response)
    else:
        return resp