feat: add http package

Makefile

@@ -52,3 +52,12 @@ run-migration:
 create-mocks:
 	@rm -rf mocks
 	mockery --all
+
+.PHONY: swag-init
+swag-init:
+	swag init -g cmd/psqlqueue/main.go
+	swag fmt
+
+.PHONY: run-server
+run-server:
+	go run cmd/psqlqueue/main.go server

cmd/psqlqueue/main.go

@@ -8,6 +8,9 @@ import (
 
 	"github.com/allisson/psqlqueue/db/migrations"
 	"github.com/allisson/psqlqueue/domain"
+	"github.com/allisson/psqlqueue/http"
+	"github.com/allisson/psqlqueue/repository"
+	"github.com/allisson/psqlqueue/service"
 )
 
 func main() {
@@ -28,6 +31,35 @@ func main() {
 					return migrations.Migrate(cfg.DatabaseURL)
 				},
 			},
+			{
+				Name:    "server",
+				Aliases: []string{"s"},
+				Usage:   "run http server",
+				Action: func(c *cli.Context) error {
+					pool, err := repository.SetupDatabaseConnection(c.Context, cfg)
+					if err != nil {
+						return err
+					}
+					defer pool.Close()
+
+					// repositories
+					queueRepository := repository.NewQueue(pool)
+					messageRepository := repository.NewMessage(pool)
+
+					// services
+					queueService := service.NewQueue(queueRepository)
+					messageService := service.NewMessage(messageRepository, queueRepository)
+
+					// http handlers
+					queueHandler := http.NewQueueHandler(queueService)
+					messageHandler := http.NewMessageHandler(messageService)
+
+					// run http server
+					http.RunServer(c.Context, cfg, http.SetupRouter(logger, queueHandler, messageHandler))
+
+					return nil
+				},
+			},
 		},
 	}