Send the correct host header when fetching keys

1 files changed, 6 insertions, 3 deletions

diff --git a/synapse/crypto/keyclient.py b/synapse/crypto/keyclient.py

index 54b83da9d8..4fca215c97 100644
--- a/synapse/crypto/keyclient.py
+++ b/synapse/crypto/keyclient.py
@@ -79,8 +79,7 @@ class SynapseKeyClientProtocol(HTTPClient):
         self.host = None
 
     def connectionMade(self):
-        self.host = self.transport.getHost()
-        logger.debug("Connected to %s", self.host)
+        logger.debug("Connected to %s", self.transport.getPeer())
         self.sendCommand(b"GET", self.path)
         if self.host:
             self.sendHeader(b"Host", self.host)
@@ -124,7 +123,10 @@ class SynapseKeyClientProtocol(HTTPClient):
         self.timer.cancel()
 
     def on_timeout(self):
-        logger.debug("Timeout waiting for response from %s", self.host)
+        logger.debug(
+            "Timeout waiting for response from %s: %s",
+            self.host, self.transport.getPeer(),
+        )
         self.errback(IOError("Timeout waiting for response"))
         self.transport.abortConnection()
 
@@ -133,4 +135,5 @@ class SynapseKeyClientFactory(Factory):
     def protocol(self):
         protocol = SynapseKeyClientProtocol()
         protocol.path = self.path
+        protocol.path = self.host
         return protocol