Add error handling for very first packet from server (Fixes #101)

amphp · Dec 24, 2020 · 8d57ecc · 8d57ecc
1 parent 03c6954
commit 8d57ecc
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/src/Internal/Processor.php b/src/Internal/Processor.php
@@ -1378,6 +1378,10 @@ private function parseMysql(): \Generator
     private function parsePayload(string $packet): void
     {
         if ($this->connectionState === self::UNCONNECTED) {
+            if (\ord($packet) == self::ERR_PACKET) {
+                $this->handleError($packet);
+                return;
+            }
             $this->established();
             $this->connectionState = self::ESTABLISHED;
             $this->handleHandshake($packet);