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

MG-408 - Fix client authentication in readers (#409)

Browse Source 
Signed-off-by: Felix Gateru <felix.gateru@gmail.com>
This commit is contained in:
Felix Gateru
2026-02-25 11:59:43 +03:00
committed by GitHub
parent f28a3e8390
commit 0c1ccf1f04
2 changed files with 421 additions and 475 deletions
Download Patch File Download Diff File Expand all files Collapse all files
readers/api/http/endpoint_test.go
+419 -473
View File
File diff suppressed because it is too large Load Diff
readers/api/http/transport.go
+2 -2
View File
@@ -212,7 +212,7 @@ func encodeResponse(_ context.Context, w http.ResponseWriter, response any) erro
func authnAuthz(ctx context.Context, req listMessagesReq, authn smqauthn.Authentication, clients grpcClientsV1.ClientsServiceClient, channels grpcChannelsV1.ChannelsServiceClient) error {
clientID, clientType, err := authenticate(ctx, req, authn, clients)
if err != nil {
return nil
return err
}
if err := authorize(ctx, clientID, clientType, req.chanID, req.domain, channels); err != nil {
return err
@@ -234,7 +234,7 @@ func authenticate(ctx context.Context, req listMessagesReq, authn smqauthn.Authe
return policies.EncodeDomainUserID(req.domain, session.UserID), policies.UserType, nil
case req.key != "":
res, err := clients.Authenticate(ctx, &grpcClientsV1.AuthnReq{
Token: smqauthn.AuthPack(smqauthn.DomainAuth, req.chanID, req.key),
Token: smqauthn.AuthPack(smqauthn.DomainAuth, req.domain, req.key),
})
if err != nil {
return "", "", err