38 lines
1.2 KiB
Go
38 lines
1.2 KiB
Go
package main
|
|
|
|
import (
|
|
"context"
|
|
|
|
"github.com/beckn/beckn-onix/pkg/log"
|
|
"github.com/beckn/beckn-onix/pkg/plugin/definition"
|
|
"github.com/beckn/beckn-onix/pkg/plugin/implementation/publisher"
|
|
)
|
|
|
|
// publisherProvider implements the PublisherProvider interface.
|
|
// It is responsible for creating a new Publisher instance.
|
|
type publisherProvider struct{}
|
|
|
|
// New creates a new Publisher instance based on the provided configuration.
|
|
func (p *publisherProvider) New(ctx context.Context, config map[string]string) (definition.Publisher, func() error, error) {
|
|
cfg := &publisher.Config{
|
|
Addr: config["addr"],
|
|
Exchange: config["exchange"],
|
|
RoutingKey: config["routing_key"],
|
|
Durable: config["durable"] == "true",
|
|
UseTLS: config["use_tls"] == "true",
|
|
}
|
|
log.Debugf(ctx, "Publisher config mapped: %+v", cfg)
|
|
|
|
pub, cleanup, err := publisher.New(cfg)
|
|
if err != nil {
|
|
log.Errorf(ctx, err, "Failed to create publisher instance")
|
|
return nil, nil, err
|
|
}
|
|
|
|
log.Infof(ctx, "Publisher instance created successfully")
|
|
return pub, cleanup, nil
|
|
}
|
|
|
|
// Provider is the instance of publisherProvider that implements the PublisherProvider interface.
|
|
var Provider = publisherProvider{}
|