Add api key support to nexus sample

nexus/options/cli.go

@@ -2,6 +2,7 @@
 package options
 
 import (
+	"context"
 	"flag"
 	"fmt"
 	"os"
@@ -10,6 +11,8 @@ import (
 	"crypto/x509"
 
 	"go.temporal.io/sdk/client"
+	"google.golang.org/grpc"
+	"google.golang.org/grpc/metadata"
 )
 
 // ParseClientOptionFlags parses the given arguments into client options. In
@@ -21,20 +24,24 @@ func ParseClientOptionFlags(args []string) (client.Options, error) {
 	targetHost := set.String("target-host", "localhost:7233", "Host:port for the Temporal service")
 	namespace := set.String("namespace", "default", "Namespace to connect to")
 	serverRootCACert := set.String("server-root-ca-cert", "", "Optional path to root server CA cert")
-	clientCert := set.String("client-cert", "", "Optional path to client cert")
-	clientKey := set.String("client-key", "", "Optional path to client key")
+	clientCert := set.String("client-cert", "", "Optional path to client cert, mutually exclusive with API key")
+	clientKey := set.String("client-key", "", "Optional path to client key, mutually exclusive with API key")
 	serverName := set.String("server-name", "", "Server name to use for verifying the server's certificate")
 	insecureSkipVerify := set.Bool("insecure-skip-verify", false, "Skip verification of the server's certificate and host name")
+	apiKey := set.String("api-key", "", "Optional API key, mutually exclusive with cert/key")
 
 	if err := set.Parse(args); err != nil {
 		return client.Options{}, fmt.Errorf("failed parsing args: %w", err)
 	}
 	if *clientCert != "" && *clientKey == "" || *clientCert == "" && *clientKey != "" {
 		return client.Options{}, fmt.Errorf("either both or neither of -client-key and -client-cert are required")
 	}
+	if *clientCert != "" && *apiKey != "" {
+		return client.Options{}, fmt.Errorf("either -client-cert and -client-key or -api-key are required, not both")
+	}
 
 	var connectionOptions client.ConnectionOptions
-
+	var credentials client.Credentials
 	if *clientCert != "" {
 		// Load client cert
 		cert, err := tls.LoadX509KeyPair(*clientCert, *clientKey)
@@ -64,12 +71,33 @@ func ParseClientOptionFlags(args []string) (client.Options, error) {
 				InsecureSkipVerify: *insecureSkipVerify,
 			},
 		}
+	} else if *apiKey != "" {
+		connectionOptions = client.ConnectionOptions{
+			TLS: &tls.Config{},
+			DialOptions: []grpc.DialOption{
+				grpc.WithUnaryInterceptor(
+					func(ctx context.Context, method string, req any, reply any, cc *grpc.ClientConn, invoker grpc.UnaryInvoker, opts ...grpc.CallOption) error {
+						return invoker(
+							metadata.AppendToOutgoingContext(ctx, "temporal-namespace", *namespace),
+							method,
+							req,
+							reply,
+							cc,
+							opts...,
+						)
+					},
+				),
+			},
+		}
+		credentials = client.NewAPIKeyStaticCredentials(*apiKey)
 	}
 
 	return client.Options{
 		HostPort:          *targetHost,
 		Namespace:         *namespace,
 		ConnectionOptions: connectionOptions,
+		Credentials:       credentials,
 	}, nil
 }
-// @@@SNIPEND
+
+// @@@SNIPEND