import (
"bytes"
"context"
"encoding/json"
"errors"
"fmt"
"github.com/qiniu/go-sdk/v7/auth"
"io"
"log"
"net/http"
"regexp"
"strings"
"time"
"github.com/qiniu/go-sdk/auth/v7"
)
type SevenCow struct {
cred *auth.Credentials
Ak string
Sk string
host string
fusionHost string // fusion相关api
timeout time.Duration
}
func NewSevenCow(ak string, sk string) *SevenCow {
return &SevenCow{
Ak: ak,
Sk: sk,
cred: auth.New(ak, sk),
host: "api.qiniu.com",
fusionHost: "https://fusion.qiniuapi.com", // 为了单元测试，host配置带http(s)
timeout: time.Second * 30,
}
}
func (c SevenCow) send(method, url string, bodyArg, result interface{}) error {
ct, cancelFunc := context.WithTimeout(context.Background(), c.timeout)
defer cancelFunc()
buf := new(bytes.Buffer)
if bodyArg != nil {
err := json.NewEncoder(buf).Encode(bodyArg)
if err != nil {
return err
}
}
req, err := http.NewRequestWithContext(ct, method, url, buf)
if err != nil {
return err
}
req.Header.Set("Content-Type", "application/json")
token, err := c.cred.SignRequest(req)
if err != nil {
return err
}
req.Header.Set("Authorization", "QBox "+token)
response, err := http.DefaultClient.Do(req)
if err != nil {
return err
}
defer response.Body.Close()
all, err := io.ReadAll(response.Body)
if err != nil {
return err
}
if response.StatusCode != 200 {
marshal, _ := json.Marshal(bodyArg)
return fmt.Errorf("%s %s --------- %d --- %s", method+url, string(marshal), response.StatusCode, string(all))
}
if result != nil {
err = json.Unmarshal(all, result)
if err != nil {
return errors.New(string(all) + err.Error())
}
}
return nil
}
//获取域名列表
func (c SevenCow) CdnDomainList() (*RetDomainList, error) {
// https://developer.qiniu.com/fusion/4246/the-domain-name#9
url := fmt.Sprintf("https://%s/domain?limit=%d", c.host, 1000)
result := new(RetDomainList)
return result, c.send(http.MethodGet, url, nil, result)
}
import (
"testing"
)
func TestSevenCow_CdnDomainList(t *testing.T) {
list, err := NewSevenCow("IAM-xxxxxx", "xxx-xxxx-xx").CdnDomainList()
if err != nil {
t.Error(err)
}
t.Log(list)
}
