Hi,
Webhook is not working in the sense that nothing hits my endpoint when an SMS comes in, but when i subscribe, it does send the validation token (so I know the end point is reachable). It was working perfectly fine and then just stopped, I have deleted the subscription and resubscribed.
Any help would be appreciated!
Endpoint:
@app.route('/webhook/ringcentral', methods=['POST'])
def ringcentral_webhook():
try:
validation_token = request.headers.get('Validation-Token')
if validation_token:
return make_response('', 200, {'Validation-Token': validation_token})
data = request.get_json(silent=True)
logging.info(data)
if data:
sender = data.get('body', {}).get('from', {})
phone_number = sender.get('phoneNumber', 'Unknown Number')
sender_name = sender.get('name', {phone_number})
message_subject = data.get('body', {}).get('subject', 'No subject')
text = f"New SMS from: {sender_name}. Message: {message_subject}."
slack.slack_sender(text)
logging.info(data)
return jsonify({'status': 'success'}), 200
else:
logging.info("No JSON payload received.")
return jsonify({'status': 'error', 'message': 'No JSON payload'}), 400
except Exception as e:
logging.error(f"Error processing the webhook data: {e}")
return jsonify({'status': 'error', 'message': str(e)}), 500the subscribe code:
def clear_webhook_subscriptions(func):
def wrapper(self, *args, **kwargs):
self.read_subscriptions()
return func(self, *args, **kwargs)
return wrapper
@clear_webhook_subscriptions
def subscribe_for_notification(self, event_filters=['/restapi/v1.0/account/~/extension/~/message-store/instant?type=SMS'], delivery_address = 'REDACTED'):
try:
body_params = {
'eventFilters': event_filters,
'deliveryMode': {
'transportType': 'WebHook',
'address': delivery_address + '/webhook/ringcentral'
},
'expiresIn': 604800 #TODO:Rework this. can be upto 10 yrs. 315360000
}
endpoint = "/restapi/v1.0/subscription"
resp = self.post(endpoint, json=body_params)
resp.raise_for_status()
response = resp.json()
logging.info(f"Subscription ID: {response['id']}")
logging.info("Ready to receive incoming SMS via WebHook.")
return response
except HTTPError as http_err:
logging.error(f"HTTP error occurred: {http_err}")
except Exception as err:
logging.error(f"An exception occurred: {err}")
def read_subscriptions(self):
try:
endpoint = "/restapi/v1.0/subscription"
resp = self.get(endpoint)
response = resp.json()
if not response['records']:
logging.info("No subscription found.")
else:
for record in response['records']:
logging.info(json.dumps(record, indent=2, sort_keys=True))
self.delete_subscription(record['id'])
except Exception as e:
logging.error(f"An exception occurred while reading subscriptions: {e}")
def delete_subscription(self, subscription_id):
try:
endpoint = f"/restapi/v1.0/subscription/{subscription_id}"
self.delete(endpoint)
logging.info(f"Subscription {subscription_id} deleted.")
except Exception as e:
logging.error(f"An exception occurred while deleting subscription {subscription_id}: {e}")