package main import ( "crypto/rand" "fmt" "os" "strconv" "strings" pb "github.com/PretendoNetwork/grpc-go/account" "github.com/PretendoNetwork/nex-go/v2" "github.com/PretendoNetwork/nex-go/v2/types" "github.com/PretendoNetwork/pikmin-3/database" "github.com/PretendoNetwork/pikmin-3/globals" "github.com/PretendoNetwork/plogger-go" "github.com/joho/godotenv" "google.golang.org/grpc" "google.golang.org/grpc/credentials/insecure" "google.golang.org/grpc/metadata" ) func init() { globals.Logger = plogger.NewLogger() var err error err = godotenv.Load() if err != nil { globals.Logger.Warning("Error loading .env file") } postgresURI := os.Getenv("PN_PIKMIN3_POSTGRES_URI") authenticationServerPort := os.Getenv("PN_PIKMIN3_AUTHENTICATION_SERVER_PORT") secureServerHost := os.Getenv("PN_PIKMIN3_SECURE_SERVER_HOST") secureServerPort := os.Getenv("PN_PIKMIN3_SECURE_SERVER_PORT") accountGRPCHost := os.Getenv("PN_PIKMIN3_ACCOUNT_GRPC_HOST") accountGRPCPort := os.Getenv("PN_PIKMIN3_ACCOUNT_GRPC_PORT") accountGRPCAPIKey := os.Getenv("PN_PIKMIN3_ACCOUNT_GRPC_API_KEY") if strings.TrimSpace(postgresURI) == "" { globals.Logger.Error("PN_PIKMIN3_POSTGRES_URI environment variable not set") os.Exit(0) } kerberosPassword := make([]byte, 0x10) _, err = rand.Read(kerberosPassword) if err != nil { globals.Logger.Error("Error generating Kerberos password") os.Exit(0) } globals.KerberosPassword = string(kerberosPassword) globals.AuthenticationServerAccount = nex.NewAccount(types.NewPID(1), "Quazal Authentication", globals.KerberosPassword) globals.SecureServerAccount = nex.NewAccount(types.NewPID(2), "Quazal Rendez-Vous", globals.KerberosPassword) if strings.TrimSpace(authenticationServerPort) == "" { globals.Logger.Error("PN_PIKMIN3_AUTHENTICATION_SERVER_PORT environment variable not set") os.Exit(0) } if port, err := strconv.Atoi(authenticationServerPort); err != nil { globals.Logger.Errorf("PN_PIKMIN3_AUTHENTICATION_SERVER_PORT is not a valid port. Expected 0-65535, got %s", authenticationServerPort) os.Exit(0) } else if port < 0 || port > 65535 { globals.Logger.Errorf("PN_PIKMIN3_AUTHENTICATION_SERVER_PORT is not a valid port. Expected 0-65535, got %s", authenticationServerPort) os.Exit(0) } if strings.TrimSpace(secureServerHost) == "" { globals.Logger.Error("PN_PIKMIN3_SECURE_SERVER_HOST environment variable not set") os.Exit(0) } if strings.TrimSpace(secureServerPort) == "" { globals.Logger.Error("PN_PIKMIN3_SECURE_SERVER_PORT environment variable not set") os.Exit(0) } if port, err := strconv.Atoi(secureServerPort); err != nil { globals.Logger.Errorf("PN_PIKMIN3_SECURE_SERVER_PORT is not a valid port. Expected 0-65535, got %s", secureServerPort) os.Exit(0) } else if port < 0 || port > 65535 { globals.Logger.Errorf("PN_PIKMIN3_SECURE_SERVER_PORT is not a valid port. Expected 0-65535, got %s", secureServerPort) os.Exit(0) } if strings.TrimSpace(accountGRPCHost) == "" { globals.Logger.Error("PN_PIKMIN3_ACCOUNT_GRPC_HOST environment variable not set") os.Exit(0) } if strings.TrimSpace(accountGRPCPort) == "" { globals.Logger.Error("PN_PIKMIN3_ACCOUNT_GRPC_PORT environment variable not set") os.Exit(0) } if port, err := strconv.Atoi(accountGRPCPort); err != nil { globals.Logger.Errorf("PN_PIKMIN3_ACCOUNT_GRPC_PORT is not a valid port. Expected 0-65535, got %s", accountGRPCPort) os.Exit(0) } else if port < 0 || port > 65535 { globals.Logger.Errorf("PN_PIKMIN3_ACCOUNT_GRPC_PORT is not a valid port. Expected 0-65535, got %s", accountGRPCPort) os.Exit(0) } if strings.TrimSpace(accountGRPCAPIKey) == "" { globals.Logger.Warning("Insecure gRPC server detected. PN_PIKMIN3_ACCOUNT_GRPC_API_KEY environment variable not set") } globals.GRPCAccountClientConnection, err = grpc.Dial(fmt.Sprintf("%s:%s", accountGRPCHost, accountGRPCPort), grpc.WithTransportCredentials(insecure.NewCredentials())) if err != nil { globals.Logger.Criticalf("Failed to connect to account gRPC server: %v", err) os.Exit(0) } globals.GRPCAccountClient = pb.NewAccountClient(globals.GRPCAccountClientConnection) globals.GRPCAccountCommonMetadata = metadata.Pairs( "X-API-Key", accountGRPCAPIKey, ) database.ConnectPostgres() }