require 'flydata/util/file_util'
require 'flydata/api_client'
require 'flydata/helper/base_action'

module Flydata
  module Helper
    module Action
      class CheckRemoteActions < BaseAction
        include FlydataCore::Logger

        MAX_ERROR_RETRY = 20

        def initialize(config)
          super
          @api_client = ApiClient.instance
          @retry_count = 0
        end

        def execute(opts = {})
          action_position = ActionPosition.new(config[:helper])

          # Get actions from flydata web server
          last_id = action_position.load
          actions = nil
          begin
            actions = @api_client.agent.actions(last_id)
            @retry_count = 0
          rescue => e
            if @retry_count >= MAX_ERROR_RETRY
              @retry_count = 0
              raise
            else
               @retry_count += 1
               log_warn "Failed to get actions with error '#{e.to_s}'.  Wait for the next turn."
               actions = {'actions' => []}
            end
          end

          actions['actions'].each do |action|
            action_name = action['name']
            action_id = action['id'].to_i
            action_info = { id: action_id, config: action['config'] }
            # Request action
            yield action_name.to_sym, action_info
            last_id = action_id if action_id > last_id
          end

          if last_id > 0
            action_position.save(last_id)
            true   # for debug
          else
            false  # for debug
          end
        end
      end

      class ActionPosition
        include Util::FileUtil

        def initialize(config)
          @path = config.helper_action_position_path
        end
        def save(position)
          write_line(@path, position.to_s)
        end
        def load
          read_line(@path).to_i
        end
      end
    end
  end
end