msgbus

type Config struct {
}

type Consumer interface {
	Subscribe(queueName string, exchangeName string, exchangeType string, routingKeys []RoutingKey, consumerName string, handlerFunc func(amqp.Delivery, chan<- bool)) error
	SubscribeToQueue(queueName string, consumerName string, handlerFunc func(amqp.Delivery, chan<- bool)) error
	SubscribeToServiceQueue(serviceName string, exchangeName string, routingKeys []RoutingKey, consumerId string, handlerFunc func(amqp.Delivery, chan<- bool)) error
	SubscribeWithArgs(queueName string, exchangeName string, exchangeType string,
		routingKeys []RoutingKey, consumerName string, queueArgs map[string]interface{}, handlerFunc func(amqp.Delivery, chan<- bool)) error
	IsClosed() bool
	Close()
}

type IMsgBus interface {
	ConnectToBroker(connectionString string)
	Publish(body []byte, queueName string, exchangeName string, routingKey RoutingKey, exchangeType string) error
	PublishOnQueue(body []byte, queueName string, initQueue bool) error
	Subscribe(queueName string, exchangeName string, exchangeType string, routingKeys []RoutingKey, consumerName string, handlerFunc func(amqp.Delivery, chan<- bool)) error
	SubscribeToQueue(queueName string, consumerName string, handlerFunc func(amqp.Delivery, chan<- bool)) error
	Close()
}

type MailMessage struct {
	To           string         `json:"to"`
	TemplateName string         `json:"templateName"`
	Values       map[string]any `json:"values"`
}

type MsgBusQConfig struct {
	Exchange         string
	Queue            string
	ExchangeType     string
	ReqRountingKeys  []RoutingKey
	RespRountingKeys []RoutingKey
}

type MsgBusShovelProvider interface {
	AddShovel(name string, s *Shovel) error
	GetShovel(name string) (s *Shovel, err error)
	RemoveShovel(name string) error
	CreateShovel(name string, s *Shovel) error
	RestartShovel(name string) error
}

type MsgClient struct {
	// contains filtered or unexported fields
}

type NodeUpdateBody struct {
	NodeId string `json:"nodeId"`
	State  string `json:"state"`
	Name   string `json:"name"`
}

type OrgCreatedBody struct {
	Name  string `json:"name"`
	Owner string `json:"owner"`
}

type Publisher interface {
	Publish(body []byte, queueName string, exchangeName string, routingKey RoutingKey, exchangeType string) error
	PublishOnQueue(msg []byte, queueName string, initQueue bool) error
	PublishOnExchange(exchange string, routingKey string, body interface{}) error
	DeclareQueue(queueName string, durable bool) (*amqp.Queue, error)
	IsClosed() bool
	Close()
}

type QPub interface {
	Publish(payload any, routingKey string) error
	PublishProto(payload proto.Message, routingKey string) error
	PublishToQueue(queueName string, payload any) error
	Close() error
}

type RPCResponse struct {
	Status     bool
	Resp       *amqp.Delivery
	RoutingKey RoutingKey
}

type RoutingKey string

type RoutingKeyBuilder struct {
	// contains filtered or unexported fields
}

type Shovel struct {
	SrcProtocol     string `json:"src-protocol" default:"amqp091"`
	DestProtocol    string `default:"amqp091" json:"dest-protocol"`
	SrcExchange     string `default:"amq.topic" json:"src-exchange"`
	SrcExchangeKey  string `json:"src-exchange-key,omitempty"`
	DestExchange    string `default:"amq.topic" json:"dest-exchange,omitempty"`
	DestExchangeKey string `json:"dest-exchange-key,omitempty"`
	DestQueue       string `json:"dest-queue,omitempty"`
	SrcQueue        string `json:"src-queue,omitempty"`
	SrcUri          string `json:"src-uri"`
	DestUri         string `json:"dest-uri"`
	Name            string `json:"name,omitempty"`
	Status          string `json:"status,omitempty"`
	Vhost           string `json:"vhost,omitempty"`
	Type            string `json:"type,omitempty"`
}