# encoding: UTF-8
#
# Copyright (c) 2010-2017 GoodData Corporation. All rights reserved.
# This source code is licensed under the BSD-style license found in the
# LICENSE file in the root directory of this source tree.

require_relative '../rest/resource'
require_relative '../extensions/hash'

module GoodData
  class Execution < Rest::Resource
    attr_reader :dirty, :json

    alias_method :data, :json

    # Initializes object instance from raw wire JSON
    #
    # @param json Json used for initialization
    def initialize(json)
      super
      @json = json
    end

    # Timestamp when execution was created
    def created
      Time.parse(json['execution']['createdTime'])
    end

    # Data for execution
    def data
      @client.get(json['execution']['data'])
    end

    # Has execution failed?
    def error?
      status == :error
    end

    # Timestamp when execution was finished
    def finished
      json['execution']['endTime'] && Time.parse(json['execution']['endTime'])
    end

    # Log for execution
    def log
      @client.get(json['execution']['log'])
    end

    # Is execution ok?
    def ok?
      status == :ok
    end

    # Returns schedule URL
    #
    # @return [String] Schedule URL
    def schedule_uri
      uri = @json['execution']['links']['self'] if @json && @json['execution'] && @json['execution']['links']
      uri.split('/')[0..-3].join('/')
    end

    # Is execution running?
    def running?
      status == :running
    end

    # Returns schedule
    #
    # @return [String] Schedule URL
    def schedule
      schedule_uri && project.schedules(schedule_uri)
    end

    # Timestamp when execution was started
    def started
      Time.parse(json['execution']['startTime'])
    end

    # Status of execution
    def status
      json['execution']['status'].downcase.to_sym
    end

    # Returns URL
    #
    # @return [String] Schedule URL
    def uri
      @json['execution']['links']['self'] if @json && @json['execution'] && @json['execution']['links']
    end

    # Wait for execution result, status different than RUNNING or SCHEDULED
    #
    # @return [GoodData::Execution] Execution result
    def wait_for_result(options = {})
      start_time = Time.now
      timeout = options[:timeout]
      res = client.poll_on_response(uri, options) do |body|
        timeout_exceeded = timeout && (start_time + timeout) < Time.now
        fail 'Waiting for schedule execution timed out.' if timeout_exceeded

        body['execution'] && (body['execution']['status'] == 'RUNNING' || body['execution']['status'] == 'SCHEDULED')
      end
      @json = res
      self
    end

    def duration
      if running?
        Time.now - started
      else
        finished && finished - started
      end
    end

    # Compares two executions - based on their URI
    def ==(other)
      other.respond_to?(:uri) && other.uri == uri && other.respond_to?(:to_hash) && other.to_hash == to_hash
    end
  end
end