telnet: best-effort skip of command data

usually a good idea for clients like PuTTY, since these are sent by default
in the very first packet even before user types anything else
also restore iac+eof handling, which call close() on the stream

resolve #2563
resolve #2606

CHANGELOG.md

@@ -27,6 +27,7 @@ and this project adheres to [Semantic Versioning](http://semver.org/).
 - `SENSOR_PUBLISH_ADDRESS` build w/ Core 2.7.4 [#2594](https://github.com/xoseperez/espurna/issues/2594)
 - SoftwareSerial swapped TX & RX in configuration [#2592](https://github.com/xoseperez/espurna/issues/2592)
 - InfluxDB using internal ID instead of public one [#2585](https://github.com/xoseperez/espurna/issues/2585)
+- Wait until parsing authentication data with PuTTY or similar clients [#2563](https://github.com/xoseperez/espurna/issues/2563), [#2606](https://github.com/xoseperez/espurna/issues/2606)
 - Sensor filter fixes and consistent number of output values [#2543](https://github.com/xoseperez/espurna/issues/2543)
 
 ### Changed

code/espurna/telnet.cpp

@@ -336,6 +336,57 @@ String address_string(Address address) {
     return IPAddress(address.ip).toString() + ':' + String(address.port, 10);
 }
 
+// clean-up pcb data stream until telnet data ends
+bool process_rfc854(pbuf* pb) {
+    static constexpr uint8_t Iac { 0xff };
+
+    static constexpr uint8_t Will { 0xfb };
+    static constexpr uint8_t Wont { 0xfc };
+    static constexpr uint8_t Do { 0xfd };
+    static constexpr uint8_t Dont { 0xfe };
+
+    static constexpr uint8_t Eof { 0xec };
+
+    auto* ptr = reinterpret_cast<uint8_t*>(pb->payload);
+    uint16_t len { pb->len };
+
+    bool out { true };
+
+    while (out && (len >= 2)) {
+        switch (ptr[0]) {
+        case Iac:
+            switch (ptr[1]) {
+            case Will:
+            case Wont:
+            case Do:
+            case Dont:
+                if (len >= 3) {
+                    ptr += 3;
+                    len -= 3;
+                    continue;
+                }
+
+                break;
+
+            case Eof:
+                len = 0;
+                out = false;
+                ptr = nullptr;
+                break;
+            }
+
+            break;
+        }
+
+        break;
+    }
+
+    pb->len = len;
+    pb->payload = ptr;
+
+    return out;
+}
+
 // tracks the provided TCP `pcb`, cannot instantiate one by itself
 class Client {
 public:
@@ -587,6 +638,11 @@ class Client {
         // socat, netcat, etc. usually send a single packet per line.
         // Otherwise, try to buffer it and everything else in the chain.
         for (auto it = pb; it != nullptr; it = it->next) {
+            // In case connection happens from an actual telnet client
+            if (!process_rfc854(pb)) {
+                return close();
+            }
+
             auto view = line_view(it);
             if (_line_buffer.size()) {
                 goto next;