nexarch/cmd/core/main.go

package main

import (
	"context"
	"log"
	"net/http"

	"gitea.perlbach24.de/scripte/nexarch/common/httpharden"
	"gitea.perlbach24.de/scripte/nexarch/internal/audit"
	"gitea.perlbach24.de/scripte/nexarch/internal/config"
	"gitea.perlbach24.de/scripte/nexarch/internal/db"
	"gitea.perlbach24.de/scripte/nexarch/internal/moduledirectory"
	"gitea.perlbach24.de/scripte/nexarch/internal/svcauth"
	"gitea.perlbach24.de/scripte/nexarch/internal/tenant"
	"gitea.perlbach24.de/scripte/nexarch/internal/tenantimportdir"
	"gitea.perlbach24.de/scripte/nexarch/internal/tenantimportdirapi"
	"gitea.perlbach24.de/scripte/nexarch/internal/user"
)

func main() {
	cfg, err := config.Load()
	if err != nil {
		log.Fatalf("config: %v", err)
	}

	adminToken := svcauth.MustToken("NEXARCH_CORE_ADMIN_TOKEN")

	ctx := context.Background()

	registryPool, err := db.Connect(ctx, cfg.RegistryDSN)
	if err != nil {
		log.Fatalf("registry db: %v", err)
	}
	defer registryPool.Close()

	adminPool, err := db.Connect(ctx, cfg.AdminDSN)
	if err != nil {
		log.Fatalf("admin db: %v", err)
	}
	defer adminPool.Close()

	// TEN-09: zentraler Audit-Log-Schreibpfad fuer Zugriffe auf die
	// Registry (Superadmin-Konten, Verbindungsinformationen).
	auditLog := audit.NewLog(registryPool)

	registry := tenant.NewRegistry(registryPool).WithAudit(auditLog)
	provisioner := tenant.NewProvisioner(adminPool, registry, cfg.TenantDSNTemplate, cfg.TenantRuntimeDSNTemplate)
	tenantHandler := tenant.NewHandler(provisioner)
	onboardingService := tenant.NewOnboardingService(provisioner, cfg.TenantSchemaPath)
	onboardingHandler := tenant.NewOnboardingHandler(onboardingService)

	// Superadmin-Konten leben mandantenuebergreifend in der Registry-DB.
	// Tenant-User-CRUD (user.TenantUserStore) braucht Connection-Routing pro
	// Mandant (TEN-06, noch nicht gebaut) und wird hier bewusst noch nicht
	// verdrahtet — Package ist bereits eigenstaendig nutzbar/testbar.
	superadmins := user.NewSuperadminStore(registryPool).WithAudit(auditLog)
	userHandler := user.NewHandler(nil, superadmins)

	// TEN-12: Abfrage der Import-Verzeichnis-Zuordnung fuer Module.
	importDirStore := tenantimportdir.NewStore(registryPool, registry, superadmins, auditLog)
	importDirHandler := tenantimportdirapi.NewHandler(importDirStore)

	// INT-14: Tenant-Bestaetigung fuer Module (DMS/Archive) ohne Admin-Auth.
	confirmHandler := tenant.NewConfirmHandler(registry)

	// API-22: Modul-Endpunkt-Discovery fuer Clients, die nur die
	// Server-Grundadresse kennen (z.B. INT-21 native App). Fehlt die
	// Konfiguration, liefert der Endpunkt bewusst eine leere Liste statt den
	// Dienststart zu verhindern.
	var modules []moduledirectory.Module
	if cfg.ModuleDirectoryPath != "" {
		modules, err = moduledirectory.LoadFile(cfg.ModuleDirectoryPath)
		if err != nil {
			log.Fatalf("modulverzeichnis: %v", err)
		}
	}

	mux := http.NewServeMux()
	mux.HandleFunc("/healthz", func(w http.ResponseWriter, r *http.Request) {
		w.WriteHeader(http.StatusOK)
	})
	registerInternalRoutes(mux, adminToken, tenantHandler.CreateTenant, onboardingHandler.Onboard, userHandler.CreateSuperadmin)
	registerImportDirectoryQueryRoutes(mux, adminToken, importDirHandler.ListForTenantHandler, importDirHandler.ResolveHandler)
	registerTenantConfirmRoute(mux, adminToken, confirmHandler.Confirm)
	registerModuleDirectoryRoute(mux, moduledirectory.Handler(modules))

	log.Printf("nexarch-core listening on %s", cfg.ListenAddr)
	if err := httpharden.ListenAndServe(cfg.ListenAddr, mux); err != nil {
		log.Fatalf("server: %v", err)
	}
}