Wait several times and specific amount of seconds each, for restore t…

…asks's RestoreSession (#5)
virtuozzo · May 26, 2020 · 90f8647 · 90f8647
1 parent 5020e21
commit 90f8647
Showing 1 changed file with 10 additions and 3 deletions.
diff --git a/restore_recovery_point.rb b/restore_recovery_point.rb
@@ -1,6 +1,8 @@
 Backups::Plugin.hook helpers: %i[client_helper task_helper query_helper session_helper] do
   RESTORE_RESULT_KEY_CHAIN = %i[QueryResult Entities RestoreSessions RestoreSession Result].freeze
   RESTORE_SESSION_REGEX = %r{restoreSessions\/(.*)}
+  TASK_GET_INTERVAL = 10 # seconds
+  TASK_GET_RETRIES = 10 # times
 
   def call(recovery_point, _virtual_server)
     restore_path = "vmRestorePoints/#{recovery_point.metadata[:veeam_id]}?action=restore"
@@ -10,9 +12,14 @@ def call(recovery_point, _virtual_server)
 
       task_poller(task_path).run
 
-      links = api_get(task_path)[:Task][:Links][:Link]
-
-      links.is_a?(Array) ? links.detect { |hash| hash[:Type] == 'RestoreSession' }[:Href] : nil
+      r = 1 # Wait TASK_GET_RETRIES times and TASK_GET_INTERVAL seconds each, for tasks's RestoreSession
+      until r == TASK_GET_RETRIES do
+          links = api_get(task_path)[:Task][:Links][:Link]
+          link = links.is_a?(Array) ? links.detect { |hash| hash[:Type] == 'RestoreSession' }[:Href] : nil
+          break link if link
+          sleep(TASK_GET_INTERVAL)
+          r +=1
+      end
     end
 
     return error('Unable to start restore session') unless restore_session_url