// package log_topic -- элемент лога шины топика.
package log_topic

import (
	"fmt"

	mKa "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kalias"
	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/ktypes"
	mL1 "gitp78su.ipnodns.ru/svi/kern/v4/lev1"
)

// LogTopic -- элемент лога шины.
type LogTopic struct {
	topic  mKa.ATopic     // Топик, куда публиковать лог
	client mKt.IBusClient // С помощью чего публиковать лог
}

// NewLogTopic -- возвращает новый элемент лога.
func NewLogTopic(topic mKa.ATopic, client mKt.IBusClient) mKt.IResult[*LogTopic] {
	if topic == "" {
		err := fmt.Errorf("NewLogTopic(): topic is empty")
		return mL1.NewErr[*LogTopic](err)
	}
	if client == nil {
		err := fmt.Errorf("NewLogTopic(): IBusClient==nil")
		return mL1.NewErr[*LogTopic](err)
	}
	sf := &LogTopic{
		topic:  topic,
		client: client,
	}
	return mL1.NewRes(sf)
}

// Pub -- публикует сообщение в топик.
func (sf *LogTopic) Pub(binMsg []byte) mKt.IResult[bool] {
	res := sf.client.Publish(sf.topic, binMsg)
	if res.IsErr() {
		err := fmt.Errorf("LogTopic.Pub(): in pub with client, err=\n\t%v", res.Err())
		return mL1.NewErr[bool](err)
	}
	return res
}