package producers

import (
	"github.com/streadway/amqp"
	"matchmaking-system/internal/conf"
)

// Producer
// @Description:
type Producer struct {
	Entrust  *ProducerEntrust
	Position *ProducerPosition
}

// NewProducer
//
//	@Description: 初始化生产者
//	@param f
//	@param con
//	@return *Producer
//	@return error
func NewProducer(f *conf.Data, con *amqp.Connection) (*Producer, error) {
	// 初始化生产者持仓消息队列
	entrust, err := NewEntrust(f, con)
	if err != nil {
		return nil, err
	}
	// 初始化生产者平仓消息队列
	position, err := NewPosition(f, con)
	if err != nil {
		return nil, err
	}

	return &Producer{Entrust: entrust, Position: position}, nil
}