add tests

Author: marle3003

kafka/record.go

@@ -44,9 +44,7 @@ func (rb *RecordBatch) ReadFrom(d *Decoder, version int16, tag kafkaTag) error {
 	d.reader = io.MultiReader(bytes.NewReader(b), d.reader)
 
 	switch magic {
-	case 0:
-		return rb.readFromV0(d)
-	case 1:
+	case 0, 1:
 		return rb.readFromV1(d)
 	case 2:
 		return rb.readFromV2(d)

kafka/record_v0.go

@@ -0,0 +1,16 @@
+package kafka_test
+
+import (
+	"github.com/stretchr/testify/require"
+	"mokapi/kafka"
+	"strings"
+	"testing"
+)
+
+func TestValidateTopicName(t *testing.T) {
+	require.EqualError(t, kafka.ValidateTopicName(""), "topic name can not be empty")
+	require.EqualError(t, kafka.ValidateTopicName("."), "topic name can not be .")
+	require.EqualError(t, kafka.ValidateTopicName(strings.Repeat("a", 250)), "topic name can not be longer than 249")
+	require.EqualError(t, kafka.ValidateTopicName("a$"), "topic name is not valid, valid characters are ASCII alphanumerics, '.', '_', and '-'")
+	require.NoError(t, kafka.ValidateTopicName("a"))
+}

kafka/validation_test.go

@@ -0,0 +1,34 @@
+package lib_test
+
+import (
+	"fmt"
+	"github.com/stretchr/testify/require"
+	"mokapi/lib"
+	"net/http"
+	"net/http/httptest"
+	"strings"
+	"testing"
+)
+
+func TestGetUrl(t *testing.T) {
+	var s *httptest.Server
+	s = httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+		u := lib.GetUrl(r)
+		require.Equal(t, fmt.Sprintf("%s/foo", s.URL), u)
+		require.True(t, strings.HasPrefix(u, "http"))
+	}))
+	defer s.Close()
+
+	_, err := s.Client().Get(s.URL + "/foo")
+	require.NoError(t, err)
+
+	s = httptest.NewTLSServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+		u := lib.GetUrl(r)
+		require.Equal(t, fmt.Sprintf("%s/foo", s.URL), u)
+		require.True(t, strings.HasPrefix(u, "https"))
+	}))
+	defer s.Close()
+
+	_, err = s.Client().Get(s.URL + "/foo")
+	require.NoError(t, err)
+}