|
| 1 | +from whatsapp_api_client_python.response import Response |
| 2 | +from datetime import datetime |
| 3 | +from enum import Enum |
| 4 | + |
| 5 | + |
| 6 | +class TypeWebhook(Enum): |
| 7 | + INCOMING_MESSAGE_RECEIVED = 'incomingMessageReceived' |
| 8 | + OUTGOING_MESSAGE_RECEIVED = 'outgoingMessageReceived' |
| 9 | + OUTGOING_API_MESSAGE_RECEIVED = 'outgoingAPIMessageReceived' |
| 10 | + OUTGOING_MESSAGE_STATUS = 'outgoingMessageStatus' |
| 11 | + STATE_INSTANCE_CHANGED = 'stateInstanceChanged' |
| 12 | + STATUS_INSTANCE_CHANGED = 'statusInstanceChanged' |
| 13 | + DEVICE_INFO = 'deviceInfo' |
| 14 | + INCOMING_CALL = 'incomingCall' |
| 15 | + |
| 16 | +class TypeMessage(Enum): |
| 17 | + TEXT_MESSAGE = 'textMessage' |
| 18 | + IMAGE_MESSAGE = 'imageMessage' |
| 19 | + VIDEO_MESSAGE = 'videoMessage' |
| 20 | + DOCUMENT_MESSAGE = 'documentMessage' |
| 21 | + AUDIO_MESSAGE = 'audioMessage' |
| 22 | + LOCATION_MESSAGE = 'locationMessage' |
| 23 | + CONTACT_MESSAGE = 'contactMessage' |
| 24 | + EXTENDED_TEXT_MESSAGE = 'extendedTextMessage' |
| 25 | + QUOTED_MESSAGE = 'quotedMessage' |
| 26 | + |
| 27 | +class Webhooks: |
| 28 | + def __init__(self, restApi) -> None: |
| 29 | + self.restApi = restApi |
| 30 | + self.started = False |
| 31 | + |
| 32 | + def startReceivingNotifications(self) -> bool: |
| 33 | + self.started = True |
| 34 | + self.job() |
| 35 | + |
| 36 | + def stopReceivingNotifications(self) -> bool: |
| 37 | + self.started = False |
| 38 | + |
| 39 | + def onIncomingMessageReceived(body): |
| 40 | + idMessage = body['idMessage'] |
| 41 | + eventDate = datetime.fromtimestamp(body['timestamp']) |
| 42 | + senderData = body['senderData'] |
| 43 | + messageData = body['messageData'] |
| 44 | + print(idMessage + ': ' |
| 45 | + + 'At ' + eventDate + 'Incoming from ' \ |
| 46 | + + senderData + ' message = ' + messageData) |
| 47 | + |
| 48 | + def onIncomingCall(body): |
| 49 | + idMessage = body['idMessage'] |
| 50 | + eventDate = datetime.fromtimestamp(body['timestamp']) |
| 51 | + fromWho = body['from'] |
| 52 | + print(idMessage + ': ' |
| 53 | + + 'Call from ' + fromWho |
| 54 | + + ' at ' + str(eventDate)) |
| 55 | + |
| 56 | + def onDeviceInfo(body): |
| 57 | + eventDate = datetime.fromtimestamp(body['timestamp']) |
| 58 | + deviceData = body['deviceData'] |
| 59 | + print('At ' + eventDate + ': ' + deviceData) |
| 60 | + |
| 61 | + def onOutgoingMessageReceived(body): |
| 62 | + idMessage = body['idMessage'] |
| 63 | + eventDate = datetime.fromtimestamp(body['timestamp']) |
| 64 | + senderData = body['senderData'] |
| 65 | + messageData = body['messageData'] |
| 66 | + print(idMessage + ': ' |
| 67 | + + 'At ' + eventDate + 'Outgoing from ' \ |
| 68 | + + senderData + ' message = ' + messageData) |
| 69 | + |
| 70 | + def onOutgoingAPIMessageReceived(body): |
| 71 | + idMessage = body['idMessage'] |
| 72 | + eventDate = datetime.fromtimestamp(body['timestamp']) |
| 73 | + senderData = body['senderData'] |
| 74 | + messageData = body['messageData'] |
| 75 | + print(idMessage + ': ' |
| 76 | + + 'At ' + eventDate + ' API outgoing from ' + senderData + \ |
| 77 | + ' message = ' + messageData) |
| 78 | + |
| 79 | + def onOutgoingMessageStatus(body): |
| 80 | + idMessage = body['idMessage'] |
| 81 | + status = body['status'] |
| 82 | + eventDate = datetime.fromtimestamp(body['timestamp']) |
| 83 | + print(idMessage + ': ' |
| 84 | + + 'At ' + eventDate + ' status = ' + status) |
| 85 | + |
| 86 | + def onStateInstanceChanged(body): |
| 87 | + eventDate = datetime.fromtimestamp(body['timestamp']) |
| 88 | + stateInstance = body['stateInstance'] |
| 89 | + print('At ' + eventDate + ' state instance = ' + stateInstance) |
| 90 | + |
| 91 | + def onStatusInstanceChanged(body): |
| 92 | + eventDate = datetime.fromtimestamp(body['timestamp']) |
| 93 | + statusInstance = body['statusInstance'] |
| 94 | + print('At ' + eventDate + ' status instance = ' + statusInstance) |
| 95 | + |
| 96 | + def job(self) -> None: |
| 97 | + print('Incoming notifications are being received. '\ |
| 98 | + 'To interrupt, press Ctrl+C') |
| 99 | + try: |
| 100 | + while self.started == True: |
| 101 | + resultReceive = self.restApi.receiving.receiveNotification() |
| 102 | + if resultReceive.code == 200: |
| 103 | + if resultReceive.data == None: |
| 104 | + # There are no incoming notifications, |
| 105 | + # we send the request again |
| 106 | + continue |
| 107 | + body = resultReceive.data['body'] |
| 108 | + typeWebhook = body['typeWebhook'] |
| 109 | + if typeWebhook == TypeWebhook.INCOMING_MESSAGE_RECEIVED: |
| 110 | + self.onIncomingMessageReceived(body) |
| 111 | + elif typeWebhook == TypeWebhook.DEVICE_INFO: |
| 112 | + self.onDeviceInfo(body) |
| 113 | + elif typeWebhook == TypeWebhook.INCOMING_CALL: |
| 114 | + self.onIncomingCall(body) |
| 115 | + elif typeWebhook == TypeWebhook.INCOMING_MESSAGE_RECEIVED: |
| 116 | + self.onIncomingMessageReceived(body) |
| 117 | + elif typeWebhook == TypeWebhook.OUTGOING_API_MESSAGE_RECEIVED: |
| 118 | + self.onOutgoingAPIMessageReceived(body) |
| 119 | + elif typeWebhook == TypeWebhook.OUTGOING_MESSAGE_RECEIVED: |
| 120 | + self.onOutgoingMessageReceived(body) |
| 121 | + elif typeWebhook == TypeWebhook.OUTGOING_MESSAGE_STATUS: |
| 122 | + self.onOutgoingMessageStatus(body) |
| 123 | + elif typeWebhook == TypeWebhook.STATE_INSTANCE_CHANGED: |
| 124 | + self.onStateInstanceChanged(body) |
| 125 | + elif typeWebhook == TypeWebhook.STATUS_INSTANCE_CHANGED: |
| 126 | + self.onStatusInstanceChanged(body) |
| 127 | + self.restApi.receiving.deleteNotification( |
| 128 | + resultReceive.data['receiptId']) |
| 129 | + print('End receiving') |
| 130 | + except KeyboardInterrupt: |
| 131 | + print('End receiving') |
| 132 | + pass |
0 commit comments