Support openapiv2 proto annotations from sdk-core#1172

  sdk-core added protoc-gen-openapiv2 imports to cloud service protos.
  This broke proto generation in two ways:

  1. protoc couldn't resolve the import — none of the existing --proto_path
     entries point to a directory where protoc-gen-openapiv2/ is a child.
     Fix: add protos/ as --proto_path, but only for the cloud protos call
     (via extra_proto_paths param). Adding it globally causes duplicate
     definition errors since files under api_upstream/ become reachable
     through both protos/api_upstream and protos/.

  2. The generated service.rb requires the openapiv2 Ruby files, which
     didn't exist. generate_service_files loads service.rb to reflect on
     the service descriptor, so the missing require crashes the build.
     Fix: generate openapiv2 protos into lib/protoc-gen-openapiv2/.

  Mirrors sdk-dotnet#633.

Author: THardy98

temporalio/ext/src/client_rpc_generated.rs

@@ -976,6 +976,14 @@ impl Client {
                     cloud_service,
                     add_user_group_member
                 ),
+                "create_account_audit_log_sink" => rpc_call!(
+                    self,
+                    callback,
+                    call,
+                    CloudService,
+                    cloud_service,
+                    create_account_audit_log_sink
+                ),
                 "create_api_key" => rpc_call!(
                     self,
                     callback,
@@ -984,6 +992,14 @@ impl Client {
                     cloud_service,
                     create_api_key
                 ),
+                "create_billing_report" => rpc_call!(
+                    self,
+                    callback,
+                    call,
+                    CloudService,
+                    cloud_service,
+                    create_billing_report
+                ),
                 "create_connectivity_rule" => rpc_call!(
                     self,
                     callback,
@@ -1040,6 +1056,14 @@ impl Client {
                     cloud_service,
                     create_user_group
                 ),
+                "delete_account_audit_log_sink" => rpc_call!(
+                    self,
+                    callback,
+                    call,
+                    CloudService,
+                    cloud_service,
+                    delete_account_audit_log_sink
+                ),
                 "delete_api_key" => rpc_call!(
                     self,
                     callback,
@@ -1128,6 +1152,22 @@ impl Client {
                     cloud_service,
                     get_account
                 ),
+                "get_account_audit_log_sink" => rpc_call!(
+                    self,
+                    callback,
+                    call,
+                    CloudService,
+                    cloud_service,
+                    get_account_audit_log_sink
+                ),
+                "get_account_audit_log_sinks" => rpc_call!(
+                    self,
+                    callback,
+                    call,
+                    CloudService,
+                    cloud_service,
+                    get_account_audit_log_sinks
+                ),
                 "get_api_key" => rpc_call!(
                     self,
                     callback,
@@ -1152,6 +1192,22 @@ impl Client {
                     cloud_service,
                     get_async_operation
                 ),
+                "get_audit_logs" => rpc_call!(
+                    self,
+                    callback,
+                    call,
+                    CloudService,
+                    cloud_service,
+                    get_audit_logs
+                ),
+                "get_billing_report" => rpc_call!(
+                    self,
+                    callback,
+                    call,
+                    CloudService,
+                    cloud_service,
+                    get_billing_report
+                ),
                 "get_connectivity_rule" => rpc_call!(
                     self,
                     callback,
@@ -1168,6 +1224,14 @@ impl Client {
                     cloud_service,
                     get_connectivity_rules
                 ),
+                "get_current_identity" => rpc_call!(
+                    self,
+                    callback,
+                    call,
+                    CloudService,
+                    cloud_service,
+                    get_current_identity
+                ),
                 "get_namespace" => rpc_call!(
                     self,
                     callback,
@@ -1176,6 +1240,14 @@ impl Client {
                     cloud_service,
                     get_namespace
                 ),
+                "get_namespace_capacity_info" => rpc_call!(
+                    self,
+                    callback,
+                    call,
+                    CloudService,
+                    cloud_service,
+                    get_namespace_capacity_info
+                ),
                 "get_namespace_export_sink" => rpc_call!(
                     self,
                     callback,
@@ -1329,6 +1401,14 @@ impl Client {
                     cloud_service,
                     update_account
                 ),
+                "update_account_audit_log_sink" => rpc_call!(
+                    self,
+                    callback,
+                    call,
+                    CloudService,
+                    cloud_service,
+                    update_account_audit_log_sink
+                ),
                 "update_api_key" => rpc_call!(
                     self,
                     callback,

temporalio/ext/src/metric.rs

@@ -320,7 +320,8 @@ static METRIC_BUFFER_METRIC: Lazy<RClass> = Lazy::new(|ruby| {
 static METRIC_KIND_COUNTER: Lazy<StaticSymbol> = Lazy::new(|ruby| ruby.sym_new("counter"));
 static METRIC_KIND_GAUGE: Lazy<StaticSymbol> = Lazy::new(|ruby| ruby.sym_new("gauge"));
 static METRIC_KIND_HISTOGRAM: Lazy<StaticSymbol> = Lazy::new(|ruby| ruby.sym_new("histogram"));
-static METRIC_KIND_UP_DOWN_COUNTER: Lazy<StaticSymbol> = Lazy::new(|ruby| ruby.sym_new("up_down_counter"));
+static METRIC_KIND_UP_DOWN_COUNTER: Lazy<StaticSymbol> =
+    Lazy::new(|ruby| ruby.sym_new("up_down_counter"));
 
 pub fn convert_metric_events(
     ruby: &Ruby,

temporalio/extra/proto_gen.rb

@@ -12,7 +12,11 @@ def run
     generate_api_protos(Dir.glob('ext/sdk-core/crates/common/protos/api_upstream/**/*.proto').reject do |proto|
       proto.include?('google')
     end)
-    generate_api_protos(Dir.glob('ext/sdk-core/crates/common/protos/api_cloud_upstream/**/*.proto'))
+    generate_openapiv2_protos
+    generate_api_protos(
+      Dir.glob('ext/sdk-core/crates/common/protos/api_cloud_upstream/**/*.proto'),
+      extra_proto_paths: ['--proto_path=ext/sdk-core/crates/common/protos']
+    )
     generate_api_protos(Dir.glob('ext/sdk-core/crates/common/protos/testsrv_upstream/**/*.proto'))
     generate_api_protos(Dir.glob('ext/additional_protos/**/*.proto'))
     generate_import_helper_files
@@ -24,7 +28,7 @@ def run
 
   private
 
-  def generate_api_protos(api_protos)
+  def generate_api_protos(api_protos, extra_proto_paths: [])
     # Generate API to temp dir and move
     FileUtils.rm_rf('tmp-proto')
     FileUtils.mkdir_p('tmp-proto')
@@ -36,6 +40,7 @@ def generate_api_protos(api_protos)
       '--proto_path=ext/sdk-core/crates/common/protos/api_cloud_upstream',
       '--proto_path=ext/sdk-core/crates/common/protos/testsrv_upstream',
       '--proto_path=ext/additional_protos',
+      *extra_proto_paths,
       '--ruby_out=tmp-proto',
       *api_protos,
       exception: true
@@ -57,6 +62,22 @@ def generate_api_protos(api_protos)
     FileUtils.rm_rf('tmp-proto')
   end
 
+  def generate_openapiv2_protos
+    FileUtils.rm_rf('tmp-proto')
+    FileUtils.mkdir_p('tmp-proto')
+    system(
+      'bundle',
+      'exec',
+      'grpc_tools_ruby_protoc',
+      '--proto_path=ext/sdk-core/crates/common/protos',
+      '--ruby_out=tmp-proto',
+      *Dir.glob('ext/sdk-core/crates/common/protos/protoc-gen-openapiv2/**/*.proto'),
+      exception: true
+    )
+    FileUtils.cp_r('tmp-proto/protoc-gen-openapiv2', 'lib')
+    FileUtils.rm_rf('tmp-proto')
+  end
+
   def generate_import_helper_files
     # Write files that will help with imports. We are requiring the
     # request_response and not the service because the service depends on Google