summaryrefslogtreecommitdiff
path: root/internal/transport
diff options
context:
space:
mode:
Diffstat (limited to 'internal/transport')
-rw-r--r--internal/transport/deliver.go4
-rw-r--r--internal/transport/dereference.go20
-rw-r--r--internal/transport/derefinstance.go10
-rw-r--r--internal/transport/derefmedia.go5
-rw-r--r--internal/transport/transport.go13
5 files changed, 31 insertions, 21 deletions
diff --git a/internal/transport/deliver.go b/internal/transport/deliver.go
index 7db3bf338..b1883b64e 100644
--- a/internal/transport/deliver.go
+++ b/internal/transport/deliver.go
@@ -29,6 +29,7 @@ import (
"codeberg.org/gruf/go-byteutil"
apiutil "github.com/superseriousbusiness/gotosocial/internal/api/util"
"github.com/superseriousbusiness/gotosocial/internal/config"
+ "github.com/superseriousbusiness/gotosocial/internal/gtserror"
)
func (t *transport) BatchDeliver(ctx context.Context, b []byte, recipients []*url.URL) error {
@@ -96,7 +97,8 @@ func (t *transport) Deliver(ctx context.Context, b []byte, to *url.URL) error {
if code := resp.StatusCode; code != http.StatusOK &&
code != http.StatusCreated && code != http.StatusAccepted {
- return fmt.Errorf("POST request to %s failed: %s", urlStr, resp.Status)
+ err := fmt.Errorf("POST request to %s failed: %s", urlStr, resp.Status)
+ return gtserror.WithStatusCode(err, resp.StatusCode)
}
return nil
diff --git a/internal/transport/dereference.go b/internal/transport/dereference.go
index f42f146ea..d82a1ac8a 100644
--- a/internal/transport/dereference.go
+++ b/internal/transport/dereference.go
@@ -20,7 +20,6 @@ package transport
import (
"context"
- "errors"
"fmt"
"io"
"net/http"
@@ -28,15 +27,10 @@ import (
apiutil "github.com/superseriousbusiness/gotosocial/internal/api/util"
"github.com/superseriousbusiness/gotosocial/internal/config"
+ "github.com/superseriousbusiness/gotosocial/internal/gtserror"
"github.com/superseriousbusiness/gotosocial/internal/uris"
)
-// ErrGone is returned from Dereference when the remote resource returns 410 GONE.
-// This is useful in cases where we're processing a delete of a resource that's already
-// been removed from the remote server, so we know we don't need to keep trying to
-// dereference it.
-var ErrGone = errors.New("remote resource returned HTTP code 410 GONE")
-
func (t *transport) Dereference(ctx context.Context, iri *url.URL) ([]byte, error) {
// if the request is to us, we can shortcut for certain URIs rather than going through
// the normal request flow, thereby saving time and energy
@@ -72,12 +66,10 @@ func (t *transport) Dereference(ctx context.Context, iri *url.URL) ([]byte, erro
}
defer rsp.Body.Close()
- switch rsp.StatusCode {
- case http.StatusOK:
- return io.ReadAll(rsp.Body)
- case http.StatusGone:
- return nil, ErrGone
- default:
- return nil, fmt.Errorf("GET request to %s failed: %s", iriStr, rsp.Status)
+ if rsp.StatusCode != http.StatusOK {
+ err := fmt.Errorf("GET request to %s failed: %s", iriStr, rsp.Status)
+ return nil, gtserror.WithStatusCode(err, rsp.StatusCode)
}
+
+ return io.ReadAll(rsp.Body)
}
diff --git a/internal/transport/derefinstance.go b/internal/transport/derefinstance.go
index 2dcf367a0..41949f449 100644
--- a/internal/transport/derefinstance.go
+++ b/internal/transport/derefinstance.go
@@ -30,6 +30,7 @@ import (
apimodel "github.com/superseriousbusiness/gotosocial/internal/api/model"
apiutil "github.com/superseriousbusiness/gotosocial/internal/api/util"
+ "github.com/superseriousbusiness/gotosocial/internal/gtserror"
"github.com/superseriousbusiness/gotosocial/internal/gtsmodel"
"github.com/superseriousbusiness/gotosocial/internal/id"
"github.com/superseriousbusiness/gotosocial/internal/log"
@@ -102,7 +103,8 @@ func dereferenceByAPIV1Instance(ctx context.Context, t *transport, iri *url.URL)
defer resp.Body.Close()
if resp.StatusCode != http.StatusOK {
- return nil, fmt.Errorf("GET request to %s failed: %s", iriStr, resp.Status)
+ err := fmt.Errorf("GET request to %s failed: %s", iriStr, resp.Status)
+ return nil, gtserror.WithStatusCode(err, resp.StatusCode)
}
b, err := io.ReadAll(resp.Body)
@@ -252,7 +254,8 @@ func callNodeInfoWellKnown(ctx context.Context, t *transport, iri *url.URL) (*ur
defer resp.Body.Close()
if resp.StatusCode != http.StatusOK {
- return nil, fmt.Errorf("callNodeInfoWellKnown: GET request to %s failed: %s", iriStr, resp.Status)
+ err := fmt.Errorf("GET request to %s failed: %s", iriStr, resp.Status)
+ return nil, gtserror.WithStatusCode(err, resp.StatusCode)
}
b, err := io.ReadAll(resp.Body)
@@ -303,7 +306,8 @@ func callNodeInfo(ctx context.Context, t *transport, iri *url.URL) (*apimodel.No
defer resp.Body.Close()
if resp.StatusCode != http.StatusOK {
- return nil, fmt.Errorf("callNodeInfo: GET request to %s failed: %s", iriStr, resp.Status)
+ err := fmt.Errorf("GET request to %s failed: %s", iriStr, resp.Status)
+ return nil, gtserror.WithStatusCode(err, resp.StatusCode)
}
b, err := io.ReadAll(resp.Body)
diff --git a/internal/transport/derefmedia.go b/internal/transport/derefmedia.go
index c8a817eef..88d7f0b32 100644
--- a/internal/transport/derefmedia.go
+++ b/internal/transport/derefmedia.go
@@ -24,6 +24,8 @@ import (
"io"
"net/http"
"net/url"
+
+ "github.com/superseriousbusiness/gotosocial/internal/gtserror"
)
func (t *transport) DereferenceMedia(ctx context.Context, iri *url.URL) (io.ReadCloser, int64, error) {
@@ -46,7 +48,8 @@ func (t *transport) DereferenceMedia(ctx context.Context, iri *url.URL) (io.Read
// Check for an expected status code
if rsp.StatusCode != http.StatusOK {
- return nil, 0, fmt.Errorf("GET request to %s failed: %s", iriStr, rsp.Status)
+ err := fmt.Errorf("GET request to %s failed: %s", iriStr, rsp.Status)
+ return nil, 0, gtserror.WithStatusCode(err, rsp.StatusCode)
}
return rsp.Body, rsp.ContentLength, nil
diff --git a/internal/transport/transport.go b/internal/transport/transport.go
index b0f68f707..4cb95bd98 100644
--- a/internal/transport/transport.go
+++ b/internal/transport/transport.go
@@ -25,6 +25,7 @@ import (
"errors"
"fmt"
"io"
+ "net"
"net/http"
"net/url"
"strconv"
@@ -36,6 +37,7 @@ import (
errorsv2 "codeberg.org/gruf/go-errors/v2"
"codeberg.org/gruf/go-kv"
"github.com/go-fed/httpsig"
+ "github.com/superseriousbusiness/gotosocial/internal/gtserror"
"github.com/superseriousbusiness/gotosocial/internal/gtsmodel"
"github.com/superseriousbusiness/gotosocial/internal/httpclient"
"github.com/superseriousbusiness/gotosocial/internal/log"
@@ -56,6 +58,7 @@ type Transport interface {
// Deliver sends an ActivityStreams object.
Deliver(ctx context.Context, b []byte, to *url.URL) error
+
// BatchDeliver sends an ActivityStreams object to multiple recipients.
BatchDeliver(ctx context.Context, b []byte, recipients []*url.URL) error
@@ -65,10 +68,13 @@ type Transport interface {
// Dereference fetches the ActivityStreams object located at this IRI with a GET request.
Dereference(ctx context.Context, iri *url.URL) ([]byte, error)
+
// DereferenceMedia fetches the given media attachment IRI, returning the reader and filesize.
DereferenceMedia(ctx context.Context, iri *url.URL) (io.ReadCloser, int64, error)
+
// DereferenceInstance dereferences remote instance information, first by checking /api/v1/instance, and then by checking /.well-known/nodeinfo.
DereferenceInstance(ctx context.Context, iri *url.URL) (*gtsmodel.Instance, error)
+
// Finger performs a webfinger request with the given username and domain, and returns the bytes from the response body.
Finger(ctx context.Context, targetUsername string, targetDomain string) ([]byte, error)
}
@@ -207,6 +213,10 @@ func (t *transport) do(r *http.Request, signer func(*http.Request) error) (*http
} else if errors.As(err, &x509.UnknownAuthorityError{}) {
// Unknown authority errors we do NOT recover from
return nil, err
+ } else if dnserr := (*net.DNSError)(nil); // nocollapse
+ errors.As(err, &dnserr) && dnserr.IsNotFound {
+ // DNS lookup failure, this domain does not exist
+ return nil, gtserror.SetNotFound(err)
}
if fastFail {
@@ -219,7 +229,7 @@ func (t *transport) do(r *http.Request, signer func(*http.Request) error) (*http
backoff = time.Duration(i) * baseBackoff
}
- l.Errorf("backing off for %s after http request error: %v", backoff.String(), err)
+ l.Errorf("backing off for %s after http request error: %v", backoff, err)
select {
// Request ctx cancelled
@@ -228,7 +238,6 @@ func (t *transport) do(r *http.Request, signer func(*http.Request) error) (*http
// Backoff for some time
case <-time.After(backoff):
- backoff *= 2
}
}
generated by cgit v1.2.3 (git 2.46.0) at 2025-08-03 12:45:40 +0000