1116fc6bb4
Several HTTP entry points still parsed RemoteAddr directly, so behind a layer-7 proxy they recorded the load balancer IP instead of the signer's. Route NDA acceptance, signing events, document sign/approve, and session updates through clientip.Extract, which honors Forwarded and X-Forwarded-For when trustedproxy allows them. Signed-off-by: Ludovic Vielle <ludovic@probo.com>
98 lines
2.5 KiB
Go
98 lines
2.5 KiB
Go
// Copyright (c) 2026 Probo Inc <hello@probo.com>.
|
|
//
|
|
// Permission to use, copy, modify, and/or distribute this software for any
|
|
// purpose with or without fee is hereby granted, provided that the above
|
|
// copyright notice and this permission notice appear in all copies.
|
|
//
|
|
// THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES WITH
|
|
// REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY
|
|
// AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY SPECIAL, DIRECT,
|
|
// INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM
|
|
// LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE OR
|
|
// OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR
|
|
// PERFORMANCE OF THIS SOFTWARE.
|
|
|
|
package clientip
|
|
|
|
import (
|
|
"net"
|
|
"net/http"
|
|
"strings"
|
|
)
|
|
|
|
// Extract resolves the client IP address from standard proxy headers
|
|
// in priority order: RFC 7239 Forwarded, then X-Forwarded-For, then
|
|
// the connection's remote address. It takes the rightmost (last)
|
|
// entry from multi-value headers — the one appended by the trusted
|
|
// load balancer closest to us.
|
|
func Extract(r *http.Request) string {
|
|
if fwd := r.Header.Get("Forwarded"); fwd != "" {
|
|
if ip := parseForwardedFor(fwd); net.ParseIP(ip) != nil {
|
|
return ip
|
|
}
|
|
}
|
|
|
|
if xff := r.Header.Get("X-Forwarded-For"); xff != "" {
|
|
if ip := parseXForwardedFor(xff); net.ParseIP(ip) != nil {
|
|
return ip
|
|
}
|
|
}
|
|
|
|
return extractRemoteAddr(r.RemoteAddr)
|
|
}
|
|
|
|
func parseXForwardedFor(xff string) string {
|
|
if i := strings.LastIndexByte(xff, ','); i != -1 {
|
|
xff = xff[i+1:]
|
|
}
|
|
|
|
xff = strings.TrimSpace(xff)
|
|
|
|
if ip, _, err := net.SplitHostPort(xff); err == nil {
|
|
return ip
|
|
}
|
|
|
|
return xff
|
|
}
|
|
|
|
func extractRemoteAddr(remoteAddr string) string {
|
|
ip, _, err := net.SplitHostPort(remoteAddr)
|
|
if err != nil {
|
|
return remoteAddr
|
|
}
|
|
|
|
return ip
|
|
}
|
|
|
|
// parseForwardedFor extracts the client IP from the last "for=" directive
|
|
// of an RFC 7239 Forwarded header value.
|
|
func parseForwardedFor(header string) string {
|
|
if i := strings.LastIndexByte(header, ','); i != -1 {
|
|
header = header[i+1:]
|
|
}
|
|
|
|
for part := range strings.SplitSeq(header, ";") {
|
|
part = strings.TrimSpace(part)
|
|
if !strings.HasPrefix(strings.ToLower(part), "for=") {
|
|
continue
|
|
}
|
|
|
|
val := part[4:]
|
|
val = strings.Trim(val, "\"")
|
|
|
|
if strings.HasPrefix(val, "[") {
|
|
if end := strings.IndexByte(val, ']'); end != -1 {
|
|
return val[1:end]
|
|
}
|
|
}
|
|
|
|
if ip, _, err := net.SplitHostPort(val); err == nil {
|
|
return ip
|
|
}
|
|
|
|
return val
|
|
}
|
|
|
|
return ""
|
|
}
|