Upstream/harbor
1
0
Fork 0
mirror of https://github.com/goharbor/harbor.git synced 2024-12-22 00:27:44 +01:00
Code Issues Projects Releases Wiki Activity

fix(webhook): fix the verify cert logic of webhook endpoint

Browse Source 
Signed-off-by: chlins <chlins.zhang@gmail.com>
This commit is contained in:
chlins 2020-09-09 19:27:27 +08:00
parent 97b9cc2d5e
commit 685d9277c4
4 changed files with 14 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/jobservice/job/impl/notification/http_helper.go
View File

@ -31,11 +31,3 @@ func init() {
Transport: commonhttp.GetHTTPTransport(commonhttp.InsecureTransport), Transport: commonhttp.GetHTTPTransport(commonhttp.InsecureTransport),
} }
} }
// GetHTTPInstance ...
func GetHTTPInstance(insec bool) *http.Client {
if insec {
return httpHelper.clients[insecure]
}
return httpHelper.clients[secure]
}

7
src/jobservice/job/impl/notification/http_helper_test.go
View File

@ -1,15 +1,16 @@
package notification package notification
import ( import (
"github.com/stretchr/testify/assert"
"testing" "testing"
"github.com/stretchr/testify/assert"
) )
func TestHttpHelper(t *testing.T) { func TestHttpHelper(t *testing.T) {
c1 := GetHTTPInstance(true) c1 := httpHelper.clients[insecure]
assert.NotNil(t, c1) assert.NotNil(t, c1)
c2 := GetHTTPInstance(false) c2 := httpHelper.clients[secure]
assert.NotNil(t, c2) assert.NotNil(t, c2)
_, ok := httpHelper.clients["notExists"] _, ok := httpHelper.clients["notExists"]

11
src/jobservice/job/impl/notification/slack_job.go
View File

@ -93,13 +93,12 @@ func (sj *SlackJob) Run(ctx job.Context, params job.Parameters) error {
func (sj *SlackJob) init(ctx job.Context, params map[string]interface{}) error { func (sj *SlackJob) init(ctx job.Context, params map[string]interface{}) error {
sj.logger = ctx.GetLogger() sj.logger = ctx.GetLogger()
// default use insecure transport // default use secure transport
sj.client = GetHTTPInstance(true) sj.client = httpHelper.clients[secure]
if v, ok := params["skip_cert_verify"]; ok { if v, ok := params["skip_cert_verify"]; ok {
if insecure, ok := v.(bool); ok { if skipCertVerify, ok := v.(bool); ok && skipCertVerify {
if insecure { // if skip cert verify is true, it means not verify remote cert, use insecure client
sj.client = GetHTTPInstance(false) sj.client = httpHelper.clients[insecure]
}
} }
} }
return nil return nil

11
src/jobservice/job/impl/notification/webhook_job.go
View File

@ -71,13 +71,12 @@ func (wj *WebhookJob) init(ctx job.Context, params map[string]interface{}) error
wj.logger = ctx.GetLogger() wj.logger = ctx.GetLogger()
wj.ctx = ctx wj.ctx = ctx
// default use insecure transport // default use secure transport
wj.client = GetHTTPInstance(true) wj.client = httpHelper.clients[secure]
if v, ok := params["skip_cert_verify"]; ok { if v, ok := params["skip_cert_verify"]; ok {
if insecure, ok := v.(bool); ok { if skipCertVerify, ok := v.(bool); ok && skipCertVerify {
if insecure { // if skip cert verify is true, it means not verify remote cert, use insecure client
wj.client = GetHTTPInstance(false) wj.client = httpHelper.clients[insecure]
}
} }
} }
return nil return nil