handler.py

import os
import json
import uuid
from urllib import request, parse
from urllib.error import URLError, HTTPError

#LINK PARA ENTENDER O ENVIO DE NOTIFICAÇÃO POR API: https://help.blip.ai/hc/pt-br/articles/4474382664855-Como-enviar-notificações-WhatsApp-via-API-do-Blip

#URLBLIP lista de endpoints da take
URLBLIP = ["https://msging.net/commands","https://http.msging.net/messages","https://http.msging.net/notifications"]
#KEYBLIP é chave do bot ou roteador que tenha o whatsapp conectado
KEYBLIP = ""
#namespace é estático sempre será o mesmo
namespace = ''
#tempalte_name será dinâmico aqui api que busca na waba()
template_name = ''
#flow_id é o identificador do bot para qual vamos amndar o cliente
flow_id = ""
#state_id é o id do bloco para qual vamos enviar o cliente
state_id = ""
#id_bot será o id do bot
id_bot = ""
#Nome do cliente dentro da aplicação de vocês
name = "Nome Do Cliente"
#variavel em que vai enviar o email do agente que efetuou o disparo 
agent_email = ""
data_response = {}

#envio de notificação com components
#Link: https://docs.blip.ai/#sending-a-notification-active-message a segunda req dessa sessão
def send_notification_components(URLBLIP ,KEYBLIP, namespace, template_name, identity, components):
    id = str(uuid.uuid4())
    id = "send-notification-api-" + id
    print("Monta Body")
    payBlip =  json.dumps({    
    "id":id,
    "to":identity,
    "type":"application/json",
    "content":{
    "type":"template",
    "template":{
        "namespace":namespace,
        "language":{
        "code":"pt_BR",
        "policy":"deterministic"},
        "name":template_name,
        "components":components

    }}
    }).encode('utf-8')
    print(payBlip)
    print("Monta Requisição")
    BlipReq = request.Request(URLBLIP[1],data = payBlip, headers={'content-type': 'application/json', 'Authorization': KEYBLIP})
    print("Faz Requisição")
    BlipResp = request.urlopen(BlipReq).read().decode()

    return BlipResp
   

#requisição que registra o evento com dados do envio
#Link: https://docs.blip.ai/#create-an-event
def create_event (URLBLIP, KEYBLIP):
    print("Evento Criado")
    id = str(uuid.uuid4())
    id = "send-notification-api-" + id
    print("Monta Body")
    payBlip =  json.dumps({
        "id": id,
        "to": "postmaster@analytics.msging.net",
        "method": "set",
        "type": "application/vnd.iris.eventTrack+json",
        "uri": "/event-track",
        "resource": {
            "category": "notifications",
            "action": "send"
    }
    }).encode('utf-8')
    print("Monta Requisição")
    BlipReq = request.Request(URLBLIP[0],data = payBlip, headers={'content-type': 'application/json', 'Authorization': KEYBLIP})
    print("Faz Requisição")
    BlipResp = request.urlopen(BlipReq).read().decode()
   
    return BlipResp

#requisição que verifica o número com o grupo meta
#Link: https://docs.blip.ai/#sending-a-notification-active-message a primeira req dessa sessão
def verification_phone (phone, URLBLIP, KEYBLIP):
    name = "Erro"
    id = str(uuid.uuid4())
    id = "send-notification-api-" + id
    payBlip =  json.dumps({ 
    "id": id,
    "to": "postmaster@wa.gw.msging.net",
    "method": "get",
    "uri": "lime://wa.gw.msging.net/accounts/"+phone
    }).encode('utf-8')
    BlipReq = request.Request(URLBLIP[0],data = payBlip, headers={'content-type': 'application/json', 'Authorization': KEYBLIP})
    BlipResp = request.urlopen(BlipReq).read().decode()
    data = json.loads(BlipResp)
    status = data['status']
    if ("fullName" in BlipResp):
        name = data ['resource']['fullName']
    return BlipResp

