From 3322fee8147ae136cbe477e664173fcf922e18b8 Mon Sep 17 00:00:00 2001
From: akloeckner <akloeckner@users.noreply.github.com>
Date: Tue, 6 Nov 2018 12:43:16 +0100
Subject: [PATCH] Fritz keepalive (#18155)

* Add keepalive support

- adds keepalive support
- adds debug messages
- corrects CONF_PHONEBOOK and CONF_PREFIXES constants

* Add keepalive config constant

* Fix default value

* More visual indentation

* move to platform

* Move to platform

* Make keepalive default and remove option

* Forgot a few lines
---
 homeassistant/components/sensor/fritzbox_callmonitor.py | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git a/homeassistant/components/sensor/fritzbox_callmonitor.py b/homeassistant/components/sensor/fritzbox_callmonitor.py
index 317416a15b8..397f08d8a7c 100644
--- a/homeassistant/components/sensor/fritzbox_callmonitor.py
+++ b/homeassistant/components/sensor/fritzbox_callmonitor.py
@@ -63,8 +63,8 @@ def setup_platform(hass, config, add_entities, discovery_info=None):
     port = config.get(CONF_PORT)
     username = config.get(CONF_USERNAME)
     password = config.get(CONF_PASSWORD)
-    phonebook_id = config.get('phonebook')
-    prefixes = config.get('prefixes')
+    phonebook_id = config.get(CONF_PHONEBOOK)
+    prefixes = config.get(CONF_PREFIXES)
 
     try:
         phonebook = FritzBoxPhonebook(
@@ -156,8 +156,10 @@ class FritzBoxCallMonitor:
 
     def connect(self):
         """Connect to the Fritz!Box."""
+        _LOGGER.debug('Setting up socket...')
         self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
         self.sock.settimeout(10)
+        self.sock.setsockopt(socket.SOL_SOCKET, socket.SO_KEEPALIVE, 1)
         try:
             self.sock.connect((self.host, self.port))
             threading.Thread(target=self._listen).start()
@@ -168,6 +170,7 @@ class FritzBoxCallMonitor:
 
     def _listen(self):
         """Listen to incoming or outgoing calls."""
+        _LOGGER.debug('Connection established, waiting for response...')
         while not self.stopped.isSet():
             try:
                 response = self.sock.recv(2048)
@@ -175,10 +178,12 @@ class FritzBoxCallMonitor:
                 # if no response after 10 seconds, just recv again
                 continue
             response = str(response, "utf-8")
+            _LOGGER.debug('Received %s', response)
 
             if not response:
                 # if the response is empty, the connection has been lost.
                 # try to reconnect
+                _LOGGER.warning('Connection lost, reconnecting...')
                 self.sock = None
                 while self.sock is None:
                     self.connect()