feat(gateway): add new gateway extension with access logging, authentication, caching, and circuit breaker

- Introduced a comprehensive gateway extension that includes:
  - Access logging for structured request logging.
  - Authentication mechanisms with support for multiple providers.
  - Caching capabilities for HTTP responses with configurable policies.
  - Circuit breaker implementation for resilience against failures.
- Updated configuration structure to accommodate new gateway settings.
- Enhanced existing files and examples to demonstrate the new features.

This update significantly enhances the functionality and robustness of the gateway component.

Author: juicycleff

.github/workflows/release.yml

@@ -26,6 +26,7 @@ on:
           - discovery
           - events
           - features
+          - gateway
           - graphql
           - grpc
           - hls
@@ -227,7 +228,7 @@ jobs:
         if: github.event_name == 'workflow_dispatch' && steps.resolve.outputs.is_all == 'true' && steps.resolve.outputs.dry_run == 'false'
         run: |
           VERSION="${{ steps.resolve.outputs.version }}"
-          EXTENSIONS=(ai auth cache consensus cron database discovery events features graphql grpc hls kafka mcp mqtt orpc queue search security storage streaming webrtc)
+          EXTENSIONS=(ai auth cache consensus cron database discovery events features gateway graphql grpc hls kafka mcp mqtt orpc queue search security storage streaming webrtc)
 
           for ext in "${EXTENSIONS[@]}"; do
             EXT_TAG="extensions/${ext}/v${VERSION}"

.release-please-manifest.json

@@ -9,6 +9,7 @@
   "extensions/discovery": "0.1.0",
   "extensions/events": "0.1.0",
   "extensions/features": "0.1.0",
+  "extensions/gateway": "0.1.0",
   "extensions/graphql": "0.1.0",
   "extensions/grpc": "0.1.0",
   "extensions/hls": "0.1.0",

app_impl.go

@@ -18,6 +18,7 @@ import (
 	healthinternal "github.com/xraph/forge/internal/health"
 	"github.com/xraph/forge/internal/logger"
 	metricsinternal "github.com/xraph/forge/internal/metrics"
+	internalrouter "github.com/xraph/forge/internal/router"
 	"github.com/xraph/forge/internal/shared"
 	"github.com/xraph/vessel"
 	"gopkg.in/yaml.v3"
@@ -253,6 +254,11 @@ func newApp(config AppConfig) *app {
 		routerOpts = append(routerOpts, WithHealth(config.HealthConfig))
 	}
 
+	// Add HTTP address for automatic localhost server in OpenAPI
+	if config.HTTPAddress != "" {
+		routerOpts = append(routerOpts, internalrouter.WithHTTPAddress(config.HTTPAddress))
+	}
+
 	router := NewRouter(routerOpts...)
 
 	// Register core services with DI - Both key-based (legacy) and type-based (new pattern)
@@ -1337,20 +1343,23 @@ func loadForgeYAMLConfig(config AppConfig, logger Logger) AppConfig {
 	}
 
 	var forgeConfigPath string
+
 	maxDepth := 5
 
 	// Search up the directory tree
-	for i := 0; i < maxDepth; i++ {
+	for range maxDepth {
 		yamlPath := filepath.Join(dir, ".forge.yaml")
 		ymlPath := filepath.Join(dir, ".forge.yml")
 
 		if _, err := os.Stat(yamlPath); err == nil {
 			forgeConfigPath = yamlPath
+
 			break
 		}
 
 		if _, err := os.Stat(ymlPath); err == nil {
 			forgeConfigPath = ymlPath
+
 			break
 		}
 
@@ -1360,6 +1369,7 @@ func loadForgeYAMLConfig(config AppConfig, logger Logger) AppConfig {
 			// Reached root
 			break
 		}
+
 		dir = parent
 	}
 
@@ -1374,6 +1384,7 @@ func loadForgeYAMLConfig(config AppConfig, logger Logger) AppConfig {
 		if logger != nil {
 			logger.Debug("failed to read .forge.yaml", F("path", forgeConfigPath), F("error", err.Error()))
 		}
+
 		return config
 	}
 
@@ -1382,6 +1393,7 @@ func loadForgeYAMLConfig(config AppConfig, logger Logger) AppConfig {
 		if logger != nil {
 			logger.Debug("failed to parse .forge.yaml", F("path", forgeConfigPath), F("error", err.Error()))
 		}
+
 		return config
 	}
 

cmd/forge/plugins/generate.go

@@ -306,9 +306,7 @@ func main() {
 				Title:       "File Upload API",
 				Version:     "1.0.0",
 				Description: "Production-ready file upload API with validation, multipart forms, and security best practices",
-				Servers: []forge.OpenAPIServer{
-					{URL: "http://localhost:8085", Description: "Development server"},
-				},
+				// Note: Localhost server is automatically added based on HTTPAddress
 			}),
 		},
 	})

examples/file_upload/main.go

