Merge pull request #69 from WarriorXK/hotfix/3.1.1

[WIP] Hotfix/3.1.1

Author: WarriorXK

VERSION

@@ -1 +1 @@
-3.1.0
+3.1.1

src/PHPWebSockets.php

@@ -6,7 +6,7 @@
  * - - - - - - - - - - - - - BEGIN LICENSE BLOCK - - - - - - - - - - - - -
  * The MIT License (MIT)
  *
- * Copyright (c) 2020 Kevin Meijer
+ * Copyright (c) 2021 Kevin Meijer
  *
  * Permission is hereby granted, free of charge, to any person obtaining a copy
  * of this software and associated documentation files (the "Software"), to deal

src/PHPWebSockets/AConnection.php

@@ -6,7 +6,7 @@
  * - - - - - - - - - - - - - BEGIN LICENSE BLOCK - - - - - - - - - - - - -
  * The MIT License (MIT)
  *
- * Copyright (c) 2020 Kevin Meijer
+ * Copyright (c) 2021 Kevin Meijer
  *
  * Permission is hereby granted, free of charge, to any person obtaining a copy
  * of this software and associated documentation files (the "Software"), to deal
@@ -131,7 +131,7 @@ abstract class AConnection implements IStreamContainer, LoggerAwareInterface, IT
     /**
      * The timestamp since when this connection has been opened
      *
-     * @var int
+     * @var float|null
      */
     protected $_openedTimestamp = NULL;
 
@@ -215,7 +215,7 @@ abstract class AConnection implements IStreamContainer, LoggerAwareInterface, IT
     /**
      * The resource stream
      *
-     * @var resource
+     * @var resource|null
      */
     protected $_stream = NULL;
 
