mirror of
https://github.com/absmach/magistrala.git
synced 2026-08-07 07:14:46 +00:00
Arvindh
16ba29cf4a
Property Based Tests / api-test (push) Has been cancelled
Continuous Delivery / lint-and-build (push) Has been cancelled
Deploy GitHub Pages / swagger-ui (push) Has been cancelled
CI Pipeline / Lint Proto (push) Has been cancelled
CI Pipeline / Detect Changes (push) Has been cancelled
Continuous Delivery / Build and Push Docker Images (push) Has been cancelled
CI Pipeline / lint-and-build (push) Has been cancelled
CI Pipeline / Test ${{ matrix.module }} (push) Has been cancelled
CI Pipeline / Upload Coverage (push) Has been cancelled
Signed-off-by: Arvindh <arvindh91@gmail.com> Signed-off-by: dusan <borovcanindusan1@gmail.com> Signed-off-by: Rodney Osodo <socials@rodneyosodo.com> Co-authored-by: Dušan Borovčanin <dusan.borovcanin@absmach.eu> Co-authored-by: Rodney Osodo <socials@rodneyosodo.com> Co-authored-by: dusan <borovcanindusan1@gmail.com>
44 lines
795 B
Go
44 lines
795 B
Go
// Copyright (c) Abstract Machines
|
|
// SPDX-License-Identifier: Apache-2.0
|
|
|
|
package messaging
|
|
|
|
import "testing"
|
|
|
|
func TestClientIdentity(t *testing.T) {
|
|
cases := []struct {
|
|
name string
|
|
msg *Message
|
|
want string
|
|
}{
|
|
{
|
|
name: "nil message",
|
|
msg: nil,
|
|
want: "",
|
|
},
|
|
{
|
|
name: "publisher wins over transport client id",
|
|
msg: &Message{
|
|
Publisher: "entity-1",
|
|
ClientId: "amqp091:connection",
|
|
},
|
|
want: "entity-1",
|
|
},
|
|
{
|
|
name: "fallback to transport client id for legacy messages",
|
|
msg: &Message{
|
|
ClientId: "legacy-client",
|
|
},
|
|
want: "legacy-client",
|
|
},
|
|
}
|
|
|
|
for _, tc := range cases {
|
|
t.Run(tc.name, func(t *testing.T) {
|
|
if got := tc.msg.ClientIdentity(); got != tc.want {
|
|
t.Fatalf("expected %q, got %q", tc.want, got)
|
|
}
|
|
})
|
|
}
|
|
}
|