release: 0.7.2

.github/workflows/ci.yml

@@ -61,14 +61,18 @@ jobs:
           GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
 
       - name: Get GitHub OIDC Token
-        if: github.repository == 'stainless-sdks/agentmail-cli'
+        if: |-
+          github.repository == 'stainless-sdks/agentmail-cli' &&
+          !startsWith(github.ref, 'refs/heads/stl/')
         id: github-oidc
         uses: actions/github-script@v8
         with:
           script: core.setOutput('github_token', await core.getIDToken());
 
       - name: Upload tarball
-        if: github.repository == 'stainless-sdks/agentmail-cli'
+        if: |-
+          github.repository == 'stainless-sdks/agentmail-cli' &&
+          !startsWith(github.ref, 'refs/heads/stl/')
         env:
           URL: https://pkg.stainless.com/s
           AUTH: ${{ steps.github-oidc.outputs.github_token }}

.release-please-manifest.json

@@ -1,3 +1,3 @@
 {
-  ".": "0.7.1"
+  ".": "0.7.2"
 }

.stats.yml

@@ -1,4 +1,4 @@
 configured_endpoints: 62
-openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/agentmail%2Fagentmail-161e9f5d786cbd431b293059ed3202a30936b4ec47aa100dd2344b6cc4b77ec0.yml
-openapi_spec_hash: b4e026c4a83dab7c8766a9179377674d
+openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/agentmail%2Fagentmail-1a6bdf8f360f2d6544f9e8a9da2671e686fc8e4cab89e5e121e89d8c6dc3000c.yml
+openapi_spec_hash: 468964c922354edb144930c5662cda7d
 config_hash: 2595ffb55fb009abe18a6566962fbf0a

CHANGELOG.md

@@ -1,5 +1,28 @@
 # Changelog
 
