MCPcopy
hub / github.com/crowdsecurity/crowdsec / TestNewDefaultClient_UnixSocket

Function TestNewDefaultClient_UnixSocket

pkg/apiclient/client_test.go:222–250  ·  view source on GitHub ↗
(t *testing.T)

Source from the content-addressed store, hash-verified

220}
221
222func TestNewDefaultClient_UnixSocket(t *testing.T) {
223 ctx := t.Context()
224
225 socket, err := nettest.LocalPath()
226 require.NoError(t, err)
227
228 mux, urlx, teardown := setupUnixSocketWithPrefix(t, socket, "v1")
229 defer teardown()
230
231 apiURL, err := url.Parse(urlx)
232 if err != nil {
233 t.Fatalf("parsing api url: %s", apiURL)
234 }
235
236 client, err := NewDefaultClient(apiURL, "/v1", "", nil)
237 if err != nil {
238 t.Fatalf("new api client: %s", err)
239 }
240
241 mux.HandleFunc("/alerts", func(w http.ResponseWriter, _ *http.Request) {
242 w.WriteHeader(http.StatusUnauthorized)
243 _, err := w.Write([]byte(`{"code": 401, "message" : "brr"}`))
244 assert.NoError(t, err)
245 })
246
247 _, _, err = client.Alerts.List(ctx, AlertsListOpts{})
248 assert.Contains(t, err.Error(), `performing request: API error: brr`)
249 log.Printf("err-> %s", err)
250}
251
252func TestNewClientRegisterKO(t *testing.T) {
253 ctx := t.Context()

Callers

nothing calls this directly

Calls 6

NewDefaultClientFunction · 0.85
WriteMethod · 0.80
ErrorMethod · 0.65
ParseMethod · 0.45
ListMethod · 0.45

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…