mirror of
https://github.com/PeernetOfficial/Cmd.git
synced 2026-07-17 02:47:52 +01:00
78 lines
3.1 KiB
Go
78 lines
3.1 KiB
Go
/*
|
|
File Name: Main.go
|
|
Copyright: 2021 Peernet Foundation s.r.o.
|
|
Author: Peter Kleissner
|
|
*/
|
|
|
|
package main
|
|
|
|
import (
|
|
"fmt"
|
|
"os"
|
|
|
|
"github.com/PeernetOfficial/core"
|
|
"github.com/google/uuid"
|
|
)
|
|
|
|
const configFile = "Config.yaml"
|
|
const appName = "Peernet Cmd"
|
|
|
|
var config struct {
|
|
// Warning: These settings are currently overwritten (deleted) when the config file is updated by core.
|
|
// In the future the core package will consider custom config fields.
|
|
|
|
// API settings
|
|
APIListen []string `yaml:"APIListen"` // WebListen is in format IP:Port and declares where the web-interface should listen on. IP can also be ommitted to listen on any.
|
|
APIUseSSL bool `yaml:"APIUseSSL"` // Enables SSL.
|
|
APICertificateFile string `yaml:"APICertificateFile"` // This is the certificate received from the CA. This can also include the intermediate certificate from the CA.
|
|
APICertificateKey string `yaml:"APICertificateKey"` // This is the private key.
|
|
APITimeoutRead string `yaml:"APITimeoutRead"` // The maximum duration for reading the entire request, including the body.
|
|
APITimeoutWrite string `yaml:"APITimeoutWrite"` // The maximum duration before timing out writes of the response. This includes processing time and is therefore the max time any HTTP function may take.
|
|
APIKey uuid.UUID `yaml:"APIKey"` // API key. Empty UUID 00000000-0000-0000-0000-000000000000 = not used.
|
|
DebugAPI bool `yaml:"DebugAPI"` // Enables the debug API which allows profiling. Do not enable in production. Only available if compiled with debug tag.
|
|
}
|
|
|
|
func main() {
|
|
userAgent := appName + "/" + core.Version
|
|
|
|
filters := &core.Filters{
|
|
DHTSearchStatus: filterSearchStatus,
|
|
IncomingRequest: filterIncomingRequest,
|
|
MessageIn: filterMessageIn,
|
|
MessageOutAnnouncement: filterMessageOutAnnouncement,
|
|
MessageOutResponse: filterMessageOutResponse,
|
|
MessageOutTraverse: filterMessageOutTraverse,
|
|
MessageOutPing: filterMessageOutPing,
|
|
MessageOutPong: filterMessageOutPong,
|
|
}
|
|
|
|
backend, status, err := core.Init(userAgent, configFile, filters, &config)
|
|
|
|
if status != core.ExitSuccess {
|
|
switch status {
|
|
case core.ExitErrorConfigAccess:
|
|
fmt.Printf("Unknown error accessing config file '%s': %s\n", configFile, err.Error())
|
|
case core.ExitErrorConfigRead:
|
|
fmt.Printf("Error reading config file '%s': %s\n", configFile, err.Error())
|
|
case core.ExitErrorConfigParse:
|
|
fmt.Printf("Error parsing config file '%s' (make sure it is valid YAML format): %s\n", configFile, err.Error())
|
|
case core.ExitErrorLogInit:
|
|
fmt.Printf("Error opening log file '%s': %s\n", backend.Config.LogFile, err.Error())
|
|
default:
|
|
fmt.Printf("Unknown error %d initializing backend: %s\n", status, err.Error())
|
|
}
|
|
os.Exit(status)
|
|
}
|
|
|
|
backend.Stdout.Subscribe(os.Stdout)
|
|
|
|
apiListen, apiKey, watchPID := parseCmdParams()
|
|
startAPI(backend, apiListen, apiKey)
|
|
|
|
go processExitMonitor(backend, watchPID)
|
|
|
|
backend.Connect()
|
|
|
|
userCommands(backend, os.Stdin, os.Stdout, nil)
|
|
}
|