controller

var ClickhousePushV2 = PushV2

var Config = Build(withOkStatusAndBody(200, []byte("Not supported")))

var DbClient chwrapper.IChClient

var FPCache numbercache.ICache[uint64]

var HealthInflux = Build(withOkStatusAndBody(200, nil))

var PromHealthStub = Build(withOkStatusAndBody(200, nil))

var Ready = Build(withOkStatusAndBody(200, []byte("ok")))

var Registry registry.ServiceRegistry

var WithExtraMiddlewareDefault = []BuildOption{
	WithOverallContextMiddleware,
}

var WithExtraMiddlewareTempo = []BuildOption{
	WithOverallContextMiddleware,
}

var WithOverallContextMiddleware = WithPreRequest(func(w http.ResponseWriter, r *http.Request) error {
	dsn := strings.Clone(r.Header.Get("X-CH-DSN"))
	meta := strings.Clone(r.Header.Get("X-Scope-Meta"))
	strTTLDays := strings.Clone(r.Header.Get("X-Ttl-Days"))
	async := getAsyncMode(r)
	TTLDays := uint16(0)
	if strTTLDays != "" {
		iTTLDays, err := strconv.ParseUint(strTTLDays, 10, 16)
		if err == nil {
			TTLDays = uint16(iTTLDays)
		}
	}

	switch r.Header.Get("Content-Encoding") {
	case "":

	case "gzip":
		reader, err := gzip.NewReader(r.Body)
		if err != nil {
			return err
		}
		r.Body = readColser{reader}
	case "snappy":
		bBody, err := io.ReadAll(r.Body)
		if err != nil {
			return err
		}
		uncompressed, err := snappy.Decode(nil, bBody)
		if err != nil {

			uncompressed = bBody
		}
		reader := bytes.NewReader(uncompressed)
		r.Body = readColser{reader}
	default:
		return errors.New400Error(fmt.Sprintf("%s encoding not supported", r.Header.Get("Content-Encoding")))
	}
	ctx := r.Context()

	ctx = context.WithValue(ctx, utils.ContextKeyDSN, dsn)

	ctx = context.WithValue(ctx, utils.ContextKeyMeta, meta)
	ctx = context.WithValue(ctx, utils.ContextKeyTTLDays, TTLDays)
	ctx = context.WithValue(ctx, utils.ContextKeyAsync, async)

	*r = *r.WithContext(ctx)
	return nil
})