feat(agent): add jwtsource package for reading projected SA tokens

internal/cyberark/jwtsource/jwtsource.go

@@ -0,0 +1,39 @@
+// internal/cyberark/jwtsource/jwtsource.go
+package jwtsource
+
+import (
+	"context"
+	"fmt"
+	"os"
+	"strings"
+)
+
+// DefaultTokenPath is the default projected ServiceAccount token mount (aud=conjur).
+const DefaultTokenPath = "/var/run/secrets/tokens/jwt"
+
+// Source produces a raw JWT to exchange at SMS authn-jwt.
+type Source interface {
+	Read(ctx context.Context) (string, error)
+}
+
+type fileSource struct{ path string }
+
+// NewFileSource reads a JWT from a file (the projected SA token).
+func NewFileSource(path string) Source {
+	if path == "" {
+		path = DefaultTokenPath
+	}
+	return &fileSource{path: path}
+}
+
+func (f *fileSource) Read(_ context.Context) (string, error) {
+	b, err := os.ReadFile(f.path)
+	if err != nil {
+		return "", fmt.Errorf("jwt source file %q not found or unreadable (is the projected serviceAccountToken volume mounted?): %w", f.path, err)
+	}
+	tok := strings.TrimSpace(string(b))
+	if tok == "" {
+		return "", fmt.Errorf("jwt source file %q is empty", f.path)
+	}
+	return tok, nil
+}

internal/cyberark/jwtsource/jwtsource_test.go

@@ -0,0 +1,33 @@
+// internal/cyberark/jwtsource/jwtsource_test.go
+package jwtsource
+
+import (
+	"context"
+	"os"
+	"path/filepath"
+	"testing"
+
+	"github.com/stretchr/testify/require"
+)
+
+func TestFileSource_ReadsToken(t *testing.T) {
+	dir := t.TempDir()
+	p := filepath.Join(dir, "jwt")
+	require.NoError(t, os.WriteFile(p, []byte("the-jwt\n"), 0o600))
+	got, err := NewFileSource(p).Read(context.Background())
+	require.NoError(t, err)
+	require.Equal(t, "the-jwt", got) // trimmed
+}
+
+func TestFileSource_MissingFile(t *testing.T) {
+	_, err := NewFileSource("/no/such/file").Read(context.Background())
+	require.Error(t, err)
+}
+
+func TestFileSource_EmptyFile(t *testing.T) {
+	dir := t.TempDir()
+	p := filepath.Join(dir, "jwt")
+	require.NoError(t, os.WriteFile(p, []byte("  \n"), 0o600))
+	_, err := NewFileSource(p).Read(context.Background())
+	require.Error(t, err)
+}