deblan-mirror/lego
1
0
Fork 0
mirror of https://github.com/go-acme/lego synced 2026-03-14 14:35:48 +01:00
Code Issues Projects Releases Packages Wiki Activity

refactor: improve sender errors

Browse source
This commit is contained in:
Fernandez Ludovic 2026-03-05 18:01:41 +01:00
commit 8c87524499
3 changed files with 16 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

11
acme/api/api.go
View file

@ -47,6 +47,10 @@ func New(httpClient *http.Client, userAgent, caDirURL, kid string, privateKey cr
return nil, err
}
return newCore(httpClient, doer, dir, kid, privateKey)
}
func newCore(httpClient *http.Client, doer *sender.Doer, dir acme.Directory, kid string, privateKey crypto.Signer) (*Core, error) {
nonceManager := nonces.NewManager(doer, dir.NewNonceURL)
c := &Core{
@ -57,6 +61,7 @@ func New(httpClient *http.Client, userAgent, caDirURL, kid string, privateKey cr
privateKey: privateKey,
kid: kid,
// NOTE(ldez): use the doer instead of the HTTP client? (only related to OCSP)
HTTPClient: httpClient,
}
@ -167,10 +172,14 @@ func (a *Core) GetDirectory() acme.Directory {
func getDirectory(ctx context.Context, do *sender.Doer, caDirURL string) (acme.Directory, error) {
var dir acme.Directory
if _, err := do.Get(ctx, caDirURL, &dir); err != nil {
resp, err := do.Get(ctx, caDirURL, &dir)
if err != nil {
return dir, fmt.Errorf("get directory at '%s': %w", caDirURL, err)
}
defer func() { _ = resp.Body.Close() }()
if dir.NewAccountURL == "" {
return dir, errors.New("directory missing new registration URL")
}

2
acme/api/internal/nonces/nonce_manager.go
View file

@ -61,6 +61,8 @@ func (n *Manager) getNonce(ctx context.Context) (string, error) {
return "", fmt.Errorf("failed to get nonce from HTTP HEAD: %w", err)
}
defer func() { _ = resp.Body.Close() }()
return GetFromResponse(resp)
}

7
acme/api/internal/sender/sender.go
View file

@ -10,6 +10,7 @@ import (
"strings"
"github.com/go-acme/lego/v5/acme"
"github.com/go-acme/lego/v5/internal/errutils"
)
type RequestOption func(*http.Request) error
@ -90,7 +91,7 @@ func (d *Doer) newRequest(ctx context.Context, method, uri string, body io.Reade
func (d *Doer) do(req *http.Request, response any) (*http.Response, error) {
resp, err := d.httpClient.Do(req)
if err != nil {
return nil, err
return nil, errutils.NewHTTPDoError(req, err)
}
if err = checkError(req, resp); err != nil {
@ -100,14 +101,14 @@ func (d *Doer) do(req *http.Request, response any) (*http.Response, error) {
if response != nil {
raw, err := io.ReadAll(resp.Body)
if err != nil {
return resp, err
return resp, errutils.NewReadResponseError(req, resp.StatusCode, err)
}
defer resp.Body.Close()
err = json.Unmarshal(raw, response)
if err != nil {
return resp, fmt.Errorf("failed to unmarshal %q to type %T: %w", raw, response, err)
return resp, errutils.NewUnmarshalError(req, resp.StatusCode, raw, err)
}
}