Recieving headers in the payload

[plpdharma]

Hi, I am trying to subscribe a Spring boots web socket topic from ESP8266. While I receive the payload in the WebSocketClient i am also receiving the header information, so it is hard for me to parse the data. Help would be appriciated.

Below is the sample payload which I receive (USE_SERIAL.printf("[WSc] get text: %s\n", payload);).

foo:bar destination:/topic/mytopic/esp8266/ content-type:application/json subscription:sub-0 message-id:7dc54e8c-08d4-269a-4fff-d4a28be7061c-8 content-length:19

{"content":"Hello"} deserializeJson() failed: InvalidInput

Please find the code below

#define USE_SERIAL Serial


// LIBRARIES

#include <Arduino.h>
#include <Hash.h>
#include <ArduinoJson.h>
#include <ESP8266WiFi.h>
#include <WebSocketsClient.h>
StaticJsonDocument<100> doc; // Allocate a static JSON document


// SETTINGS

const char* wlan_ssid             = "xxxxx";
const char* wlan_password         = "xxxxxx";

const char* ws_host               = "192.168.55.106";
const int   ws_port               = 8081;

// URL for STOMP endpoint.
// For the default config of Spring's STOMP support, the default URL is "/socketentry/websocket".
const char* stompUrl            = "/gs-guide-websocket/websocket"; // don't forget the leading "/" !!!


// VARIABLES

WebSocketsClient webSocket;


// FUNCTIONS

/**
 * STOMP messages need to be NULL-terminated (i.e., \0 or \u0000).
 * However, when we send a String or a char[] array without specifying 
 * a length, the size of the message payload is derived by strlen() internally,
 * thus dropping any NULL values appended to the "msg"-String.
 * 
 * To solve this, we first convert the String to a NULL terminated char[] array
 * via "c_str" and set the length of the payload to include the NULL value.
 */
void sendMessage(String & msg) {
    webSocket.sendTXT(msg.c_str(), msg.length() + 1);
}

void webSocketEvent(WStype_t type, uint8_t * payload, size_t length) {

    switch (type) {
        case WStype_DISCONNECTED:
            USE_SERIAL.printf("[WSc] Disconnected!\n");
            break;
        case WStype_CONNECTED:
            {
                USE_SERIAL.printf("[WSc] Connected to url: %s\n",  payload);
                
                String msg = "CONNECT\r\naccept-version:1.1,1.0\r\nheart-beat:10000,10000\r\n\r\n";
                sendMessage(msg);
            }
            break;
        case WStype_TEXT:
            {
                // #####################
                // handle STOMP protocol
                // #####################
                  
                String text = (char*) payload;
                //USE_SERIAL.printf("[WSc] get text: %s\n", payload);
                delay(6000);
                if (text.startsWith("CONNECTED")) {

                    // subscribe to some channels

                    String msg = "SUBSCRIBE\nid:sub-0\ndestination:/topic/mytopic/esp8266/\n\n";
                    sendMessage(msg);
                    delay(1000);

                    // and send a message

                    //msg = "SEND\ndestination:/app/message\n\n{\"user\":\"esp\",\"message\":\"Hello!\"}";
                    //sendMessage(msg);
                    //delay(1000);
                    
                }  if (text.startsWith("MESSAGE")) {
                       DeserializationError error = deserializeJson(doc, payload); // deserialize incoming Json String
                          if (error) { // Print erro msg if incomig String is not JSON formated
                            Serial.print(F("deserializeJson() failed: "));
                            Serial.println(error.c_str());
                            return;
                          }
                      //USE_SERIAL.printf("[WSc] Message from Server: %s\n asdfghjkl", payloadObj[0].c_str());
                }else {
                    
                    // do something with messages
                    
                }

                break;
            }
        case WStype_BIN:
            USE_SERIAL.printf("[WSc] get binary length: %u\n", length);
            hexdump(payload, length);

            // send data to server
            // webSocket.sendBIN(payload, length);
            break;
    }

}

void setup() {

    // setup serial

    // USE_SERIAL.begin(921600);
    USE_SERIAL.begin(115200);

    //    USE_SERIAL.setDebugOutput(true);

    USE_SERIAL.println();


    // connect to WiFi

    USE_SERIAL.print("Logging into WLAN: "); Serial.print(wlan_ssid); Serial.print(" ...");
    WiFi.mode(WIFI_STA);
    WiFi.begin(wlan_ssid, wlan_password);

    while (WiFi.status() != WL_CONNECTED) {
        delay(500);
        USE_SERIAL.print(".");
    }
    USE_SERIAL.println(" success.");
    USE_SERIAL.print("IP: "); USE_SERIAL.println(WiFi.localIP());


    // connect to websocket
    webSocket.begin(ws_host, ws_port, stompUrl);
    webSocket.setExtraHeaders(); // remove "Origin: file://" header because it breaks the connection with Spring's default websocket config
    //    webSocket.setExtraHeaders("foo: I am so funny\r\nbar: not"); // some headers, in case you feel funny
    webSocket.onEvent(webSocketEvent);
}

void loop() {
    webSocket.loop();
}

[shrynshjn]

can you show what exactly are you getting in the message?