diff --git a/cmd/browser_pools.go b/cmd/browser_pools.go index 81240e2..74c7e41 100644 --- a/cmd/browser_pools.go +++ b/cmd/browser_pools.go @@ -569,7 +569,7 @@ func init() { browserPoolsCreateCmd.Flags().String("name", "", "Optional unique name for the pool") browserPoolsCreateCmd.Flags().Int64("size", 0, "Number of browsers in the pool") _ = browserPoolsCreateCmd.MarkFlagRequired("size") - browserPoolsCreateCmd.Flags().Int64("fill-rate", 0, "Fill rate per minute") + browserPoolsCreateCmd.Flags().Int64("fill-rate", 25, "Fill rate per minute") browserPoolsCreateCmd.Flags().Int64("timeout", 0, "Idle timeout in seconds") browserPoolsCreateCmd.Flags().Bool("stealth", false, "Enable stealth mode") browserPoolsCreateCmd.Flags().Bool("headless", false, "Enable headless mode") diff --git a/cmd/browser_pools_test.go b/cmd/browser_pools_test.go index 25ec0ee..d953723 100644 --- a/cmd/browser_pools_test.go +++ b/cmd/browser_pools_test.go @@ -8,6 +8,7 @@ import ( "github.com/kernel/kernel-go-sdk/option" "github.com/kernel/kernel-go-sdk/packages/pagination" "github.com/stretchr/testify/assert" + "github.com/stretchr/testify/require" ) // FakeBrowserPoolsService is a configurable fake implementing BrowserPoolsService. @@ -158,6 +159,24 @@ func TestBrowserPoolsCreate_WithRefreshOnProfileUpdate(t *testing.T) { assert.True(t, captured.RefreshOnProfileUpdate.Value) } +func TestBrowserPoolsCreate_DefaultFillRate(t *testing.T) { + setupStdoutCapture(t) + + var captured kernel.BrowserPoolNewParams + fake := &FakeBrowserPoolsService{ + NewFunc: func(ctx context.Context, body kernel.BrowserPoolNewParams, opts ...option.RequestOption) (*kernel.BrowserPool, error) { + captured = body + return &kernel.BrowserPool{ID: "pool-default-fill-rate"}, nil + }, + } + + c := BrowserPoolsCmd{client: fake} + err := c.Create(context.Background(), BrowserPoolsCreateInput{Size: 1, FillRate: 25}) + require.NoError(t, err) + assert.True(t, captured.FillRatePerMinute.Valid()) + assert.Equal(t, int64(25), captured.FillRatePerMinute.Value) +} + func TestBrowserPoolsUpdate_WithRefreshOnProfileUpdate(t *testing.T) { setupStdoutCapture(t)