@@ -75,11 +75,8 @@ func main() {
 				Version:     "1.0.0",
 
 				// Server configuration
+				// Note: Localhost server is automatically added based on HTTPAddress
 				Servers: []forge.OpenAPIServer{
-					{
-						URL:         "http://localhost:8080",
-						Description: "Development server",
-					},
 					{
 						URL:         "https://api.example.com",
 						Description: "Production server",

examples/openapi-demo/main.go

@@ -69,11 +69,8 @@ func main() {
 				Title:       "User Management API",
 				Description: "A comprehensive API demonstrating OpenAPI schema generation with Forge",
 				Version:     "1.0.0",
+				// Note: Localhost server is automatically added based on HTTPAddress
 				Servers: []forge.OpenAPIServer{
-					{
-						URL:         "http://localhost:8084",
-						Description: "Development server",
-					},
 					{
 						URL:         "https://api.example.com",
 						Description: "Production server",

examples/openapi_complete/main.go

@@ -188,8 +188,8 @@ func main() {
 				Title:       "Unified Request Schema API",
 				Description: "Demonstrates unified request schema with path, query, header, and body parameters in a single struct",
 				Version:     "2.0.0",
+				// Note: Localhost server is automatically added based on HTTPAddress
 				Servers: []forge.OpenAPIServer{
-					{URL: "http://localhost:8085", Description: "Development server"},
 					{URL: "https://api.example.com", Description: "Production server"},
 				},
 				UIPath:      "/swagger",

examples/openapi_unified/main.go

@@ -88,12 +88,7 @@ func main() {
 				Title:       "Optional Tag Demo API",
 				Description: "API demonstrating the optional tag for query parameters",
 				Version:     "1.0.0",
-				Servers: []forge.OpenAPIServer{
-					{
-						URL:         "http://localhost:8080",
-						Description: "Development server",
-					},
-				},
+				// Note: Localhost server is automatically added based on HTTPAddress
 			}),
 		},
 	})

examples/optional_tag/main.go

@@ -21,7 +21,6 @@ type Extension struct {
 	*forge.BaseExtension
 
 	config Config
-	// No longer storing manager - Vessel manages it
 }
 
 // NewExtension creates a new database extension with variadic options.
@@ -80,7 +79,6 @@ func (e *Extension) Register(app forge.App) error {
 
 // loadConfiguration loads configuration from YAML files or programmatic sources.
 func (e *Extension) loadConfiguration() error {
-	fmt.Println("database: loading configuration", e.config.Databases)
 	programmaticConfig := e.config
 	hasProgrammaticDatabases := e.hasProgrammaticDatabases(programmaticConfig)
 
@@ -129,7 +127,6 @@ func (e *Extension) tryLoadFromConfigFile() (Config, bool) {
 	// Try "extensions.database" first (namespaced pattern)
 	if cm.IsSet("extensions.database") {
 		if err := cm.Bind("extensions.database", &finalConfig); err == nil {
-			fmt.Println("database: loaded from config file", finalConfig.Databases[0].DSN)
 			e.Logger().Debug("database: loaded from config file",
 				forge.F("key", "extensions.database"),
 				forge.F("databases", len(finalConfig.Databases)),
@@ -143,7 +140,6 @@ func (e *Extension) tryLoadFromConfigFile() (Config, bool) {
 	// Try legacy "database" key if not loaded yet
 	if cm.IsSet("database") {
 		if err := cm.Bind("database", &finalConfig); err == nil {
-			fmt.Println("database: loaded from config file 2", finalConfig.Databases[0].DSN)
 			e.Logger().Debug("database: loaded from config file",
 				forge.F("key", "database"),
 				forge.F("databases", len(finalConfig.Databases)),
@@ -179,15 +175,13 @@ func (e *Extension) mergeConfigurations(yamlConfig, programmaticConfig Config, h
 	// Build a set of existing database names from YAML config
 	existingNames := make(map[string]bool)
 	for _, db := range yamlConfig.Databases {
-		fmt.Println("database: merging database", db.Name, db.DSN)
 		existingNames[db.Name] = true
 	}
 
 	// Only append programmatic databases that don't already exist
 	// YAML config takes precedence over programmatic config
 	skipped := 0
 	for _, db := range programmaticConfig.Databases {
-		fmt.Println("database: merging database 2", db.Name, db.DSN)
 		if existingNames[db.Name] {
 			e.Logger().Warn("database: skipping duplicate programmatic database (YAML config takes precedence)",
 				forge.F("name", db.Name))
@@ -244,7 +238,6 @@ func (e *Extension) registerDatabaseManager() error {
 
 // createDatabase creates a database instance based on its type.
 func (e *Extension) createDatabase(config DatabaseConfig, logger forge.Logger, metrics forge.Metrics) (Database, error) {
-	fmt.Println("database: creating database", config.Name, config.DSN)
 	switch config.Type {
 	case TypePostgres, TypeMySQL, TypeSQLite:
 		return NewSQLDatabase(config, logger, metrics)
@@ -300,7 +293,6 @@ func (e *Extension) registerDefaultDatabase(defaultName string) error {
 // findDatabaseConfig finds a database configuration by name.
 func (e *Extension) findDatabaseConfig(name string) *DatabaseConfig {
 	for i := range e.config.Databases {
-		fmt.Println("database: finding database config", name, e.config.Databases[i].DSN)
 		if e.config.Databases[i].Name == name {
 			return &e.config.Databases[i]
 		}