Update

.app.config

@@ -9,6 +9,8 @@
 	},
 	"Check": {
 		"TCP": "__IP__:443",
+		"Interval": "5s",
+		"Timeout": "1s",
 		"DeregisterCriticalServiceAfter": "10s"
 	}
 }

.env.dist

@@ -7,7 +7,7 @@ APP_PATH_PREFIX=/identity
 APP_KV_NAMESPACE=dev.egommerce/service/identity-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

bin/entrypoint.sh

@@ -17,8 +17,11 @@ waitForService()
 update-resolv # provided by stack - better approach - single copy
 update-ca-certificates
 
-waitForService "postgres-db:5432"
+waitForService "api-registry:8501"
 waitForService "api-logger:24224"
+waitForService "db-postgres:5432"
+
+register-service
 
 # run migrations
 migrate.sh

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
 	}

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)

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/go-pg/migrations/v8 v8.1.0
 	github.com/go-pg/pg/v10 v10.11.1
 	github.com/go-redis/redis/v8 v8.11.5

src/go.sum

@@ -7,8 +7,8 @@ cloud.google.com/go/iam v1.1.1 h1:lW7fzj15aVIXYHREOqjRBV9PsH0Z6u8Y46a1YGvQP4Y=
 cloud.google.com/go/iam v1.1.1/go.mod h1:A5avdyVL2tCppe4unb0951eI9jreack+RJ0/d+KUZOU=
 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 v68.0.0+incompatible h1:fcYLmCpyNYRnvJbPerq7U0hS+6+I79yEDJBqVNcqUzU=
 github.com/Azure/go-autorest v14.2.0+incompatible h1:V5VMDjClD3GiElqLWO7mz2MxNAK/vTfRHdAubSIPRgs=
 github.com/Azure/go-autorest/autorest v0.11.28 h1:ndAExarwr5Y+GaHE6VCaY1kyS/HwwGGyuimVhWsHOEM=

src/internal/server/config.go

@@ -21,7 +21,7 @@ const (
 	defNetAddr          = ":443"
 	defMongoDbURL       = "mongodb://mongodb:12345678@mongo-db:27017"
 	defPathPrefix       = "/identity"
-	defRegistryAddr     = "api-registry:8500"
+	defRegistryAddr     = "api-registry:8501"
 	defEbEventsExchange = "api-events"
 	defEbEventsQueue    = "identity-svc"
 )

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"
@@ -18,10 +16,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(),

src/internal/server/server.go

@@ -68,7 +68,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()