Skip to content

Commit

Permalink
fix unit test and avoid httpmock
Browse files Browse the repository at this point in the history
  • Loading branch information
mmetc committed Mar 22, 2024
1 parent 77b5d16 commit d70d3ad
Show file tree
Hide file tree
Showing 2 changed files with 37 additions and 33 deletions.
8 changes: 3 additions & 5 deletions pkg/cwhub/cwhub.go
Expand Up @@ -13,20 +13,18 @@ import (

// hubTransport wraps a Transport to set a custom User-Agent.
type hubTransport struct {
Transport http.RoundTripper
http.RoundTripper
}

func (t *hubTransport) RoundTrip(req *http.Request) (*http.Response, error) {
req.Header.Set("User-Agent", "crowdsec/"+version.String())
return t.Transport.RoundTrip(req)
return t.RoundTripper.RoundTrip(req)
}

// hubClient is the HTTP client used to communicate with the CrowdSec Hub.
var hubClient = &http.Client{
Timeout: 120 * time.Second,
Transport: &hubTransport{
Transport: http.DefaultTransport,
},
Transport: &hubTransport{http.DefaultTransport},
}

// safePath returns a joined path and ensures that it does not escape the base directory.
Expand Down
62 changes: 34 additions & 28 deletions pkg/cwhub/dataset_test.go
@@ -1,50 +1,56 @@
package cwhub

import (
"io"
"net/http"
"net/http/httptest"
"os"
"path/filepath"
"testing"

"github.com/jarcoal/httpmock"
"github.com/stretchr/testify/assert"
"github.com/stretchr/testify/require"

"github.com/crowdsecurity/go-cs-lib/cstest"
)

func TestDownloadFile(t *testing.T) {
examplePath := "./example.txt"
defer os.Remove(examplePath)

httpmock.Activate()
defer httpmock.DeactivateAndReset()

// OK
httpmock.RegisterResponder(
"GET",
"https://example.com/xx",
httpmock.NewStringResponder(200, "example content oneoneone"),
)

httpmock.RegisterResponder(
"GET",
"https://example.com/x",
httpmock.NewStringResponder(404, "not found"),
)

err := downloadFile("https://example.com/xx", examplePath)
ts := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
switch r.URL.Path {
case "/xx":
w.WriteHeader(http.StatusOK)
_, _ = io.WriteString(w, "example content oneoneone")
default:
w.WriteHeader(http.StatusNotFound)
_, _ = io.WriteString(w, "not found")
}
}))
defer ts.Close()

dest := filepath.Join(t.TempDir(), "example.txt")
defer os.Remove(dest)

err := downloadFile(ts.URL+"/xx", dest)
require.NoError(t, err)

content, err := os.ReadFile(examplePath)
content, err := os.ReadFile(dest)
assert.Equal(t, "example content oneoneone", string(content))
require.NoError(t, err)

// bad uri
err = downloadFile("https://zz.com", examplePath)
require.Error(t, err)
err = downloadFile("https://zz.com", dest)
cstest.RequireErrorContains(t, err, "lookup zz.com")
cstest.RequireErrorContains(t, err, "no such host")

// 404
err = downloadFile("https://example.com/x", examplePath)
require.Error(t, err)
err = downloadFile(ts.URL+"/x", dest)
cstest.RequireErrorContains(t, err, "bad http code 404")

// bad target
err = downloadFile("https://example.com/xx", "")
require.Error(t, err)
err = downloadFile(ts.URL+"/xx", "")
cstest.RequireErrorContains(t, err, "no such file or directory")

// destination directory does not exist
err = downloadFile(ts.URL+"/xx", filepath.Join(t.TempDir(), "missing/example.txt"))
cstest.RequireErrorContains(t, err, "no such file or directory")
}

0 comments on commit d70d3ad

Please sign in to comment.