Add support for basic auth username and password (#36)

cli/cmd/helper.go

@@ -4,8 +4,9 @@ import (
 	"crypto/tls"
 	"encoding/json"
 	"fmt"
-	"github.com/ricardo-ch/go-kafka-connect/lib/connectors"
 	"log"
+
+	"github.com/ricardo-ch/go-kafka-connect/lib/connectors"
 )
 
 func printResponse(response interface{}) error {
@@ -25,6 +26,9 @@ func getClient() connectors.HighLevelClient {
 	if SSLInsecure {
 		client.SetInsecureSSL()
 	}
+	if basicAuthUsername != "" && basicAuthPassword != "" {
+		client.SetBasicAuth(basicAuthUsername, basicAuthPassword)
+	}
 	if len(SSLClientCertificate) > 0 && len(SSLClientPrivateKey) > 0 {
 		cert, err := tls.LoadX509KeyPair(SSLClientCertificate, SSLClientPrivateKey)
 		if err != nil {

cli/cmd/root.go

@@ -35,6 +35,8 @@ var (
 	parallel             int
 	SSLClientCertificate string
 	SSLClientPrivateKey  string
+	basicAuthUsername    string
+	basicAuthPassword    string
 )
 
 var RootCmd = &cobra.Command{
@@ -60,4 +62,6 @@ func init() {
 	RootCmd.PersistentFlags().BoolVarP(&SSLInsecure, "insecure-skip-verify", "i", false, `skip SSL/TLS verification`)
 	RootCmd.PersistentFlags().StringVarP(&SSLClientCertificate, "ssl-client-certificate", "C", "", `path to client certificate, must contain PEM encoded data`)
 	RootCmd.PersistentFlags().StringVarP(&SSLClientPrivateKey, "ssl-client-key", "K", "", `path to client private key`)
+	RootCmd.PersistentFlags().StringVarP(&basicAuthUsername, "username", "U", "", `HTTP Basic Auth username`)
+	RootCmd.PersistentFlags().StringVarP(&basicAuthPassword, "password", "P", "", `HTTP Basic Auth password`)
 }

lib/connectors/base_client.go

@@ -3,10 +3,11 @@ package connectors
 import (
 	"crypto/tls"
 	"fmt"
-	"github.com/pkg/errors"
-	"gopkg.in/resty.v1"
 	"strconv"
 	"time"
+
+	"github.com/pkg/errors"
+	"gopkg.in/resty.v1"
 )
 
 // BaseClient implement the kafka-connect contract as a client
@@ -29,6 +30,7 @@ type BaseClient interface {
 	SetInsecureSSL()
 	SetDebug()
 	SetClientCertificates(certs ...tls.Certificate)
+	SetBasicAuth(username string, password string)
 }
 
 type baseClient struct {
@@ -47,6 +49,10 @@ func (c *baseClient) SetClientCertificates(certs ...tls.Certificate) {
 	c.restClient.SetCertificates(certs...)
 }
 
+func (c *baseClient) SetBasicAuth(username string, password string) {
+	c.restClient.SetBasicAuth(username, password)
+}
+
 //ErrorResponse is generic error returned by kafka connect
 type ErrorResponse struct {
 	ErrorCode int    `json:"error_code,omitempty"`

lib/connectors/highlevel_client.go

@@ -35,6 +35,7 @@ type HighLevelClient interface {
 	SetDebug()
 	SetClientCertificates(certs ...tls.Certificate)
 	SetParallelism(value int)
+	SetBasicAuth(username string, password string)
 }
 
 type highLevelClient struct {
@@ -65,6 +66,10 @@ func (c *highLevelClient) SetClientCertificates(certs ...tls.Certificate) {
 	c.client.SetClientCertificates(certs...)
 }
 
+func (c *highLevelClient) SetBasicAuth(username string, password string) {
+	c.client.SetBasicAuth(username, password)
+}
+
 //GetAll gets the list of all active connectors
 func (c *highLevelClient) GetAll() (GetAllConnectorsResponse, error) {
 	return c.client.GetAll()