diff --git a/.app.config b/.app.config index f0cd1cc..6c10c2a 100644 --- a/.app.config +++ b/.app.config @@ -9,6 +9,8 @@ }, "Check": { "TCP": "__IP__:443", + "Interval": "5s", + "Timeout": "1s", "DeregisterCriticalServiceAfter": "10s" } } \ No newline at end of file diff --git a/.env.dist b/.env.dist index 44d3329..1be54fe 100644 --- a/.env.dist +++ b/.env.dist @@ -7,7 +7,7 @@ APP_PATH_PREFIX=/pricing APP_KV_NAMESPACE=dev.egommerce/service/pricing-svc LOGGER_ADDR=api-logger:24224 -REGISTRY_ADDR=api-registry:8500 +REGISTRY_ADDR=api-registry:8501 DATABASE_URL=postgres://postgres:12345678@postgres-db:5432/egommerce CACHE_ADDR=api-cache:6379 CACHE_PASSWORD=12345678 diff --git a/Dockerfile.target b/Dockerfile.target index 289bb14..1f0475d 100644 --- a/Dockerfile.target +++ b/Dockerfile.target @@ -22,6 +22,7 @@ COPY --from=builder $BIN_OUTPUT /app COPY --from=builder /go/bin/migrate /bin/migrate COPY --from=builder /go/bin/health /bin/health COPY .env.docker /.env +COPY ./.app.config / COPY ./bin /bin RUN chmod 755 /bin/entrypoint.sh /bin/migrate.sh diff --git a/bin/entrypoint.sh b/bin/entrypoint.sh index f8c3ce9..12cc874 100755 --- a/bin/entrypoint.sh +++ b/bin/entrypoint.sh @@ -17,10 +17,12 @@ waitForService() update-resolv # provided by stack - better approach - single copy update-ca-certificates -waitForService "postgres-db:5432" waitForService "api-eventbus:5672" waitForService "api-logger:24224" -waitForService "api-registry:8500" +waitForService "api-registry:8501" +waitForService "db-postgres:5432" + +register-service # run migrations migrate.sh diff --git a/src/cmd/health/main.go b/src/cmd/health/main.go index c27f125..4c4420e 100644 --- a/src/cmd/health/main.go +++ b/src/cmd/health/main.go @@ -29,7 +29,7 @@ func main() { } func healthCheck() bool { - run, err := os.Open("/app.run") + run, err := os.Open("./app.run") if err != nil { return false } diff --git a/src/cmd/server/main.go b/src/cmd/server/main.go index 5d687ce..1e4bcf8 100644 --- a/src/cmd/server/main.go +++ b/src/cmd/server/main.go @@ -25,7 +25,7 @@ func main() { a.RegisterPlugin(app.CachePlugin(cArr)) a.RegisterPlugin(app.DatabasePlugin(cArr)) a.RegisterPlugin(app.EventbusPlugin(cArr)) - a.RegisterPlugin(app.RegistryPlugin(cArr)) + // a.RegisterPlugin(app.RegistryPlugin(cArr)) while := make(chan struct{}) err := a.Start(while) diff --git a/src/go.mod b/src/go.mod index ec89b86..ce7980d 100644 --- a/src/go.mod +++ b/src/go.mod @@ -4,7 +4,7 @@ go 1.18 require ( git.pbiernat.io/egommerce/api-entities v0.2.3 - git.pbiernat.io/egommerce/go-api-pkg v0.3.18 + git.pbiernat.io/egommerce/go-api-pkg v0.3.24 github.com/georgysavva/scany/v2 v2.0.0 github.com/go-pg/migrations/v8 v8.1.0 github.com/go-pg/pg/v10 v10.10.7 diff --git a/src/go.sum b/src/go.sum index 179810e..91600a8 100644 --- a/src/go.sum +++ b/src/go.sum @@ -37,8 +37,8 @@ cloud.google.com/go/storage v1.10.0/go.mod h1:FLPqc6j+Ki4BU591ie1oL6qBQGu2Bl/tZ9 dmitri.shuralyov.com/gpu/mtl v0.0.0-20190408044501-666a987793e9/go.mod h1:H6x//7gZCb22OMCxBHrMx7a5I7Hp++hsVxbQ4BYO7hU= git.pbiernat.io/egommerce/api-entities v0.2.3 h1:mR6EYfZkAzh4teydb7KXDBWoxwVW3qasnmmH5J3mnas= git.pbiernat.io/egommerce/api-entities v0.2.3/go.mod h1:INXAG5x4+i+vNwg1NpfPHiDW8nY1kn1K7pgLOtX+/I0= -git.pbiernat.io/egommerce/go-api-pkg v0.3.18 h1:0+C9BMsllrNvRbh4kb7dJ5lrzP1Lc7J4pb+KV76YrXk= -git.pbiernat.io/egommerce/go-api-pkg v0.3.18/go.mod h1:XIy2mmvRNIzQmYIUAcDZafhRPxTQFS2HDmsK7ZQ6980= +git.pbiernat.io/egommerce/go-api-pkg v0.3.24 h1:if6xsFOStckWdGm7kcgKWOhOGOe6iIBOOr+3DjgX5tM= +git.pbiernat.io/egommerce/go-api-pkg v0.3.24/go.mod h1:XIy2mmvRNIzQmYIUAcDZafhRPxTQFS2HDmsK7ZQ6980= github.com/Azure/azure-sdk-for-go v44.0.0+incompatible h1:e82Yv2HNpS0kuyeCrV29OPKvEiqfs2/uJHic3/3iKdg= github.com/Azure/go-autorest v14.2.0+incompatible h1:V5VMDjClD3GiElqLWO7mz2MxNAK/vTfRHdAubSIPRgs= github.com/Azure/go-autorest/autorest v0.11.18 h1:90Y4srNYrwOtAgVo3ndrQkTYn6kf1Eg/AjTFJ8Is2aM= diff --git a/src/internal/server/config.go b/src/internal/server/config.go index 12686eb..4d6f6e3 100644 --- a/src/internal/server/config.go +++ b/src/internal/server/config.go @@ -21,7 +21,7 @@ const ( defNetAddr = ":443" defMongoDbURL = "mongodb://mongodb:12345678@mongo-db:27017" defPathPrefix = "/pricing" - defRegistryAddr = "api-registry:8500" + defRegistryAddr = "api-registry:8501" defEbEventsExchange = "api-events" defEbEventsQueue = "pricing-svc" ) diff --git a/src/internal/server/middleware.go b/src/internal/server/middleware.go index 32328d9..8c7a36c 100644 --- a/src/internal/server/middleware.go +++ b/src/internal/server/middleware.go @@ -1,8 +1,6 @@ package server import ( - "strings" - "github.com/gofiber/fiber/v2" "git.pbiernat.io/egommerce/go-api-pkg/fluentd" @@ -17,10 +15,10 @@ func SetupMiddleware(s *Server) { func LoggingMiddleware(log *fluentd.Logger) func(c *fiber.Ctx) error { return func(c *fiber.Ctx) error { - path := string(c.Request().URI().Path()) - if strings.Contains(path, "/health") { - return c.Next() - } + // path := string(c.Request().URI().Path()) + // if strings.Contains(path, "/health") { + // return c.Next() + // } log.Log("Request: %s, remote: %s, via: %s", c.Request().URI().String(), diff --git a/src/internal/server/server.go b/src/internal/server/server.go index 1bfa7b6..e76063e 100644 --- a/src/internal/server/server.go +++ b/src/internal/server/server.go @@ -69,7 +69,7 @@ func (s *Server) RegisterHandler(name string, fn func() any) { func (s *Server) OnShutdown() { // s.GetLogger().Log("Server %s is going down...", s.ID) - s.GetRegistry().Unregister() + // s.GetRegistry().Unregister() // a.clearMetadataCache() s.GetEventBus().Close() s.GetDatabase().Close()