Migrate dialogflow over to the new webhook component

homeassistant/components/dialogflow/.translations/en.json

@@ -0,0 +1,18 @@
+{
+  "config": {
+    "title": "Dialogflow",
+    "step": {
+      "user": {
+        "title": "Set up the Dialogflow Webhook",
+        "description": "Are you sure you want to set up Dialogflow?"
+      }
+    },
+    "abort": {
+      "one_instance_allowed": "Only a single instance is necessary.",
+      "not_internet_accessible": "Your Home Assistant instance needs to be accessible from the internet to receive Dialogflow messages."
+    },
+    "create_entry": {
+      "default": "To send events to Home Assistant, you will need to setup [webhook integration of Dialogflow]({dialogflow_url}).\n\nFill in the following info:\n\n- URL: `{webhook_url}`\n- Method: POST\n- Content Type: application/json\n\nSee [the documentation]({docs_url}) for further details."
+    }
+  }
+}

homeassistant/components/dialogflow.py → homeassistant/components/dialogflow/__init__.py

@@ -7,24 +7,16 @@
 import logging
 
 import voluptuous as vol
+from aiohttp import web
 
+from homeassistant.const import CONF_WEBHOOK_ID
 from homeassistant.exceptions import HomeAssistantError
-from homeassistant.helpers import intent, template
-from homeassistant.components.http import HomeAssistantView
-
+from homeassistant.helpers import intent, template, config_entry_flow
 _LOGGER = logging.getLogger(__name__)
 
-CONF_INTENTS = 'intents'
-CONF_SPEECH = 'speech'
-CONF_ACTION = 'action'
-CONF_ASYNC_ACTION = 'async_action'
-
-DEFAULT_CONF_ASYNC_ACTION = False
-DEPENDENCIES = ['http']
+DEPENDENCIES = ['webhook']
 DOMAIN = 'dialogflow'
 
-INTENTS_API_ENDPOINT = '/api/dialogflow'
-
 SOURCE = "Home Assistant Dialogflow"
 
 CONFIG_SCHEMA = vol.Schema({
@@ -38,52 +30,72 @@ class DialogFlowError(HomeAssistantError):
 
 async def async_setup(hass, config):
     """Set up Dialogflow component."""
-    hass.http.register_view(DialogflowIntentsView)
-
     return True
 
 
-class DialogflowIntentsView(HomeAssistantView):
-    """Handle Dialogflow requests."""
-
-    url = INTENTS_API_ENDPOINT
-    name = 'api:dialogflow'
-
-    async def post(self, request):
-        """Handle Dialogflow."""
-        hass = request.app['hass']
-        message = await request.json()
-
-        _LOGGER.debug("Received Dialogflow request: %s", message)
-
-        try:
-            response = await async_handle_message(hass, message)
-            return b'' if response is None else self.json(response)
-
-        except DialogFlowError as err:
-            _LOGGER.warning(str(err))
-            return self.json(dialogflow_error_response(
-                hass, message, str(err)))
+async def handle_webhook(hass, webhook_id, request):
+    """Handle incoming webhook with Dialogflow requests."""
+    message = await request.json()
+
+    _LOGGER.debug("Received Dialogflow request: %s", message)
+
+    try:
+        response = await async_handle_message(hass, message)
+        return b'' if response is None else web.json_response(response)
+
+    except DialogFlowError as err:
+        _LOGGER.warning(str(err))
+        return web.json_response(
+            dialogflow_error_response(message, str(err))
+        )
+
+    except intent.UnknownIntent as err:
+        _LOGGER.warning(str(err))
+        return web.json_response(
+            dialogflow_error_response(
+                message,
+                "This intent is not yet configured within Home Assistant."
+            )
+        )
+
+    except intent.InvalidSlotInfo as err:
+        _LOGGER.warning(str(err))
+        return web.json_response(
+            dialogflow_error_response(
+                message,
+                "Invalid slot information received for this intent."
+            )
+        )
+
+    except intent.IntentError as err:
+        _LOGGER.warning(str(err))
+        return web.json_response(
+            dialogflow_error_response(message, "Error handling intent."))
+
+
+async def async_setup_entry(hass, entry):
+    """Configure based on config entry."""
+    hass.components.webhook.async_register(
+        entry.data[CONF_WEBHOOK_ID], handle_webhook)
+    return True
 
-        except intent.UnknownIntent as err:
-            _LOGGER.warning(str(err))
-            return self.json(dialogflow_error_response(
-                hass, message,
-                "This intent is not yet configured within Home Assistant."))
 
-        except intent.InvalidSlotInfo as err:
-            _LOGGER.warning(str(err))
-            return self.json(dialogflow_error_response(
-                hass, message,
-                "Invalid slot information received for this intent."))
+async def async_unload_entry(hass, entry):
+    """Unload a config entry."""
+    hass.components.webhook.async_unregister(entry.data[CONF_WEBHOOK_ID])
+    return True
 
-        except intent.IntentError as err:
-            _LOGGER.warning(str(err))
-            return self.json(dialogflow_error_response(
-                hass, message, "Error handling intent."))
+config_entry_flow.register_webhook_flow(
+    DOMAIN,
+    'Dialogflow Webhook',
+    {
+        'dialogflow_url': 'https://dialogflow.com/docs/fulfillment#webhook',
+        'docs_url': 'https://www.home-assistant.io/components/dialogflow/'
+    }
+)
 
 
-def dialogflow_error_response(hass, message, error):
+def dialogflow_error_response(message, error):
     """Return a response saying the error message."""
     dialogflow_response = DialogflowResponse(message['result']['parameters'])
     dialogflow_response.add_speech(error)

homeassistant/components/dialogflow/strings.json

@@ -0,0 +1,18 @@
+{
+  "config": {
+    "title": "Dialogflow",
+    "step": {
+      "user": {
+        "title": "Set up the Dialogflow Webhook",
+        "description": "Are you sure you want to set up Dialogflow?"
+      }
+    },
+    "abort": {
+      "one_instance_allowed": "Only a single instance is necessary.",
+      "not_internet_accessible": "Your Home Assistant instance needs to be accessible from the internet to receive Dialogflow messages."
+    },
+    "create_entry": {
+      "default": "To send events to Home Assistant, you will need to setup [webhook integration of Dialogflow]({dialogflow_url}).\n\nFill in the following info:\n\n- URL: `{webhook_url}`\n- Method: POST\n- Content Type: application/json\n\nSee [the documentation]({docs_url}) for further details."
+    }
+  }
+}

homeassistant/config_entries.py

@@ -137,6 +137,7 @@ async def async_step_discovery(info):
 FLOWS = [
     'cast',
     'deconz',
+    'dialogflow',
     'hangouts',
     'homematicip_cloud',
     'hue',

tests/components/dialogflow/__init__.py

@@ -0,0 +1 @@
+"""Tests for the Dialogflow component."""