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

NOISSUE - Update CLI (#2642)

Browse Source 
Signed-off-by: nyagamunene <stevenyaga2014@gmail.com>
This commit is contained in:
Steve Munene
2025-01-10 14:49:38 +03:00
committed by GitHub
parent a9169276e5
commit 33407fad16
5 changed files with 58 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files
cli/clients.go
+23 -8
View File
@@ -198,22 +198,29 @@ var cmdClients = []cobra.Command{
},
},
{
Use: "connect <client_id> <channel_id> <domain_id> <user_auth_token>",
Use: "connect <client_id> <channel_id> <conn_types_json_list> <domain_id> <user_auth_token>",
Short: "Connect client",
Long: "Connect client to the channel\n" +
"Usage:\n" +
"\tsupermq-cli clients connect <client_id> <channel_id> $DOMAINID $USERTOKEN\n",
"\tsupermq-cli clients connect <client_id> <channel_id> <conn_types_json_list> $DOMAINID $USERTOKEN\n",
Run: func(cmd *cobra.Command, args []string) {
if len(args) != 4 {
if len(args) != 5 {
logUsageCmd(*cmd, cmd.Use)
return
}
var conn_types []string
err := json.Unmarshal([]byte(args[2]), &conn_types)
if err != nil {
logErrorCmd(*cmd, err)
return
}
connIDs := smqsdk.Connection{
ChannelIDs: []string{args[1]},
ClientIDs: []string{args[0]},
Types: conn_types,
}
if err := sdk.Connect(connIDs, args[2], args[3]); err != nil {
if err := sdk.Connect(connIDs, args[3], args[4]); err != nil {
logErrorCmd(*cmd, err)
return
}
@@ -222,22 +229,30 @@ var cmdClients = []cobra.Command{
},
},
{
Use: "disconnect <client_id> <channel_id> <domain_id> <user_auth_token>",
Use: "disconnect <client_id> <channel_id> <conn_types_json_list> <domain_id> <user_auth_token>",
Short: "Disconnect client",
Long: "Disconnect client to the channel\n" +
"Usage:\n" +
"\tsupermq-cli clients disconnect <client_id> <channel_id> $DOMAINID $USERTOKEN\n",
"\tsupermq-cli clients disconnect <client_id> <channel_id> <conn_types_json_list> $DOMAINID $USERTOKEN\n",
Run: func(cmd *cobra.Command, args []string) {
if len(args) != 4 {
if len(args) != 5 {
logUsageCmd(*cmd, cmd.Use)
return
}
var conn_types []string
err := json.Unmarshal([]byte(args[2]), &conn_types)
if err != nil {
logErrorCmd(*cmd, err)
return
}
connIDs := smqsdk.Connection{
ClientIDs: []string{args[0]},
ChannelIDs: []string{args[1]},
Types: conn_types,
}
if err := sdk.Disconnect(connIDs, args[2], args[3]); err != nil {
if err := sdk.Disconnect(connIDs, args[3], args[4]); err != nil {
logErrorCmd(*cmd, err)
return
}
cli/clients_test.go
+13 -2
View File
@@ -28,6 +28,7 @@ var (
tokenWithoutDomain = "valid"
relation = "administrator"
all = "all"
conntype = `["publish","subscribe"]`
)
var client = sdk.Client{
@@ -817,6 +818,7 @@ func TestConnectClientCmd(t *testing.T) {
args: []string{
client.ID,
channel.ID,
conntype,
domainID,
token,
},
@@ -827,6 +829,7 @@ func TestConnectClientCmd(t *testing.T) {
args: []string{
client.ID,
channel.ID,
conntype,
domainID,
token,
extraArg,
@@ -838,6 +841,7 @@ func TestConnectClientCmd(t *testing.T) {
args: []string{
invalidID,
channel.ID,
conntype,
domainID,
token,
},
@@ -850,6 +854,7 @@ func TestConnectClientCmd(t *testing.T) {
args: []string{
client.ID,
invalidID,
conntype,
domainID,
token,
},
@@ -862,6 +867,7 @@ func TestConnectClientCmd(t *testing.T) {
args: []string{
client.ID,
channel.ID,
conntype,
invalidID,
token,
},
@@ -873,7 +879,7 @@ func TestConnectClientCmd(t *testing.T) {
for _, tc := range cases {
t.Run(tc.desc, func(t *testing.T) {
sdkCall := sdkMock.On("Connect", mock.Anything, tc.args[2], tc.args[3]).Return(tc.sdkErr)
sdkCall := sdkMock.On("Connect", mock.Anything, tc.args[3], tc.args[4]).Return(tc.sdkErr)
out := executeCommand(t, rootCmd, append([]string{connCmd}, tc.args...)...)
switch tc.logType {
@@ -907,6 +913,7 @@ func TestDisconnectClientCmd(t *testing.T) {
args: []string{
client.ID,
channel.ID,
conntype,
domainID,
token,
},
@@ -917,6 +924,7 @@ func TestDisconnectClientCmd(t *testing.T) {
args: []string{
client.ID,
channel.ID,
conntype,
domainID,
token,
extraArg,
@@ -928,6 +936,7 @@ func TestDisconnectClientCmd(t *testing.T) {
args: []string{
invalidID,
channel.ID,
conntype,
domainID,
token,
},
@@ -940,6 +949,7 @@ func TestDisconnectClientCmd(t *testing.T) {
args: []string{
client.ID,
invalidID,
conntype,
domainID,
token,
},
@@ -952,6 +962,7 @@ func TestDisconnectClientCmd(t *testing.T) {
args: []string{
client.ID,
channel.ID,
conntype,
invalidID,
token,
},
@@ -963,7 +974,7 @@ func TestDisconnectClientCmd(t *testing.T) {
for _, tc := range cases {
t.Run(tc.desc, func(t *testing.T) {
sdkCall := sdkMock.On("Disconnect", mock.Anything, tc.args[2], tc.args[3]).Return(tc.sdkErr)
sdkCall := sdkMock.On("Disconnect", mock.Anything, tc.args[3], tc.args[4]).Return(tc.sdkErr)
out := executeCommand(t, rootCmd, append([]string{disconnCmd}, tc.args...)...)
switch tc.logType {
cli/config.go
+16 -2
View File
@@ -20,8 +20,10 @@ import (
const (
defURL string = "http://localhost"
defUsersURL string = defURL + ":9002"
defCLientsURL string = defURL + ":9000"
defDomainsURL string = defURL + ":8189"
defCLientsURL string = defURL + ":9006"
defDomainsURL string = defURL + ":9003"
defChannelsURL string = defURL + ":9005"
defGroupsURL string = defURL + ":9004"
defCertsURL string = defURL + ":9019"
defInvitationsURL string = defURL + ":9020"
defHTTPURL string = defURL + ":8008"
@@ -37,6 +39,8 @@ type remotes struct {
ClientsURL string `toml:"clients_url"`
UsersURL string `toml:"users_url"`
DomainsURL string `toml:"domains_url"`
ChannelsURL string `toml:"channels_url"`
GroupsURL string `toml:"groups_url"`
HTTPAdapterURL string `toml:"http_adapter_url"`
CertsURL string `toml:"certs_url"`
InvitationsURL string `toml:"invitations_url"`
@@ -106,6 +110,8 @@ func ParseConfig(sdkConf smqsdk.Config) (smqsdk.Config, error) {
ClientsURL: defCLientsURL,
UsersURL: defUsersURL,
DomainsURL: defDomainsURL,
ChannelsURL: defChannelsURL,
GroupsURL: defGroupsURL,
HTTPAdapterURL: defHTTPURL,
CertsURL: defCertsURL,
InvitationsURL: defInvitationsURL,
@@ -177,6 +183,14 @@ func ParseConfig(sdkConf smqsdk.Config) (smqsdk.Config, error) {
sdkConf.DomainsURL = config.Remotes.DomainsURL
}
if sdkConf.ChannelsURL == "" && config.Remotes.ChannelsURL != "" {
sdkConf.ChannelsURL = config.Remotes.ChannelsURL
}
if sdkConf.GroupsURL == "" && config.Remotes.GroupsURL != "" {
sdkConf.GroupsURL = config.Remotes.GroupsURL
}
if sdkConf.HTTPAdapterURL == "" && config.Remotes.HTTPAdapterURL != "" {
sdkConf.HTTPAdapterURL = config.Remotes.HTTPAdapterURL
}