removed unused function, add listen_socket to CI package tests

pkg/apiclient/client.go

@@ -175,24 +175,24 @@ func RegisterClient(config *Config, client *http.Client) (*ApiClient, error) {
 
 func createTransport(url *url.URL) (*http.Transport, *url.URL) {
 	urlString := url.String()
+
+	// TCP transport
 	if !strings.HasPrefix(urlString, "/") {
 		return nil, url
 	}
 
-	ToUnixSocketUrl(url)
+	// Unix transport
+	url.Path = "/"
+	url.Host = "unix"
+	url.Scheme = "http"
+
 	return &http.Transport{
 		DialContext: func(_ context.Context, _, _ string) (net.Conn, error) {
 			return net.Dial("unix", strings.TrimSuffix(urlString, "/"))
 		},
 	}, url
 }
 
-func ToUnixSocketUrl(url *url.URL) {
-	url.Path = "/"
-	url.Host = "unix"
-	url.Scheme = "http"
-}
-
 type Response struct {
 	Response *http.Response
 	//add our pagination stuff

pkg/apiserver/middlewares/v1/jwt.go

@@ -4,7 +4,6 @@ import (
 	"crypto/rand"
 	"errors"
 	"fmt"
-	"net"
 	"net/http"
 	"os"
 	"strings"
@@ -178,14 +177,6 @@ func (j *JWT) authPlain(c *gin.Context) (*authInput, error) {
 	return &ret, nil
 }
 
-func isUnixSocket(c *gin.Context) bool {
-	if localAddr, ok := c.Request.Context().Value(http.LocalAddrContextKey).(net.Addr); ok {
-		return strings.HasPrefix(localAddr.Network(), "unix")
-	}
-
-	return false
-}
-
 func (j *JWT) Authenticator(c *gin.Context) (interface{}, error) {
 	var (
 		err  error

test/lib/config/config-global

@@ -58,6 +58,7 @@ config_prepare() {
     # remove trailing slash from CONFIG_DIR
     # since it's assumed to be missing during the tests
     yq e -i '
+        .api.server.listen_socket="/run/crowdsec.sock" |
         .config_paths.config_dir |= sub("/$", "")
     ' "${CONFIG_DIR}/config.yaml"
 }