加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
文件
克隆/下载
install.go 16.21 KB
一键复制 编辑 原始数据 按行查看 历史
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562
package dget
import (
"archive/tar"
"bytes"
"compress/gzip"
"crypto/sha256"
"encoding/hex"
"encoding/json"
"fmt"
"io"
"io/ioutil"
"net/http"
"net/url"
"os"
"path/filepath"
"strings"
"time"
"github.com/docker/distribution/manifest/manifestlist"
"github.com/opencontainers/go-digest"
"github.com/pkg/errors"
"github.com/sirupsen/logrus"
)
// const _registry = "registry-1.docker.io"
const _authUrl = "https://auth.docker.io/token"
const _regService = "registry.docker.io"
type LayerInfo struct {
Id string `json:"id"`
Parent string `json:"parent"`
Created time.Time `json:"created"`
ContainerConfig struct {
Hostname string
Domainname string
User string
AttachStdin bool
AttachStdout bool
AttachStderr bool
Tty bool
OpenStdin bool
StdinOnce bool
Env []string
CMd []string
Image string
Volumes map[string]interface{}
WorkingDir string
Entrypoint []string
OnBuild []string
Labels map[string]interface{}
} `json:"container_config"`
}
type Layer struct {
Digest string
Urls []string
}
type Info struct {
Layers []Layer `json:"layers"`
Config struct {
Digest digest.Digest `json:"digest,omitempty"`
} `json:"config"`
}
type PackageConfig struct {
Config string
RepoTags []string
Layers []string
}
type Client struct {
c *http.Client
}
type TagList struct {
Name string
Tags []string
}
type SyncSignal struct{}
func (m *Client) SetClient(c *http.Client) {
m.c = c
}
func (m *Client) Install(syncCount int, _registry, d, tag string, arch string, printInfo bool, onlyGetTag bool, username string, password string) (err error) {
var authUrl = _authUrl
var regService = _regService
resp, err := m.c.Get(fmt.Sprintf("https://%s/v2/", _registry))
if err == nil {
if !strings.Contains(d, "/") {
d = "library/" + d
}
if resp.StatusCode == 401 {
//Bearer realm="https://auth.docker.io/token",service="registry.docker.io"
var hAuths = strings.Split(resp.Header.Get("Www-Authenticate"), "\"")
logrus.Debugln("Www-Authenticate", hAuths)
if len(hAuths) > 1 {
authUrl = hAuths[1]
}
if len(hAuths) > 3 {
regService = hAuths[3]
} else {
regService = _registry
}
}
resp.Body.Close()
var accessToken string
logrus.Debugln("reg_service", regService)
logrus.Debugln("authUrl", authUrl)
if username != "" && password != "" {
accessToken, err = m.getTokenWithBasicAuth(authUrl, regService, d, username, password)
} else {
accessToken, err = m.getAuthHead(authUrl, regService, d)
}
if err == nil {
var req *http.Request
if onlyGetTag {
var tagListURL = fmt.Sprintf("https://%s/v2/%s/tags/list", _registry, d)
logrus.Debugln("tags request", tagListURL)
req, err = http.NewRequest("GET", tagListURL, nil)
if err == nil {
req.Header.Add("Authorization", "Bearer "+accessToken)
resp, err = m.c.Do(req)
if err == nil && resp.StatusCode == 200 {
var bts []byte
bts, err = io.ReadAll(resp.Body)
logrus.Debugln("tags response", string(bts))
if err == nil {
var tagList TagList
err = json.Unmarshal(bts, &tagList)
if err == nil && len(tagList.Tags) > 0 {
tag = tagList.Tags[0]
fmt.Println("获取到的tag列表为:")
fmt.Println(strings.Join(tagList.Tags, ","))
return
}
}
resp.Body.Close()
}
}
}
var manifestURL = fmt.Sprintf("https://%s/v2/%s/manifests/%s", _registry, d, tag)
req, err = http.NewRequest("GET", manifestURL, nil)
logrus.Infoln("获取manifests信息", manifestURL)
if err == nil {
logrus.Debugln("Authorization by", accessToken)
req.Header.Add("Authorization", "Bearer "+accessToken)
// req.Header.Add("Accept", "application/vnd.oci.image.manifest.v1+json")
req.Header.Add("Accept", "application/vnd.docker.distribution.manifest.list.v2+json")
req.Header.Add("Accept", "application/vnd.oci.image.index.v1+json")
var authHeader = req.Header
resp, err = m.c.Do(req)
if resp.StatusCode != 200 {
bts, er := io.ReadAll(resp.Body)
resp.Body.Close()
logrus.Debugln(string(bts), er)
switch resp.StatusCode {
case 401:
logrus.Errorf("[-] Cannot fetch manifest for %s [HTTP %d] with error access_token", d, resp.StatusCode)
case 404:
logrus.Errorf("[-] Cannot fetch manifest for %s [HTTP %d] with url %s", d, resp.StatusCode, manifestURL)
resp.Body.Close()
req.Header.Set("Accept", "application/vnd.docker.distribution.manifest.list.v2+json")
resp, err = m.c.Do(req)
bts, er := ioutil.ReadAll(resp.Body)
fmt.Println(string(bts), er)
}
//TODO
os.Exit(1)
} else {
var bts []byte
bts, err = io.ReadAll(resp.Body)
if err == nil {
logrus.WithField("Content-Type", resp.Header.Get("Content-Type")).Debugln("Get manifest list")
switch resp.Header.Get("Content-Type") {
case "application/vnd.docker.distribution.manifest.list.v2+json", "application/vnd.oci.image.index.v1+json":
var info manifestlist.ManifestList
err = json.Unmarshal(bts, &info)
if err == nil {
resp.Body.Close()
logrus.Infof("获得%d个架构信息:", len(info.Manifests))
var selectedManifest *manifestlist.ManifestDescriptor
for i := 0; i < len(info.Manifests); i++ {
var m = info.Manifests[i]
logrus.Infof("[%d]架构:%s,OS:%s", i+1, m.Platform.Architecture, m.Platform.OS)
if m.Platform.OS+"/"+m.Platform.Architecture == arch {
logrus.Infoln("找到匹配的架构,开始下载")
selectedManifest = &m
req.URL, _ = url.Parse(fmt.Sprintf("https://%s/v2/%s/manifests/%s", _registry, d, m.Digest.String()))
break
}
}
if printInfo {
fmt.Println(string(bts))
os.Exit(0)
}
if selectedManifest == nil {
return errors.New("未找到匹配的架构:" + arch)
}
logrus.Debug("找到的架构信息为", selectedManifest)
req.Header.Set("Accept", selectedManifest.MediaType)
}
case "application/vnd.docker.distribution.manifest.v1+prettyjws":
req.Header.Set("Accept", "application/vnd.docker.distribution.manifest.v2+json")
}
resp, err = m.c.Do(req)
if err == nil {
var info Info
err = json.NewDecoder(resp.Body).Decode(&info)
if err == nil {
resp.Body.Close()
logrus.Infof("获得Manifest信息,共%d层需要下载", len(info.Layers))
err = m.download(syncCount, _registry, d, tag, info.Config.Digest, authHeader, info.Layers)
if err != nil {
goto response
}
}
}
}
}
}
}
}
response:
return
}
func (m *Client) getTokenWithBasicAuth(url, service, repository, username, password string) (string, error) {
req, err := http.NewRequest(http.MethodGet, url, http.NoBody)
if err != nil {
logrus.Fatal(err)
return "", err
}
req.SetBasicAuth(username, password)
query := req.URL.Query()
query.Add("service", service)
query.Add("scope", fmt.Sprintf("repository:%s:pull", repository))
req.URL.RawQuery = query.Encode()
resp, err := m.c.Do(req)
if err == nil {
defer resp.Body.Close()
var results map[string]interface{}
err = json.NewDecoder(resp.Body).Decode(&results)
logrus.Debug(results)
if err == nil && results["token"] != nil {
return results["token"].(string), nil
}
}
return "", err
}
func (m *Client) download(syncCount int, _registry, d, tag string, digest digest.Digest, authHeader http.Header, layers []Layer) (err error) {
var tmpDir = fmt.Sprintf("tmp_%s_%s", d, tag)
err = os.MkdirAll(tmpDir, 0777)
if err == nil {
if _, e := os.Stat(filepath.Join(tmpDir, "repositories")); e == nil {
logrus.Info(tmpDir, " is downloaded,use dir as cache")
} else {
var req *http.Request
req, err = http.NewRequest("GET", fmt.Sprintf("https://%s/v2/%s/blobs/%s", _registry, d, digest), nil)
if err == nil {
req.Header = authHeader
var resp *http.Response
resp, err = m.c.Do(req)
if err == nil {
var dest *os.File
dest, err = os.OpenFile(filepath.Join(tmpDir, digest.Encoded()+".json"), os.O_CREATE|os.O_TRUNC|os.O_WRONLY, 0666)
if err == nil {
var bts []byte
bts, err = ioutil.ReadAll(resp.Body)
var lastLayerInfo LayerInfo
err = json.Unmarshal(bts, &lastLayerInfo)
resp.Body.Close()
var config []PackageConfig
config = append(config, PackageConfig{
Config: digest.Encoded() + ".json",
RepoTags: []string{d + ":" + tag},
})
if err == nil {
_, err = io.Copy(dest, bytes.NewReader(bts))
dest.Close()
if err == nil {
parentid := ""
var fakeLayerId string
var downloadStatus = make(map[int]bool)
var notifyChan = make(chan int, 1)
//限制并发下载数为3
var ch = make(chan SyncSignal, syncCount)
for n, layer := range layers {
namer := sha256.New()
namer.Write([]byte(parentid + "\n" + layer.Digest + "\n"))
fakeLayerId = hex.EncodeToString(namer.Sum(nil))
logrus.Infoln("handle layer", n, fakeLayerId, layer.Urls)
var layerInfo LayerInfo
if n == len(layers)-1 {
layerInfo = lastLayerInfo
}
layerInfo.Id = fakeLayerId
if parentid != "" {
layerInfo.Parent = parentid
}
config[0].Layers = append(config[0].Layers, fakeLayerId+"/layer.tar")
var copyedHeader = make(http.Header)
for k, v := range authHeader {
copyedHeader[k] = v
}
go func(fakeLayerId string, layer Layer, n int, notifyChan chan int, layerInfo *LayerInfo, tmpDir string, _registry string, d string, authHeader http.Header) {
ch <- SyncSignal{}
er := m.downloadLayer(fakeLayerId, &layer, layerInfo, tmpDir, _registry, d, authHeader)
if er != nil {
logrus.Errorf("下载第%d/%d层失败:%s", n+1, len(layers), err)
err = er
}
notifyChan <- n
<-ch
}(fakeLayerId, layer, n, notifyChan, &layerInfo, tmpDir, _registry, d, copyedHeader)
parentid = fakeLayerId
}
for len(downloadStatus) < len(layers) {
n := <-notifyChan
downloadStatus[n] = true
if len(downloadStatus) == len(layers) {
close(notifyChan)
logrus.Infof("[%d/%d]下载完成", len(downloadStatus), len(layers))
break
} else {
logrus.Infof("[%d/%d]第%d层下载完成", len(downloadStatus), len(layers), n+1)
}
}
if err != nil {
return err
}
var manifest *os.File
logrus.Debugln("write manifest to", filepath.Join(tmpDir, "manifest.json"))
manifest, err = os.OpenFile(filepath.Join(tmpDir, "manifest.json"), os.O_CREATE|os.O_TRUNC|os.O_WRONLY, 0666)
if err == nil {
err = json.NewEncoder(manifest).Encode(&config)
if err == nil {
manifest.Close()
var repositories = make(map[string]interface{})
repositories[d] = map[string]string{
tag: fakeLayerId,
}
var rFile *os.File
rFile, err = os.OpenFile(filepath.Join(tmpDir, "repositories"), os.O_CREATE|os.O_TRUNC|os.O_WRONLY, 0666)
if err == nil {
err = json.NewEncoder(rFile).Encode(&repositories)
logrus.Debugln("write repositories to", filepath.Join(tmpDir, "repositories"))
goto maketar
}
}
}
logrus.Debugln("write manifest fail", err)
}
}
}
}
}
}
maketar:
if err == nil {
err = writeDirToTarGz(tmpDir, tmpDir+"-img.tar.gz")
if err == nil {
fmt.Println("write tar success", tmpDir+"-img.tar.gz")
} else {
logrus.Debugln("write tar fail", err)
}
}
}
return
}
func (m *Client) getAuthHead(a, r, d string) (string, error) {
var regUrl = fmt.Sprintf("%s?service=%s&scope=repository:%s:pull", a, r, d)
logrus.Debug("get auth head from ", regUrl)
resp, err := m.c.Get(regUrl)
if err == nil {
defer resp.Body.Close()
var results map[string]interface{}
err = json.NewDecoder(resp.Body).Decode(&results)
logrus.Debug(results)
if err == nil {
var accessToken string
if results["access_token"] != nil {
accessToken = results["access_token"].(string)
} else if results["token"] != nil {
accessToken = results["token"].(string)
}
if accessToken != "" {
return accessToken, nil
}
return "", errors.New("access_token is empty")
}
}
return "", err
}
func writeDirToTarGz(sourcedir, destinationfile string) error {
// create tar file
gzFile, err := os.Create(destinationfile)
gf := gzip.NewWriter(gzFile)
tw := tar.NewWriter(gf)
logrus.Debug("write tgz file to ", destinationfile)
if err == nil {
defer func() {
tw.Close()
gf.Close()
gzFile.Close()
}()
// get list of files
return filepath.Walk(sourcedir, func(path string, info os.FileInfo, err error) error {
if err != nil {
return err
}
relPath, err := filepath.Rel(sourcedir, path)
if err == nil && relPath != "." {
logrus.Debugln("write", relPath)
header, err := tar.FileInfoHeader(info, path)
if err != nil {
return err
}
// must provide real name
// (see https://golang.org/src/archive/tar/common.go?#L626)
header.Name = filepath.ToSlash(relPath)
// write header
if err := tw.WriteHeader(header); err != nil {
return err
}
// if not a dir, write file content
if !info.IsDir() {
data, err := os.Open(path)
if err != nil {
return err
}
if _, err := io.Copy(tw, data); err != nil {
return err
}
}
return nil
}
return err
})
}
return err
}
func SetLogLevel(lvl logrus.Level) {
logrus.SetLevel(lvl)
logrus.Debugln("设置日志级别为", lvl)
}
func (m *Client) downloadLayer(fakeLayerId string, layer *Layer, layerInfo *LayerInfo, tmpDir string, _registry string, d string, authHeader http.Header) error {
layerDirName := filepath.Join(tmpDir, fakeLayerId)
err := os.Mkdir(layerDirName, 0777)
if _, er := os.Stat(filepath.Join(layerDirName, "layer.tar")); er == nil {
logrus.Infoln("layer", fakeLayerId, "is existed, continue")
return nil
}
if err == nil || os.IsExist(err) {
err = ioutil.WriteFile(filepath.Join(layerDirName, "VERSION"), []byte("1.0"), 0666)
if err == nil {
var req *http.Request
req, err = http.NewRequest("GET", fmt.Sprintf("https://%s/v2/%s/blobs/%s", _registry, d, layer.Digest), nil)
if err == nil {
req.Header = authHeader
req.Header.Set("Accept", "application/vnd.docker.distribution.manifest.v2+json")
var resp *http.Response
resp, err = m.c.Do(req)
if err == nil {
if resp.StatusCode != 200 {
defer resp.Body.Close()
if len(layer.Urls) > 0 {
req, err = http.NewRequest("GET", layer.Urls[0], nil)
if err == nil {
req.Header = authHeader
req.Header.Set("Accept", "application/vnd.docker.distribution.manifest.v2+json")
resp, err = m.c.Do(req)
if err == nil {
if resp.StatusCode != 200 {
err = fmt.Errorf("download from customized url fail")
return err
}
}
}
} else {
bts, _ := ioutil.ReadAll(resp.Body)
logrus.Fatalln("下载失败", string(bts))
}
}
}
if err != nil {
return errors.Wrap(err, "请求失败")
}
var dst *os.File
dst, err = os.OpenFile(filepath.Join(layerDirName, "layer.tar.part"), os.O_CREATE|os.O_TRUNC|os.O_WRONLY, 0666)
if err == nil {
var greader *gzip.Reader
greader, err = gzip.NewReader(resp.Body)
if err == nil {
_, err = io.Copy(dst, greader)
if err == nil {
dst.Close()
var jsonFile *os.File
jsonFile, err = os.OpenFile(filepath.Join(layerDirName, "json"), os.O_CREATE|os.O_TRUNC|os.O_WRONLY, 0666)
if err == nil {
err = json.NewEncoder(jsonFile).Encode(layerInfo)
if err == nil {
jsonFile.Close()
err = os.Rename(filepath.Join(layerDirName, "layer.tar.part"), filepath.Join(layerDirName, "layer.tar"))
}
}
}
}
}
if err != nil {
err = errors.Wrap(err, "下载失败")
}
return err
}
}
}
return err
}
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化