4cc711357a
Add notification data field to the message send to Facebook. Allows to construct richer messages like cards, quick replies, attach images, videos, etc
74 lines
2.4 KiB
Python
74 lines
2.4 KiB
Python
"""
|
|
Facebook platform for notify component.
|
|
|
|
For more details about this platform, please refer to the documentation at
|
|
https://home-assistant.io/components/notify.facebook/
|
|
"""
|
|
import logging
|
|
|
|
import requests
|
|
|
|
import voluptuous as vol
|
|
|
|
import homeassistant.helpers.config_validation as cv
|
|
from homeassistant.components.notify import (
|
|
ATTR_TARGET, ATTR_DATA, PLATFORM_SCHEMA, BaseNotificationService)
|
|
from homeassistant.const import CONTENT_TYPE_JSON
|
|
|
|
_LOGGER = logging.getLogger(__name__)
|
|
|
|
CONF_PAGE_ACCESS_TOKEN = 'page_access_token'
|
|
BASE_URL = 'https://graph.facebook.com/v2.6/me/messages'
|
|
|
|
PLATFORM_SCHEMA = PLATFORM_SCHEMA.extend({
|
|
vol.Required(CONF_PAGE_ACCESS_TOKEN): cv.string,
|
|
})
|
|
|
|
|
|
def get_service(hass, config, discovery_info=None):
|
|
"""Get the Facebook notification service."""
|
|
return FacebookNotificationService(config[CONF_PAGE_ACCESS_TOKEN])
|
|
|
|
|
|
class FacebookNotificationService(BaseNotificationService):
|
|
"""Implementation of a notification service for the Facebook service."""
|
|
|
|
def __init__(self, access_token):
|
|
"""Initialize the service."""
|
|
self.page_access_token = access_token
|
|
|
|
def send_message(self, message="", **kwargs):
|
|
"""Send some message."""
|
|
payload = {'access_token': self.page_access_token}
|
|
targets = kwargs.get(ATTR_TARGET)
|
|
data = kwargs.get(ATTR_DATA)
|
|
|
|
body_message = {"text": message}
|
|
|
|
if data is not None:
|
|
body_message.update(data)
|
|
# Only one of text or attachment can be specified
|
|
if 'attachment' in body_message:
|
|
body_message.pop('text')
|
|
|
|
if not targets:
|
|
_LOGGER.error("At least 1 target is required")
|
|
return
|
|
|
|
for target in targets:
|
|
body = {
|
|
"recipient": {"phone_number": target},
|
|
"message": body_message
|
|
}
|
|
import json
|
|
resp = requests.post(BASE_URL, data=json.dumps(body),
|
|
params=payload,
|
|
headers={'Content-Type': CONTENT_TYPE_JSON},
|
|
timeout=10)
|
|
if resp.status_code != 200:
|
|
obj = resp.json()
|
|
error_message = obj['error']['message']
|
|
error_code = obj['error']['code']
|
|
_LOGGER.error("Error %s : %s (Code %s)", resp.status_code,
|
|
error_message,
|
|
error_code)
|