79 lines
1.4 KiB
Go
79 lines
1.4 KiB
Go
package client
|
|
|
|
import (
|
|
"crypto/tls"
|
|
"errors"
|
|
"io/ioutil"
|
|
"net/http"
|
|
"net/url"
|
|
"strconv"
|
|
"strings"
|
|
"time"
|
|
)
|
|
|
|
const (
|
|
urlPath = "/url/open"
|
|
)
|
|
|
|
type RemoteClient struct {
|
|
client *http.Client
|
|
baseUrl string
|
|
token string
|
|
}
|
|
|
|
func New(host, token string) *RemoteClient {
|
|
client := &http.Client{
|
|
Timeout: 30 * time.Second,
|
|
Transport: &http.Transport{
|
|
TLSClientConfig: &tls.Config{InsecureSkipVerify: true},
|
|
},
|
|
}
|
|
|
|
return &RemoteClient{client: client, baseUrl: "https://" + host, token: token}
|
|
}
|
|
|
|
func (r *RemoteClient) OpenURL(urlStr string) error {
|
|
formData := url.Values{
|
|
"url": {urlStr},
|
|
}
|
|
|
|
status, _, err := r.doRequest(urlPath, formData)
|
|
|
|
if err != nil {
|
|
return err
|
|
} else if status != http.StatusOK {
|
|
return errors.New("invalid status: " + strconv.Itoa(status))
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func (r *RemoteClient) doRequest(path string, v url.Values) (int, []byte, error) {
|
|
encoded := v.Encode()
|
|
|
|
req, err := http.NewRequest(http.MethodPost, r.baseUrl + path, strings.NewReader(encoded))
|
|
|
|
if err != nil {
|
|
return -1, nil, err
|
|
}
|
|
|
|
req.Header.Set("Authorization", "Bearer " + r.token)
|
|
req.Header.Set("Content-Length", strconv.Itoa(len(encoded)))
|
|
req.Header.Set("Content-Type", "application/x-www-form-urlencoded")
|
|
|
|
res, err := r.client.Do(req)
|
|
|
|
if err != nil {
|
|
return -1, nil, err
|
|
}
|
|
|
|
defer res.Body.Close()
|
|
|
|
b, err := ioutil.ReadAll(res.Body)
|
|
|
|
if err != nil {
|
|
return -1, nil, err
|
|
}
|
|
|
|
return res.StatusCode, b, nil
|
|
} |