* Add LDAP Key Synchronization feature Signed-off-by: Magnus Lindvall <magnus@dnmgns.com> * Add migration: add login source id column for public_key table * Only update keys if needed * Add function to only list pubkey synchronized from ldap * Only list pub ssh keys synchronized from ldap. Do not sort strings as ExistsInSlice does it. * Only get keys belonging to current login source id * Set default login source id to 0 * Some minor cleanup. Add integration tests (updete dep testify)
		
			
				
	
	
		
			128 lines
		
	
	
		
			4.4 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
			
		
		
	
	
			128 lines
		
	
	
		
			4.4 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
| package assert
 | |
| 
 | |
| import (
 | |
| 	"fmt"
 | |
| 	"net/http"
 | |
| 	"net/http/httptest"
 | |
| 	"net/url"
 | |
| 	"strings"
 | |
| )
 | |
| 
 | |
| // httpCode is a helper that returns HTTP code of the response. It returns -1 and
 | |
| // an error if building a new request fails.
 | |
| func httpCode(handler http.HandlerFunc, method, url string, values url.Values) (int, error) {
 | |
| 	w := httptest.NewRecorder()
 | |
| 	req, err := http.NewRequest(method, url+"?"+values.Encode(), nil)
 | |
| 	if err != nil {
 | |
| 		return -1, err
 | |
| 	}
 | |
| 	handler(w, req)
 | |
| 	return w.Code, nil
 | |
| }
 | |
| 
 | |
| // HTTPSuccess asserts that a specified handler returns a success status code.
 | |
| //
 | |
| //  assert.HTTPSuccess(t, myHandler, "POST", "http://www.google.com", nil)
 | |
| //
 | |
| // Returns whether the assertion was successful (true) or not (false).
 | |
| func HTTPSuccess(t TestingT, handler http.HandlerFunc, method, url string, values url.Values, msgAndArgs ...interface{}) bool {
 | |
| 	code, err := httpCode(handler, method, url, values)
 | |
| 	if err != nil {
 | |
| 		Fail(t, fmt.Sprintf("Failed to build test request, got error: %s", err))
 | |
| 		return false
 | |
| 	}
 | |
| 
 | |
| 	isSuccessCode := code >= http.StatusOK && code <= http.StatusPartialContent
 | |
| 	if !isSuccessCode {
 | |
| 		Fail(t, fmt.Sprintf("Expected HTTP success status code for %q but received %d", url+"?"+values.Encode(), code))
 | |
| 	}
 | |
| 
 | |
| 	return isSuccessCode
 | |
| }
 | |
| 
 | |
| // HTTPRedirect asserts that a specified handler returns a redirect status code.
 | |
| //
 | |
| //  assert.HTTPRedirect(t, myHandler, "GET", "/a/b/c", url.Values{"a": []string{"b", "c"}}
 | |
| //
 | |
| // Returns whether the assertion was successful (true) or not (false).
 | |
| func HTTPRedirect(t TestingT, handler http.HandlerFunc, method, url string, values url.Values, msgAndArgs ...interface{}) bool {
 | |
| 	code, err := httpCode(handler, method, url, values)
 | |
| 	if err != nil {
 | |
| 		Fail(t, fmt.Sprintf("Failed to build test request, got error: %s", err))
 | |
| 		return false
 | |
| 	}
 | |
| 
 | |
| 	isRedirectCode := code >= http.StatusMultipleChoices && code <= http.StatusTemporaryRedirect
 | |
| 	if !isRedirectCode {
 | |
| 		Fail(t, fmt.Sprintf("Expected HTTP redirect status code for %q but received %d", url+"?"+values.Encode(), code))
 | |
| 	}
 | |
| 
 | |
| 	return isRedirectCode
 | |
| }
 | |
| 
 | |
| // HTTPError asserts that a specified handler returns an error status code.
 | |
| //
 | |
| //  assert.HTTPError(t, myHandler, "POST", "/a/b/c", url.Values{"a": []string{"b", "c"}}
 | |
| //
 | |
| // Returns whether the assertion was successful (true) or not (false).
 | |
| func HTTPError(t TestingT, handler http.HandlerFunc, method, url string, values url.Values, msgAndArgs ...interface{}) bool {
 | |
| 	code, err := httpCode(handler, method, url, values)
 | |
| 	if err != nil {
 | |
| 		Fail(t, fmt.Sprintf("Failed to build test request, got error: %s", err))
 | |
| 		return false
 | |
| 	}
 | |
| 
 | |
| 	isErrorCode := code >= http.StatusBadRequest
 | |
| 	if !isErrorCode {
 | |
| 		Fail(t, fmt.Sprintf("Expected HTTP error status code for %q but received %d", url+"?"+values.Encode(), code))
 | |
| 	}
 | |
| 
 | |
| 	return isErrorCode
 | |
| }
 | |
| 
 | |
| // HTTPBody is a helper that returns HTTP body of the response. It returns
 | |
| // empty string if building a new request fails.
 | |
| func HTTPBody(handler http.HandlerFunc, method, url string, values url.Values) string {
 | |
| 	w := httptest.NewRecorder()
 | |
| 	req, err := http.NewRequest(method, url+"?"+values.Encode(), nil)
 | |
| 	if err != nil {
 | |
| 		return ""
 | |
| 	}
 | |
| 	handler(w, req)
 | |
| 	return w.Body.String()
 | |
| }
 | |
| 
 | |
| // HTTPBodyContains asserts that a specified handler returns a
 | |
| // body that contains a string.
 | |
| //
 | |
| //  assert.HTTPBodyContains(t, myHandler, "www.google.com", nil, "I'm Feeling Lucky")
 | |
| //
 | |
| // Returns whether the assertion was successful (true) or not (false).
 | |
| func HTTPBodyContains(t TestingT, handler http.HandlerFunc, method, url string, values url.Values, str interface{}, msgAndArgs ...interface{}) bool {
 | |
| 	body := HTTPBody(handler, method, url, values)
 | |
| 
 | |
| 	contains := strings.Contains(body, fmt.Sprint(str))
 | |
| 	if !contains {
 | |
| 		Fail(t, fmt.Sprintf("Expected response body for \"%s\" to contain \"%s\" but found \"%s\"", url+"?"+values.Encode(), str, body))
 | |
| 	}
 | |
| 
 | |
| 	return contains
 | |
| }
 | |
| 
 | |
| // HTTPBodyNotContains asserts that a specified handler returns a
 | |
| // body that does not contain a string.
 | |
| //
 | |
| //  assert.HTTPBodyNotContains(t, myHandler, "www.google.com", nil, "I'm Feeling Lucky")
 | |
| //
 | |
| // Returns whether the assertion was successful (true) or not (false).
 | |
| func HTTPBodyNotContains(t TestingT, handler http.HandlerFunc, method, url string, values url.Values, str interface{}, msgAndArgs ...interface{}) bool {
 | |
| 	body := HTTPBody(handler, method, url, values)
 | |
| 
 | |
| 	contains := strings.Contains(body, fmt.Sprint(str))
 | |
| 	if contains {
 | |
| 		Fail(t, fmt.Sprintf("Expected response body for \"%s\" to NOT contain \"%s\" but found \"%s\"", url+"?"+values.Encode(), str, body))
 | |
| 	}
 | |
| 
 | |
| 	return !contains
 | |
| }
 |