module Scooter
  module HttpDispatchers
    module Orchestrator
      # Methods here are generally representative of endpoints
      module V1

        def initialize(host)
          super(host)
          @version = 'v1'
        end

        # jobs endpoints
        def get_last_jobs(limit=nil, offset=nil, order_by=nil, order=nil)
          path = "#{@version}/jobs"
          @connection.get(path) do |request|
            request.params['limit'] = limit if limit
            request.params['offset'] = offset if offset
            request.params['order_by'] = order_by if order_by
            request.params['order'] = order if order
          end
        end

        # plan_jobs endpoints
        def get_last_plan_jobs(limit=nil, offset=nil, results=nil)
          path = "#{@version}/plan_jobs"
          @connection.get(path) do |request|
            request.params['limit'] = limit if limit
            request.params['offset'] = offset if offset
            request.params['results'] = results if results
          end
        end

        def get_job(job_id)
          @connection.get("#{@version}/jobs/#{job_id}")
        end

        def get_nodes(job_id)
          @connection.get("#{@version}/jobs/#{job_id}/nodes")
        end

        def get_report(job_id)
          @connection.get("#{@version}/jobs/#{job_id}/report")
        end

        def get_events(job_id)
          @connection.get("#{@version}/jobs/#{job_id}/events")
        end

        #environments endpoints
        def get_environments
          @connection.get("v1/environments")
        end

        def get_environment(environment)
          @connection.get("#{@version}/environments/#{environment}")
        end

        def get_applications_in_environment(environment)
          @connection.get("#{@version}/environments/#{environment}/applications")
        end

        def get_instances_in_environment(environment)
          @connection.get("#{@version}/environments/#{environment}/instances")
        end

        #command endpoints
        def post_deploy(payload)
          @connection.post("#{@version}/command/deploy") do |req|
            req.body = payload
          end
        end

        def post_stop(payload)
          @connection.post("#{@version}/command/stop") do |req|
            req.body = payload
          end
        end

        def post_plan(payload)
          @connection.post("#{@version}/command/plan") do |req|
            req.body = payload
          end
        end

        def post_schedule_task(payload)
          @connection.post("#{@version}/command/schedule_task") do |req|
            req.body = payload
          end
        end

        def post_schedule_plan(payload)
          @connection.post("#{@version}/command/schedule_plan") do |req|
            req.body = payload
          end
        end

        #inventory endpoints
        def get_inventory(node=nil)
          url = "#{@version}/inventory"
          url << "/#{node}" if node
          @connection.get(url)
        end

        def post_inventory(payload)
          @connection.post("#{@version}/inventory") do |req|
            req.body = payload
          end
        end

        #status endpoint
        def get_status
          @connection.get("#{@version}/status")
        end

        #task endpoints
        def get_task(mod, task)
          @connection.get("#{@version}/tasks/#{mod}/#{task}")
        end

        def get_tasks
          @connection.get("#{@version}/tasks")
        end

        def post_task(payload)
          @connection.post("#{@version}/command/task") do |req|
            req.body = payload
          end
        end

        #dumpling endpoints
        def post_dumpling(payload)
          @connection.post("#{@version}/dumplings") do |req|
            req.body = payload
          end
        end

        #task plan endpoints
        def start_plan(payload)
          @connection.post("#{@version}/command/plan_start") do |req|
            req.body = payload
          end
        end

        def finish_plan(payload)
          @connection.post("#{@version}/command/plan_finish") do |req|
            req.body = payload
          end
        end

        def plan_task(payload)
          @connection.post("#{@version}/command/plan_task") do |req|
            req.body = payload
          end
        end

        def get_plan_job(plan_job_id)
          @connection.get("#{@version}/plan_jobs/#{plan_job_id}")
        end

        def get_scheduled_jobs(limit=nil, offset=nil)
          path = "#{@version}/scheduled_jobs"
          @connection.get(path) do |request|
            request.params['limit'] = limit if limit
            request.params['offset'] = offset if offset
          end
        end

        def delete_scheduled_job(job_id)
          @connection.delete("#{@version}/scheduled_jobs/#{job_id}")
        end
      end
    end
  end
end