onMessage method

Implementation

@override
onMessage(Payload payload)
{
  // enabled?
  if (enabled == false) return;

  // increment the number of messages received
  _received.set(received + 1);

  // set last serial received
    _serial.set(payload.id);

  // set last message bindable
  _message.set(payload.message);

  // deserialize the data
  Data data = Data.from(payload.message, root: root);

  // if the message didn't deserialize (length 0)
  // is the payload url encoded?
  if (data.isEmpty && payload.message != null)
  {
    // is a valid url query string?
    String msg = payload.message!.trim();

    // parse the string
    Uri? uri = URI.parse(msg);
    if (uri != null && !uri.hasQuery) uri = URI.parse("?$msg");
    if (uri != null && uri.hasQuery)
    {
      // add payload url parameters
      Map<String, dynamic> map = <String, dynamic>{};
      uri.queryParameters.forEach((k, v) => map[k] = v);
      if(!map.containsKey('payload')) map['payload'] = payload.message;
      if(!map.containsKey('serial'))  map['serial'] = payload.id;
      data.add(map);
    }
  }

  // if the message didn't deserialize (length 0)
  // create a simple map with topic and message bindables <id>.data.topic and <id>.data.message
  // otherwise the data is the deserialized message payload
  if (data.isEmpty) data.insert(0, {'id' : payload.id, 'serial': payload.id , 'payload' : payload.message});

  // fire the onresponse
  onSuccess(data, code: 200);
}