'''
    ESME connection to ncell or ntc
'''
import sys
import time
from datetime import datetime

import smpplib.gsm
import smpplib.client
import smpplib.consts

from v2.repositories.smsrepo import insert_outgoing_history
from configs.loggerconf import logger

def send_sms_alert(data: dict) -> int:
    '''
    param: dict(ip, port, alert_username, alert_password, alert_id, mobile_number, message, provider, user)
    '''
    count = 0
    client = None
    try:
        logger.info(data)
        parts, encoding_flag, msg_type_flag = smpplib.gsm.make_parts(u"{}".format(data.get('message')))
        client = smpplib.client.Client(data.get('ip'), int(data.get('port')), timeout=15)
        client.set_message_sent_handler(
            lambda pdu: sys.stdout.write('send {} {} \n'.format(pdu.sequence, pdu.message_id))
        )
        client.connect()
        client.bind_transmitter(system_id=data.get('alert_username'), password=data.get('alert_password'))

        for part in parts:
            _ = client.send_message(
                source_addr_ton=smpplib.consts.SMPP_TON_ALNUM,
                source_addr_npi=smpplib.consts.SMPP_NPI_UNK,
                source_addr=data.get('alert_id'),

                dest_addr_ton=smpplib.consts.SMPP_TON_INTL,
                dest_addr_npi=smpplib.consts.SMPP_NPI_ISDN,
                destination_addr=data.get('mobile_number'),
                short_message=part,
                data_coding=encoding_flag,
                esm_class=msg_type_flag,
                registered_delivery=False,
            )
            count += 1
        
        insert_outgoing_history({
            'username': data.get('user'),
            'receiver_phone_number': data.get('mobile_number'),
            'message': data.get('message'),
            'service_provider': data.get('provider'),
            'is_success': True,
            'credit_used': count,
            'date': datetime.now().strftime("%m/%d/%Y, %H:%M:%S"),
            'with_code': True,
            'api_token': data.get('api_token')
        })

    except ConnectionError:
        insert_outgoing_history({
            'username': data.get('user'),
            'receiver_phone_number': data.get('mobile_number'),
            'message': data.get('message'),
            'service_provider': data.get('provider'),
            'is_success': False,
            'credit_used': count,
            'date': datetime.now().strftime("%m/%d/%Y, %H:%M:%S"),
            'with_code': True,
            'api_token': data.get('api_token')
        })
        raise ConnectionError()

    except Exception as ex:
        insert_outgoing_history({
            'username': data.get('user'),
            'receiver_phone_number': data.get('mobile_number'),
            'message': data.get('message'),
            'service_provider': data.get('provider'),
            'is_success': False,
            'credit_used': count,
            'date': datetime.now().strftime("%m/%d/%Y, %H:%M:%S"),
            'with_code':True,
            'api_token': data.get('api_token')
        })
        raise Exception()
    
    finally:
        try:
            client.unbind()
            client.disconnect()
        except Exception as ex:
            logger.error(ex)