Merge pull request #3 from temporalio/abhinav/setAPIVersion

Set api version

Makefile

@@ -27,8 +27,9 @@ copy-api-cloud-api:
 	@printf $(COLOR) "Copy api-cloud..."
 	rm -rf $(PROTO_ROOT)/temporal/api
 	mkdir -p $(PROTO_ROOT)/temporal/api
-	git clone [email protected]:temporalio/api-cloud.git --depth=1 --branch abhinav/userMgmt --single-branch $(PROTO_ROOT)/api-cloud-tmp
+	git clone [email protected]:temporalio/api-cloud.git --depth=1 --branch main --single-branch $(PROTO_ROOT)/api-cloud-tmp
 	mv -f $(PROTO_ROOT)/api-cloud-tmp/temporal/api/cloud $(PROTO_ROOT)/temporal/api
+	mv $(PROTO_ROOT)/api-cloud-tmp/VERSION client/api/version
 	rm -rf $(PROTO_ROOT)/api-cloud-tmp
 
 ##### Compile proto files for go #####

client/api/client.go

@@ -1,18 +1,16 @@
 package api
 
 import (
+	"context"
 	"crypto/tls"
 	"fmt"
 	"net/url"
+	"strings"
 
 	"google.golang.org/grpc"
 	"google.golang.org/grpc/credentials"
 	"google.golang.org/grpc/credentials/insecure"
-)
-
-const (
-	VersionHeader = "cloud-operations-workflows-version"
-	CommitHeader  = "cloud-operations-workflows-commit"
+	"google.golang.org/grpc/metadata"
 )
 
 func NewConnectionWithAPIKey(addrStr string, allowInsecure bool, apiKey string, opts ...grpc.DialOption) (*grpc.ClientConn, error) {
@@ -53,6 +51,20 @@ func defaultDialOptions(addr *url.URL, allowInsecure bool) ([]grpc.DialOption, e
 	if allowInsecure {
 		transport = insecure.NewCredentials()
 	}
+
 	opts = append(opts, grpc.WithTransportCredentials(transport))
+	opts = append(opts, grpc.WithUnaryInterceptor(setAPIVersionInterceptor))
 	return opts, nil
 }
+
+func setAPIVersionInterceptor(
+	ctx context.Context,
+	method string,
+	req, reply interface{},
+	cc *grpc.ClientConn,
+	invoker grpc.UnaryInvoker,
+	opts ...grpc.CallOption,
+) error {
+	ctx = metadata.AppendToOutgoingContext(ctx, TemporalCloudAPIVersionHeader, strings.TrimSpace(TemporalCloudAPIVersion))
+	return invoker(ctx, method, req, reply, cc, opts...)
+}

client/api/version

@@ -0,0 +1 @@
+2023-10-01-00

client/api/version.go

@@ -0,0 +1,12 @@
+package api
+
+import _ "embed"
+
+const (
+	TemporalCloudAPIVersionHeader = "temporal-cloud-api-version"
+)
+
+var (
+	//go:embed version
+	TemporalCloudAPIVersion string
+)

cmd/worker/README.md

@@ -24,12 +24,12 @@ Generate an apikey by either visiting the [Cloud UI](https://cloud.temporal.io/s
 ### Step 2: Start the worker 
 Start the worker using the APIKey
 ```
-TEMPORAL_CLOUD_API_KEY=<apikey> go run ./demo
+TEMPORAL_CLOUD_API_KEY=<apikey> go run ./cmd/worker
 ```
 
 ### Step 3: Run a workflow
 Run a workflow using `tctl` for example to invoke `get-users` workflow run:
 ```
-tctl wf start --tq demo --wt cloud-operations-workflows.get-users -i '{}'
+tctl wf start --tq demo --wt tmprlcloud-wf.get-users -i '{}'
 ```