Rename Go code to use Fetcher and FetchFeed

- Rename feedgetter.go to fetcher.go
- Rename feedgetter_integration_test.go to fetcher_integration_test.go
- Rename FeedGetter struct to Fetcher
- Rename NewFeedGetter function to NewFetcher
- Rename Get method to FetchFeed
- Update all test function names and references
- Use consistent 'f' receiver variable instead of 'fg'

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude <noreply@anthropic.com>

Author: Arpith Siromoney

feedfetcher/feedgetter.go feedfetcher/fetcher.gofeedfetcher/feedgetter.go renamed to feedfetcher/fetcher.go

@@ -14,7 +14,7 @@ import (
 	"github.com/mmcdole/gofeed"
 )
 
-type FeedGetter struct {
+type Fetcher struct {
 	redisClient *redis.Client
 	s3Client    *s3.Client
 	httpClient  *http.Client
@@ -32,20 +32,20 @@ type FeedResponse struct {
 	StatusMessage string   `json:"statusMessage,omitempty"`
 }
 
-func NewFeedGetter(redisClient *redis.Client, s3Client *s3.Client, s3Bucket string) *FeedGetter {
-	return &FeedGetter{
+func NewFetcher(redisClient *redis.Client, s3Client *s3.Client, s3Bucket string) *Fetcher {
+	return &Fetcher{
 		redisClient: redisClient,
 		s3Client:    s3Client,
 		httpClient:  &http.Client{},
 		s3Bucket:    s3Bucket,
 	}
 }
 
-func (fg *FeedGetter) Get(ctx context.Context, feedURI string) (*FeedResponse, error) {
+func (f *Fetcher) FetchFeed(ctx context.Context, feedURI string) (*FeedResponse, error) {
 	keys := BuildRedisKeys(feedURI)
 
 	// Fetch stored feed metadata from Redis
-	storedFeed, err := fg.redisClient.HGetAll(ctx, keys.FeedKey).Result()
+	storedFeed, err := f.redisClient.HGetAll(ctx, keys.FeedKey).Result()
 	if err != nil && err != redis.Nil {
 		return nil, fmt.Errorf("failed to get stored feed: %w", err)
 	}
@@ -63,7 +63,7 @@ func (fg *FeedGetter) Get(ctx context.Context, feedURI string) (*FeedResponse, e
 		req.Header.Set(key, value)
 	}
 
-	resp, err := fg.httpClient.Do(req)
+	resp, err := f.httpClient.Do(req)
 	if err != nil {
 		return &FeedResponse{
 			Success:       false,
@@ -75,7 +75,7 @@ func (fg *FeedGetter) Get(ctx context.Context, feedURI string) (*FeedResponse, e
 	// Handle HTTP status codes
 	if resp.StatusCode == http.StatusNotModified {
 		// Feed not modified, return cached articles
-		articles, err := fg.getArticleIds(ctx, keys.ArticlesKey)
+		articles, err := f.getArticleIds(ctx, keys.ArticlesKey)
 		if err != nil {
 			return nil, err
 		}
@@ -124,7 +124,7 @@ func (fg *FeedGetter) Get(ctx context.Context, feedURI string) (*FeedResponse, e
 		"etag":         etag,
 	}
 
-	if err := fg.redisClient.HMSet(ctx, keys.FeedKey, feedMeta).Err(); err != nil {
+	if err := f.redisClient.HMSet(ctx, keys.FeedKey, feedMeta).Err(); err != nil {
 		return nil, fmt.Errorf("failed to store feed metadata: %w", err)
 	}
 
@@ -153,15 +153,15 @@ func (fg *FeedGetter) Get(ctx context.Context, feedURI string) (*FeedResponse, e
 		articleKey := BuildArticleKey(processedArticle.Hash)
 
 		// Get old score from Redis
-		oldScoreStr, err := fg.redisClient.ZScore(ctx, keys.ArticlesKey, articleKey).Result()
+		oldScoreStr, err := f.redisClient.ZScore(ctx, keys.ArticlesKey, articleKey).Result()
 		var oldScore *string
 		if err == nil {
 			scoreStr := strconv.FormatInt(int64(oldScoreStr), 10)
 			oldScore = &scoreStr
 		}
 
 		// Add article to sorted set
-		err = fg.redisClient.ZAdd(ctx, keys.ArticlesKey, &redis.Z{
+		err = f.redisClient.ZAdd(ctx, keys.ArticlesKey, &redis.Z{
 			Score:  float64(processedArticle.Score),
 			Member: articleKey,
 		}).Err()
@@ -171,14 +171,14 @@ func (fg *FeedGetter) Get(ctx context.Context, feedURI string) (*FeedResponse, e
 
 		// Store article in S3 if score changed
 		if ShouldStoreArticle(oldScore, processedArticle.Score) {
-			if err := fg.storeArticleInS3(ctx, processedArticle); err != nil {
+			if err := f.storeArticleInS3(ctx, processedArticle); err != nil {
 				return nil, fmt.Errorf("failed to store article in S3: %w", err)
 			}
 		}
 	}
 
 	// Get all article IDs
-	articles, err := fg.getArticleIds(ctx, keys.ArticlesKey)
+	articles, err := f.getArticleIds(ctx, keys.ArticlesKey)
 	if err != nil {
 		return nil, err
 	}
@@ -194,14 +194,14 @@ func (fg *FeedGetter) Get(ctx context.Context, feedURI string) (*FeedResponse, e
 	}, nil
 }
 
-func (fg *FeedGetter) storeArticleInS3(ctx context.Context, article Article) error {
+func (f *Fetcher) storeArticleInS3(ctx context.Context, article Article) error {
 	body, err := GenerateArticleBody(article)
 	if err != nil {
 		return err
 	}
 
-	_, err = fg.s3Client.PutObject(ctx, &s3.PutObjectInput{
-		Bucket:      aws.String(fg.s3Bucket),
+	_, err = f.s3Client.PutObject(ctx, &s3.PutObjectInput{
+		Bucket:      aws.String(f.s3Bucket),
 		Key:         aws.String(article.Hash + ".json"),
 		Body:        bytes.NewReader([]byte(body)),
 		ContentType: aws.String("application/json"),
@@ -210,8 +210,8 @@ func (fg *FeedGetter) storeArticleInS3(ctx context.Context, article Article) err
 	return err
 }
 
-func (fg *FeedGetter) getArticleIds(ctx context.Context, articlesKey string) ([]string, error) {
-	allArticles, err := fg.redisClient.ZRevRange(ctx, articlesKey, 0, -1).Result()
+func (f *Fetcher) getArticleIds(ctx context.Context, articlesKey string) ([]string, error) {
+	allArticles, err := f.redisClient.ZRevRange(ctx, articlesKey, 0, -1).Result()
 	if err != nil {
 		return nil, fmt.Errorf("failed to get articles from sorted set: %w", err)
 	}

…edfetcher/feedgetter_integration_test.go feedfetcher/fetcher_integration_test.gofeedfetcher/feedgetter_integration_test.go renamed to feedfetcher/fetcher_integration_test.go feedfetcher/feedgetter_integration_test.go renamed to feedfetcher/fetcher_integration_test.go

@@ -19,7 +19,7 @@ import (
 	"gopkg.in/yaml.v3"
 )
 
-type FeedGetTestCases struct {
+type FetchFeedTestCases struct {
 	FeedGetTests []struct {
 		Description            string `yaml:"description"`
 		FeedFixture            string `yaml:"feed_fixture"`
@@ -93,14 +93,14 @@ func setupS3Client() (*s3.Client, error) {
 	return client, nil
 }
 
-func TestFeedGetIntegration(t *testing.T) {
+func TestFetchFeedIntegration(t *testing.T) {
 	// Load test cases
 	data, err := os.ReadFile("../testdata/feed-get-tests.yaml")
 	if err != nil {
 		t.Fatalf("Failed to read test data: %v", err)
 	}
 
-	var testCases FeedGetTestCases
+	var testCases FetchFeedTestCases
 	if err := yaml.Unmarshal(data, &testCases); err != nil {
 		t.Fatalf("Failed to parse test data: %v", err)
 	}
@@ -144,11 +144,11 @@ func TestFeedGetIntegration(t *testing.T) {
 			}))
 			defer server.Close()
 
-			// Create FeedGetter and fetch the feed
-			fg := NewFeedGetter(redisClient, s3Client, bucket)
-			result, err := fg.Get(ctx, server.URL)
+			// Create Fetcher and fetch the feed
+			fetcher := NewFetcher(redisClient, s3Client, bucket)
+			result, err := fetcher.FetchFeed(ctx, server.URL)
 			if err != nil {
-				t.Fatalf("FeedGetter.Get() failed: %v", err)
+				t.Fatalf("Fetcher.FetchFeed() failed: %v", err)
 			}
 
 			// Verify success
@@ -210,7 +210,7 @@ func TestFeedGetIntegration(t *testing.T) {
 	}
 }
 
-func TestFeedGetCaching(t *testing.T) {
+func TestFetchFeedCaching(t *testing.T) {
 	ctx := context.Background()
 
 	// Setup clients
@@ -264,14 +264,14 @@ func TestFeedGetCaching(t *testing.T) {
 	}))
 	defer server.Close()
 
-	fg := NewFeedGetter(redisClient, s3Client, bucket)
+	fetcher := NewFetcher(redisClient, s3Client, bucket)
 
 	// Clear Redis
 	keys := BuildRedisKeys(server.URL)
 	redisClient.Del(ctx, keys.FeedKey, keys.ArticlesKey)
 
 	// First request
-	result1, err := fg.Get(ctx, server.URL)
+	result1, err := fetcher.FetchFeed(ctx, server.URL)
 	if err != nil {
 		t.Fatalf("First request failed: %v", err)
 	}
@@ -285,7 +285,7 @@ func TestFeedGetCaching(t *testing.T) {
 	}
 
 	// Second request (should use caching)
-	result2, err := fg.Get(ctx, server.URL)
+	result2, err := fetcher.FetchFeed(ctx, server.URL)
 	if err != nil {
 		t.Fatalf("Second request failed: %v", err)
 	}