support long poll option for get_workflow_execution_history

lib/temporal/connection/grpc.rb

@@ -187,8 +187,18 @@ def get_workflow_execution_history(
           wait_new_event: wait_for_new_event,
           history_event_filter_type: HISTORY_EVENT_FILTER[event_type]
         )
-        deadline = timeout ? Time.now + timeout : nil
-        client.get_workflow_execution_history(request, deadline: deadline)
+
+        loop do
+          deadline = timeout ? Time.now + timeout : nil
+          response = client.get_workflow_execution_history(request, deadline: deadline)
+
+          if wait_for_new_event && response.history.events.empty? && !response.next_page_token.empty?
+            request.next_page_token = response.next_page_token
+            next
+          end
+
+          return response
+        end
       end
 
       def poll_workflow_task_queue(namespace:, task_queue:, binary_checksum:)

spec/unit/lib/temporal/client_spec.rb

@@ -556,6 +556,30 @@ class NamespacedWorkflow < Temporal::Workflow
           )
         end.to raise_error(Temporal::TimeoutError)
     end
+
+    it 'recurring polling until a close event is received'
+      completed_event = Fabricate(:workflow_completed_event, result: nil)
+      response_with_no_closed_event = Fabricate(:workflow_execution_history, events: [], _next_page_token: 'test_token')
+      response_with_closed_event = Fabricate(:workflow_execution_history, events: [completed_event])
+
+      expect(connection)
+        .to receive(:get_workflow_execution_history)
+        .with(
+          namespace: 'default-test-namespace',
+          workflow_id: workflow_id,
+          run_id: run_id,
+          wait_for_new_event: true,
+          event_type: :close,
+          timeout: 30,
+        )
+        .and_return(response_with_no_closed_event, response_with_closed_event)
+
+        subject.await_workflow_result(
+          TestStartWorkflow,
+          workflow_id: workflow_id,
+          run_id: run_id,
+        )
+    end
   end
 
   describe '#reset_workflow' do