add unit tests

Author: freeznet

.licenserc.yaml

@@ -0,0 +1,40 @@
+# Copyright 2024 StreamNative
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+
+header:
+  license:
+    spdx-id: Apache-2.0
+    copyright-owner: StreamNative
+
+  paths-ignore:
+    - 'dist'
+    - 'licenses'
+    - '**/*.md'
+    - 'LICENSE'
+    - 'NOTICE'
+    - '.github/**'
+    - 'PROJECT'
+    - '**/go.mod'
+    - '**/go.work'
+    - '**/go.work.sum'
+    - '**/go.sum'
+    - '**/*.json'
+    - 'sdk/**'
+    - '**/*.yaml'
+    - '**/*.yml'
+    - 'Makefile'
+    - '.gitignore'
+
+  comment: on-failure

Makefile

@@ -19,7 +19,11 @@ build:
 		-X ${VERSION_PATH}.date=${BUILD_DATE}" \
 		-o bin/snmcp cmd/streamnative-mcp-server/main.go
 
-# go install github.com/elastic/go-licenser@latest
-.PHONY: fix-license
-fix-license:
-	go-licenser -license ASL2 -exclude sdk
+.PHONY: license-check
+license-check:
+	license-eye header check
+
+# go install github.com/apache/skywalking-eyes/cmd/license-eye@latest
+.PHONY: license-fix
+license-fix:
+	license-eye header fix

go.mod

@@ -17,6 +17,7 @@ require (
 	github.com/streamnative/pulsarctl v0.4.3-0.20250312214758-e472faec284b
 	github.com/streamnative/streamnative-mcp-server/sdk/sdk-apiserver v0.0.0-20250506174209-b67ea08ddd82
 	github.com/streamnative/streamnative-mcp-server/sdk/sdk-kafkaconnect v0.0.0-00010101000000-000000000000
+	github.com/stretchr/testify v1.10.0
 	github.com/twmb/franz-go v1.18.1
 	github.com/twmb/franz-go/pkg/kadm v1.16.0
 	github.com/twmb/franz-go/pkg/sr v1.3.0

pkg/common/utils.go

@@ -55,9 +55,22 @@ func RequiredParam[T comparable](arguments map[string]interface{}, p string) (T,
 		return zero, fmt.Errorf("parameter %s is not of type %T", p, zero)
 	}
 
-	if arguments[p].(T) == zero {
-		return zero, fmt.Errorf("missing required parameter: %s", p)
-
+	_, isBool := interface{}(zero).(bool)
+	_, isInt := interface{}(zero).(int)
+	_, isInt8 := interface{}(zero).(int8)
+	_, isInt16 := interface{}(zero).(int16)
+	_, isInt32 := interface{}(zero).(int32)
+	_, isInt64 := interface{}(zero).(int64)
+	_, isFloat32 := interface{}(zero).(float32)
+	_, isFloat64 := interface{}(zero).(float64)
+	_, isUint8 := interface{}(zero).(uint8)
+	_, isUint16 := interface{}(zero).(uint16)
+	_, isUint32 := interface{}(zero).(uint32)
+	_, isUint64 := interface{}(zero).(uint64)
+	if !isBool && !isInt && !isInt8 && !isInt16 && !isInt32 && !isInt64 && !isFloat32 && !isFloat64 && !isUint8 && !isUint16 && !isUint32 && !isUint64 {
+		if arguments[p].(T) == zero {
+			return zero, fmt.Errorf("missing required parameter: %s", p)
+		}
 	}
 
 	return arguments[p].(T), nil