main.go

package caddy

import (
	"context"
	"io"
	"net/http"

	"github.com/caddyserver/caddy/v2"
	"github.com/caddyserver/caddy/v2/modules/caddyhttp"
)

func init() {
	caddy.RegisterModule(SablierMiddleware{})
}

type SablierMiddleware struct {
	Config  Config
	client  *http.Client
	request *http.Request
}

// CaddyModule returns the Caddy module information.
func (SablierMiddleware) CaddyModule() caddy.ModuleInfo {
	return caddy.ModuleInfo{
		ID:  "http.handlers.sablier",
		New: func() caddy.Module { return new(SablierMiddleware) },
	}
}

// Provision implements caddy.Provisioner.
func (m *SablierMiddleware) Provision(ctx caddy.Context) error {
	req, err := m.Config.BuildRequest()
	if err != nil {
		return err
	}

	m.request = req
	m.client = &http.Client{}

	return nil
}

// ServeHTTP implements caddyhttp.MiddlewareHandler.
func (sm SablierMiddleware) ServeHTTP(rw http.ResponseWriter, req *http.Request, next caddyhttp.Handler) error {
	sablierRequest := sm.request.Clone(context.TODO())

	// Expand Caddy placeholders (e.g. {labels.3}) in query parameters at request time
	if repl, ok := req.Context().Value(caddy.ReplacerCtxKey).(*caddy.Replacer); ok && repl != nil {
		q := sablierRequest.URL.Query()
		if names, exists := q["names"]; exists {
			q.Del("names")
			for _, name := range names {
				if expanded := repl.ReplaceAll(name, ""); expanded != "" {
					q.Add("names", expanded)
				}
			}
			sablierRequest.URL.RawQuery = q.Encode()
		}
		if group := q.Get("group"); group != "" {
			q.Set("group", repl.ReplaceAll(group, ""))
			sablierRequest.URL.RawQuery = q.Encode()
		}
	}

	resp, err := sm.client.Do(sablierRequest)
	if err != nil {
		http.Error(rw, err.Error(), http.StatusInternalServerError)
		return err
	}
	//nolint:errcheck
	defer resp.Body.Close()

	if resp.Header.Get("X-Sablier-Session-Status") == "ready" {
		return next.ServeHTTP(rw, req)
	}

	return forward(resp, rw)
}

func forward(resp *http.Response, rw http.ResponseWriter) error {
	rw.Header().Set("Content-Type", resp.Header.Get("Content-Type"))
	rw.Header().Set("Content-Length", resp.Header.Get("Content-Length"))
	_, err := io.Copy(rw, resp.Body)
	return err
}

// Interface guards
var (
	_ caddy.Provisioner           = (*SablierMiddleware)(nil)
	_ caddyhttp.MiddlewareHandler = (*SablierMiddleware)(nil)
)