process.go

package cloud66

import "strconv"

type Process struct {
	Name                string         `json:"name"`
	Md5                 string         `json:"md5"`
	Command             string         `json:"command"`
	ServerProcessCount  map[string]int `json:"servers"`
	ServerProcessPauses map[string]int `json:"servers_pauses"`
}

func (c *Client) GetProcesses(stackUid string, serverUid *string) ([]Process, error) {
	queryStrings := make(map[string]string)
	queryStrings["page"] = "1"

	if serverUid != nil {
		queryStrings["server_uid"] = *serverUid
	}

	var p Pagination
	var result []Process
	var processRes []Process

	for {
		req, err := c.NewRequest("GET", "/stacks/"+stackUid+"/processes.json", nil, queryStrings)
		if err != nil {
			return nil, err
		}

		processRes = nil
		err = c.DoReq(req, &processRes, &p)
		if err != nil {
			return nil, err
		}

		result = append(result, processRes...)
		if p.Current < p.Next {
			queryStrings["page"] = strconv.Itoa(p.Next)
		} else {
			break
		}
	}
	return result, nil
}

func (c *Client) GetProcess(stackUid string, name string, serverUid *string) (*Process, error) {
	queryStrings := make(map[string]string)
	queryStrings["page"] = "1"
	if serverUid != nil {
		queryStrings["server_uid"] = *serverUid
	}

	req, err := c.NewRequest("GET", "/stacks/"+stackUid+"/processes/"+name+".json", nil, queryStrings)
	if err != nil {
		return nil, err
	}
	var processRes *Process
	return processRes, c.DoReq(req, &processRes, nil)
}

func (c *Client) ScaleProcess(stackUid string, processName string, serverCount map[string]int) (*AsyncResult, error) {
	params := struct {
		ProcessName string         `json:"process_name"`
		ServerCount map[string]int `json:"server_count"`
	}{
		ProcessName: processName,
		ServerCount: serverCount,
	}
	req, err := c.NewRequest("POST", "/stacks/"+stackUid+"/processes.json", params, nil)
	if err != nil {
		return nil, err
	}
	var asyncRes *AsyncResult
	return asyncRes, c.DoReq(req, &asyncRes, nil)
}

func (c *Client) InvokeProcessAction(stackUid string, processName *string, serverUid *string, action string) (*AsyncResult, error) {
	var params interface{}
	if serverUid != nil && processName != nil {
		params = struct {
			Command     string `json:"command"`
			ProcessName string `json:"process_name"`
			ServerUid   string `json:"server_uid"`
		}{
			Command:     action,
			ProcessName: *processName,
			ServerUid:   *serverUid,
		}
	} else if serverUid == nil {
		params = struct {
			Command     string `json:"command"`
			ProcessName string `json:"process_name"`
		}{
			Command:     action,
			ProcessName: *processName,
		}
	} else if processName == nil {
		params = struct {
			Command   string `json:"command"`
			ServerUid string `json:"server_uid"`
		}{
			Command:   action,
			ServerUid: *serverUid,
		}
	}
	req, err := c.NewRequest("POST", "/stacks/"+stackUid+"/actions.json", params, nil)
	if err != nil {
		return nil, err
	}
	var asyncRes *AsyncResult
	return asyncRes, c.DoReq(req, &asyncRes, nil)
}