rabbitmq

type AMQPChannel interface {
	ExchangeDeclare(name, kind string, durable, autoDelete, internal, noWait bool, args amqp.Table) error
	ExchangeBind(destination, key, source string, noWait bool, args amqp.Table) error
	QueueDeclare(name string, durable, autoDelete, exclusive, noWait bool, args amqp.Table) (amqp.Queue, error)
	QueueBind(name, key, exchange string, noWait bool, args amqp.Table) error
	Consume(queue, consumer string, autoAck, exclusive, noLocal, noWait bool, args amqp.Table) (<-chan amqp.Delivery, error)
	Publish(exchange, key string, mandatory, immediate bool, msg amqp.Publishing) error
}

type AMQPConnection interface {
	Channel() (*amqp.Channel, error)
}

type BindingOpts struct {
	RoutingKey string
	// contains filtered or unexported fields
}

type ConsumerHandler = func(msg any, metadata *DeliveryMetadata) error

type DeadLetterOpts struct {
	QueueName    string
	ExchangeName string
	RoutingKey   string
}

type DelayedOpts struct {
	QueueName    string
	ExchangeName string
	RoutingKey   string
}

type DeliveryMetadata struct {
	MessageId string
	XCount    int64
	Type      string
	TraceId   string
	Headers   map[string]interface{}
}

type Dispatcher struct {
	Queue         string
	Topology      *Topology
	MsgType       string
	ReflectedType reflect.Value
	Handler       ConsumerHandler
}

type ExchangeKind string

type ExchangeOpts struct {
	Name     string
	Type     ExchangeKind
	Bindings []string
}

type FallbackType string

type IRabbitMQMessaging interface {
	// Declare a new topology
	Declare(opts *Topology) IRabbitMQMessaging

	// Binding bind an exchange/queue with the following parameters without extra RabbitMQ configurations such as Dead Letter.
	ApplyBinds() IRabbitMQMessaging

	// Publish a message
	Publisher(exchange, routingKey string, msg any, opts *PublishOpts) error

	// Create a new goroutine to each dispatcher registered
	//
	// When messages came, some validations will be mad and based on the topology configured message could sent to dql or retry
	Consume() error

	// RegisterDispatcher Add the handler and msg type
	//
	// Each time a message came, we check the queue, and get the available handlers for that queue.
	// After we do a coercion of the msg type to check which handler expect this msg type
	RegisterDispatcher(event string, handler ConsumerHandler, t any) error

	// Build the topology configured
	Build() (IRabbitMQMessaging, error)
}

type MockAMQPChannel struct {
	mock.Mock
}

type MockAMQPConnection struct {
	mock.Mock
}

type MockRabbitMQMessaging struct {
	mock.Mock
}

type PublishOpts struct {
	Type      string
	Count     int64
	TraceId   string
	MessageId string
	Delay     time.Duration
}

type QueueOpts struct {
	Name           string
	TTL            time.Duration
	Retryable      *Retry
	WithDeadLatter bool
}

type RabbitMQMessaging struct {
	Err error
	// contains filtered or unexported fields
}

type Retry struct {
	NumberOfRetry int64
	DelayBetween  time.Duration
}

type Topology struct {
	Queue    *QueueOpts
	Exchange *ExchangeOpts
	Binding  *BindingOpts
	// contains filtered or unexported fields
}