fix: use publisher adapter

internal/adapters/publisher/adapter.go

@@ -0,0 +1,25 @@
+package publisher
+
+type EventPublisherAdapter struct {
+	Publisher IEventPublisher
+}
+
+func NewEventPublisherAdapter(cfg IPublisherConfigFactory) *EventPublisherAdapter {
+
+	config := cfg.Config()
+	adapter := &EventPublisherAdapter{}
+
+	switch config.Type {
+	case PublisherTypeRabbitMQ:
+		pub, err := NewRabbitPublisher(cfg)
+		if err != nil {
+			return nil
+		}
+
+		adapter.Publisher = pub
+
+		return adapter
+	default:
+		return nil
+	}
+}

internal/adapters/wire.go

@@ -10,5 +10,5 @@ var AdaptersSet = wire.NewSet(
 	telegram.NewTelegramBotAdapter,
 	telegram.NewTelegramListener,
 	publisher.NewRabbitPublisher,
-	wire.Bind(new(publisher.IEventPublisher), new(*publisher.RabbitPublisher)),
+	publisher.NewEventPublisherAdapter,
 )

internal/app.go

@@ -29,10 +29,10 @@ var AppSet = wire.NewSet(
 
 // Server represents the main server configuration.
 type Server struct {
-	App       *fiber.App
-	Bot       *telegram.TelegramListener
-	Publisher publisher.IEventPublisher
-	AppConfig *configs.AppConfig
+	App        *fiber.App
+	Bot        *telegram.TelegramListener
+	PubAdapter *publisher.EventPublisherAdapter
+	AppConfig  *configs.AppConfig
 }
 
 func (srv *Server) Run(ctx context.Context) {
@@ -58,7 +58,7 @@ func (srv *Server) Shutdown() {
 	}
 
 	slog.Debug("shutdown publisher")
-	err := srv.Publisher.Close()
+	err := srv.PubAdapter.Publisher.Close()
 	if err != nil {
 		slog.Error("unable to shutdown publisher.", models.LogEntryAttr(&models.LogEntry{
 			Err: err,
@@ -74,7 +74,7 @@ func NewApp(
 	br *router.BotRouter,
 	sr *router.SwaggerRouter,
 	bot *telegram.TelegramListener,
-	ps *publisher.RabbitPublisher,
+	ps *publisher.EventPublisherAdapter,
 	pc *configs.PostgresConfig,
 ) *Server {
 	logger := slogger.NewLogger(
@@ -115,9 +115,9 @@ func NewApp(
 	}
 
 	return &Server{
-		App:       app,
-		Bot:       bot,
-		Publisher: ps,
-		AppConfig: ac,
+		App:        app,
+		Bot:        bot,
+		PubAdapter: ps,
+		AppConfig:  ac,
 	}
 }

internal/repositories/topics.go

@@ -33,20 +33,20 @@ type ITopicsRepository interface {
 type TopicRepository struct {
 	redis           *redis.RedisConnection
 	postgres        *postgres.PostgresConnection
-	publisher       publisher.IEventPublisher
+	pubAdapter      *publisher.EventPublisherAdapter
 	publisherConfig *configs.PublisherConfig
 }
 
 func NewTopicsRepository(
 	redis *redis.RedisConnection,
 	postgres *postgres.PostgresConnection,
-	publisher publisher.IEventPublisher,
+	pubAdapter *publisher.EventPublisherAdapter,
 	publisherConfig *configs.PublisherConfig,
 ) *TopicRepository {
 	return &TopicRepository{
 		redis,
 		postgres,
-		publisher,
+		pubAdapter,
 		publisherConfig,
 	}
 }
@@ -239,7 +239,7 @@ func (r *TopicRepository) LeaveFeedback(feedback *models.CreateTopicFeedbackAttr
 		return nil, err
 	}
 
-	err = r.publisher.Publish(context.TODO(), r.publisherConfig.Topic, &publisher.Event{
+	err = r.pubAdapter.Publisher.Publish(context.TODO(), r.publisherConfig.Topic, &publisher.Event{
 		Data: &publisher.TopicFeedbackEvent{
 			Pattern: "topic_feedbacks",
 			Data: publisher.TopicFeedbackEventData{