From 061a4ede23abaf1c8cdbbd7a043161a980cdff77 Mon Sep 17 00:00:00 2001
From: jesopo
Date: Mon, 5 Nov 2018 13:14:00 +0000
Subject: One-shot STS policies should still be cleared if a reconnect fails

---
 modules/sts.py | 23 ++++++++++-------------
 1 file changed, 10 insertions(+), 13 deletions(-)

diff --git a/modules/sts.py b/modules/sts.py
index 30d9678f..5f01827b 100644
--- a/modules/sts.py
+++ b/modules/sts.py
@@ -38,16 +38,13 @@ class Module(ModuleManager.BaseModule):
     @utils.hook("new.server")
     def new_server(self, event):
         sts_policy = event["server"].get_setting("sts-policy")
-        if sts_policy and not event["server"].tls:
-            expiration = sts_policy["expiration"]
-            if not expiration or time.time() <= expiration:
-                self.log.debug("Applying STS policy for '%s'",
-                    [str(event["server"])])
-                event["server"].tls = True
-                event["server"].port = sts_policy["port"]
-
-    @utils.hook("received.numeric.001"):
-    def on_connect(self, event):
-        sts_policy = event["server"].get_setting("sts-policy")
-        if sts_policy and sts_policy["one-shot"]:
-            event["server"].del_setting("sts-policy")
+        if sts_policy:
+            if sts_policy["one-shot"]:
+                event["server"].del_setting("sts-policy")
+            if not event["server"].tls:
+                expiration = sts_policy["expiration"]
+                if not expiration or time.time() <= expiration:
+                    self.log.debug("Applying STS policy for '%s'",
+                        [str(event["server"])])
+                    event["server"].tls = True
+                    event["server"].port = sts_policy["port"]
-- 
cgit v1.3.1-10-gc9f91