#requsição que definifinitavemente envia a notificação para o cliente
#Mudar para modelo com váriavel
#Link: https://docs.blip.ai/#sending-a-notification-active-message a segunda req dessa sessão
def send_notification(URLBLIP ,KEYBLIP, namespace, template_name, identity):
    id = str(uuid.uuid4())
    id = "send-notification-api-" + id
    print("Monta Body")
    payBlip =  json.dumps({      
    "id":id,
    "to":identity,
    "type":"application/json",
    "content":{
    "type":"template",
    "template":{
        "namespace":namespace,
        "name":template_name,
        "language":{
        "code":"pt_BR",
        "policy":"deterministic"

    }}}
    }).encode('utf-8')
    print("Monta Requisição")
    BlipReq = request.Request(URLBLIP[1],data = payBlip, headers={'content-type': 'application/json', 'Authorization': KEYBLIP})
    print("Faz Requisição")
    BlipResp = request.urlopen(BlipReq).read().decode()
   
    return BlipResp

#Requisição que altera o bloco do cliente
#Link da Doc:https://docs.blip.ai/#change-user-state
def change_state(URLBLIP, KEYBLIP, identity, flow_id, state_id):
    uri = "/contexts/"+identity+"/stateid@"+flow_id 
    id = str(uuid.uuid4())
    id = "send-notification-api-" + id
    payBlip =  json.dumps({   
    "id": id,
    "to": "postmaster@msging.net",
    "method": "set",
    "uri": uri,
    "type": "text/plain",
    "resource": state_id
    }).encode('utf-8')
    BlipReq = request.Request(URLBLIP[0],data = payBlip, headers={'content-type': 'application/json', 'Authorization': KEYBLIP})
    BlipResp = request.urlopen(BlipReq).read().decode()
    data = json.loads(BlipResp)
    status = data['status']
    return BlipResp

#Requisição que altera o bot que o cliente se encontra
#Atualmente não tem documentação atualizada
def change_bot(URLBLIP, KEYBLIP, identity, id_bot):
    uri = "/contexts/"+identity+"/master-state"
    id = str(uuid.uuid4())
    id = "send-notification-api-" + id
    id_bot = id_bot + "@msging.net"
    payBlip =  json.dumps({     
        "id": id,
        "to": "postmaster@msging.net",
        "method": "set",
        "uri": uri,
        "type": "text/plain",
        "resource": id_bot
    }).encode('utf-8')
    BlipReq = request.Request(URLBLIP[0],data = payBlip, headers={'content-type': 'application/json', 'Authorization': KEYBLIP})
    BlipResp = request.urlopen(BlipReq).read().decode()
    data = json.loads(BlipResp)
    status = data['status']
    return BlipResp

#requisição que cria ou atualiza o contato do cliente dentro do blip
#Link Doc: https://docs.blip.ai/#update-a-contact
def cria_att_ctt (URLBLIP, KEYBLIP, identity, name, jsonExtras):
    id = str(uuid.uuid4())
    id = "send-notification-api-" + id
    payBlip =  json.dumps({
                "id": id,
                "method": "merge",
                "type": "application/vnd.lime.contact+json",
                "uri": "/contacts",
                "resource": {
                "identity":identity,
                "name": name,
                "extras": jsonExtras
                
          } 
        }).encode('utf-8')
    BlipReq = request.Request(URLBLIP[0],data = payBlip, headers={'content-type': 'application/json', 'Authorization': KEYBLIP})
    BlipResp = request.urlopen(BlipReq).read().decode()
    try:
        BlipResp = request.urlopen(BlipReq).read().decode()
        print('Lead no Blip aceito')
        return BlipResp

    except HTTPError as e:
            
        print('Notificação no Blip rejeitada - StatusCode: ', e.code, ' Resposta: ', e.read(), ' Payload: ', payBlip)  

