adds Zap logger so it can be seen in Loki

Author: nextinterfaces

README.md

@@ -15,17 +15,16 @@
 
 
 ## Local Development
-This project uses [Task](https://taskfile.dev/) to common development workflows, Run `task` to see all available tasks.
+Project uses [Task](https://taskfile.dev/) to common dev workflows, Run `task` to see all available tasks.
 
 ```bash
 task local:setup
 task local:start
 
 Tilt UI:               http://localhost:10350
-
 Jaeger UI:             http://localhost:16686
-PostgreSQL:            localhost:5432
-     - Connection:          psql postgresql://{.env.POSTGRES_USER}:{.env.POSTGRES_PASSWORD}@localhost:5432/
+Postgre:               localhost:5432
+Postgre connection     psql postgresql://{.env.POSTGRES_USER}:{.env.POSTGRES_PASSWORD}@localhost:5432/
 ```
 
 ## Production Links

apps/semcache-service/api/openapi.yaml

@@ -1,19 +1,11 @@
 openapi: 3.0.3
 info:
   title: Semcache Service API
-  description: |
-    Semantic cache service for storing and searching key-value pairs with metadata and TTL support.
 
-    ## Features
-    - Store key-value pairs with optional metadata
-    - TTL (Time To Live) support for automatic expiration
-    - Flexible search by key or metadata
-    - Unique key constraint
-    - Automatic expiration filtering
-  version: 1.0.0
+  version: 0.1.0
   contact:
     name: API Support
-    url: https://github.com/nextinterfaces/semcache-service
+    url: https://github.com/nextinterfaces/roussev.com
 
 servers:
   - url: https://app.roussev.com/semcache

apps/semcache-service/cmd/server/main.go

@@ -15,6 +15,7 @@ import (
 	"github.com/nextinterfaces/semcache-service/internal/config"
 	"github.com/nextinterfaces/semcache-service/internal/database"
 	"github.com/nextinterfaces/semcache-service/internal/handlers"
+	"github.com/nextinterfaces/semcache-service/internal/logger"
 	"github.com/nextinterfaces/semcache-service/internal/models"
 	"github.com/nextinterfaces/semcache-service/internal/util"
 	"go.opentelemetry.io/otel"
@@ -33,19 +34,27 @@ func main() {
 func run() error {
 	cfg, err := config.Load()
 	cfgJSON, _ := json.MarshalIndent(util.RedactedConfig(cfg), "", "  ")
-	log.Println("Loaded configuration:\n" + string(cfgJSON))
 	if err != nil {
 		return fmt.Errorf("failed to load config: %w", err)
 	}
 
+	// Initialize logger
+	logger.InitLogger(cfg.Debug)
+	defer logger.Sync()
+
+	logger.Logger.Info("Starting semcache-service")
+	logger.Logger.Debug("Debug mode enabled")
+	logger.Logger.Info("Loaded configuration:\n" + string(cfgJSON))
+	//logger.Logger.Info("Server port", zap.Int("port", cfg.Server.Port))
+
 	// Initialize OpenTelemetry
 	if cfg.OTEL.Enabled {
 		shutdown, err := initTracer(cfg)
 		if err != nil {
-			log.Printf("Warning: Failed to initialize tracer: %v", err)
+			logger.Logger.Warn(fmt.Sprintf("Failed to initialize tracer: %v", err))
 		} else {
 			defer shutdown()
-			log.Printf("OpenTelemetry tracing enabled: %s", cfg.OTEL.Endpoint)
+			logger.Logger.Info(fmt.Sprintf("OpenTelemetry tracing enabled: %s", cfg.OTEL.Endpoint))
 		}
 	}
 
@@ -92,22 +101,22 @@ func run() error {
 	go func() {
 		addr := fmt.Sprintf(":%d", port)
 		if err := e.Start(addr); err != nil {
-			log.Printf("Server error: %v", err)
+			logger.Logger.Error(fmt.Sprintf("Server error: %v", err))
 		}
 	}()
 
-	log.Printf("Server started, endpoints:")
-	log.Printf("  http://localhost:%d/v1/health", port)
-	log.Printf("  http://localhost:%d/docs", port)
-	log.Printf("  POST http://localhost:%d/v1/create", port)
-	log.Printf("  POST http://localhost:%d/v1/search", port)
+	logger.Logger.Info(fmt.Sprintf("Server started, endpoints:"))
+	logger.Logger.Info(fmt.Sprintf("  http://localhost:%d/v1/health", port))
+	logger.Logger.Info(fmt.Sprintf("  http://localhost:%d/docs", port))
+	logger.Logger.Info(fmt.Sprintf("  POST http://localhost:%d/v1/create", port))
+	logger.Logger.Info(fmt.Sprintf("  POST http://localhost:%d/v1/search", port))
 
 	// Wait for interrupt signal to gracefully shutdown the server
 	quit := make(chan os.Signal, 1)
 	signal.Notify(quit, os.Interrupt, syscall.SIGTERM)
 	<-quit
 
-	log.Println("Shutting down server...")
+	logger.Logger.Info(fmt.Sprintf("Shutting down server..."))
 
 	// Graceful shutdown with timeout
 	ctx, cancel = context.WithTimeout(context.Background(), 10*time.Second)
@@ -117,7 +126,7 @@ func run() error {
 		return fmt.Errorf("server shutdown error: %w", err)
 	}
 
-	log.Println("Server stopped")
+	logger.Logger.Info(fmt.Sprintf("Server stopped"))
 	return nil
 }
 
@@ -156,7 +165,7 @@ func initTracer(cfg *config.Config) (func(), error) {
 		ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
 		defer cancel()
 		if err := tp.Shutdown(ctx); err != nil {
-			log.Printf("Error shutting down tracer provider: %v", err)
+			logger.Logger.Info(fmt.Sprintf("Error shutting down tracer provider: %v", err))
 		}
 	}, nil
 }

apps/semcache-service/go.mod

@@ -8,6 +8,7 @@ require (
 	go.opentelemetry.io/otel v1.24.0
 	go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracehttp v1.24.0
 	go.opentelemetry.io/otel/sdk v1.24.0
+	go.uber.org/zap v1.27.0
 )
 
 require (
@@ -25,6 +26,7 @@ require (
 	go.opentelemetry.io/otel/metric v1.24.0 // indirect
 	go.opentelemetry.io/otel/trace v1.24.0 // indirect
 	go.opentelemetry.io/proto/otlp v1.1.0 // indirect
+	go.uber.org/multierr v1.10.0 // indirect
 	golang.org/x/crypto v0.22.0 // indirect
 	golang.org/x/net v0.24.0 // indirect
 	golang.org/x/sys v0.19.0 // indirect

apps/semcache-service/go.sum

@@ -46,6 +46,12 @@ go.opentelemetry.io/otel/trace v1.24.0 h1:CsKnnL4dUAr/0llH9FKuc698G04IrpWV0MQA/Y
 go.opentelemetry.io/otel/trace v1.24.0/go.mod h1:HPc3Xr/cOApsBI154IU0OI0HJexz+aw5uPdbs3UCjNU=
 go.opentelemetry.io/proto/otlp v1.1.0 h1:2Di21piLrCqJ3U3eXGCTPHE9R8Nh+0uglSnOyxikMeI=
 go.opentelemetry.io/proto/otlp v1.1.0/go.mod h1:GpBHCBWiqvVLDqmHZsoMM3C5ySeKTC7ej/RNTae6MdY=
+go.uber.org/goleak v1.3.0 h1:2K3zAYmnTNqV73imy9J1T3WC+gmCePx2hEGkimedGto=
+go.uber.org/goleak v1.3.0/go.mod h1:CoHD4mav9JJNrW/WLlf7HGZPjdw8EucARQHekz1X6bE=
+go.uber.org/multierr v1.10.0 h1:S0h4aNzvfcFsC3dRF1jLoaov7oRaKqRGC/pUEJ2yvPQ=
+go.uber.org/multierr v1.10.0/go.mod h1:20+QtiLqy0Nd6FdQB9TLXag12DsQkrbs3htMFfDN80Y=
+go.uber.org/zap v1.27.0 h1:aJMhYGrd5QSmlpLMr2MftRKl7t8J8PTZPA732ud/XR8=
+go.uber.org/zap v1.27.0/go.mod h1:GB2qFLM7cTU87MWRP2mPIjqfIDnGu+VIO4V/SdhGo2E=
 golang.org/x/crypto v0.22.0 h1:g1v0xeRhjcugydODzvb3mEM9SQ0HGp9s/nh3COQ/C30=
 golang.org/x/crypto v0.22.0/go.mod h1:vr6Su+7cTlO45qkww3VDJlzDn0ctJvRgYbC2NvXHt+M=
 golang.org/x/net v0.24.0 h1:1PcaxkF854Fu3+lvBIx5SYn9wRlBzzcnHZSiaFFAb0w=

apps/semcache-service/internal/config/config.go

@@ -11,6 +11,7 @@ type Config struct {
 	Server   ServerConfig
 	Database DatabaseConfig
 	OTEL     OTELConfig
+	Debug    bool
 }
 
 // ServerConfig holds server configuration
@@ -71,6 +72,7 @@ func Load() (*Config, error) {
 			Endpoint:    getEnv("OTEL_EXPORTER_OTLP_ENDPOINT", "http://localhost:4318"),
 			ServiceName: getEnv("OTEL_SERVICE_NAME", "semcache-service"),
 		},
+		Debug: true,
 	}, nil
 }
 
@@ -115,4 +117,3 @@ func (c *DatabaseConfig) ConnectionString() string {
 		c.Host, c.Port, c.User, c.Password, c.Database, c.SSLMode,
 	)
 }
-

apps/semcache-service/internal/database/database.go

@@ -4,11 +4,11 @@ import (
 	"context"
 	"database/sql"
 	"fmt"
-	"log"
 	"time"
 
 	_ "github.com/lib/pq"
 	"github.com/nextinterfaces/semcache-service/internal/config"
+	"github.com/nextinterfaces/semcache-service/internal/logger"
 )
 
 // DB wraps the database connection
@@ -19,7 +19,7 @@ type DB struct {
 // New creates a new database connection
 func New(cfg *config.DatabaseConfig) (*DB, error) {
 	connStr := cfg.ConnectionString()
-	
+
 	db, err := sql.Open("postgres", connStr)
 	if err != nil {
 		return nil, fmt.Errorf("failed to open database: %w", err)
@@ -38,7 +38,7 @@ func New(cfg *config.DatabaseConfig) (*DB, error) {
 		return nil, fmt.Errorf("failed to ping database: %w", err)
 	}
 
-	log.Printf("Connected to database: %s:%d/%s", cfg.Host, cfg.Port, cfg.Database)
+	logger.Logger.Info(fmt.Sprintf("Connected to database: %s:%d/%s", cfg.Host, cfg.Port, cfg.Database))
 
 	return &DB{db}, nil
 }
@@ -66,7 +66,7 @@ func (db *DB) InitSchema(ctx context.Context) error {
 		return fmt.Errorf("failed to create schema: %w", err)
 	}
 
-	log.Println("Database schema initialized")
+	logger.Logger.Info(fmt.Sprintf("Database schema initialized"))
 	return nil
 }
 
@@ -79,4 +79,3 @@ func (db *DB) HealthCheck(ctx context.Context) error {
 func (db *DB) Close() error {
 	return db.DB.Close()
 }
-

apps/semcache-service/internal/logger/logger.go

@@ -0,0 +1,38 @@
+package logger
+
+import (
+	"go.uber.org/zap"
+	"go.uber.org/zap/zapcore"
+)
+
+var (
+	// Logger is the global logger instance
+	Logger *zap.Logger
+)
+
+// InitLogger initializes the global logger
+func InitLogger(debug bool) {
+	var config zap.Config
+	if debug {
+		config = zap.NewDevelopmentConfig()
+		config.EncoderConfig.EncodeLevel = zapcore.CapitalColorLevelEncoder
+	} else {
+		config = zap.NewProductionConfig()
+		config.EncoderConfig.MessageKey = "message"
+		config.EncoderConfig.LevelKey = "level"
+		config.EncoderConfig.EncodeLevel = zapcore.LowercaseLevelEncoder
+		config.EncoderConfig.TimeKey = "time"
+		config.EncoderConfig.EncodeTime = zapcore.ISO8601TimeEncoder
+	}
+
+	var err error
+	Logger, err = config.Build()
+	if err != nil {
+		panic("failed to initialize logger: " + err.Error())
+	}
+}
+
+// Sync flushes any buffered log entries
+func Sync() {
+	_ = Logger.Sync()
+}