diff --git a/dtmcli/dtmimp/consts.go b/dtmcli/dtmimp/consts.go index 95757ac..54586af 100644 --- a/dtmcli/dtmimp/consts.go +++ b/dtmcli/dtmimp/consts.go @@ -55,4 +55,9 @@ const ( // XaBarrier1 const for xa barrier id XaBarrier1 = "01" + + // ProtocolGRPC const for protocol grpc + ProtocolGRPC = "grpc" + // ProtocolHTTP const for protocol http + ProtocolHTTP = "http" ) diff --git a/dtmcli/dtmimp/vars.go b/dtmcli/dtmimp/vars.go index e9d265b..ad688d0 100644 --- a/dtmcli/dtmimp/vars.go +++ b/dtmcli/dtmimp/vars.go @@ -46,9 +46,8 @@ func init() { RestyClient.OnBeforeRequest(func(c *resty.Client, r *resty.Request) error { r.URL = MayReplaceLocalhost(r.URL) u, err := dtmdriver.GetHTTPDriver().ResolveURL(r.URL) - logger.Debugf("requesting: %s %s %s", r.Method, r.URL, MustMarshalString(r.Body)) + logger.Debugf("requesting: %s %s %s resolved: %s", r.Method, r.URL, MustMarshalString(r.Body), u) r.URL = u - logger.Debugf("resolved: %s err: %v", r.URL, err) return err }) RestyClient.OnAfterResponse(func(c *resty.Client, resp *resty.Response) error { diff --git a/dtmsvr/trans_class.go b/dtmsvr/trans_class.go index 5023e06..bedb590 100644 --- a/dtmsvr/trans_class.go +++ b/dtmsvr/trans_class.go @@ -31,7 +31,7 @@ func (t *TransGlobal) setupPayloads() { } } if t.Protocol == "" { - t.Protocol = "http" + t.Protocol = dtmimp.ProtocolHTTP } } diff --git a/dtmsvr/trans_status.go b/dtmsvr/trans_status.go index 67552db..6184c2f 100644 --- a/dtmsvr/trans_status.go +++ b/dtmsvr/trans_status.go @@ -89,7 +89,7 @@ func (t *TransGlobal) getURLResult(uri string, branchID, op string, branchPayloa if uri == "" { // empty url is success return nil } - if strings.HasPrefix(uri, "http://") || strings.HasPrefix(uri, "https://") { + if t.Protocol == dtmimp.ProtocolHTTP || strings.HasPrefix(uri, "http://") || strings.HasPrefix(uri, "https://") { if t.RequestTimeout != 0 { dtmimp.RestyClient.SetTimeout(time.Duration(t.RequestTimeout) * time.Second) } @@ -146,7 +146,7 @@ func (t *TransGlobal) getURLResult(uri string, branchID, op string, branchPayloa } return dtmimp.RespAsErrorCompatible(resp) } - dtmimp.PanicIf(t.Protocol == "http", fmt.Errorf("bad url for http: %s", uri)) + dtmimp.PanicIf(t.Protocol == dtmimp.ProtocolHTTP, fmt.Errorf("bad url for http: %s", uri)) // grpc handler server, method, err := dtmdriver.GetDriver().ParseServerMethod(uri) if err != nil { diff --git a/go.mod b/go.mod index 8d383ec..3b75b36 100644 --- a/go.mod +++ b/go.mod @@ -7,7 +7,7 @@ require ( github.com/BurntSushi/toml v0.4.1 // indirect github.com/dtm-labs/dtmdriver v0.0.3 github.com/dtm-labs/dtmdriver-gozero v0.0.2 - github.com/dtm-labs/dtmdriver-http v1.2.0 + github.com/dtm-labs/dtmdriver-http v1.2.2 github.com/dtm-labs/dtmdriver-kratos v0.0.8 github.com/dtm-labs/dtmdriver-polaris v0.0.4 github.com/dtm-labs/dtmdriver-protocol1 v0.0.1 @@ -38,4 +38,4 @@ require ( // replace github.com/dtm-labs/dtmdriver v0.0.2 => /Users/wangxi/dtm/dtmdriver -// replace github.com/horseLk/dtmdriver-nacos v1.1.0 => /Users/wangxi/dtm/dtmdriver-http-nacos +// replace github.com/dtm-labs/dtmdriver-http => /Users/wangxi/dtm/dtmdriver-http-nacos diff --git a/go.sum b/go.sum index 8d640de..dea3f75 100644 --- a/go.sum +++ b/go.sum @@ -127,6 +127,8 @@ github.com/dtm-labs/dtmdriver-gozero v0.0.2 h1:T+JH9kwVNMmISPU1BNviiTrvPdMA7UMFD github.com/dtm-labs/dtmdriver-gozero v0.0.2/go.mod h1:5AAKwYok5f56e0kATOXvc+DAsfu4elISDuCV+G3+fYE= github.com/dtm-labs/dtmdriver-http v1.2.0 h1:9v1od77rSrJUuiBnZ/o6Ic4jRJpToxjP2nUOnx9CIas= github.com/dtm-labs/dtmdriver-http v1.2.0/go.mod h1:UtWShS61TiiudZUAabQ2ww0CzSEpBYF3AS3F3G2Jc2o= +github.com/dtm-labs/dtmdriver-http v1.2.2 h1:QOul+PpK1KQyXXx5viNrHrEFIc/nFxmX4fJfI3DLUqI= +github.com/dtm-labs/dtmdriver-http v1.2.2/go.mod h1:UtWShS61TiiudZUAabQ2ww0CzSEpBYF3AS3F3G2Jc2o= github.com/dtm-labs/dtmdriver-kratos v0.0.8 h1:AAIfFzpzuu7K3B/wpx71y0FdZqO1X/Bsklva0bayS9s= github.com/dtm-labs/dtmdriver-kratos v0.0.8/go.mod h1:MlREYO7d7Ocbs4NsuU/LQMBBcHix6rubjW+in2hNRyk= github.com/dtm-labs/dtmdriver-polaris v0.0.4 h1:yli0YmAsEgl47ymJHTxIzULeNe5dnmfN2ixLJRWm2Ok=