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

NOISSUE - Fix return role on user creation (#2551)

Browse Source 
Signed-off-by: Felix Gateru <felix.gateru@gmail.com>
This commit is contained in:
Felix Gateru
2024-11-26 11:39:52 +03:00
committed by GitHub
parent 8d4e752274
commit ba556e1e0d
8 changed files with 14 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files
cmd/certs/main.go
+1 -1
View File
@@ -110,7 +110,7 @@ func main() {
return
}
defer authnClient.Close()
logger.Info("AutN successfully connected to auth gRPC server " + authnClient.Secure())
logger.Info("AuthN successfully connected to auth gRPC server " + authnClient.Secure())
tp, err := jaegerclient.NewProvider(ctx, svcName, cfg.JaegerURL, cfg.InstanceID, cfg.TraceRatio)
if err != nil {
cmd/journal/main.go
+2 -2
View File
@@ -109,7 +109,7 @@ func main() {
return
}
defer authnHandler.Close()
logger.Info("Authn successfully connected to auth gRPC server " + authnHandler.Secure())
logger.Info("AuthN successfully connected to auth gRPC server " + authnHandler.Secure())
authz, authzHandler, err := authsvcAuthz.NewAuthorization(ctx, authClientCfg)
if err != nil {
@@ -118,7 +118,7 @@ func main() {
return
}
defer authzHandler.Close()
logger.Info("Authz successfully connected to auth gRPC server " + authzHandler.Secure())
logger.Info("AuthZ successfully connected to auth gRPC server " + authzHandler.Secure())
tp, err := jaegerclient.NewProvider(ctx, svcName, cfg.JaegerURL, cfg.InstanceID, cfg.TraceRatio)
if err != nil {
cmd/postgres-reader/main.go
+2 -2
View File
@@ -99,7 +99,7 @@ func main() {
return
}
defer authzHandler.Close()
logger.Info("Authz successfully connected to auth gRPC server " + authzHandler.Secure())
logger.Info("AuthZ successfully connected to auth gRPC server " + authzHandler.Secure())
authn, authnHandler, err := authsvcAuthn.NewAuthentication(ctx, clientCfg)
if err != nil {
@@ -108,7 +108,7 @@ func main() {
return
}
defer authnHandler.Close()
logger.Info("Authn successfully connected to auth gRPC server " + authnHandler.Secure())
logger.Info("AuthN successfully connected to auth gRPC server " + authnHandler.Secure())
thingsClientCfg := grpcclient.Config{}
if err := env.ParseWithOptions(&thingsClientCfg, env.Options{Prefix: envPrefixThings}); err != nil {
cmd/things/main.go
+1 -1
View File
@@ -160,7 +160,7 @@ func main() {
exitCode = 1
return
}
logger.Info("Policy Evaluator and Policy manager are successfully connected to SpiceDB gRPC server")
logger.Info("Policy evaluator and Policy manager are successfully connected to SpiceDB gRPC server")
grpcCfg := grpcclient.Config{}
if err := env.ParseWithOptions(&grpcCfg, env.Options{Prefix: envPrefixAuth}); err != nil {
cmd/timescale-reader/main.go
+3 -3
View File
@@ -99,7 +99,7 @@ func main() {
return
}
defer authzHandler.Close()
logger.Info("Authz successfully connected to auth gRPC server " + authzHandler.Secure())
logger.Info("AuthZ successfully connected to auth gRPC server " + authzHandler.Secure())
authn, authnHandler, err := authsvcAuthn.NewAuthentication(ctx, clientCfg)
if err != nil {
@@ -108,7 +108,7 @@ func main() {
return
}
defer authnHandler.Close()
logger.Info("Authn successfully connected to auth gRPC server " + authnHandler.Secure())
logger.Info("AuthN successfully connected to auth gRPC server " + authnHandler.Secure())
thingsClientCfg := grpcclient.Config{}
if err := env.ParseWithOptions(&thingsClientCfg, env.Options{Prefix: envPrefixThings}); err != nil {
@@ -125,7 +125,7 @@ func main() {
}
defer thingsHandler.Close()
logger.Info("ThingsService gRPC client successfully connected to things gRPC server " + thingsHandler.Secure())
logger.Info("Things service gRPC client successfully connected to things gRPC server " + thingsHandler.Secure())
httpServerConfig := server.Config{Port: defSvcHTTPPort}
if err := env.ParseWithOptions(&httpServerConfig, env.Options{Prefix: envPrefixHTTP}); err != nil {
cmd/users/main.go
+2 -2
View File
@@ -185,7 +185,7 @@ func main() {
return
}
defer authnHandler.Close()
logger.Info("Authn successfully connected to auth gRPC server " + authnHandler.Secure())
logger.Info("AuthN successfully connected to auth gRPC server " + authnHandler.Secure())
authz, authzHandler, err := authsvcAuthz.NewAuthorization(ctx, clientConfig)
if err != nil {
@@ -194,7 +194,7 @@ func main() {
return
}
defer authzHandler.Close()
logger.Info("Authz successfully connected to auth gRPC server " + authzHandler.Secure())
logger.Info("AuthZ successfully connected to auth gRPC server " + authzHandler.Secure())
domainsClient, domainsHandler, err := grpcclient.SetupDomainsClient(ctx, clientConfig)
if err != nil {
internal/groups/middleware/logging.go
+2 -2
View File
@@ -225,10 +225,10 @@ func (lm *loggingMiddleware) Unassign(ctx context.Context, session authn.Session
}
if err != nil {
args = append(args, slog.Any("error", err))
lm.logger.Warn("Unassign member to group failed", args...)
lm.logger.Warn("Unassign member from group failed", args...)
return
}
lm.logger.Info("Unassign member to group completed successfully", args...)
lm.logger.Info("Unassign member from group completed successfully", args...)
}(time.Now())
return lm.svc.Unassign(ctx, session, groupID, relation, memberKind, memberIDs...)
users/postgres/users.go
+1 -1
View File
@@ -33,7 +33,7 @@ func NewRepository(db postgres.Database) users.Repository {
func (repo *userRepo) Save(ctx context.Context, c users.User) (users.User, error) {
q := `INSERT INTO users (id, tags, email, secret, metadata, created_at, status, role, first_name, last_name, username, profile_picture)
VALUES (:id, :tags, :email, :secret, :metadata, :created_at, :status, :role, :first_name, :last_name, :username, :profile_picture)
RETURNING id, tags, email, metadata, created_at, status, first_name, last_name, username, profile_picture`
RETURNING id, tags, email, metadata, created_at, status, role, first_name, last_name, username, profile_picture`
dbu, err := toDBUser(c)
if err != nil {