mirror of https://github.com/status-im/consul.git
161 lines
4.4 KiB
Go
161 lines
4.4 KiB
Go
package packngo
|
|
|
|
import (
|
|
"fmt"
|
|
"strings"
|
|
)
|
|
|
|
const projectBasePath = "/projects"
|
|
|
|
// ProjectService interface defines available project methods
|
|
type ProjectService interface {
|
|
List(listOpt *ListOptions) ([]Project, *Response, error)
|
|
Get(string) (*Project, *Response, error)
|
|
GetExtra(projectID string, includes, excludes []string) (*Project, *Response, error)
|
|
Create(*ProjectCreateRequest) (*Project, *Response, error)
|
|
Update(string, *ProjectUpdateRequest) (*Project, *Response, error)
|
|
Delete(string) (*Response, error)
|
|
}
|
|
|
|
type projectsRoot struct {
|
|
Projects []Project `json:"projects"`
|
|
Meta meta `json:"meta"`
|
|
}
|
|
|
|
// Project represents a Packet project
|
|
type Project struct {
|
|
ID string `json:"id"`
|
|
Name string `json:"name,omitempty"`
|
|
Organization Organization `json:"organization,omitempty"`
|
|
Created string `json:"created_at,omitempty"`
|
|
Updated string `json:"updated_at,omitempty"`
|
|
Users []User `json:"members,omitempty"`
|
|
Devices []Device `json:"devices,omitempty"`
|
|
SSHKeys []SSHKey `json:"ssh_keys,omitempty"`
|
|
URL string `json:"href,omitempty"`
|
|
PaymentMethod PaymentMethod `json:"payment_method,omitempty"`
|
|
}
|
|
|
|
func (p Project) String() string {
|
|
return Stringify(p)
|
|
}
|
|
|
|
// ProjectCreateRequest type used to create a Packet project
|
|
type ProjectCreateRequest struct {
|
|
Name string `json:"name"`
|
|
PaymentMethodID string `json:"payment_method_id,omitempty"`
|
|
OrganizationID string `json:"organization_id,omitempty"`
|
|
}
|
|
|
|
func (p ProjectCreateRequest) String() string {
|
|
return Stringify(p)
|
|
}
|
|
|
|
// ProjectUpdateRequest type used to update a Packet project
|
|
type ProjectUpdateRequest struct {
|
|
Name *string `json:"name,omitempty"`
|
|
PaymentMethodID *string `json:"payment_method_id,omitempty"`
|
|
}
|
|
|
|
func (p ProjectUpdateRequest) String() string {
|
|
return Stringify(p)
|
|
}
|
|
|
|
// ProjectServiceOp implements ProjectService
|
|
type ProjectServiceOp struct {
|
|
client *Client
|
|
}
|
|
|
|
// List returns the user's projects
|
|
func (s *ProjectServiceOp) List(listOpt *ListOptions) (projects []Project, resp *Response, err error) {
|
|
var params string
|
|
if listOpt != nil {
|
|
params = listOpt.createURL()
|
|
}
|
|
root := new(projectsRoot)
|
|
|
|
path := fmt.Sprintf("%s?%s", projectBasePath, params)
|
|
|
|
for {
|
|
resp, err = s.client.DoRequest("GET", path, nil, root)
|
|
if err != nil {
|
|
return nil, resp, err
|
|
}
|
|
|
|
projects = append(projects, root.Projects...)
|
|
|
|
if root.Meta.Next != nil && (listOpt == nil || listOpt.Page == 0) {
|
|
path = root.Meta.Next.Href
|
|
if params != "" {
|
|
path = fmt.Sprintf("%s&%s", path, params)
|
|
}
|
|
continue
|
|
}
|
|
|
|
return
|
|
}
|
|
}
|
|
|
|
// GetExtra returns a project by id with extra information
|
|
func (s *ProjectServiceOp) GetExtra(projectID string, includes, excludes []string) (*Project, *Response, error) {
|
|
path := fmt.Sprintf("%s/%s", projectBasePath, projectID)
|
|
if includes != nil {
|
|
path += fmt.Sprintf("?include=%s", strings.Join(includes, ","))
|
|
} else if excludes != nil {
|
|
path += fmt.Sprintf("?exclude=%s", strings.Join(excludes, ","))
|
|
}
|
|
|
|
project := new(Project)
|
|
resp, err := s.client.DoRequest("GET", path, nil, project)
|
|
if err != nil {
|
|
return nil, resp, err
|
|
}
|
|
|
|
return project, resp, err
|
|
}
|
|
|
|
// Get returns a project by id
|
|
func (s *ProjectServiceOp) Get(projectID string) (*Project, *Response, error) {
|
|
path := fmt.Sprintf("%s/%s", projectBasePath, projectID)
|
|
project := new(Project)
|
|
|
|
resp, err := s.client.DoRequest("GET", path, nil, project)
|
|
if err != nil {
|
|
return nil, resp, err
|
|
}
|
|
|
|
return project, resp, err
|
|
}
|
|
|
|
// Create creates a new project
|
|
func (s *ProjectServiceOp) Create(createRequest *ProjectCreateRequest) (*Project, *Response, error) {
|
|
project := new(Project)
|
|
|
|
resp, err := s.client.DoRequest("POST", projectBasePath, createRequest, project)
|
|
if err != nil {
|
|
return nil, resp, err
|
|
}
|
|
|
|
return project, resp, err
|
|
}
|
|
|
|
// Update updates a project
|
|
func (s *ProjectServiceOp) Update(id string, updateRequest *ProjectUpdateRequest) (*Project, *Response, error) {
|
|
path := fmt.Sprintf("%s/%s", projectBasePath, id)
|
|
project := new(Project)
|
|
|
|
resp, err := s.client.DoRequest("PATCH", path, updateRequest, project)
|
|
if err != nil {
|
|
return nil, resp, err
|
|
}
|
|
|
|
return project, resp, err
|
|
}
|
|
|
|
// Delete deletes a project
|
|
func (s *ProjectServiceOp) Delete(projectID string) (*Response, error) {
|
|
path := fmt.Sprintf("%s/%s", projectBasePath, projectID)
|
|
|
|
return s.client.DoRequest("DELETE", path, nil, nil)
|
|
}
|