main.go

// main.go
package main

import (
	"flag"
	"log"
	"os"
	"strings"

	"maintainerd/onboarding"
)

func main() {
	// command‑line flags
	var (
		dbPath        = flag.String("db-path", "/data/onboarding.db", "Path to SQLite database file")
		dbDriver      = flag.String("db-driver", "sqlite", "Database driver (sqlite or postgres)")
		dbDSN         = flag.String("db-dsn", "", "Database DSN (required for postgres)")
		fossaEnvVar   = flag.String("fossa-token-env", "FOSSA_API_TOKEN", "Name of the env var holding the FOSSA API token")
		webhookSecret = flag.String("webhook-secret", "", "GitHub webhook secret (raw string)")
		addr          = flag.String("addr", "2525", "Address to listen on (e.g. :2525)")
		ghRep         = flag.String("repo", "sandbox", "Name of the repository (e.g. sandbox)")
		ghOrg         = flag.String("org", "cncf", "Name of the GitHub org (e.g. cncf)")
		ghToken       = flag.String("gh-api", "", "GitHub API token (raw string)")
	)
	flag.Parse()

	if *webhookSecret == "" {
		*webhookSecret = os.Getenv("GITHUB_WEBHOOK_SECRET")
	}
	if *webhookSecret == "" {
		log.Fatal("must provide --webhook-secret or set GITHUB_WEBHOOK_SECRET")
	}
	if *ghToken == "" {
		*ghToken = os.Getenv("GITHUB_API_TOKEN")
	}

	// Allow environment overrides for org/repo.
	// Two modes supported:
	// 1) If flags are left at their defaults (cncf/sandbox), use ORG/REPO env if set.
	// 2) If flags are provided as "$ENVNAME", resolve from that env variable.
	if *ghOrg == "cncf" {
		if v := os.Getenv("ORG"); v != "" {
			*ghOrg = v
		}
	} else if strings.HasPrefix(*ghOrg, "$") {
		if v := os.Getenv(strings.TrimPrefix(*ghOrg, "$")); v != "" {
			*ghOrg = v
		}
	}
	if *ghRep == "sandbox" {
		if v := os.Getenv("REPO"); v != "" {
			*ghRep = v
		}
	} else if strings.HasPrefix(*ghRep, "$") {
		if v := os.Getenv(strings.TrimPrefix(*ghRep, "$")); v != "" {
			*ghRep = v
		}
	}

	// instantiate and initialize listener
	listener := &onboarding.EventListener{
		Secret: []byte(*webhookSecret),
	}
	dsn := *dbPath
	if *dbDriver == "postgres" {
		if *dbDSN == "" {
			log.Fatal("must provide --db-dsn when --db-driver=postgres")
		}
		dsn = *dbDSN
	}
	if err := listener.Init(*dbDriver, dsn, *fossaEnvVar, *ghToken, *ghOrg, *ghRep); err != nil {
		log.Fatalf("maintainerd: ERR, failed to init EventListener: %v", err)
	}

	log.Printf("maintainerd: DBG, Starting onboarding server on %s…", *addr)
	if err := listener.Run(*addr); err != nil {
		log.Fatalf("maintainerd: ERR, server error: %v", err)
	}
}