Merge pull request #5117 from gopalkildoliya/dev

Notify component for Facebook Messenger

.coveragerc

@@ -228,6 +228,7 @@ omit =
     homeassistant/components/notify/aws_lambda.py
     homeassistant/components/notify/aws_sns.py
     homeassistant/components/notify/aws_sqs.py
+    homeassistant/components/notify/facebook.py
     homeassistant/components/notify/free_mobile.py
     homeassistant/components/notify/gntp.py
     homeassistant/components/notify/group.py

homeassistant/components/notify/facebook.py

@@ -0,0 +1,65 @@
+"""
+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, 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):
+    """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)
+
+        if not targets:
+            _LOGGER.error("At least 1 target is required")
+            return
+
+        for target in targets:
+            body = {
+                "recipient": {"phone_number": target},
+                "message": {"text": 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)