Add globally defined HTTPS certs, fixed an ineffective assignment, isolated registering services into its own function
Signed-off-by: arzumify <jliwin98@danwin1210.de>
This commit is contained in:
parent
975b24a13f
commit
322e901d16
|
@ -12,13 +12,20 @@ global: {
|
||||||
serviceDirectory: "./services",
|
serviceDirectory: "./services",
|
||||||
# resourceDirectory defines the directory to look for resources in.
|
# resourceDirectory defines the directory to look for resources in.
|
||||||
resourceDirectory: "./resources",
|
resourceDirectory: "./resources",
|
||||||
# compression defines the compression settings on a global level - per-route settings override these.
|
# compression defines the compression settings on a global level - per-route settings override these. It is optional.
|
||||||
compression: {
|
compression: {
|
||||||
# algorithm defines the compression algorithm to use, possible values are "gzip", "brotli" and "zstd".
|
# algorithm defines the compression algorithm to use, possible values are "gzip", "brotli" and "zstd".
|
||||||
algorithm: "gzip",
|
algorithm: "gzip",
|
||||||
# level defines the compression level to use, possible values are 1-9 for gzip, 0-11 for brotli and 1-22 for zstd.
|
# level defines the compression level to use, possible values are 1-9 for gzip, 0-11 for brotli and 1-22 for zstd.
|
||||||
level: 5
|
level: 5
|
||||||
},
|
},
|
||||||
|
# https defines the HTTPS settings on a global level - per-route settings override these. It is optional.
|
||||||
|
https: {
|
||||||
|
# certificate defines the path to the certificate file (must be a wildcard in order to support multiple subdomains).
|
||||||
|
certificate: "./certs/localhost.crt",
|
||||||
|
# key defines the path to the key file (must be a wildcard in order to support multiple subdomains).
|
||||||
|
key: "./certs/localhost.key"
|
||||||
|
},
|
||||||
# logging defines the logging settings.
|
# logging defines the logging settings.
|
||||||
logging: {
|
logging: {
|
||||||
# enabled defines whether logging is enabled.
|
# enabled defines whether logging is enabled.
|
||||||
|
|
117
main.go
117
main.go
|
@ -45,6 +45,10 @@ type Config struct {
|
||||||
Algorithm string `yaml:"algorithm" validate:"omitempty,oneof=gzip brotli zstd"`
|
Algorithm string `yaml:"algorithm" validate:"omitempty,oneof=gzip brotli zstd"`
|
||||||
Level float64 `yaml:"level" validate:"omitempty,min=1,max=22"`
|
Level float64 `yaml:"level" validate:"omitempty,min=1,max=22"`
|
||||||
} `yaml:"compression"`
|
} `yaml:"compression"`
|
||||||
|
HTTPS struct {
|
||||||
|
CertificatePath string `yaml:"certificatePath" validate:"required"`
|
||||||
|
KeyPath string `yaml:"keyPath" validate:"required"`
|
||||||
|
}
|
||||||
Logging struct {
|
Logging struct {
|
||||||
Enabled bool `yaml:"enabled"`
|
Enabled bool `yaml:"enabled"`
|
||||||
File string `yaml:"file" validate:"required_if=Enabled true"`
|
File string `yaml:"file" validate:"required_if=Enabled true"`
|
||||||
|
@ -499,7 +503,11 @@ func loadTLSCertificate(certificatePath, keyPath string) (*tls.Certificate, erro
|
||||||
func getTLSCertificate(hello *tls.ClientHelloInfo) (*tls.Certificate, error) {
|
func getTLSCertificate(hello *tls.ClientHelloInfo) (*tls.Certificate, error) {
|
||||||
cert, ok := certificates[hello.ServerName]
|
cert, ok := certificates[hello.ServerName]
|
||||||
if !ok {
|
if !ok {
|
||||||
return nil, errors.New("no certificate found")
|
if config.Global.HTTPS.CertificatePath == "" || config.Global.HTTPS.KeyPath == "" {
|
||||||
|
return nil, errors.New("no certificate found")
|
||||||
|
} else {
|
||||||
|
return certificates["none"], nil
|
||||||
|
}
|
||||||
} else {
|
} else {
|
||||||
return cert, nil
|
return cert, nil
|
||||||
}
|
}
|
||||||
|
@ -971,6 +979,54 @@ func iterateThroughSubdomains(globalOutbox chan library.InterServiceMessage) {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func registerServices() (err error) {
|
||||||
|
err = filepath.Walk(config.Global.ServiceDirectory, func(path string, info os.FileInfo, err error) error {
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
if info.IsDir() || filepath.Ext(path) != ".fgs" {
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
// Open the service
|
||||||
|
service, err := plugin.Open(path)
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
// Load the service information
|
||||||
|
serviceInformation, err := service.Lookup("ServiceInformation")
|
||||||
|
if err != nil {
|
||||||
|
return errors.New("service lacks necessary information")
|
||||||
|
}
|
||||||
|
|
||||||
|
// Load the main function
|
||||||
|
mainFunc, err := service.Lookup("Main")
|
||||||
|
if err != nil {
|
||||||
|
return errors.New("service lacks necessary main function")
|
||||||
|
}
|
||||||
|
|
||||||
|
// Register the service
|
||||||
|
var inbox = make(chan library.InterServiceMessage, 1)
|
||||||
|
lock.Lock()
|
||||||
|
registeredServices[strings.ToLower(serviceInformation.(*library.Service).Name)] = Service{
|
||||||
|
ServiceID: serviceInformation.(*library.Service).ServiceID,
|
||||||
|
Inbox: inbox,
|
||||||
|
ServiceMetadata: *serviceInformation.(*library.Service),
|
||||||
|
ServiceMainFunc: mainFunc.(func(library.ServiceInitializationInformation)),
|
||||||
|
}
|
||||||
|
lock.Unlock()
|
||||||
|
|
||||||
|
// Log the service registration
|
||||||
|
slog.Info("Service " + strings.ToLower(serviceInformation.(*library.Service).Name) + " registered with ID " + serviceInformation.(*library.Service).ServiceID.String())
|
||||||
|
|
||||||
|
return nil
|
||||||
|
})
|
||||||
|
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
func initializeService(service Service, globalOutbox chan library.InterServiceMessage, subdomainRouter *chi.Mux) {
|
func initializeService(service Service, globalOutbox chan library.InterServiceMessage, subdomainRouter *chi.Mux) {
|
||||||
// Get the plugin from the map
|
// Get the plugin from the map
|
||||||
slog.Info("Activating service " + strings.ToLower(service.ServiceMetadata.Name) + " with ID " + service.ServiceMetadata.ServiceID.String())
|
slog.Info("Activating service " + strings.ToLower(service.ServiceMetadata.Name) + " with ID " + service.ServiceMetadata.ServiceID.String())
|
||||||
|
@ -1033,50 +1089,23 @@ func main() {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Check if the root TLS certificate exists
|
||||||
|
if config.Global.HTTPS.CertificatePath != "" && config.Global.HTTPS.KeyPath != "" {
|
||||||
|
certificate, err := loadTLSCertificate(config.Global.HTTPS.CertificatePath, config.Global.HTTPS.KeyPath)
|
||||||
|
if err != nil {
|
||||||
|
slog.Error("Error loading TLS certificate: " + err.Error())
|
||||||
|
os.Exit(1)
|
||||||
|
}
|
||||||
|
|
||||||
|
certificates["none"] = certificate
|
||||||
|
}
|
||||||
|
|
||||||
// Walk through the service directory and load the plugins
|
// Walk through the service directory and load the plugins
|
||||||
err := filepath.Walk(config.Global.ServiceDirectory, func(path string, info os.FileInfo, err error) error {
|
err := registerServices()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
slog.Error("Error registering services: " + err.Error())
|
||||||
}
|
os.Exit(1)
|
||||||
|
}
|
||||||
if info.IsDir() || filepath.Ext(path) != ".fgs" {
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
// Open the service
|
|
||||||
service, err := plugin.Open(path)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
|
|
||||||
// Load the service information
|
|
||||||
serviceInformation, err := service.Lookup("ServiceInformation")
|
|
||||||
if err != nil {
|
|
||||||
return errors.New("service lacks necessary information")
|
|
||||||
}
|
|
||||||
|
|
||||||
// Load the main function
|
|
||||||
mainFunc, err := service.Lookup("Main")
|
|
||||||
if err != nil {
|
|
||||||
return errors.New("service lacks necessary main function")
|
|
||||||
}
|
|
||||||
|
|
||||||
// Register the service
|
|
||||||
var inbox = make(chan library.InterServiceMessage, 1)
|
|
||||||
lock.Lock()
|
|
||||||
registeredServices[strings.ToLower(serviceInformation.(*library.Service).Name)] = Service{
|
|
||||||
ServiceID: serviceInformation.(*library.Service).ServiceID,
|
|
||||||
Inbox: inbox,
|
|
||||||
ServiceMetadata: *serviceInformation.(*library.Service),
|
|
||||||
ServiceMainFunc: mainFunc.(func(library.ServiceInitializationInformation)),
|
|
||||||
}
|
|
||||||
lock.Unlock()
|
|
||||||
|
|
||||||
// Log the service registration
|
|
||||||
slog.Info("Service " + strings.ToLower(serviceInformation.(*library.Service).Name) + " registered with ID " + serviceInformation.(*library.Service).ServiceID.String())
|
|
||||||
|
|
||||||
return nil
|
|
||||||
})
|
|
||||||
|
|
||||||
var globalOutbox = make(chan library.InterServiceMessage, 1)
|
var globalOutbox = make(chan library.InterServiceMessage, 1)
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue