mark as read in get&export flow

Author: skoowoo

cmd/root.go

@@ -5,6 +5,7 @@ import (
 	"os"
 	"strings"
 
+	"github.com/hardhacker/podwise-cli/internal/async"
 	"github.com/hardhacker/podwise-cli/internal/update"
 	"github.com/spf13/cobra"
 )
@@ -31,10 +32,12 @@ func Execute(version, commit, date string) {
 	updateCh := maybeStartUpdateCheck(version)
 
 	if err := rootCmd.Execute(); err != nil {
+		async.Wait() // Wait for background tasks before exit
 		os.Exit(1)
 	}
 
 	printUpdateNotice(updateCh)
+	async.Wait() // Wait for background tasks before exit
 }
 
 // maybeStartUpdateCheck starts an async update check and returns a channel that

internal/async/async.go

@@ -0,0 +1,36 @@
+package async
+
+import "sync"
+
+// Manager manages background goroutines and ensures they complete before exit.
+type Manager struct {
+	wg sync.WaitGroup
+}
+
+// defaultManager is the global instance used by package-level functions.
+var defaultManager = &Manager{}
+
+// Go spawns a goroutine and tracks it for graceful shutdown.
+// The function f is executed in a new goroutine.
+func (m *Manager) Go(f func()) {
+	m.wg.Add(1)
+	go func() {
+		defer m.wg.Done()
+		f()
+	}()
+}
+
+// Wait blocks until all tracked goroutines have completed.
+func (m *Manager) Wait() {
+	m.wg.Wait()
+}
+
+// Go spawns a goroutine using the default manager.
+func Go(f func()) {
+	defaultManager.Go(f)
+}
+
+// Wait blocks until all goroutines spawned via the default manager have completed.
+func Wait() {
+	defaultManager.Wait()
+}

internal/episode/export.go

@@ -5,6 +5,7 @@ import (
 	"fmt"
 
 	"github.com/hardhacker/podwise-cli/internal/api"
+	"github.com/hardhacker/podwise-cli/internal/async"
 )
 
 // NotionExportOptions holds parameters for exporting to Notion.
@@ -73,6 +74,11 @@ func ExportToNotion(ctx context.Context, client *api.Client, seq int, opts Notio
 		return nil, formatNotionError(err)
 	}
 
+	// Mark episode as read in background
+	async.Go(func() {
+		_ = MarkAsRead(context.Background(), client, seq)
+	})
+
 	return &resp.Result, nil
 }
 
@@ -170,6 +176,11 @@ func ExportToReadwise(ctx context.Context, client *api.Client, seq int, opts Rea
 		return nil, formatReadwiseError(err)
 	}
 
+	// Mark episode as read in background
+	async.Go(func() {
+		_ = MarkAsRead(context.Background(), client, seq)
+	})
+
 	return &resp.Result, nil
 }
 

internal/episode/mark.go

@@ -0,0 +1,57 @@
+package episode
+
+import (
+	"context"
+	"fmt"
+
+	"github.com/hardhacker/podwise-cli/internal/api"
+)
+
+// MarkResponse represents the API response for mark read/unread operations.
+type MarkResponse struct {
+	Success bool `json:"success"`
+}
+
+// MarkAsRead marks an episode as read for the authenticated user.
+// The operation is idempotent - if the episode is already marked as read,
+// the request succeeds silently.
+//
+// Returns an error if:
+//   - The episode does not exist (404 not_found)
+//   - The API request fails for other reasons
+func MarkAsRead(ctx context.Context, client *api.Client, seq int) error {
+	path := fmt.Sprintf("/open/v1/episodes/%d/read", seq)
+
+	var resp MarkResponse
+	if err := client.Post(ctx, path, nil, &resp); err != nil {
+		return fmt.Errorf("mark episode %d as read: %w", seq, err)
+	}
+
+	if !resp.Success {
+		return fmt.Errorf("mark episode %d as read: operation failed", seq)
+	}
+
+	return nil
+}
+
+// MarkAsUnread marks an episode as unread for the authenticated user.
+// The operation is idempotent - if the episode is already unread or has no
+// read record, the request succeeds silently.
+//
+// Returns an error if:
+//   - The episode does not exist (404 not_found)
+//   - The API request fails for other reasons
+func MarkAsUnread(ctx context.Context, client *api.Client, seq int) error {
+	path := fmt.Sprintf("/open/v1/episodes/%d/unread", seq)
+
+	var resp MarkResponse
+	if err := client.Post(ctx, path, nil, &resp); err != nil {
+		return fmt.Errorf("mark episode %d as unread: %w", seq, err)
+	}
+
+	if !resp.Success {
+		return fmt.Errorf("mark episode %d as unread: operation failed", seq)
+	}
+
+	return nil
+}

internal/episode/summary.go

@@ -7,6 +7,7 @@ import (
 	"time"
 
 	"github.com/hardhacker/podwise-cli/internal/api"
+	"github.com/hardhacker/podwise-cli/internal/async"
 	"github.com/hardhacker/podwise-cli/internal/cache"
 )
 
@@ -197,6 +198,11 @@ func FetchSummary(ctx context.Context, client *api.Client, seq int, forceRefresh
 		fmt.Printf("warning: could not write cache: %v\n", err)
 	}
 
+	// Mark episode as read in background
+	async.Go(func() {
+		_ = MarkAsRead(context.Background(), client, seq)
+	})
+
 	return &resp.Result, nil
 }
 

internal/episode/transcript.go

@@ -9,6 +9,7 @@ import (
 	"time"
 
 	"github.com/hardhacker/podwise-cli/internal/api"
+	"github.com/hardhacker/podwise-cli/internal/async"
 	"github.com/hardhacker/podwise-cli/internal/cache"
 )
 
@@ -65,6 +66,11 @@ func FetchTranscripts(ctx context.Context, client *api.Client, seq int, forceRef
 		fmt.Printf("warning: could not write cache: %v\n", err)
 	}
 
+	// Mark episode as read in background
+	async.Go(func() {
+		_ = MarkAsRead(context.Background(), client, seq)
+	})
+
 	return resp.Result, nil
 }