-
Notifications
You must be signed in to change notification settings - Fork 2
/
Copy pathclient.go
144 lines (127 loc) · 6.53 KB
/
client.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
package client
import (
"context"
"fmt"
"io"
"net/http"
"net/url"
"regexp"
"time"
"github.com/nikolalohinski/free-go/types"
)
//nolint:interfacebloat
type Client interface {
// configuration
WithAppID(string) Client
WithPrivateToken(types.PrivateToken) Client
WithHTTPClient(HTTPClient) Client
// unauthenticated
APIVersion(context.Context) (types.APIVersion, error)
// authentication
Authorize(context.Context, types.AuthorizationRequest) (types.PrivateToken, error)
Login(context.Context) (types.Permissions, error)
Logout(context.Context) error
// port forwarding
ListPortForwardingRules(context.Context) ([]types.PortForwardingRule, error)
GetPortForwardingRule(ctx context.Context, identifier int64) (types.PortForwardingRule, error)
CreatePortForwardingRule(ctx context.Context, payload types.PortForwardingRulePayload) (types.PortForwardingRule, error)
UpdatePortForwardingRule(ctx context.Context, identifier int64, payload types.PortForwardingRulePayload) (types.PortForwardingRule, error)
DeletePortForwardingRule(ctx context.Context, identifier int64) error
// dhcp
ListDHCPStaticLease(context.Context) ([]types.DHCPStaticLeaseInfo, error)
GetDHCPStaticLease(ctx context.Context, identifier string) (types.DHCPStaticLeaseInfo, error)
UpdateDHCPStaticLease(ctx context.Context, identifier string, payload types.DHCPStaticLeasePayload) (types.LanInterfaceHost, error)
CreateDHCPStaticLease(ctx context.Context, payload types.DHCPStaticLeasePayload) (types.LanInterfaceHost, error)
DeleteDHCPStaticLease(ctx context.Context, identifier string) error
// lan browser
ListLanInterfaceInfo(context.Context) ([]types.LanInfo, error)
GetLanInterface(ctx context.Context, name string) (result []types.LanInterfaceHost, err error)
GetLanInterfaceHost(ctx context.Context, interfaceName, identifier string) (result types.LanInterfaceHost, err error)
// virtual machines
GetVirtualMachineInfo(context.Context) (result types.VirtualMachinesInfo, err error)
GetVirtualMachineDistributions(context.Context) (result []types.VirtualMachineDistribution, err error)
ListVirtualMachines(context.Context) (result []types.VirtualMachine, err error)
CreateVirtualMachine(ctx context.Context, payload types.VirtualMachinePayload) (result types.VirtualMachine, err error)
GetVirtualMachine(ctx context.Context, identifier int64) (result types.VirtualMachine, err error)
UpdateVirtualMachine(ctx context.Context, identifier int64, payload types.VirtualMachinePayload) (result types.VirtualMachine, err error)
DeleteVirtualMachine(ctx context.Context, identifier int64) error
StartVirtualMachine(ctx context.Context, identifier int64) error
KillVirtualMachine(ctx context.Context, identifier int64) error
StopVirtualMachine(ctx context.Context, identifier int64) error
// virtual machines disks
GetVirtualDiskInfo(ctx context.Context, path string) (result types.VirtualDiskInfo, err error)
GetVirtualDiskTask(ctx context.Context, identifier int64) (result types.VirtualMachineDiskTask, err error)
CreateVirtualDisk(ctx context.Context, payload types.VirtualDisksCreatePayload) (result int64, err error)
ResizeVirtualDisk(ctx context.Context, payload types.VirtualDisksResizePayload) (result int64, err error)
DeleteVirtualDiskTask(ctx context.Context, identifier int64) error
// websocket
ListenEvents(ctx context.Context, events []types.EventDescription) (chan types.Event, error)
// filesystem
GetFileInfo(ctx context.Context, path string) (types.FileInfo, error)
RemoveFiles(ctx context.Context, paths []string) (types.FileSystemTask, error)
UpdateFileSystemTask(ctx context.Context, identifier int64, payload types.FileSytemTaskUpdate) (types.FileSystemTask, error)
ListFileSystemTasks(ctx context.Context) (task []types.FileSystemTask, err error)
GetFileSystemTask(ctx context.Context, identifier int64) (types.FileSystemTask, error)
DeleteFileSystemTask(ctx context.Context, identifier int64) error
CreateDirectory(ctx context.Context, parent, name string) (path string, err error)
AddHashFileTask(ctx context.Context, payload types.HashPayload) (task types.FileSystemTask, err error)
GetHashResult(ctx context.Context, identifier int64) (result string, err error)
GetFile(ctx context.Context, path string) (result types.File, err error)
MoveFiles(ctx context.Context, sources []string, destination string, mode types.FileMoveMode) (result types.FileSystemTask, err error)
CopyFiles(ctx context.Context, sources []string, destination string, mode types.FileCopyMode) (result types.FileSystemTask, err error)
ExtractFile(ctx context.Context, payload types.ExtractFilePayload) (task types.FileSystemTask, err error)
// downloads
ListDownloadTasks(ctx context.Context) ([]types.DownloadTask, error)
GetDownloadTask(ctx context.Context, identifier int64) (types.DownloadTask, error)
AddDownloadTask(ctx context.Context, request types.DownloadRequest) (identifier int64, err error)
DeleteDownloadTask(ctx context.Context, identifier int64) error
EraseDownloadTask(ctx context.Context, identifier int64) error
UpdateDownloadTask(ctx context.Context, identifier int64, payload types.DownloadTaskUpdate) error
// uploads
FileUploadStart(ctx context.Context, input types.FileUploadStartActionInput) (io.WriteCloser, types.UploadRequestID, error)
GetUploadTask(ctx context.Context, identifier int64) (types.UploadTask, error)
ListUploadTasks(ctx context.Context) ([]types.UploadTask, error)
CancelUploadTask(ctx context.Context, identifier int64) error
DeleteUploadTask(ctx context.Context, identifier int64) error
CleanUploadTasks(ctx context.Context) error
}
type HTTPClient interface {
Do(*http.Request) (*http.Response, error)
}
var matchHTTPSRegex = regexp.MustCompile("^https?://.*")
func New(endpoint, version string) (Client, error) {
if !matchHTTPSRegex.MatchString(endpoint) {
endpoint = fmt.Sprintf("http://%s", endpoint)
}
base, err := url.Parse(fmt.Sprintf("%s/api/%s", endpoint, version))
if err != nil {
return nil, fmt.Errorf("can not build base url from endpoint \"%s\" and version \"%s\"", endpoint, version)
}
return &client{
httpClient: http.DefaultClient,
base: base,
}, nil
}
type client struct {
httpClient HTTPClient
privateToken *string
appID *string
session *session
base *url.URL
}
type session struct {
token string
expires time.Time
}
func (c *client) WithAppID(appID string) Client {
c.appID = &appID
return c
}
func (c *client) WithPrivateToken(privateToken types.PrivateToken) Client {
c.privateToken = &privateToken
return c
}
func (c *client) WithHTTPClient(httpClient HTTPClient) Client {
c.httpClient = httpClient
return c
}