mirror of
https://github.com/go-gitea/gitea.git
synced 2026-08-26 19:34:06 +00:00
silverwind
32728fc581
Follow-up to https://github.com/go-gitea/gitea/pull/39068, which disabled `modernize` entirely. - re-enable `modernize`, with only the new `embedlit` rule disabled. It flattens embedded struct literals across ~145 files, and orphans imports in 6 of them that the fixer does not remove - apply the rest of the suite: `errors.AsType`, `reflect.TypeAssert`, `strings.Cut`, and dropping the legacy import comment - use the new stdlib `uuid` package, `github.com/google/uuid` becomes indirect - use `strings.CutLast` in place of manual `LastIndex` slicing in label scopes, email domains and the diff tree list - take the header lint skip dirs from the `go.mod` `ignore` directive and skip dot-directories, instead of hardcoding the list Assisted-by: Claude Code:claude-opus-5
56 lines
1.6 KiB
Go
56 lines
1.6 KiB
Go
// Copyright 2026 The Gitea Authors. All rights reserved.
|
|
// SPDX-License-Identifier: MIT
|
|
|
|
package avatar
|
|
|
|
import (
|
|
"context"
|
|
"errors"
|
|
"net"
|
|
"strconv"
|
|
"strings"
|
|
"time"
|
|
|
|
"gitea.dev/modules/cache"
|
|
)
|
|
|
|
// LookupFederatedHost returns the avatar host from the email domain's SRV record. https://wiki.libravatar.org/api/
|
|
func LookupFederatedHost(ctx context.Context, email string, secure bool) string {
|
|
_, domain, found := strings.CutLast(email, "@")
|
|
if !found {
|
|
return ""
|
|
}
|
|
domain = strings.ToLower(domain)
|
|
|
|
service, defaultPort := "avatars", uint16(80)
|
|
if secure {
|
|
service, defaultPort = "avatars-sec", 443
|
|
}
|
|
|
|
host, _ := cache.GetString(cache.SafeCacheKey("Avatar:SRV:"+service, domain), func() (string, error) {
|
|
lookupCtx, cancel := context.WithTimeout(ctx, 3*time.Second) // a slow resolver must not stall the request
|
|
defer cancel()
|
|
|
|
// LookupSRV already sorts by priority and randomizes by weight (RFC 2782)
|
|
_, records, err := net.DefaultResolver.LookupSRV(lookupCtx, service, "tcp", domain)
|
|
var dnsErr *net.DNSError
|
|
if err != nil && !(errors.As(err, &dnsErr) && dnsErr.IsNotFound) {
|
|
return "", err // a timeout or a cancelled request must not cache as "no record"
|
|
}
|
|
if err != nil || len(records) == 0 {
|
|
return "", nil
|
|
}
|
|
return srvHost(records[0], defaultPort), nil
|
|
})
|
|
return host
|
|
}
|
|
|
|
// a target of "." means the service is unavailable (RFC 2782)
|
|
func srvHost(record *net.SRV, defaultPort uint16) string {
|
|
target := strings.TrimSuffix(record.Target, ".")
|
|
if target == "" || record.Port == defaultPort {
|
|
return target
|
|
}
|
|
return net.JoinHostPort(target, strconv.Itoa(int(record.Port)))
|
|
}
|