package main import ( "crypto/rsa" "fmt" "net/url" "github.com/RichardKnop/machinery/v1" "github.com/RichardKnop/machinery/v1/config" "github.com/go-redis/redis" "github.com/spf13/cobra" "github.com/spf13/viper" activitypub "github.com/yukimochi/Activity-Relay/ActivityPub" keyloader "github.com/yukimochi/Activity-Relay/KeyLoader" state "github.com/yukimochi/Activity-Relay/State" ) // Actor : Relay's Actor var Actor activitypub.Actor var hostname *url.URL var hostkey *rsa.PrivateKey var macServer *machinery.Server var relayState state.RelayState func initConfig() { viper.SetConfigName("config") viper.AddConfigPath(".") err := viper.ReadInConfig() if err != nil { fmt.Println("Config file is not exists. Use environment variables.") viper.BindEnv("actor_pem") viper.BindEnv("relay_domain") viper.BindEnv("relay_bind") viper.BindEnv("relay_servicename") viper.BindEnv("redis_url") } else { Actor.Summary = viper.GetString("relay_summary") Actor.Icon = activitypub.Image{viper.GetString("relay_icon")} Actor.Image = activitypub.Image{viper.GetString("relay_image")} } Actor.Name = viper.GetString("relay_servicename") hostkey, err := keyloader.ReadPrivateKeyRSAfromPath(viper.GetString("actor_pem")) if err != nil { panic(err) } hostname, err = url.Parse("https://" + viper.GetString("relay_domain")) if err != nil { panic(err) } redOption, err := redis.ParseURL(viper.GetString("redis_url")) if err != nil { panic(err) } redClient := redis.NewClient(redOption) var macConfig = &config.Config{ Broker: viper.GetString("redis_url"), DefaultQueue: "relay", ResultBackend: viper.GetString("redis_url"), ResultsExpireIn: 5, } macServer, err = machinery.NewServer(macConfig) if err != nil { panic(err) } relayState = state.NewState(redClient) Actor.GenerateSelfKey(hostname, &hostkey.PublicKey) } func buildNewCmd() *cobra.Command { var app = &cobra.Command{} app.AddCommand(domainCmdInit()) app.AddCommand(followCmdInit()) app.AddCommand(configCmdInit()) return app } func main() { initConfig() var app = buildNewCmd() app.Execute() }