50 lines
1.1 KiB
Go
50 lines
1.1 KiB
Go
/*
|
|
Copyright IBM Corp. All Rights Reserved.
|
|
|
|
SPDX-License-Identifier: Apache-2.0
|
|
*/
|
|
|
|
package osnadmin
|
|
|
|
import (
|
|
"bytes"
|
|
"crypto/tls"
|
|
"crypto/x509"
|
|
"fmt"
|
|
"mime/multipart"
|
|
"net/http"
|
|
)
|
|
|
|
// Joins an OSN to a new or existing channel.
|
|
func Join(osnURL string, blockBytes []byte, caCertPool *x509.CertPool, tlsClientCert tls.Certificate) (*http.Response, error) {
|
|
url := fmt.Sprintf("%s/participation/v1/channels", osnURL)
|
|
req, err := createJoinRequest(url, blockBytes)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return httpDo(req, caCertPool, tlsClientCert)
|
|
}
|
|
|
|
func createJoinRequest(url string, blockBytes []byte) (*http.Request, error) {
|
|
joinBody := new(bytes.Buffer)
|
|
writer := multipart.NewWriter(joinBody)
|
|
part, err := writer.CreateFormFile("config-block", "config.block")
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
part.Write(blockBytes)
|
|
err = writer.Close()
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
req, err := http.NewRequest(http.MethodPost, url, joinBody)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
req.Header.Set("Content-Type", writer.FormDataContentType())
|
|
|
|
return req, nil
|
|
}
|