diff options
Diffstat (limited to 'internal/api/s2s/user/repliesget.go')
-rw-r--r-- | internal/api/s2s/user/repliesget.go | 62 |
1 files changed, 31 insertions, 31 deletions
diff --git a/internal/api/s2s/user/repliesget.go b/internal/api/s2s/user/repliesget.go index 388f69885..6ef5a5f43 100644 --- a/internal/api/s2s/user/repliesget.go +++ b/internal/api/s2s/user/repliesget.go @@ -20,13 +20,15 @@ package user import ( "encoding/json" + "errors" "fmt" "net/http" "strconv" + "strings" "github.com/gin-gonic/gin" - "github.com/sirupsen/logrus" "github.com/superseriousbusiness/gotosocial/internal/api" + "github.com/superseriousbusiness/gotosocial/internal/gtserror" ) // StatusRepliesGETHandler swagger:operation GET /users/{username}/statuses/{status}/replies s2sRepliesGet @@ -86,29 +88,39 @@ import ( // '404': // description: not found func (m *Module) StatusRepliesGETHandler(c *gin.Context) { - l := logrus.WithFields(logrus.Fields{ - "func": "StatusRepliesGETHandler", - "url": c.Request.RequestURI, - }) - - requestedUsername := c.Param(UsernameKey) + // usernames on our instance are always lowercase + requestedUsername := strings.ToLower(c.Param(UsernameKey)) if requestedUsername == "" { - c.JSON(http.StatusBadRequest, gin.H{"error": "no username specified in request"}) + err := errors.New("no username specified in request") + api.ErrorHandler(c, gtserror.NewErrorBadRequest(err, err.Error()), m.processor.InstanceGet) return } - requestedStatusID := c.Param(StatusIDKey) + // status IDs on our instance are always uppercase + requestedStatusID := strings.ToUpper(c.Param(StatusIDKey)) if requestedStatusID == "" { - c.JSON(http.StatusBadRequest, gin.H{"error": "no status id specified in request"}) + err := errors.New("no status id specified in request") + api.ErrorHandler(c, gtserror.NewErrorBadRequest(err, err.Error()), m.processor.InstanceGet) return } + format, err := api.NegotiateAccept(c, api.HTMLOrActivityPubHeaders...) + if err != nil { + api.ErrorHandler(c, gtserror.NewErrorNotAcceptable(err, err.Error()), m.processor.InstanceGet) + return + } + + if format == string(api.TextHTML) { + // redirect to the status + c.Redirect(http.StatusSeeOther, "/@"+requestedUsername+"/statuses/"+requestedStatusID) + } + var page bool if pageString := c.Query(PageKey); pageString != "" { i, err := strconv.ParseBool(pageString) if err != nil { - l.Debugf("error parsing page string: %s", err) - c.JSON(http.StatusBadRequest, gin.H{"error": "couldn't parse page query param"}) + err := fmt.Errorf("error parsing %s: %s", PageKey, err) + api.ErrorHandler(c, gtserror.NewErrorBadRequest(err, err.Error()), m.processor.InstanceGet) return } page = i @@ -119,8 +131,8 @@ func (m *Module) StatusRepliesGETHandler(c *gin.Context) { if onlyOtherAccountsString != "" { i, err := strconv.ParseBool(onlyOtherAccountsString) if err != nil { - l.Debugf("error parsing only_other_accounts string: %s", err) - c.JSON(http.StatusBadRequest, gin.H{"error": "couldn't parse only_other_accounts query param"}) + err := fmt.Errorf("error parsing %s: %s", OnlyOtherAccountsKey, err) + api.ErrorHandler(c, gtserror.NewErrorBadRequest(err, err.Error()), m.processor.InstanceGet) return } onlyOtherAccounts = i @@ -132,27 +144,15 @@ func (m *Module) StatusRepliesGETHandler(c *gin.Context) { minID = minIDString } - format, err := api.NegotiateAccept(c, api.ActivityPubAcceptHeaders...) - if err != nil { - c.JSON(http.StatusNotAcceptable, gin.H{"error": err.Error()}) - return - } - l.Tracef("negotiated format: %s", format) - - ctx := transferContext(c) - - replies, errWithCode := m.processor.GetFediStatusReplies(ctx, requestedUsername, requestedStatusID, page, onlyOtherAccounts, minID, c.Request.URL) + resp, errWithCode := m.processor.GetFediStatusReplies(transferContext(c), requestedUsername, requestedStatusID, page, onlyOtherAccounts, minID, c.Request.URL) if errWithCode != nil { - l.Info(errWithCode.Error()) - c.JSON(errWithCode.Code(), gin.H{"error": errWithCode.Safe()}) + api.ErrorHandler(c, errWithCode, m.processor.InstanceGet) return } - b, mErr := json.Marshal(replies) - if mErr != nil { - err := fmt.Errorf("could not marshal json: %s", mErr) - l.Error(err) - c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()}) + b, err := json.Marshal(resp) + if err != nil { + api.ErrorHandler(c, gtserror.NewErrorInternalError(err), m.processor.InstanceGet) return } |