Added list_namespace to client and fixed gRPC request (coinbase#137)

Author: calum-stripe

examples/spec/integration/list_namespaces_spec.rb

@@ -0,0 +1,6 @@
+describe 'Temporal.list_namespaces', :integration do
+  it 'returns the correct values' do
+    result = Temporal.list_namespaces(page_size: 100)
+    expect(result).to be_an_instance_of(Temporal::Api::WorkflowService::V1::ListNamespacesResponse)
+  end
+end

lib/temporal.rb

@@ -18,6 +18,7 @@ module Temporal
                  :schedule_workflow,
                  :register_namespace,
                  :describe_namespace,
+                 :list_namespaces,
                  :signal_workflow,
                  :await_workflow_result,
                  :reset_workflow,

lib/temporal/client.rb

@@ -143,6 +143,14 @@ def describe_namespace(name)
       connection.describe_namespace(name: name)
     end
 
+    # Fetches all the namespaces.
+    #
+    # @param page_size [Integer] number of namespace results to return per page.
+    # @param next_page_token [String] a optional pagination token returned by a previous list_namespaces call
+    def list_namespaces(page_size:, next_page_token: "")
+      connection.list_namespaces(page_size: page_size, next_page_token: next_page_token)
+    end
+
     # Send a signal to a running workflow
     #
     # @param workflow [Temporal::Workflow, nil] workflow class or nil

lib/temporal/connection/grpc.rb

@@ -50,8 +50,8 @@ def describe_namespace(name:)
         client.describe_namespace(request)
       end
 
-      def list_namespaces(page_size:)
-        request = Temporal::Api::WorkflowService::V1::ListNamespacesRequest.new(pageSize: page_size)
+      def list_namespaces(page_size:, next_page_token: "")
+        request = Temporal::Api::WorkflowService::V1::ListNamespacesRequest.new(page_size: page_size, next_page_token: next_page_token)
         client.list_namespaces(request)
       end
 

spec/unit/lib/temporal/grpc_client_spec.rb

@@ -73,6 +73,32 @@
     end
   end
 
+  describe "#list_namespaces" do
+    let (:response) do
+      Temporal::Api::WorkflowService::V1::ListNamespacesResponse.new(
+        namespaces: [Temporal::Api::WorkflowService::V1::DescribeNamespaceResponse.new],
+        next_page_token: ""
+      )
+    end
+
+    before { allow(grpc_stub).to receive(:list_namespaces).and_return(response) }
+
+    it 'calls GRPC service with supplied arguments' do
+      next_page_token = "next-page-token-id"
+
+      subject.list_namespaces(
+        page_size: 10,
+        next_page_token: next_page_token,
+      )
+
+      expect(grpc_stub).to have_received(:list_namespaces) do |request|
+        expect(request).to be_an_instance_of(Temporal::Api::WorkflowService::V1::ListNamespacesRequest)
+        expect(request.page_size).to eq(10)
+        expect(request.next_page_token).to eq(next_page_token)
+      end
+    end
+  end
+
   describe '#get_workflow_execution_history' do
     let(:response) do
       Temporal::Api::WorkflowService::V1::GetWorkflowExecutionHistoryResponse.new(