client_handlers.go

// Copyright (c) 2020 Contributors to the Eclipse Foundation
//
// See the NOTICE file(s) distributed with this work for additional
// information regarding copyright ownership.
//
// This program and the accompanying materials are made available under the
// terms of the Eclipse Public License 2.0 which is available at
// http://www.eclipse.org/legal/epl-2.0
//
// SPDX-License-Identifier: EPL-2.0

package ditto

import (
	//import the Paho Go MQTT library
	MQTT "github.com/eclipse/paho.mqtt.golang"
)

func (client *honoClient) defaultMessageHandler(mqttClient MQTT.Client, message MQTT.Message) {
	DEBUG.Printf("unexpected message received: %v", message)
}

func (client *honoClient) honoMessageHandler(mqttClient MQTT.Client, message MQTT.Message) {
	DEBUG.Printf("received message for client subscription: %v", message)
	// wait for handlers added in the ConnectHandler
	client.wgConnectHandler.Wait()

	client.handlersLock.RLock()
	defer client.handlersLock.RUnlock()

	if len(client.handlers) == 0 {
		WARN.Printf("message received, but no handlers were found")
		return
	}
	dittoMsg, err := getEnvelope(message.Payload())
	if err != nil {
		ERROR.Printf("error getting Ditto message: %v", err)
		return
	}
	requestID := extractHonoRequestID(message.Topic())
	if requestID == "" {
		DEBUG.Printf("no request ID is available in the received message with topic: %s", message.Topic())
	} else {
		DEBUG.Printf("received a command with request ID: %s", requestID)
	}
	for _, handler := range client.handlers {
		go handler(requestID, dittoMsg)
	}
}