package emqx

import (
	"context"
	mqtt "github.com/eclipse/paho.mqtt.golang"
	"strings"
)

type Context struct {
	context.Context
	Client  mqtt.Client
	Message mqtt.Message
	URI     string
	Topic   string
	Buffer  []byte
	Body    string
}

// NewContext 创建上下文
func NewContext(client mqtt.Client, msg mqtt.Message, path []string) *Context {
	return &Context{
		Context: context.Background(),
		Message: msg,
		Client:  client,
		Topic:   msg.Topic(),
		URI:     strings.Join(path, "/"),
		Buffer:  msg.Payload(),
		Body:    string(msg.Payload()),
	}
}