package mqtt

import (
	"context"
)

// based off of paho.mqtt.golang: https://github.com/eclipse/paho.mqtt.golang
// in the future can implment methods for Connect, Disconnect, Subscribe etc.
type Client interface {
	Publish(context.Context, Payload) error
}

type Payload interface {
	Data() []byte
	Attributes() map[string]string
}

// NopPublisher does nothing when you call Publish. This is for stubbing purposes.
type NopPublisher struct{}

// Publish does nothing
func (n NopPublisher) Publish(_ context.Context, _ Payload) error {
	return nil
}