122 lines
3.5 KiB
Go
122 lines
3.5 KiB
Go
package models
|
|
|
|
import (
|
|
"crypto/rsa"
|
|
"errors"
|
|
"fmt"
|
|
"net/url"
|
|
"os"
|
|
|
|
"github.com/RichardKnop/machinery/v1"
|
|
"github.com/RichardKnop/machinery/v1/config"
|
|
"github.com/go-redis/redis"
|
|
"github.com/spf13/viper"
|
|
)
|
|
|
|
// RelayConfig contains valid configuration.
|
|
type RelayConfig struct {
|
|
actorKey *rsa.PrivateKey
|
|
domain *url.URL
|
|
redisClient *redis.Client
|
|
redisURL string
|
|
serverBind string
|
|
serviceName string
|
|
serviceSummary string
|
|
serviceIconURL *url.URL
|
|
serviceImageURL *url.URL
|
|
}
|
|
|
|
// NewRelayConfig create valid RelayConfig from viper configuration. If invalid configuration detected, return error.
|
|
func NewRelayConfig() (*RelayConfig, error) {
|
|
domain, err := url.ParseRequestURI("https://" + viper.GetString("RELAY_DOMAIN"))
|
|
if err != nil {
|
|
return nil, errors.New("RELAY_DOMAIN: " + err.Error())
|
|
}
|
|
|
|
iconURL, err := url.ParseRequestURI(viper.GetString("RELAY_ICON"))
|
|
if err != nil {
|
|
fmt.Fprintln(os.Stderr, "RELAY_ICON IS INVALID OR EMPTY. THIS COLUMN IS DISABLED.")
|
|
iconURL = nil
|
|
}
|
|
|
|
imageURL, err := url.ParseRequestURI(viper.GetString("RELAY_IMAGE"))
|
|
if err != nil {
|
|
fmt.Fprintln(os.Stderr, "RELAY_IMAGE IS INVALID OR EMPTY. THIS COLUMN IS DISABLED.")
|
|
imageURL = nil
|
|
}
|
|
|
|
privateKey, err := readPrivateKeyRSA(viper.GetString("ACTOR_PEM"))
|
|
if err != nil {
|
|
return nil, errors.New("ACTOR_PEM: " + err.Error())
|
|
}
|
|
|
|
redisURL := viper.GetString("REDIS_URL")
|
|
redisOption, err := redis.ParseURL(redisURL)
|
|
if err != nil {
|
|
return nil, errors.New("REDIS_URL: " + err.Error())
|
|
}
|
|
redisClient := redis.NewClient(redisOption)
|
|
err = redisClient.Ping().Err()
|
|
if err != nil {
|
|
return nil, errors.New("Redis Connection Test: " + err.Error())
|
|
}
|
|
|
|
serverBind := viper.GetString("RELAY_BIND")
|
|
|
|
return &RelayConfig{
|
|
actorKey: privateKey,
|
|
domain: domain,
|
|
redisClient: redisClient,
|
|
redisURL: redisURL,
|
|
serverBind: serverBind,
|
|
serviceName: viper.GetString("RELAY_SERVICENAME"),
|
|
serviceSummary: viper.GetString("RELAY_SUMMARY"),
|
|
serviceIconURL: iconURL,
|
|
serviceImageURL: imageURL,
|
|
}, nil
|
|
}
|
|
|
|
// ServerBind is API Server's bind interface definition.
|
|
func (relayConfig *RelayConfig) ServerBind() string {
|
|
return relayConfig.serverBind
|
|
}
|
|
|
|
// ServerHostname is API Server's hostname definition.
|
|
func (relayConfig *RelayConfig) ServerHostname() *url.URL {
|
|
return relayConfig.domain
|
|
}
|
|
|
|
// ServerHostname is API Server's hostname definition.
|
|
func (relayConfig *RelayConfig) ServerServicename() string {
|
|
return relayConfig.serviceName
|
|
}
|
|
|
|
// CreateRedisClient is create new redis client from RelayConfig.
|
|
func (relayConfig *RelayConfig) RedisClient() *redis.Client {
|
|
return relayConfig.redisClient
|
|
}
|
|
|
|
// DumpWelcomeMessage provide build and config information string.
|
|
func (relayConfig *RelayConfig) DumpWelcomeMessage(moduleName string, version string) string {
|
|
return fmt.Sprintf(`Welcome to YUKIMOCHI Activity-Relay %s - %s
|
|
- Configuration
|
|
RELAY NAME : %s
|
|
RELAY DOMAIN : %s
|
|
REDIS URL : %s
|
|
BIND ADDRESS : %s
|
|
`, version, moduleName, relayConfig.serviceName, relayConfig.domain.Host, relayConfig.redisURL, relayConfig.serverBind)
|
|
}
|
|
|
|
// NewMachineryServer create Redis backed Machinery Server from RelayConfig.
|
|
func NewMachineryServer(globalConfig *RelayConfig) (*machinery.Server, error) {
|
|
cnf := &config.Config{
|
|
Broker: globalConfig.redisURL,
|
|
DefaultQueue: "relay",
|
|
ResultBackend: globalConfig.redisURL,
|
|
ResultsExpireIn: 1,
|
|
}
|
|
newServer, err := machinery.NewServer(cnf)
|
|
|
|
return newServer, err
|
|
}
|