#ajusta telefone para padrão de auteticação BR da API
def regex_num (phone):
    phone=phone.replace(' ','',)
    phone=phone.replace('(','')
    phone=phone.replace(')','')
    phone=phone.replace('-','')
    phone=phone.replace('.','')
    tam_phone= len (phone)
    if (tam_phone > 2):
        ddd=phone[0]+phone[1]
    if (ddd == "+5") :
        phone = phone
    elif (ddd == "55"):
        phone =  "+"+phone
    else:
        phone = "+55" + phone
    return phone

def sendnotification(event, context):
    try:
        #ler JSON
        headers       = event['headers']
        data          = json.loads(event['body'])
        state_id      = data['state_id']
        flow_id       = data['flow_id']
        template_name = data['template']
        phone         = data['phone']
        name          = data['name']
        id_bot        = data['id_bot']
        jsonExtras    = data['extras']
        content       = data['content']

        #headers
        KEYBLIP   = headers['Authorization']
        namespace = headers['namespace']

        # print(namespace)

        #identifica caso authorization não exista
        if(KEYBLIP == "" or KEYBLIP == None):
            raise Exception("Authorization não encontrado")

        #identifica caso namesapce não exista
        if(namespace == "" or namespace == None):
            raise Exception("Namespace não encontrado")

        #Ajustar Telefone Para Verificação do Número
        adjustment_phone = regex_num(phone=phone)
        # print("Ajustar Telefone Para Verificação do Número")

        #Verifica o Número na API do WhatsApp
        response_verification = verification_phone(phone = adjustment_phone, URLBLIP = URLBLIP, KEYBLIP = KEYBLIP)
        # print("Verifica o Número na API do WhatsApp")

        #Carrega Informações retornadas no formato de JSON
        data_verification = json.loads(response_verification)
        # print("Carrega Informações retornadas no formato de JSON")

        #Identifica o Identity do número no whatsapp       
        identity = data_verification ['resource']['alternativeAccount']
        # print(content)

        if content == None:
            #Enviar Notificação Sem Variaveis
            response_notification = send_notification(URLBLIP = URLBLIP,KEYBLIP = KEYBLIP,namespace = namespace, template_name = template_name, identity = identity)
            # print("Sem Content")
        else:
            # print(content)
            #Enviar Notificação Sem Variaveis
            response_notification = send_notification_components(URLBLIP = URLBLIP,KEYBLIP = KEYBLIP,namespace = namespace, template_name = template_name, identity = identity, components = content)

        #Levar o Cliente para o bloco correto
        response_state = change_state(URLBLIP = URLBLIP, KEYBLIP = KEYBLIP,identity = identity, state_id = state_id, flow_id = flow_id)
        
        #Coloca o usuário dentro do bot desejado, e no bloco selecionado anteriomente
        response_bot_change = change_bot(URLBLIP = URLBLIP, KEYBLIP = KEYBLIP, identity = identity, id_bot = id_bot)
        # print("Coloca o usuário dentro do bot desejado, e no bloco selecionado anteriomente")

        #atuaiza dados do cliente de acordo com as informações passadas
        response_ctt = cria_att_ctt (URLBLIP = URLBLIP, KEYBLIP = KEYBLIP,identity = identity, name = name, jsonExtras = jsonExtras)

        #cria evento guardando a informação que a notificação foi enviada
        response_event = create_event (URLBLIP, KEYBLIP)

        #envia informações como retorno
        data_response = {
            "response_verification":data_verification,
            "response_change_bot":response_bot_change,
            "response_change_state":response_state,
            "response_send_notification":response_notification,
            "phone_number":adjustment_phone,
            "response_event":response_event,
            "response_ctt":response_ctt
        }
        response = {
            "statusCode": 200,
            "body": json.dumps(data_response)
        }
        return response
    
    except Exception as e: 
        msgError = json.dumps({"message": "Falha ao executar API: " + str(e)})
        conteudoNotificacao = 'Falha - Envio de Lead(s) genérico para o BLIP da solução Bots2U ' + str(e) + json.dumps(data)
        print(conteudoNotificacao)
        response = {
            "statusCode": 400,
            "body": msgError
        }
        return response