Merge pull request #7 from bitovi/sdk-temporal-cloud-api

Using (experimental) Cloud API from Temporal SDK directly

Author: phillipskevin

encryption_jwt/README.md

@@ -140,38 +140,4 @@ Open the Web UI and select a workflow, you'll only see encrypted results. To see
 Once those requirements are met you can then see the unencrypted results. This is possible because
 CORS settings in the codec server allow the browser to access the codec server directly over
 localhost. Decrypted data never leaves your local machine. See [Codec
-Server](https://docs.temporal.io/production-deployment/data-encryption)
-
-## Protobuf
-
-> [!WARNING]
-> You will not normally need to rebuild protobuf support; the generated files have been committed to
-> this repo. The instructions are included because:
-> - If the API changes these steps will need to be followed to get those changes
-> - A reminder of how to generate the protobuf files for python 😃
-
-To rebuild protobuf support.
-
-1. Install the python [grpc_tools](https://grpc.io/docs/languages/python/quickstart/) for protobufs.
-1. Clone the following two repositories (you need to copy files from them, they can be deleted after
-   setup):
-
-```sh
-git clone https://github.com/temporalio/api-cloud.git
-git clone https://github.com/googleapis/googleapis.git
-```
-
-3. Copy the `temporal` directory and its contents, from `api_cloud` into the root of this **project**.
-1. Copy the `google` directory and its contents, from `googleapis` into the root of this
-   **project**.
-1. From the project root generate the python wrappers for each subdirectory of `temporal/api/cloud`
-   and `google/api` like so:
-
-```sh
-python -m grpc_tools.protoc -I./ --python_out=./ --grpc_python_out=./ temporal/api/cloud/cloudservice/v1/*.proto
-python -m grpc_tools.protoc -I./ --python_out=./ --grpc_python_out=./ temporal/api/cloud/identity/v1/*.proto
-python -m grpc_tools.protoc -I./ --python_out=./ --grpc_python_out=./ temporal/api/cloud/namespace/v1/*.proto
-python -m grpc_tools.protoc -I./ --python_out=./ --grpc_python_out=./ temporal/api/cloud/operation/v1/*.proto
-python -m grpc_tools.protoc -I./ --python_out=./ --grpc_python_out=./ temporal/api/cloud/region/v1/*.proto
-python -m grpc_tools.protoc -I./ --python_out=./ --grpc_python_out=./ google/api/*.proto
-```
+Server](https://docs.temporal.io/production-deployment/data-encryption)

encryption_jwt/codec_server.py

@@ -6,11 +6,10 @@
 from aiohttp import hdrs, web
 
 from temporalio.api.common.v1 import Payload, Payloads
+from temporalio.api.cloud.cloudservice.v1 import request_response_pb2, service_pb2_grpc
 from google.protobuf import json_format
-from temporal.api.cloud.cloudservice.v1 import request_response_pb2, service_pb2_grpc
 from encryption_jwt.codec import EncryptionCodec
 
-
 DECRYPT_ROLES = ["admin"]
 
 temporal_ops_address = "saas-api.tmprl.cloud:443"
@@ -76,7 +75,7 @@ async def handler(req: web.Request):
                 decoded["https://saas-api.tmprl.cloud/user/email"])
             if role.lower() in DECRYPT_ROLES:
                 codec = EncryptionCodec(namespace)
-                payloads = Payloads(payloads=await codec[fn](payloads.payloads))
+                payloads = Payloads(payloads=await  getattr(codec, fn)(payloads.payloads))
 
             # Apply CORS and return JSON
             resp = await cors_options(req)