Upstream/harbor
1
0
Fork 0
mirror of https://github.com/goharbor/harbor.git synced 2024-10-31 23:59:32 +01:00
Code Issues Projects Releases Wiki Activity

Merge pull request #10754 from chlins/cherry-pick/huawei-adapter-authorization

Browse Source 
[CHERRY-PICK]fix(replication): huawei adapter multi authorization
This commit is contained in:
Wenkai Yin(尹文开) 2020-08-04 16:08:48 +08:00 committed by GitHub
commit e046d87f6b
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
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
}