require File.join(File.dirname(__FILE__), 'http_enabled')
require File.join(File.dirname(__FILE__), 'api_auth')
require File.join(File.dirname(__FILE__), 'worker')

module SimpleWorker

    class Service < SimpleWorker::ApiAuth

        include SimpleWorker::HttpEnabled

        def initialize(access_key, secret_key, options={})
            super(access_key, secret_key, options)
        end

        # Options:
        #    - :callback_url
        def upload(filename, class_name, options={})
            mystring = nil
            file = File.open(filename, "r") do |f|
                mystring = f.read
            end
            options = {"code"=>mystring, "class_name"=>class_name}
            response = run_http(@host, @access_key, @secret_key, :post, "code/put", nil, options)
#            puts "response=" + response
            return ActiveSupport::JSON.decode(response)
        end

        #
        # data: 
        def queue(class_name, data={})

            params = nil
            if !data.is_a?(Array)
                data = [data]
            end
            hash_to_send = {}
            hash_to_send["data"] = data
            hash_to_send["class_name"] = class_name
            puts 'hash_to_send=' + hash_to_send.inspect
            response = run_http(@host, @access_key, @secret_key, :put, "queue/add", hash_to_send, params)
            puts "response=" + response
            return ActiveSupport::JSON.decode(response)

        end

        def queue_raw(class_name, data={})
            params = nil
            hash_to_send = data
            #            puts 'hash_to_send=' + hash_to_send.inspect
            response = run_http(@host, @access_key, @secret_key, :put, "queue/add", hash_to_send, params)
            #            puts "response=" + response
            return ActiveSupport::JSON.decode(response)
        end


        #
        # schedule: hash of scheduling options that can include:
        #     Required:
        #     - start_at:      Time of first run - DateTime or Time object.
        #     Optional:
        #     - run_every:     Time in seconds between runs. If ommitted, task will only run once.
        #     - delay_type:    Fixed Rate or Fixed Delay. Default is fixed_delay.
        #     - end_at:        Scheduled task will stop running after this date (optional, if ommitted, runs forever or until cancelled)
        #     - run_times:     Task will run exactly :run_times. For instance if :run_times is 5, then the task will run 5 times.
        #
        def schedule(class_name, data, schedule)
            raise "Schedule must be a hash." if !schedule.is_a? Hash
            params = nil
            if !data.is_a?(Array)
                data = [data]
            end
            hash_to_send = {}
            hash_to_send["data"] = data
            hash_to_send["class_name"] = class_name
            hash_to_send["schedule"] = schedule
#            puts 'hash_to_send=' + hash_to_send.inspect
            response = run_http(@host, @access_key, @secret_key, :put, "queue/schedule", hash_to_send, params)
#            puts "response=" + response
            return ActiveSupport::JSON.decode(response)
        end

        #
        #
        #
        def get_scheduled_tasks(schedule_id)
            params = nil
            if !data.is_a?(Array)
                data = [data]
            end
            hash_to_send = {}
            hash_to_send["data"] = data
            hash_to_send["class_name"] = class_name
#            puts 'hash_to_send=' + hash_to_send.inspect
            response = run_http(@host, @access_key, @secret_key, :put, "queue/add", hash_to_send, params)
#            puts "response=" + response
            return ActiveSupport::JSON.decode(response)
        end

        def status(task_id)
            data = {"task_id"=>task_id}
            #puts run_http(@access_key, @secret_key, :post, "queue/status", nil, {"task_id"=>@task_id})
            response = run_http(@host, @access_key, @secret_key, :get, "queue/status", nil, data)
#            puts "response=" + response
            return ActiveSupport::JSON.decode(response)
        end


    end
end