remove retries for exceeding posts limit

twitter/api.go

@@ -3,6 +3,9 @@ package twitter
 import (
 	"fmt"
 	"net/url"
+
+	"github.com/go-resty/resty/v2"
+	"github.com/tidwall/gjson"
 )
 
 const HOST = "https://x.com"
@@ -181,3 +184,11 @@ func (l *likes) QueryParam() url.Values {
 func (l *likes) SetCursor(cursor string) {
 	l.cursor = cursor
 }
+
+func CheckApiResp(resp *resty.Response) error {
+	errors := gjson.GetBytes(resp.Body(), "errors")
+	if errors.Exists() {
+		return fmt.Errorf(errors.String())
+	}
+	return nil
+}

twitter/client.go

@@ -54,8 +54,12 @@ func Login(ctx context.Context, authToken string, ct0 string) (*resty.Client, st
 		return !strings.HasSuffix(r.Request.RawRequest.Host, "twimg.com") && err != nil
 	})
 	client.AddRetryCondition(func(r *resty.Response, err error) bool {
-		// For OverCapacity, Rate Limit Exceed
-		return r.Request.RawRequest.Host == "x.com" && (r.StatusCode() == 400 || r.StatusCode() == 429)
+		// For OverCapacity
+		return r.Request.RawRequest.Host == "x.com" && r.StatusCode() == 400
+	})
+	client.AddRetryCondition(func(r *resty.Response, err error) bool {
+		// 仅重试 429 Rate Limit Exceed
+		return r.Request.RawRequest.Host == "x.com" && r.StatusCode() == 429 && CheckApiResp(r) == nil
 	})
 
 	client.SetTransport(&http.Transport{

twitter/timeline.go

@@ -95,7 +95,9 @@ func getTimelineResp(ctx context.Context, api timelineApi, client *resty.Client)
 	if err = utils.CheckRespStatus(resp); err != nil {
 		return nil, err
 	}
-
+	if err = CheckApiResp(resp); err != nil {
+		return nil, err
+	}
 	return resp.Body(), nil
 }