mirror of
https://github.com/lukaszraczylo/graphql-monitoring-proxy.git
synced 2026-10-21 06:37:21 +00:00
Move location of the global proxy client from the per-req to main.
There's no need to re-create it every single time.
This commit is contained in:
@@ -4,6 +4,7 @@ import (
|
|||||||
"os"
|
"os"
|
||||||
"strings"
|
"strings"
|
||||||
|
|
||||||
|
"github.com/gofiber/fiber/v2/middleware/proxy"
|
||||||
"github.com/gookit/goutil/envutil"
|
"github.com/gookit/goutil/envutil"
|
||||||
graphql "github.com/lukaszraczylo/go-simple-graphql"
|
graphql "github.com/lukaszraczylo/go-simple-graphql"
|
||||||
libpack_config "github.com/lukaszraczylo/graphql-monitoring-proxy/config"
|
libpack_config "github.com/lukaszraczylo/graphql-monitoring-proxy/config"
|
||||||
@@ -66,6 +67,7 @@ func parseConfig() {
|
|||||||
}()
|
}()
|
||||||
c.Client.ClientTimeout = getDetailsFromEnv("PROXIED_CLIENT_TIMEOUT", 120)
|
c.Client.ClientTimeout = getDetailsFromEnv("PROXIED_CLIENT_TIMEOUT", 120)
|
||||||
c.Client.FastProxyClient = createFasthttpClient(c.Client.ClientTimeout)
|
c.Client.FastProxyClient = createFasthttpClient(c.Client.ClientTimeout)
|
||||||
|
proxy.WithClient(c.Client.FastProxyClient) // setting the global proxy client here instead of per request
|
||||||
c.Server.EnableApi = getDetailsFromEnv("ENABLE_API", false)
|
c.Server.EnableApi = getDetailsFromEnv("ENABLE_API", false)
|
||||||
c.Server.ApiPort = getDetailsFromEnv("API_PORT", 9090)
|
c.Server.ApiPort = getDetailsFromEnv("API_PORT", 9090)
|
||||||
c.Api.BannedUsersFile = getDetailsFromEnv("BANNED_USERS_FILE", "/go/src/app/banned_users.json")
|
c.Api.BannedUsersFile = getDetailsFromEnv("BANNED_USERS_FILE", "/go/src/app/banned_users.json")
|
||||||
|
|||||||
@@ -39,8 +39,6 @@ func proxyTheRequest(c *fiber.Ctx) error {
|
|||||||
c.Request().Header.Add(fiber.HeaderXForwardedFor, string(c.Request().Header.Peek("X-Forwarded-For")))
|
c.Request().Header.Add(fiber.HeaderXForwardedFor, string(c.Request().Header.Peek("X-Forwarded-For")))
|
||||||
c.Request().Header.Del(fiber.HeaderAcceptEncoding)
|
c.Request().Header.Del(fiber.HeaderAcceptEncoding)
|
||||||
|
|
||||||
proxy.WithClient(cfg.Client.FastProxyClient)
|
|
||||||
|
|
||||||
cfg.Logger.Debug("Proxying the request", map[string]interface{}{"path": c.Path(), "body": string(c.Request().Body()), "headers": c.GetReqHeaders(), "request_uuid": c.Locals("request_uuid")})
|
cfg.Logger.Debug("Proxying the request", map[string]interface{}{"path": c.Path(), "body": string(c.Request().Body()), "headers": c.GetReqHeaders(), "request_uuid": c.Locals("request_uuid")})
|
||||||
err := proxy.DoRedirects(c, cfg.Server.HostGraphQL+c.Path(), 3)
|
err := proxy.DoRedirects(c, cfg.Server.HostGraphQL+c.Path(), 3)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
|||||||
Reference in New Issue
Block a user