Release v1.1.0

Author: novatechflow

.github/workflows/test.yml

@@ -1,6 +1,4 @@
 name: Tests
-permissions:
-  contents: read
 
 on:
   push:

backend/cmd/api/main.go

@@ -3,6 +3,7 @@ package main
 import (
 	"context"
 	"database/sql"
+	"flag"
 	"fmt"
 	"log"
 	"net/http"
@@ -19,17 +20,34 @@ import (
 	"github.com/lucendex/backend/internal/store"
 )
 
+var (
+	version     = "dev"
+	buildTime   = "unknown"
+	showVersion = flag.Bool("version", false, "Show version and exit")
+)
+
 func main() {
-	ctx := context.Background()
+	flag.Parse()
+
+	if *showVersion {
+		fmt.Printf("lucendex-api, build %s\n", buildTime)
+		return
+	}
 
-	dbHost := getEnv("DB_HOST", "localhost")
-	dbPort := getEnv("DB_PORT", "5432")
-	dbName := getEnv("DB_NAME", "lucendex")
-	dbUser := getEnv("DB_USER", "api_ro")
-	dbPassword := getEnv("DB_PASSWORD", "")
+	ctx := context.Background()
 
-	apiConnStr := fmt.Sprintf("host=%s port=%s dbname=%s user=%s password=%s sslmode=disable",
-		dbHost, dbPort, dbName, dbUser, dbPassword)
+	// Use DATABASE_URL if provided (for Docker), otherwise fall back to individual vars
+	apiConnStr := getEnv("DATABASE_URL", "")
+	if apiConnStr == "" {
+		dbHost := getEnv("DB_HOST", "localhost")
+		dbPort := getEnv("DB_PORT", "5432")
+		dbName := getEnv("DB_NAME", "lucendex")
+		dbUser := getEnv("DB_USER", "api_ro")
+		dbPassword := getEnv("DB_PASSWORD", "")
+		dbSSLMode := getEnv("DB_SSLMODE", "require")
+		apiConnStr = fmt.Sprintf("host=%s port=%s dbname=%s user=%s password=%s sslmode=%s",
+			dbHost, dbPort, dbName, dbUser, dbPassword, dbSSLMode)
+	}
 
 	db, err := sql.Open("postgres", apiConnStr)
 	if err != nil {
@@ -42,26 +60,26 @@ func main() {
 	}
 
 	kvStore := kv.NewMemoryStore()
+	internalToken := getEnv("INTERNAL_TOKEN", "")
 
-	routerConnStr := fmt.Sprintf("host=%s port=%s dbname=%s user=router_ro password=%s sslmode=disable",
-		dbHost, dbPort, dbName, getEnv("ROUTER_PASSWORD", ""))
-	routerStore, err := store.NewRouterStore(routerConnStr)
+	// Router uses same database for read-only access (reuse connection)
+	routerStore, err := store.NewRouterStore(apiConnStr)
 	if err != nil {
 		log.Fatalf("failed to create router store: %v", err)
 	}
 	defer routerStore.Close()
-	
+
 	validator := router.NewValidator()
 	pathfinder := router.NewPathfinder([]router.AMMPool{}, []router.Offer{})
 	breaker := router.NewCircuitBreaker(0.05)
 	quoteEngine := router.NewQuoteEngine(validator, pathfinder, breaker, kvStore, 20)
-	r := router.NewRouter(quoteEngine, routerStore)
+	r := router.NewRouter(quoteEngine, routerStore, kvStore)
 
 	apiStore := api.NewPostgresStore(db)
 
 	authMiddleware := api.NewAuthMiddleware(apiStore)
 	rateLimiter := api.NewRateLimiter(kvStore, apiStore)
-	handlers := api.NewHandlers(r, apiStore, kvStore)
+	handlers := api.NewHandlers(r, apiStore, kvStore, internalToken)
 
 	mux := http.NewServeMux()
 
@@ -72,6 +90,7 @@ func main() {
 	partnerMux.HandleFunc("/partner/v1/health", handlers.HealthHandler)
 
 	mux.Handle("/partner/", rateLimiter.Middleware(authMiddleware.Middleware(partnerMux)))
+	mux.HandleFunc("/internal/v1/ledger", handlers.LedgerUpdateHandler)
 
 	port := getEnv("API_PORT", "8080")
 	srv := &http.Server{