Skip to content

Commit f2b5847

Browse files
authored
Ensure processedUsernames in findNewTwitterRegistrations is preserved across pages (#98)
1 parent 16a62c4 commit f2b5847

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

pkg/code/async/user/twitter.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -103,6 +103,7 @@ func (p *service) findNewTwitterRegistrations(ctx context.Context) error {
103103

104104
err := func() error {
105105
var pageToken *string
106+
processedUsernames := make(map[string]any)
106107
for {
107108
tweets, nextPageToken, err := p.twitterClient.SearchRecentTweets(
108109
ctx,
@@ -114,7 +115,6 @@ func (p *service) findNewTwitterRegistrations(ctx context.Context) error {
114115
return errors.Wrap(err, "error searching tweets")
115116
}
116117

117-
processedUsernames := make(map[string]any)
118118
for _, tweet := range tweets {
119119
if tweet.AdditionalMetadata.Author == nil {
120120
return errors.Errorf("author missing in tweet %s", tweet.ID)

0 commit comments

Comments
 (0)