Update 2 files

- /internal/utils/transfer/privilege.go
- /internal/kafka/tariff/producer.go

internal/kafka/tariff/producer.go

@@ -39,6 +39,7 @@ func NewProducer(deps ProducerDeps) *Producer {
 }
 
 func (p *Producer) Send(ctx context.Context, userID string, tariff *models.Tariff) error {
+	fmt.Println("PMTP0", tariff)
 	bytes, err := proto.Marshal(transfer.TariffModelToProtoMessage(userID, tariff))
 	if err != nil {
 		p.logger.Error("failed to marshal tariff model", zap.Error(err))

internal/utils/transfer/privilege.go

@@ -3,12 +3,14 @@ package transfer
 import (
 	"codeword/internal/models"
 	"codeword/internal/proto/broker"
+	"fmt"
 )
 
 func PrivilegeModelToProto(privilege *models.Privilege) *broker.PrivilegeMessage {
 	if privilege == nil {
 		return &broker.PrivilegeMessage{}
 	}
+	fmt.Println("PMTP", privilege.ServiceKey)
 
 	return &broker.PrivilegeMessage{
 		PrivilegeID: privilege.PrivilegeID,