yjp 3 anni fa
parent
commit
7e180e6055
3 ha cambiato i file con 10 aggiunte e 10 eliminazioni
  1. 4 4
      invoke/invoke.go
  2. 1 1
      pubsub/pubsub.go
  3. 5 5
      state/state.go

+ 4 - 4
invoke/invoke.go

@@ -71,7 +71,7 @@ func (api *API) Post(methodName string, headers map[string]string, data []byte)
 	}
 
 	if resp.IsError() {
-		return nil, utils.ResponseStatusError(resp)
+		return nil, utils.ResponseStatusError(invokeUrl, resp)
 	}
 
 	return resp.Body(), nil
@@ -91,7 +91,7 @@ func (api *API) Delete(methodName string, headers map[string]string) ([]byte, er
 	}
 
 	if resp.IsError() {
-		return nil, utils.ResponseStatusError(resp)
+		return nil, utils.ResponseStatusError(invokeUrl, resp)
 	}
 
 	return resp.Body(), nil
@@ -112,7 +112,7 @@ func (api *API) Put(methodName string, headers map[string]string, data []byte) (
 	}
 
 	if resp.IsError() {
-		return nil, utils.ResponseStatusError(resp)
+		return nil, utils.ResponseStatusError(invokeUrl, resp)
 	}
 
 	return resp.Body(), nil
@@ -132,7 +132,7 @@ func (api *API) Get(methodName string, headers map[string]string) ([]byte, error
 	}
 
 	if resp.IsError() {
-		return nil, utils.ResponseStatusError(resp)
+		return nil, utils.ResponseStatusError(invokeUrl, resp)
 	}
 
 	return resp.Body(), nil

+ 1 - 1
pubsub/pubsub.go

@@ -54,7 +54,7 @@ func (api *API) publish(pubsubName string, topic string, contentType string, dat
 	}
 
 	if resp.IsError() {
-		return utils.ResponseStatusError(resp)
+		return utils.ResponseStatusError(publishUrl, resp)
 	}
 
 	return nil

+ 5 - 5
state/state.go

@@ -51,7 +51,7 @@ func (api *API) SaveState(storeName string, request []SaveStateRequest) error {
 	}
 
 	if resp.IsError() {
-		return utils.ResponseStatusError(resp)
+		return utils.ResponseStatusError(saveUrl, resp)
 	}
 
 	return nil
@@ -68,7 +68,7 @@ func (api *API) GetState(storeName string, key string, queryParams map[string]st
 	}
 
 	if resp.IsError() {
-		return "", "", utils.ResponseStatusError(resp)
+		return "", "", utils.ResponseStatusError(getUrl, resp)
 	}
 
 	var body string
@@ -97,7 +97,7 @@ func (api *API) GetStateBulk(storeName string, queryParams map[string]string, re
 	}
 
 	if resp.IsError() {
-		return nil, utils.ResponseStatusError(resp)
+		return nil, utils.ResponseStatusError(getBulkUrl, resp)
 	}
 
 	items := make([]GetStateBulkItem, 0)
@@ -122,7 +122,7 @@ func (api *API) DeleteState(storeName string, key string, queryParams map[string
 	}
 
 	if resp.IsError() {
-		return utils.ResponseStatusError(resp)
+		return utils.ResponseStatusError(deleteUrl, resp)
 	}
 
 	return nil
@@ -140,7 +140,7 @@ func (api *API) Transaction(storeName string, request TransactionRequest) error
 	}
 
 	if resp.IsError() {
-		return utils.ResponseStatusError(resp)
+		return utils.ResponseStatusError(transactionUrl, resp)
 	}
 
 	return nil