add fetch and update helper functions

Signed-off-by: dimaxgl <[email protected]>

Author: dimaxgl

internal/osnadmin/update.go

@@ -2,6 +2,7 @@ package osnadmin
 
 import (
 	"bytes"
+	"context"
 	"crypto/tls"
 	"crypto/x509"
 	"fmt"
@@ -10,18 +11,18 @@ import (
 )
 
 // Update channel configuration using presented config envelope.
-func Update(osnURL, channelID string, caCertPool *x509.CertPool, tlsClientCert tls.Certificate, configEnvelope []byte) (*http.Response, error) {
+func Update(ctx context.Context, osnURL, channelID string, caCertPool *x509.CertPool, tlsClientCert tls.Certificate, configEnvelope []byte) (*http.Response, error) {
 	url := fmt.Sprintf("%s/participation/v1/channels/%s", osnURL, channelID)
 
-	req, err := createUpdateRequest(url, configEnvelope)
+	req, err := createUpdateRequest(ctx, url, configEnvelope)
 	if err != nil {
 		return nil, fmt.Errorf("create update request: %w", err)
 	}
 
 	return httpDo(req, caCertPool, tlsClientCert)
 }
 
-func createUpdateRequest(url string, configEnvelope []byte) (*http.Request, error) {
+func createUpdateRequest(ctx context.Context, url string, configEnvelope []byte) (*http.Request, error) {
 	joinBody := new(bytes.Buffer)
 	writer := multipart.NewWriter(joinBody)
 	part, err := writer.CreateFormFile("config-update-envelope", "config_update.pb")
@@ -37,7 +38,7 @@ func createUpdateRequest(url string, configEnvelope []byte) (*http.Request, erro
 		return nil, err
 	}
 
-	req, err := http.NewRequest(http.MethodPut, url, joinBody)
+	req, err := http.NewRequestWithContext(ctx, http.MethodPut, url, joinBody)
 	if err != nil {
 		return nil, err
 	}

pkg/channel/channel.go

@@ -13,9 +13,9 @@ import (
 	"github.com/hyperledger/fabric-admin-sdk/internal/protoutil"
 	"github.com/hyperledger/fabric-admin-sdk/pkg/identity"
 	"github.com/hyperledger/fabric-admin-sdk/pkg/internal/proposal"
-	"github.com/hyperledger/fabric-protos-go-apiv2/peer"
 
 	cb "github.com/hyperledger/fabric-protos-go-apiv2/common"
+	"github.com/hyperledger/fabric-protos-go-apiv2/peer"
 	"google.golang.org/grpc"
 	"google.golang.org/protobuf/proto"
 )
@@ -110,3 +110,8 @@ func ListChannelOnPeer(ctx context.Context, connection grpc.ClientConnInterface,
 	}
 	return channelQueryResponse.GetChannels(), nil
 }
+
+func UpdateChannel(ctx context.Context, osnURL string, caCertPool *x509.CertPool, tlsClientCert tls.Certificate, channelName string, env *cb.Envelope) (*http.Response, error) {
+	envelopeBytes := protoutil.MarshalOrPanic(env)
+	return osnadmin.Update(ctx, osnURL, channelName, caCertPool, tlsClientCert, envelopeBytes)
+}