ci: fix linter warnings

Signed-off-by: Felix Gateru <[email protected]>
absmach · Jan 30, 2025 · f1aeccf · f1aeccf
1 parent 0d127da
commit f1aeccf
Show file tree

Hide file tree

Showing 5 changed files with 0 additions and 22 deletions.
diff --git a/cmd/coap/main.go b/cmd/coap/main.go
@@ -49,7 +49,6 @@ type config struct {
 	InstanceID    string  `env:"SMQ_COAP_ADAPTER_INSTANCE_ID" envDefault:""`
 	TraceRatio    float64 `env:"SMQ_JAEGER_TRACE_RATIO"       envDefault:"1.0"`
 	ESURL         string  `env:"SMQ_ES_URL"                   envDefault:"nats://localhost:4222"`
-	ESURL         string  `env:"SMQ_ES_URL"                   envDefault:"nats://localhost:4222"`
 }
 
 func main() {

diff --git a/cmd/http/main.go b/cmd/http/main.go
@@ -61,7 +61,6 @@ type config struct {
 	InstanceID    string  `env:"SMQ_HTTP_ADAPTER_INSTANCE_ID" envDefault:""`
 	TraceRatio    float64 `env:"SMQ_JAEGER_TRACE_RATIO"       envDefault:"1.0"`
 	ESURL         string  `env:"SMQ_ES_URL"                   envDefault:"nats://localhost:4222"`
-	ESURL         string  `env:"SMQ_ES_URL"                   envDefault:"nats://localhost:4222"`
 }
 
 func main() {

diff --git a/mqtt/events/events.go b/mqtt/events/events.go
@@ -41,7 +41,6 @@ type subscribeEvent struct {
 	subtopic     string
 }
 
-func (se subscribeEvent) Encode() (map[string]interface{}, error) {
 func (se subscribeEvent) Encode() (map[string]interface{}, error) {
 	return map[string]interface{}{
 		"operation":     se.operation,

diff --git a/mqtt/handler.go b/mqtt/handler.go
@@ -53,7 +53,6 @@ var (
 	ErrFailedParseSubtopic          = errors.New("failed to parse subtopic")
 	ErrFailedPublishConnectEvent    = errors.New("failed to publish connect event")
 	ErrFailedSubscribeEvent         = errors.New("failed to publish subscribe event")
-	ErrFailedSubscribeEvent         = errors.New("failed to publish subscribe event")
 	ErrFailedPublishToMsgBroker     = errors.New("failed to publish to supermq message broker")
 )
 
@@ -290,23 +289,6 @@ func parseTopic(topic string) (string, string, error) {
 	return chanID, subtopic, nil
 }
 
-func parseTopic(topic string) (string, string, error) {
-	channelParts := channelRegExp.FindStringSubmatch(topic)
-	if len(channelParts) < 2 {
-		return "", "", errors.Wrap(ErrFailedPublish, ErrMalformedTopic)
-	}
-
-	chanID := channelParts[1]
-	subtopic := channelParts[2]
-
-	subtopic, err := parseSubtopic(subtopic)
-	if err != nil {
-		return "", "", errors.Wrap(ErrFailedParseSubtopic, err)
-	}
-
-	return chanID, subtopic, nil
-}
-
 func parseSubtopic(subtopic string) (string, error) {
 	if subtopic == "" {
 		return subtopic, nil

diff --git a/mqtt/handler_test.go b/mqtt/handler_test.go
@@ -450,7 +450,6 @@ func TestSubscribe(t *testing.T) {
 		assert.Contains(t, logBuffer.String(), tc.logMsg)
 		assert.Equal(t, tc.err, err)
 		eventsCall.Unset()
-		eventsCall.Unset()
 	}
 }