+## 0.7.2 (2026-03-10)
+
+Full Changelog: [v0.7.1...v0.7.2](https://github.com/agentmail-to/agentmail-cli/compare/v0.7.1...v0.7.2)
+
+### Features
+
+* add `--max-items` flag for paginated/streaming endpoints ([cab651f](https://github.com/agentmail-to/agentmail-cli/commit/cab651f16b51cc0b8fd8197307bd9a2a3149097f))
+* **api:** api update ([5978d7a](https://github.com/agentmail-to/agentmail-cli/commit/5978d7ab85c90ec624165671208606c5d3bb9825))
+* **api:** api update ([212d624](https://github.com/agentmail-to/agentmail-cli/commit/212d6248a314de915377c0fa35c346e7b9fe3549))
+* **api:** api update ([b3aa3b4](https://github.com/agentmail-to/agentmail-cli/commit/b3aa3b49b6b1077ba92aa4146f7860dff0b05920))
+* support passing required body params through pipes ([5caad8a](https://github.com/agentmail-to/agentmail-cli/commit/5caad8a5272b56a28394d040333c420a9f853b56))
+
+
+### Bug Fixes
+
+* fix for encoding arrays with `any` type items ([7898e52](https://github.com/agentmail-to/agentmail-cli/commit/7898e52f357d2232cb5db0c22791692dabc13d30))
+
+
+### Chores
+
+* **ci:** skip uploading artifacts on stainless-internal branches ([5a4be3e](https://github.com/agentmail-to/agentmail-cli/commit/5a4be3e1c740c2b1f89d116f6cd9348fd81a5dae))
+* **internal:** codegen related update ([41d32f3](https://github.com/agentmail-to/agentmail-cli/commit/41d32f3b7bcb7c421d033e0d18c4cf70f7343dd2))
+
 ## 0.7.1 (2026-03-06)
 
 Full Changelog: [v0.7.0...v0.7.1](https://github.com/agentmail-to/agentmail-cli/compare/v0.7.0...v0.7.1)

internal/apiform/encoder.go

@@ -101,6 +101,15 @@ func (e *encoder) encodeArray(key string, val reflect.Value, writer *multipart.W
 		var values []string
 		for i := 0; i < val.Len(); i++ {
 			item := val.Index(i)
+			if (item.Kind() == reflect.Pointer || item.Kind() == reflect.Interface) && item.IsNil() {
+				// Null values are sent as an empty string
+				values = append(values, "")
+				continue
+			}
+			// If item is an interface, reduce it to the concrete type
+			if item.Kind() == reflect.Interface {
+				item = item.Elem()
+			}
 			var strValue string
 			switch item.Kind() {
 			case reflect.String:

internal/binaryparam/binary_param.go

@@ -17,7 +17,7 @@ func FileOrStdin(stdin io.ReadCloser, path string) (io.ReadCloser, bool, error)
 	// When the special glyph "-" is used, read from stdin. Although probably less necessary, also support
 	// special Unix files that refer to stdin.
 	switch path {
-	case stdinGlyph, "/dev/fd/0", "/dev/stdin":
+	case "", stdinGlyph, "/dev/fd/0", "/dev/stdin":
 		return stdin, true, nil
 	}
 

internal/binaryparam/binary_param_test.go

@@ -28,57 +28,32 @@ func TestFileOrStdin(t *testing.T) {
 		require.False(t, stdinInUse)
 	})
 
-	t.Run("WithStdinGlyph", func(t *testing.T) {
-		tempFile := t.TempDir() + "/test_file.txt"
-		require.NoError(t, os.WriteFile(tempFile, []byte(expectedContents), 0600))
-
-		stubStdin, err := os.Open(tempFile)
-		require.NoError(t, err)
-		t.Cleanup(func() { require.NoError(t, stubStdin.Close()) })
-
-		readCloser, stdinInUse, err := FileOrStdin(stubStdin, "-")
-		require.NoError(t, err)
-
-		actualContents, err := io.ReadAll(readCloser)
-		require.NoError(t, err)
-		require.Equal(t, expectedContents, string(actualContents))
-
-		require.True(t, stdinInUse)
-	})
-
-	t.Run("WithDevFD0File", func(t *testing.T) {
-		tempFile := t.TempDir() + "/dev_fd_0"
-		require.NoError(t, os.WriteFile(tempFile, []byte(expectedContents), 0600))
-
-		stubStdin, err := os.Open(tempFile)
-		require.NoError(t, err)
-		t.Cleanup(func() { require.NoError(t, stubStdin.Close()) })
-
-		readCloser, stdinInUse, err := FileOrStdin(stubStdin, "/dev/fd/0")
-		require.NoError(t, err)
-
-		actualContents, err := io.ReadAll(readCloser)
-		require.NoError(t, err)
-		require.Equal(t, expectedContents, string(actualContents))
-
-		require.True(t, stdinInUse)
-	})
-
-	t.Run("WithDevStdinFile", func(t *testing.T) {
-		tempFile := t.TempDir() + "/dev_stdin"
-		require.NoError(t, os.WriteFile(tempFile, []byte(expectedContents), 0600))
-
-		stubStdin, err := os.Open(tempFile)
-		require.NoError(t, err)
-		t.Cleanup(func() { require.NoError(t, stubStdin.Close()) })
-
-		readCloser, stdinInUse, err := FileOrStdin(stubStdin, "/dev/stdin")
-		require.NoError(t, err)
-
-		actualContents, err := io.ReadAll(readCloser)
-		require.NoError(t, err)
-		require.Equal(t, expectedContents, string(actualContents))
-
-		require.True(t, stdinInUse)
-	})
+	stdinTests := []struct {
+		testName string
+		path     string
+	}{
+		{"TestEmptyString", ""},
+		{"TestDash", "-"},
+		{"TestDevStdin", "/dev/stdin"},
+		{"TestDevFD0", "/dev/fd/0"},
+	}
+	for _, test := range stdinTests {
+		t.Run(test.testName, func(t *testing.T) {
+			tempFile := t.TempDir() + "/test_file.txt"
+			require.NoError(t, os.WriteFile(tempFile, []byte(expectedContents), 0600))
+
+			stubStdin, err := os.Open(tempFile)
+			require.NoError(t, err)
+			t.Cleanup(func() { require.NoError(t, stubStdin.Close()) })
+
+			readCloser, stdinInUse, err := FileOrStdin(stubStdin, test.path)
+			require.NoError(t, err)
+
+			actualContents, err := io.ReadAll(readCloser)
+			require.NoError(t, err)
+			require.Equal(t, expectedContents, string(actualContents))
+
+			require.True(t, stdinInUse)
+		})
+	}
 }

internal/mocktest/mocktest.go

@@ -1,6 +1,7 @@
 package mocktest
 
 import (
+	"bytes"
 	"context"
 	"fmt"
 	"net"
@@ -14,6 +15,7 @@ import (
 	"testing"
 	"time"
 
+	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
 )
 
@@ -54,8 +56,14 @@ func restoreNetwork(origClient, origDefault http.RoundTripper) {
 }
 
 // TestRunMockTestWithFlags runs a test against a mock server with the provided
-// CLI flags and ensures it succeeds
-func TestRunMockTestWithFlags(t *testing.T, flags ...string) {
+// CLI args and ensures it succeeds
+func TestRunMockTestWithFlags(t *testing.T, args ...string) {
+	TestRunMockTestWithPipeAndFlags(t, nil, args...)
+}
+
+// TestRunMockTestWithPipeAndFlags runs a test against a mock server with the provided
+// data piped over stdin and CLI args and ensures it succeeds
+func TestRunMockTestWithPipeAndFlags(t *testing.T, pipeData []byte, args ...string) {
 	origClient, origDefault := blockNetworkExceptMockServer()
 	defer restoreNetwork(origClient, origDefault)
 
@@ -71,52 +79,18 @@ func TestRunMockTestWithFlags(t *testing.T, flags ...string) {
 	_, filename, _, ok := runtime.Caller(0)
 	require.True(t, ok, "Could not get current file path")
 	dirPath := filepath.Dir(filename)
-	project := filepath.Join(dirPath, "..", "..", "cmd", "...")
-
-	args := []string{"run", project, "--base-url", mockServerURL.String()}
-	args = append(args, flags...)
-
-	t.Logf("Testing command: agentmail %s", strings.Join(args[4:], " "))
-
-	cliCmd := exec.Command("go", args...)
-
-	// Pipe the CLI tool's output into `head` so it doesn't hang when simulating
-	// paginated or streamed endpoints. 100 lines of output should be enough to
-	// test that the API endpoint worked, or report back a meaningful amount of
-	// data if something went wrong.
-	headCmd := exec.Command("head", "-n", "100")
-	pipe, err := cliCmd.StdoutPipe()
-	require.NoError(t, err, "Failed to create pipe for CLI command")
-	headCmd.Stdin = pipe
-
-	// Capture `head` output and CLI command stderr outputs:
-	var output strings.Builder
-	headCmd.Stdout = &output
-	headCmd.Stderr = &output
-	cliCmd.Stderr = &output
-
-	// First start `head`, so it's ready for data to come in:
-	err = headCmd.Start()
-	require.NoError(t, err, "Failed to start `head` command")
-
-	// Next start the CLI command so it can pipe data to `head` without
-	// buffering any data in advance:
-	err = cliCmd.Start()
-	require.NoError(t, err, "Failed to start CLI command")
-
-	// Ensure that the stdout pipe is closed as soon as `head` exits, to let the
-	// CLI tool know that no more output is needed and it can stop streaming
-	// test data for streaming/paginated endpoints. This needs to happen before
-	// calling `cliCmd.Wait()`, otherwise there will be a deadlock.
-	err = headCmd.Wait()
-	pipe.Close()
-	require.NoError(t, err, "`head` command finished with an error")
-
-	// Finally, wait for the CLI tool to finish up:
-	err = cliCmd.Wait()
-	require.NoError(t, err, "CLI command failed\n%s", output.String())
-
-	t.Logf("Test passed successfully\nOutput:\n%s", output.String())
+	project := filepath.Join(dirPath, "..", "..", "cmd", "agentmail")
+
+	args = append([]string{"run", project, "--base-url", mockServerURL.String()}, args...)
+
+	t.Logf("Testing command: go run ./cmd/agentmail %s", strings.Join(args[2:], " "))
+
+	cmd := exec.Command("go", args...)
+	cmd.Stdin = bytes.NewReader(pipeData)
+	output, err := cmd.CombinedOutput()
+	assert.NoError(t, err, "Test failed\nError: %v\nOutput: %s", err, output)
+
+	t.Logf("Test passed successfully\nOutput:\n%s", string(output))
 }
 
 func TestFile(t *testing.T, contents string) string {

internal/requestflag/requestflag.go

@@ -110,6 +110,40 @@ func ExtractRequestContents(cmd *cli.Command) RequestContents {
 	return res
 }
 
+func GetMissingRequiredFlags(cmd *cli.Command, body any) []cli.Flag {
+	missing := []cli.Flag{}
+	for _, flag := range cmd.Flags {
+		if flag.IsSet() {
+			continue
+		}
+
+		if required, ok := flag.(cli.RequiredFlag); ok && required.IsRequired() {
+			missing = append(missing, flag)
+			continue
+		}
+
+		if r, ok := flag.(RequiredFlagOrStdin); !ok || !r.IsRequiredAsFlagOrStdin() {
+			continue
+		}
+
+		if toSend, ok := flag.(InRequest); ok {
+			if toSend.IsBodyRoot() {
+				if body != nil {
+					continue
+				}
+			} else if bodyPath := toSend.GetBodyPath(); bodyPath != "" {
+				if bodyMap, ok := body.(map[string]any); ok {
+					if _, found := bodyMap[bodyPath]; found {
+						continue
+					}
+				}
+			}
+		}
+		missing = append(missing, flag)
+	}
+	return missing
+}
+
 // Implementation of the cli.Flag interface
 var _ cli.Flag = (*Flag[any])(nil) // Type assertion to ensure interface compliance
 
@@ -221,6 +255,19 @@ func (f *Flag[T]) SetCategory(c string) {
 var _ cli.RequiredFlag = (*Flag[any])(nil) // Type assertion to ensure interface compliance
 
 func (f *Flag[T]) IsRequired() bool {
+	// Intentionally don't use `f.Required`, because request flags may be passed
+	// over stdin as well as by flag.
+	if f.BodyPath != "" || f.BodyRoot {
+		return false
+	}
+	return f.Required
+}
+
+type RequiredFlagOrStdin interface {
+	IsRequiredAsFlagOrStdin() bool
+}
+
+func (f *Flag[T]) IsRequiredAsFlagOrStdin() bool {
 	return f.Required
 }
 

pkg/cmd/apikey_test.go

@@ -10,32 +10,44 @@ import (
 
 func TestAPIKeysCreate(t *testing.T) {
 	t.Skip("Mock server tests are disabled")
-	mocktest.TestRunMockTestWithFlags(
-		t,
-		"api-keys", "create",
-		"--api-key", "string",
-		"--name", "name",
-	)
+	t.Run("regular flags", func(t *testing.T) {
+		mocktest.TestRunMockTestWithFlags(
+			t, "api-keys", "create",
+			"--api-key", "string",
+			"--name", "name",
+		)
+	})
+
+	t.Run("piping data", func(t *testing.T) {
+		// Test piping YAML data over stdin
+		pipeData := []byte("name: name")
+		mocktest.TestRunMockTestWithPipeAndFlags(
+			t, pipeData, "api-keys", "create",
+			"--api-key", "string",
+		)
+	})
 }
 
 func TestAPIKeysList(t *testing.T) {
 	t.Skip("Mock server tests are disabled")
-	mocktest.TestRunMockTestWithFlags(
-		t,
-		"api-keys", "list",
-		"--api-key", "string",
-		"--ascending=true",
-		"--limit", "0",
-		"--page-token", "page_token",
-	)
+	t.Run("regular flags", func(t *testing.T) {
+		mocktest.TestRunMockTestWithFlags(
+			t, "api-keys", "list",
+			"--api-key", "string",
+			"--ascending=true",
+			"--limit", "0",
+			"--page-token", "page_token",
+		)
+	})
 }
 
 func TestAPIKeysDelete(t *testing.T) {
 	t.Skip("Mock server tests are disabled")
-	mocktest.TestRunMockTestWithFlags(
-		t,
-		"api-keys", "delete",
-		"--api-key", "string",
-		"--api-key", "api_key",
-	)
+	t.Run("regular flags", func(t *testing.T) {
+		mocktest.TestRunMockTestWithFlags(
+			t, "api-keys", "delete",
+			"--api-key", "string",
+			"--api-key", "api_key",
+		)
+	})
 }