opensource/supermq
1
0
Fork 0
mirror of https://github.com/absmach/supermq.git synced 2026-06-23 04:00:27 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

NOISSUE - Fix typos

Browse Source 
Signed-off-by: Dusan Borovcanin <borovcanindusan1@gmail.com>
This commit is contained in:
Dusan Borovcanin
2025-06-06 13:39:20 +02:00
parent 33289561c0
commit c35bc42210
12 changed files with 27 additions and 27 deletions
Download Patch File Download Diff File Expand all files Collapse all files
alarms/consumer/consumer.go
+1 -1
View File
@@ -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}
}
bootstrap/postgres/configs_test.go
+4 -4
View File
@@ -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) {
cli/bootstrap_test.go
+5 -5
View File
@@ -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)),
cmd/alarms/main.go
+1 -1
View File
@@ -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,
consumers/notifiers/api/endpoint.go
+2 -2
View File
@@ -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 {
consumers/notifiers/api/transport.go
+3 -3
View File
@@ -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...,
docker/addons/vault/README.md
+1 -1
View File
@@ -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
docker/supermq-docker/addons/vault/README.md
+1 -1
View File
@@ -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
pkg/sdk/bootstrap_test.go
+5 -5
View File
@@ -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)
}
re/handlers.go
+2 -2
View File
@@ -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)
tools/mqtt-bench/README.md
+1 -1
View File
@@ -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
tools/mqtt-bench/cmd/main.go
+1 -1
View File
@@ -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 != "" {