// TODO: Get appropriate copyright header

package awx

import (
	"fmt"
)

// WorkflowJobsResource defines the resource for workflow jobs
type WorkflowJobsResource struct {
	Resource
}

// NewWorkflowJobsResource Creating a new WorkflowJobsResource
func NewWorkflowJobsResource(connection Connecter, path string) WorkflowActions {
	resource := new(WorkflowJobsResource)
	resource.connection = connection
	resource.path = path
	return resource
}

// Get retrieves the sender request for this resource
func (r *WorkflowJobsResource) Get() Sender {
	request := new(WorkflowJobsGetRequest)
	request.resource = &r.Resource
	request.addFilter("page_size", defaultPageSize)
	return request
}

// ID retrieves the getter resource for this resource
func (r *WorkflowJobsResource) ID(id int) Getter {
	return NewWorkflowJobResource(r.connection, fmt.Sprintf("%s/%d", r.path, id))
}

// Nodes retrieves the getter resource for this resource
func (r *WorkflowJobsResource) Nodes(id int) Getter {
	return NewWorkflowJobNodesResource(r.connection, fmt.Sprintf("%s/%d/workflow_nodes", r.path, id))
}

// WorkflowJobsGetRequest defines the get request for workflow jobs
type WorkflowJobsGetRequest struct {
	Request
}

// Filter adds the given filter to the workflow jobs get request and returns it
func (r *WorkflowJobsGetRequest) Filter(name string, value interface{}) Sender {
	r.addFilter(name, value)
	return r
}

// Send sends the workflow job get request and returns the response
func (r *WorkflowJobsGetRequest) Send() (response interface{}, err error) {
	response = new(WorkflowJobsGetResponse)
	err = r.get(response)
	if err != nil {
		return
	}
	return
}