mirror of
https://github.com/lukaszraczylo/graphql-monitoring-proxy.git
synced 2026-06-05 23:03:48 +00:00
63 lines
2.0 KiB
Go
63 lines
2.0 KiB
Go
package main
|
|
|
|
import (
|
|
"strings"
|
|
|
|
"github.com/gookit/goutil/envutil"
|
|
graphql "github.com/lukaszraczylo/go-simple-graphql"
|
|
libpack_config "github.com/lukaszraczylo/graphql-monitoring-proxy/config"
|
|
libpack_logging "github.com/lukaszraczylo/graphql-monitoring-proxy/logging"
|
|
)
|
|
|
|
var cfg *config
|
|
|
|
func init() {
|
|
for _, query := range retrospection_queries {
|
|
retrospectionQuerySet[query] = struct{}{}
|
|
}
|
|
}
|
|
|
|
func parseConfig() {
|
|
libpack_config.PKG_NAME = "graphql_proxy"
|
|
var c config
|
|
c.Server.PortGraphQL = envutil.GetInt("PORT_GRAPHQL", 8080)
|
|
c.Server.PortMonitoring = envutil.GetInt("MONITORING_PORT", 9393)
|
|
c.Server.HostGraphQL = envutil.Getenv("HOST_GRAPHQL", "http://localhost/")
|
|
c.Client.JWTUserClaimPath = envutil.Getenv("JWT_USER_CLAIM_PATH", "")
|
|
c.Client.JWTRoleClaimPath = envutil.Getenv("JWT_ROLE_CLAIM_PATH", "")
|
|
c.Client.RoleFromHeader = envutil.Getenv("ROLE_FROM_HEADER", "")
|
|
c.Client.RoleRateLimit = envutil.GetBool("ROLE_RATE_LIMIT", false)
|
|
c.Cache.CacheEnable = envutil.GetBool("ENABLE_GLOBAL_CACHE", false)
|
|
c.Cache.CacheTTL = envutil.GetInt("CACHE_TTL", 60)
|
|
c.Security.BlockIntrospection = envutil.GetBool("BLOCK_SCHEMA_INTROSPECTION", false)
|
|
c.Security.IntrospectionAllowed = func() []string {
|
|
urls := envutil.Getenv("ALLOWED_INTROSPECTION", "")
|
|
if urls == "" {
|
|
return nil
|
|
}
|
|
return strings.Split(urls, ",")
|
|
}()
|
|
c.Logger = libpack_logging.NewLogger()
|
|
c.Client.GQLClient = graphql.NewConnection()
|
|
c.Client.GQLClient.SetEndpoint(c.Server.HostGraphQL)
|
|
c.Server.AccessLog = envutil.GetBool("ENABLE_ACCESS_LOG", false)
|
|
c.Server.ReadOnlyMode = envutil.GetBool("READ_ONLY_MODE", false)
|
|
c.Server.AllowURLs = func() []string {
|
|
urls := envutil.Getenv("ALLOWED_URLS", "")
|
|
if urls == "" {
|
|
return nil
|
|
}
|
|
return strings.Split(urls, ",")
|
|
}()
|
|
c.Client.FastProxyClient = createFasthttpClient()
|
|
cfg = &c
|
|
enableCache() // takes close to no resources, but can be used with dynamic query cache
|
|
loadRatelimitConfig()
|
|
}
|
|
|
|
func main() {
|
|
parseConfig()
|
|
StartMonitoringServer()
|
|
StartHTTPProxy()
|
|
}
|