mirror of
https://github.com/elyby/chrly.git
synced 2024-12-23 21:50:03 +05:30
103 lines
2.5 KiB
Go
103 lines
2.5 KiB
Go
package bootstrap
|
|
|
|
import (
|
|
"net/url"
|
|
"os"
|
|
"time"
|
|
|
|
"github.com/getsentry/raven-go"
|
|
"github.com/mono83/slf"
|
|
"github.com/mono83/slf/rays"
|
|
"github.com/mono83/slf/recievers/sentry"
|
|
"github.com/mono83/slf/recievers/statsd"
|
|
"github.com/mono83/slf/recievers/writer"
|
|
"github.com/mono83/slf/wd"
|
|
"github.com/spf13/viper"
|
|
|
|
"github.com/elyby/chrly/dispatcher"
|
|
"github.com/elyby/chrly/http"
|
|
"github.com/elyby/chrly/mojangtextures"
|
|
"github.com/elyby/chrly/version"
|
|
)
|
|
|
|
func CreateLogger(sentryAddr string) (slf.Logger, error) {
|
|
wd.AddReceiver(writer.New(writer.Options{
|
|
Marker: false,
|
|
TimeFormat: "15:04:05.000",
|
|
}))
|
|
|
|
if sentryAddr != "" {
|
|
ravenClient, err := raven.New(sentryAddr)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
ravenClient.SetEnvironment("production")
|
|
ravenClient.SetDefaultLoggerName("sentry-watchdog-receiver")
|
|
programVersion := version.Version()
|
|
if programVersion != "" {
|
|
raven.SetRelease(programVersion)
|
|
}
|
|
|
|
sentryReceiver, err := sentry.NewReceiverWithCustomRaven(ravenClient, &sentry.Config{
|
|
MinLevel: "warn",
|
|
})
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
wd.AddReceiver(sentryReceiver)
|
|
}
|
|
|
|
return wd.New("", "").WithParams(rays.Host), nil
|
|
}
|
|
|
|
func CreateStatsReceiver(statsdAddr string) (slf.StatsReporter, error) {
|
|
hostname, _ := os.Hostname()
|
|
statsdReceiver, err := statsd.NewReceiver(statsd.Config{
|
|
Address: statsdAddr,
|
|
Prefix: "ely.skinsystem." + hostname + ".app.",
|
|
FlushEvery: 1,
|
|
})
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
wd.AddReceiver(statsdReceiver)
|
|
|
|
return wd.New("", "").WithParams(rays.Host), nil
|
|
}
|
|
|
|
func init() {
|
|
viper.SetDefault("queue.loop_delay", 2*time.Second+500*time.Millisecond)
|
|
viper.SetDefault("queue.batch_size", 10)
|
|
}
|
|
|
|
func CreateMojangUUIDsProvider(emitter http.Emitter) (mojangtextures.UUIDsProvider, error) {
|
|
var uuidsProvider mojangtextures.UUIDsProvider
|
|
preferredUuidsProvider := viper.GetString("mojang_textures.uuids_provider.driver")
|
|
if preferredUuidsProvider == "remote" {
|
|
remoteUrl, err := url.Parse(viper.GetString("mojang_textures.uuids_provider.url"))
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
uuidsProvider = &mojangtextures.RemoteApiUuidsProvider{
|
|
Emitter: emitter,
|
|
Url: *remoteUrl,
|
|
}
|
|
} else {
|
|
uuidsProvider = &mojangtextures.BatchUuidsProvider{
|
|
Emitter: emitter,
|
|
IterationDelay: viper.GetDuration("queue.loop_delay"),
|
|
IterationSize: viper.GetInt("queue.batch_size"),
|
|
}
|
|
}
|
|
|
|
return uuidsProvider, nil
|
|
}
|
|
|
|
func CreateEventDispatcher() dispatcher.EventDispatcher {
|
|
return dispatcher.New()
|
|
}
|