Return error message when healthcheck set to false and credentials ar…

…e incorrect (#148)

Signed-off-by: Rupa Lahiri <[email protected]>

provider/provider.go

@@ -398,6 +398,8 @@ func getClient(conf *ProviderConf) (*elastic7.Client, error) {
 		info, httpStatus, err := client.Ping(conf.rawUrl).Do(ctx)
 		if httpStatus == http.StatusForbidden {
 			return nil, errors.New("HTTP 403 Forbidden: Permission denied. Please ensure that the correct credentials are being used to access the cluster.")
+		} else if httpStatus == http.StatusUnauthorized {
+			return nil, errors.New("HTTP 401 Unauthorized: Please ensure that the correct credentials are being used to access the cluster")
 		}
 		if err != nil {
 			// Replace the timeout error because it gives no context

provider/provider_test.go

@@ -4,6 +4,7 @@ import (
 	"context"
 	"net/http"
 	"net/http/httptest"
+	"net/url"
 	"os"
 	"strings"
 	"testing"
@@ -69,6 +70,29 @@ func testAccPreCheck(t *testing.T) {
 	}
 }
 
+// Given:
+// 1. invalid username and password and healthcheck is false
+//
+// this tests that 401 error is returned by getClient
+func TestInvalidCredentials(t *testing.T) {
+	parsedUrl, _ := url.Parse("http://127.0.0.1:9200")
+	testConfig := &ProviderConf{
+		username:           "1234",
+		password:           "1234",
+		healthchecking:     false,
+		rawUrl:             "http://127.0.0.1:9200",
+		sniffing:           false,
+		parsedUrl:          parsedUrl,
+		pingTimeoutSeconds: 10,
+	}
+	_, err := getClient(testConfig)
+
+	errString := "HTTP 401 Unauthorized: Please ensure that the correct credentials are being used to access the cluster"
+	if err.Error() != errString {
+		t.Errorf("Error thrown should be %s", errString)
+	}
+}
+
 // Given:
 // 1. AWS credentials are specified via environment variables
 // 2. aws access key and secret access key are specified via the provider configuration