From c35bc4221078a64fe06b1f291bd8b25101adf452 Mon Sep 17 00:00:00 2001 From: Dusan Borovcanin Date: Fri, 6 Jun 2025 13:39:20 +0200 Subject: [PATCH] NOISSUE - Fix typos Signed-off-by: Dusan Borovcanin --- alarms/consumer/consumer.go | 2 +- bootstrap/postgres/configs_test.go | 8 ++++---- cli/bootstrap_test.go | 10 +++++----- cmd/alarms/main.go | 2 +- consumers/notifiers/api/endpoint.go | 4 ++-- consumers/notifiers/api/transport.go | 6 +++--- docker/addons/vault/README.md | 2 +- docker/supermq-docker/addons/vault/README.md | 2 +- pkg/sdk/bootstrap_test.go | 10 +++++----- re/handlers.go | 4 ++-- tools/mqtt-bench/README.md | 2 +- tools/mqtt-bench/cmd/main.go | 2 +- 12 files changed, 27 insertions(+), 27 deletions(-) diff --git a/alarms/consumer/consumer.go b/alarms/consumer/consumer.go index 7cb14f22d..3ad22c129 100644 --- a/alarms/consumer/consumer.go +++ b/alarms/consumer/consumer.go @@ -20,7 +20,7 @@ type handler struct { logger *slog.Logger } -func Newhandler(svc alarms.Service, logger *slog.Logger) messaging.MessageHandler { +func NewHandler(svc alarms.Service, logger *slog.Logger) messaging.MessageHandler { return &handler{svc: svc, logger: logger} } diff --git a/bootstrap/postgres/configs_test.go b/bootstrap/postgres/configs_test.go index dfbb6cf89..6eceb8b5e 100644 --- a/bootstrap/postgres/configs_test.go +++ b/bootstrap/postgres/configs_test.go @@ -676,15 +676,15 @@ func TestUpdateChannel(t *testing.T) { cfg, err := repo.RetrieveByID(context.Background(), c.DomainID, c.ClientID) assert.Nil(t, err, fmt.Sprintf("Retrieving config expected to succeed: %s.\n", err)) - var retreved bootstrap.Channel + var retrieved bootstrap.Channel for _, c := range cfg.Channels { if c.ID == id { - retreved = c + retrieved = c break } } - update.DomainID = retreved.DomainID - assert.Equal(t, update, retreved, fmt.Sprintf("expected %s, go %s", update, retreved)) + update.DomainID = retrieved.DomainID + assert.Equal(t, update, retrieved, fmt.Sprintf("expected %s, go %s", update, retrieved)) } func TestRemoveChannel(t *testing.T) { diff --git a/cli/bootstrap_test.go b/cli/bootstrap_test.go index 3b28677cd..2e7acf5dd 100644 --- a/cli/bootstrap_test.go +++ b/cli/bootstrap_test.go @@ -45,7 +45,7 @@ func TestCreateBootstrapConfigCmd(t *testing.T) { rootCmd := setFlags(bootCmd) jsonConfig := fmt.Sprintf("{\"external_id\":\"09:6:0:sb:sa\", \"client_id\": \"%s\", \"external_key\":\"key\", \"name\": \"%s\", \"channels\":[\"%s\"]}", clientID, "Test Bootstrap", channelID) - invalidJson := fmt.Sprintf("{\"external_id\":\"09:6:0:sb:sa\", \"client_id\": \"%s\", \"external_key\":\"key\", \"name\": \"%s\", \"channels\":[\"%s\"]", clientID, "Test Bootdtrap", channelID) + invalidJson := fmt.Sprintf("{\"external_id\":\"09:6:0:sb:sa\", \"client_id\": \"%s\", \"external_key\":\"key\", \"name\": \"%s\", \"channels\":[\"%s\"]", clientID, "Test Bootstrap", channelID) cases := []struct { desc string args []string @@ -549,7 +549,7 @@ func TestBootstrapConfigCmd(t *testing.T) { rootCmd := setFlags(bootCmd) var boot mgsdk.BootstrapConfig - crptoKey := "v7aT0HGxJxt2gULzr3RHwf4WIf6DusPp" + cryptoKey := "v7aT0HGxJxt2gULzr3RHwf4WIf6DusPp" invalidKey := "invalid key" cases := []struct { desc string @@ -565,7 +565,7 @@ func TestBootstrapConfigCmd(t *testing.T) { "secure", bootConfig.ExternalID, bootConfig.ExternalKey, - crptoKey, + cryptoKey, }, boot: bootConfig, logType: entityLog, @@ -582,7 +582,7 @@ func TestBootstrapConfigCmd(t *testing.T) { { desc: "bootstrap secure config with invalid args", args: []string{ - crptoKey, + cryptoKey, }, logType: usageLog, @@ -593,7 +593,7 @@ func TestBootstrapConfigCmd(t *testing.T) { "secure", bootConfig.ExternalID, invalidKey, - crptoKey, + cryptoKey, }, sdkErr: errors.NewSDKErrorWithStatus(svcerr.ErrAuthorization, http.StatusUnauthorized), errLogMessage: fmt.Sprintf("\nerror: %s\n\n", errors.NewSDKErrorWithStatus(svcerr.ErrAuthorization, http.StatusUnauthorized)), diff --git a/cmd/alarms/main.go b/cmd/alarms/main.go index 39fc3bdf7..61311595f 100644 --- a/cmd/alarms/main.go +++ b/cmd/alarms/main.go @@ -163,7 +163,7 @@ func main() { defer pubSub.Close() pubSub = brokerstracing.NewPubSub(httpServerConfig, tracer, pubSub) - consumer := consumer.Newhandler(svc, logger) + consumer := consumer.NewHandler(svc, logger) subCfg := messaging.SubscriberConfig{ ID: svcName, diff --git a/consumers/notifiers/api/endpoint.go b/consumers/notifiers/api/endpoint.go index 77267b67f..6acfd3198 100644 --- a/consumers/notifiers/api/endpoint.go +++ b/consumers/notifiers/api/endpoint.go @@ -34,7 +34,7 @@ func createSubscriptionEndpoint(svc notifiers.Service) endpoint.Endpoint { } } -func viewSubscriptionEndpint(svc notifiers.Service) endpoint.Endpoint { +func viewSubscriptionEndpoint(svc notifiers.Service) endpoint.Endpoint { return func(ctx context.Context, request interface{}) (interface{}, error) { req := request.(subReq) if err := req.validate(); err != nil { @@ -89,7 +89,7 @@ func listSubscriptionsEndpoint(svc notifiers.Service) endpoint.Endpoint { } } -func deleteSubscriptionEndpint(svc notifiers.Service) endpoint.Endpoint { +func deleteSubscriptionEndpoint(svc notifiers.Service) endpoint.Endpoint { return func(ctx context.Context, request interface{}) (interface{}, error) { req := request.(subReq) if err := req.validate(); err != nil { diff --git a/consumers/notifiers/api/transport.go b/consumers/notifiers/api/transport.go index e3924563f..1d05bde45 100644 --- a/consumers/notifiers/api/transport.go +++ b/consumers/notifiers/api/transport.go @@ -55,21 +55,21 @@ func MakeHandler(svc notifiers.Service, logger *slog.Logger, instanceID string) ), "list").ServeHTTP) r.Delete("/", otelhttp.NewHandler(kithttp.NewServer( - deleteSubscriptionEndpint(svc), + deleteSubscriptionEndpoint(svc), decodeSubscription, api.EncodeResponse, opts..., ), "delete").ServeHTTP) r.Get("/{subID}", otelhttp.NewHandler(kithttp.NewServer( - viewSubscriptionEndpint(svc), + viewSubscriptionEndpoint(svc), decodeSubscription, api.EncodeResponse, opts..., ), "view").ServeHTTP) r.Delete("/{subID}", otelhttp.NewHandler(kithttp.NewServer( - deleteSubscriptionEndpint(svc), + deleteSubscriptionEndpoint(svc), decodeSubscription, api.EncodeResponse, opts..., diff --git a/docker/addons/vault/README.md b/docker/addons/vault/README.md index ab9f1fc73..ac6117d5f 100644 --- a/docker/addons/vault/README.md +++ b/docker/addons/vault/README.md @@ -202,7 +202,7 @@ policies ["default" "magistrala_things_certs_issue"] token_meta_role_name magistrala_things_certs_issuer ``` -By default, the `vault_create_approle.sh` script tries to enable the AppRole authentication method. Certs service uses the approle credentials to issue and revoke things certificate from vault intermedate CA. If AppRole is already enabled, you can skip this step by passing the `--skip-enable-approle` argument: +By default, the `vault_create_approle.sh` script tries to enable the AppRole authentication method. Certs service uses the approle credentials to issue and revoke things certificate from vault intermediate CA. If AppRole is already enabled, you can skip this step by passing the `--skip-enable-approle` argument: ```sh ./vault_create_approle.sh --skip-enable-approle diff --git a/docker/supermq-docker/addons/vault/README.md b/docker/supermq-docker/addons/vault/README.md index 4b84b4012..f92deeb87 100644 --- a/docker/supermq-docker/addons/vault/README.md +++ b/docker/supermq-docker/addons/vault/README.md @@ -202,7 +202,7 @@ policies ["default" "supermq_clients_certs_issue"] token_meta_role_name supermq_clients_certs_issuer ``` -By default, the `vault_create_approle.sh` script tries to enable the AppRole authentication method. Certs service uses the approle credentials to issue and revoke clients certificate from vault intermedate CA. If AppRole is already enabled, you can skip this step by passing the `--skip-enable-approle` argument: +By default, the `vault_create_approle.sh` script tries to enable the AppRole authentication method. Certs service uses the approle credentials to issue and revoke clients certificate from vault intermediate CA. If AppRole is already enabled, you can skip this step by passing the `--skip-enable-approle` argument: ```sh ./vault_create_approle.sh --skip-enable-approle diff --git a/pkg/sdk/bootstrap_test.go b/pkg/sdk/bootstrap_test.go index 16a13094c..f586d3818 100644 --- a/pkg/sdk/bootstrap_test.go +++ b/pkg/sdk/bootstrap_test.go @@ -77,7 +77,7 @@ var ( Content: content, State: state, } - sdkBootsrapConfigRes = sdk.BootstrapConfig{ + sdkBootstrapConfigRes = sdk.BootstrapConfig{ ClientID: clientId, ClientSecret: clientSecret, Channels: []smqSDK.Channel{ @@ -528,7 +528,7 @@ func TestViewBootstrap(t *testing.T) { viewBoostrapRes := sdk.BootstrapConfig{ ClientID: clientId, - Channels: sdkBootsrapConfigRes.Channels, + Channels: sdkBootstrapConfigRes.Channels, ExternalID: externalId, ExternalKey: externalKey, Name: bsName, @@ -1145,7 +1145,7 @@ func TestBoostrap(t *testing.T) { svcErr: nil, readerResp: readConfigResponse, readerErr: nil, - response: sdkBootsrapConfigRes, + response: sdkBootstrapConfigRes, err: nil, }, { @@ -1258,7 +1258,7 @@ func TestBootstrapSecure(t *testing.T) { svcErr: nil, readerResp: encResponse, readerErr: nil, - response: sdkBootsrapConfigRes, + response: sdkBootstrapConfigRes, err: nil, }, { @@ -1328,7 +1328,7 @@ func TestBootstrapSecure(t *testing.T) { resp, err := mgsdk.BootstrapSecure(context.Background(), tc.externalID, tc.externalKey, tc.cryptoKey) assert.Equal(t, tc.err, err) if err == nil { - assert.Equal(t, sdkBootsrapConfigRes, resp) + assert.Equal(t, sdkBootstrapConfigRes, resp) ok := svcCall.Parent.AssertCalled(t, "Bootstrap", mock.Anything, mock.Anything, tc.externalID, true) assert.True(t, ok) } diff --git a/re/handlers.go b/re/handlers.go index f9cb5be3c..00eff1fa8 100644 --- a/re/handlers.go +++ b/re/handlers.go @@ -173,7 +173,7 @@ func (re *re) StartScheduler(ctx context.Context) error { for _, r := range page.Rules { go func(rule Rule) { if _, err := re.repo.UpdateRuleDue(ctx, rule.ID, rule.Schedule.NextDue()); err != nil { - re.runInfo <- RunInfo{Level: slog.LevelError, Message: fmt.Sprintf("falied to update rule: %s", err), Details: []slog.Attr{slog.Time("time", time.Now().UTC())}} + re.runInfo <- RunInfo{Level: slog.LevelError, Message: fmt.Sprintf("failed to update rule: %s", err), Details: []slog.Attr{slog.Time("time", time.Now().UTC())}} return } @@ -202,7 +202,7 @@ func (re *re) StartScheduler(ctx context.Context) error { for _, c := range reportConfigs.ReportConfigs { go func(cfg ReportConfig) { if _, err := re.repo.UpdateReportDue(ctx, cfg.ID, cfg.Schedule.NextDue()); err != nil { - re.runInfo <- RunInfo{Level: slog.LevelError, Message: fmt.Sprintf("falied to update report: %s", err), Details: []slog.Attr{slog.Time("time", time.Now().UTC())}} + re.runInfo <- RunInfo{Level: slog.LevelError, Message: fmt.Sprintf("failed to update report: %s", err), Details: []slog.Attr{slog.Time("time", time.Now().UTC())}} return } _, err := re.generateReport(ctx, cfg, EmailReport) diff --git a/tools/mqtt-bench/README.md b/tools/mqtt-bench/README.md index 9765f078a..86a6bc087 100644 --- a/tools/mqtt-bench/README.md +++ b/tools/mqtt-bench/README.md @@ -37,7 +37,7 @@ Flags: --mtls Use mtls for connection -p, --pubs int Number of publishers (default 10) -q, --qos int QoS for published messages, values 0 1 2 - --quiet Supress messages + --quiet Suppress messages -r, --retain Retain mqtt messages -z, --size int Size of message payload bytes (default 100) -t, --skipTLSVer Skip tls verification diff --git a/tools/mqtt-bench/cmd/main.go b/tools/mqtt-bench/cmd/main.go index a93820a68..9e58fcb1c 100644 --- a/tools/mqtt-bench/cmd/main.go +++ b/tools/mqtt-bench/cmd/main.go @@ -20,7 +20,7 @@ func main() { rootCmd := &cobra.Command{ Use: "mqtt-bench", Short: "mqtt-bench is MQTT benchmark tool for SuperMQ", - Long: `Tool for exctensive load and benchmarking of MQTT brokers used within the SuperMQ platform. + Long: `Tool for extensive load and benchmarking of MQTT brokers used within the SuperMQ platform. Complete documentation is available at https://docs.supermq.abstractmachines.fr`, Run: func(cmd *cobra.Command, args []string) { if confFile != "" {