@@ -478,9 +478,10 @@ protected function _handlePacket(string $newData) : \Generator {
 
                             if ($res === FALSE) {
 
-                                $this->close();
                                 yield new Update\Error(Update\Error::C_WRITE_INVALID_TARGET_STREAM, $this);
 
+                                $this->close();
+
                             }
 
                         } else {
@@ -540,10 +541,10 @@ protected function _handlePacket(string $newData) : \Generator {
 
                             $this->_isClosed = TRUE;
 
-                            $this->close();
-
                             yield new Update\Read(Update\Read::C_SOCK_DISCONNECT, $this);
 
+                            $this->close();
+
                         } elseif (!$this->_weSentDisconnect) {
 
                             $this->_log(LogLevel::DEBUG, '  Remote initiated the disconnect, echo disconnect');
@@ -717,7 +718,18 @@ public function writeMultiFramed(string $data, int $opcode = \PHPWebSockets::OPC
             throw new \LogicException('FrameSize should be at least 1');
         }
 
-        $frames = str_split($data, $frameSize);
+        $dataLen = strlen($data);
+        if (strlen($data) > $frameSize) {
+
+            $frames = str_split($data, $frameSize);
+            if ($frames === FALSE) {
+                throw new \UnexpectedValueException('Unable to split ' . $dataLen . ' bytes into frames of ' . $frameSize . ' bytes');
+            }
+
+        } else {
+            $frames = [$data];
+        }
+
         end($frames);
         $lastKey = key($frames);
 
@@ -757,6 +769,10 @@ protected function _getStreamForNewMessage(array $headers) {
      */
     public function writeRaw(string $data, bool $priority) : void {
 
+        if (!$this->isOpen()) {
+            throw new \LogicException('Unable to write: Connection is closed');
+        }
+
         if ($priority) {
             $this->_priorityFramesBuffer[] = $data;
         } else {
@@ -859,7 +875,7 @@ public function setNewMessageStreamCallback(callable $callable = NULL) : void {
     /**
      * Returns the stream object for this connection
      *
-     * @return resource
+     * @return resource|null
      */
     public function getStream() {
         return $this->_stream;
@@ -960,10 +976,31 @@ public function close() : void {
         $this->_isClosed = TRUE;
 
         if (is_resource($this->_stream)) {
-            fclose($this->_stream);
+
+            $stream = $this->_stream;
             $this->_stream = NULL;
+
+            fclose($stream);
+
         }
 
+        // To prevent the warning that there was still data to write
+        $this->_clearBuffers();
+        $this->_resetFrameData();
+
+    }
+
+    /**
+     * Clears all buffers
+     */
+    private function _clearBuffers() : void {
+
+        $this->_currentFrameRemainingBytes = 0;
+        $this->_priorityFramesBuffer = [];
+        $this->_framesBuffer = [];
+        $this->_writeBuffer = NULL;
+        $this->_readBuffer = NULL;
+
     }
 
     /**

src/PHPWebSockets/AUpdate.php

@@ -6,7 +6,7 @@
  * - - - - - - - - - - - - - BEGIN LICENSE BLOCK - - - - - - - - - - - - -
  * The MIT License (MIT)
  *
- * Copyright (c) 2020 Kevin Meijer
+ * Copyright (c) 2021 Kevin Meijer
  *
  * Permission is hereby granted, free of charge, to any person obtaining a copy
  * of this software and associated documentation files (the "Software"), to deal

src/PHPWebSockets/BasicLogger.php

@@ -6,7 +6,7 @@
  * - - - - - - - - - - - - - BEGIN LICENSE BLOCK - - - - - - - - - - - - -
  * The MIT License (MIT)
  *
- * Copyright (c) 2020 Kevin Meijer
+ * Copyright (c) 2021 Kevin Meijer
  *
  * Permission is hereby granted, free of charge, to any person obtaining a copy
  * of this software and associated documentation files (the "Software"), to deal

src/PHPWebSockets/Client.php

@@ -6,7 +6,7 @@
  * - - - - - - - - - - - - - BEGIN LICENSE BLOCK - - - - - - - - - - - - -
  * The MIT License (MIT)
  *
- * Copyright (c) 2020 Kevin Meijer
+ * Copyright (c) 2021 Kevin Meijer
  *
  * Permission is hereby granted, free of charge, to any person obtaining a copy
  * of this software and associated documentation files (the "Software"), to deal

src/PHPWebSockets/Framer.php

@@ -6,7 +6,7 @@
  * - - - - - - - - - - - - - BEGIN LICENSE BLOCK - - - - - - - - - - - - -
  * The MIT License (MIT)
  *
- * Copyright (c) 2020 Kevin Meijer
+ * Copyright (c) 2021 Kevin Meijer
  *
  * Permission is hereby granted, free of charge, to any person obtaining a copy
  * of this software and associated documentation files (the "Software"), to deal

src/PHPWebSockets/IStreamContainer.php

@@ -6,7 +6,7 @@
  * - - - - - - - - - - - - - BEGIN LICENSE BLOCK - - - - - - - - - - - - -
  * The MIT License (MIT)
  *
- * Copyright (c) 2020 Kevin Meijer
+ * Copyright (c) 2021 Kevin Meijer
  *
  * Permission is hereby granted, free of charge, to any person obtaining a copy
  * of this software and associated documentation files (the "Software"), to deal
@@ -76,7 +76,7 @@ public function handleRead() : \Generator;
     /**
      * Returns the stream object for this connection
      *
-     * @return resource
+     * @return resource|null
      */
     public function getStream();
 

src/PHPWebSockets/ITaggable.php

@@ -6,7 +6,7 @@
  * - - - - - - - - - - - - - BEGIN LICENSE BLOCK - - - - - - - - - - - - -
  * The MIT License (MIT)
  *
- * Copyright (c) 2020 Kevin Meijer
+ * Copyright (c) 2021 Kevin Meijer
  *
  * Permission is hereby granted, free of charge, to any person obtaining a copy
  * of this software and associated documentation files (the "Software"), to deal

src/PHPWebSockets/Server.php

@@ -6,7 +6,7 @@
  * - - - - - - - - - - - - - BEGIN LICENSE BLOCK - - - - - - - - - - - - -
  * The MIT License (MIT)
  *
- * Copyright (c) 2020 Kevin Meijer
+ * Copyright (c) 2021 Kevin Meijer
  *
  * Permission is hereby granted, free of charge, to any person obtaining a copy
  * of this software and associated documentation files (the "Software"), to deal