change csv package name

core/engine.go

@@ -30,7 +30,7 @@ import (
 	"go.ddosify.com/ddosify/core/proxy"
 	"go.ddosify.com/ddosify/core/report"
 	"go.ddosify.com/ddosify/core/scenario"
-	"go.ddosify.com/ddosify/core/scenario/testdata"
+	"go.ddosify.com/ddosify/core/scenario/data"
 	"go.ddosify.com/ddosify/core/types"
 )
 
@@ -378,7 +378,7 @@ var readTestData = func(testDataConf map[string]types.CsvConf) (map[string]types
 	for k, conf := range testDataConf {
 		var rows []map[string]interface{}
 		var err error
-		rows, err = testdata.ReadCsv(conf)
+		rows, err = data.ReadCsv(conf)
 		if err != nil {
 			return nil, err
 		}

core/scenario/testdata/csv.go → core/scenario/data/csv.go

@@ -1,4 +1,4 @@
-package testdata
+package data
 
 import (
 	"encoding/csv"

core/scenario/testdata/csv_test.go → core/scenario/data/csv_test.go

@@ -1,8 +1,10 @@
-package testdata
+package data
 
 import (
 	"errors"
 	"fmt"
+	"net/http"
+	"net/http/httptest"
 	"reflect"
 	"strings"
 	"testing"
@@ -79,6 +81,48 @@ func TestWrapAsRemoteCsvError(t *testing.T) {
 	}
 }
 
+func TestReadCsvFromRemote(t *testing.T) {
+	// Test server
+	handler := func(w http.ResponseWriter, r *http.Request) {
+		w.WriteHeader(http.StatusUnauthorized)
+	}
+
+	path := "/csv"
+	mux := http.NewServeMux()
+	mux.HandleFunc(path, handler)
+
+	server := httptest.NewServer(mux)
+	defer server.Close()
+
+	conf := types.CsvConf{
+		Path:          server.URL + path,
+		Delimiter:     ";",
+		SkipFirstLine: true,
+		Vars: map[string]types.Tag{
+			"0": {Tag: "name", Type: "string"},
+			"3": {Tag: "payload", Type: "json"},
+			"4": {Tag: "age", Type: "int"},
+			"5": {Tag: "percent", Type: "float"},
+			"6": {Tag: "boolField", Type: "bool"},
+		},
+		SkipEmptyLine: true,
+		AllowQuota:    true,
+		Order:         "sequential",
+	}
+
+	_, err := ReadCsv(conf)
+
+	if err == nil {
+		t.Errorf("TestReadCsvFromRemote %v", err)
+	}
+
+	var remoteCsvErr RemoteCsvError
+	if !errors.As(err, &remoteCsvErr) {
+		t.Errorf("Expected: %v, Found: %v", remoteCsvErr, err)
+	}
+
+}
+
 func TestReadCsv(t *testing.T) {
 	t.Parallel()
 	conf := types.CsvConf{