Improve BlynkConsole and WidgetTerminal reliability

Co-authored-by: Copilot <copilot@github.com>

Author: vshymanskyy

src/Blynk/BlynkConsole.h

@@ -154,7 +154,7 @@ class BlynkConsole
     }
 
     ProcessResult process(char c) {
-        if (cmdPtr >= cmdBuff+sizeof(cmdBuff)) {
+        if (cmdPtr >= cmdBuff + sizeof(cmdBuff) - 1) {
             reset_buff();
         }
 
@@ -227,10 +227,12 @@ class BlynkConsole
 
     void begin(Stream& s) {
         stream = &s;
+        reset_buff();
     }
 
     void begin(Stream* s) {
         stream = s;
+        reset_buff();
     }
 
     Stream& getStream() {

src/WidgetTerminal.h

@@ -19,8 +19,10 @@
 
 #if defined(ARDUINO) && !(defined(LINUX) || defined(__MBED__))
     #define BLYNK_USE_STREAM_CLASS
+    #define BLYNK_STREAM_CLASS_OVERRIDE
 #elif defined(SPARK) || defined(PARTICLE)
     #define BLYNK_USE_STREAM_CLASS
+    #define BLYNK_STREAM_CLASS_OVERRIDE
 #endif
 
 #include <Blynk/BlynkWidgetBase.h>
@@ -48,7 +50,7 @@ class WidgetTerminal
      * Writing
      */
 
-    virtual size_t write(uint8_t byte) {
+    virtual size_t write(uint8_t byte) BLYNK_STREAM_CLASS_OVERRIDE {
         mOutBuf[mOutQty++] = byte;
         if (byte == '\n' && Blynk.connected()) {
             flush();
@@ -59,7 +61,7 @@ class WidgetTerminal
         return 1;
     }
 
-    virtual void flush() {
+    virtual void flush() BLYNK_STREAM_CLASS_OVERRIDE {
         if (mOutQty) {
             Blynk.virtualWriteBinary(mPin, mOutBuf, mOutQty);
             mOutQty = 0;
@@ -70,9 +72,9 @@ class WidgetTerminal
      * Reading
      */
 
-    virtual int read()      { return mRxBuff.readable() ? mRxBuff.get() : -1;  }
-    virtual int available() { return mRxBuff.size(); }
-    virtual int peek()      { return mRxBuff.readable() ? mRxBuff.peek() : -1; }
+    virtual int read()      BLYNK_STREAM_CLASS_OVERRIDE { return mRxBuff.readable() ? mRxBuff.get() : -1;  }
+    virtual int available() BLYNK_STREAM_CLASS_OVERRIDE { return mRxBuff.size(); }
+    virtual int peek()      BLYNK_STREAM_CLASS_OVERRIDE { return mRxBuff.readable() ? mRxBuff.peek() : -1; }
 
     void process(const BlynkParam& param) {
         mRxBuff.put((uint8_t*)param.getBuffer(), param.getLength());
@@ -108,17 +110,12 @@ class WidgetTerminal
 
     using Stream::write;
 
-    virtual size_t write(const void* buff, size_t len) {
-        return write((char*)buff, len);
-    }
-
 #else
 
-    virtual size_t write(const void* buff, size_t len) {
-        uint8_t* buf = (uint8_t*)buff;
+    virtual size_t write(const uint8_t* buff, size_t len) {
         size_t left = len;
         while (left--) {
-            write(*buf++);
+            write(*buff++);
         }
         return len;
     }