Upstream/harbor
1
0
Fork 0
mirror of https://github.com/goharbor/harbor.git synced 2024-09-29 13:57:33 +02:00
Code Issues Projects Releases Wiki Activity

fix(replication): huawei adapter multi authorization

Browse Source 
Signed-off-by: chlins <chlins.zhang@gmail.com>
This commit is contained in:
chlins 2019-11-15 11:33:01 +08:00
parent 29be93725d
commit 130e406d3c
2 changed files with 11 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/replication/adapter/huawei/huawei_adapter.go
View File

@ -45,6 +45,10 @@ type adapter struct {
*native.Adapter
registry *model.Registry
client *common_http.Client
// original http client with no modifer,
// huawei's some api interface with basic authorization,
// some with bearer token authorization.
oriClient *http.Client
}
// Info gets info about Huawei SWR
@ -243,15 +247,19 @@ func newAdapter(registry *model.Registry) (adp.Adapter, error) {
modifiers = append(modifiers, authorizer)
}
transport := util.GetHTTPTransport(registry.Insecure)
return &adapter{
Adapter: dockerRegistryAdapter,
registry: registry,
client: common_http.NewClient(
&http.Client{
Transport: util.GetHTTPTransport(registry.Insecure),
Transport: transport,
},
modifiers...,
),
oriClient: &http.Client{
Transport: transport,
},
}, nil
}

4
src/replication/adapter/huawei/image_registry.go
View File

@ -70,7 +70,7 @@ func (a *adapter) ManifestExist(repository, reference string) (exist bool, diges
r.Header.Add("content-type", "application/json; charset=utf-8")
r.Header.Add("Authorization", "Bearer "+token.Token)
resp, err := a.client.Do(r)
resp, err := a.oriClient.Do(r)
if err != nil {
return exist, digest, err
}
@ -113,7 +113,7 @@ func (a *adapter) DeleteManifest(repository, reference string) error {
r.Header.Add("content-type", "application/json; charset=utf-8")
r.Header.Add("Authorization", "Bearer "+token.Token)
resp, err := a.client.Do(r)
resp, err := a.oriClient.Do(r)
if err != nil {
return err
}