OrgGo/Mainflux.mainflux
1
0
Fork 0
mirror of https://github.com/mainflux/mainflux.git synced 2025-04-27 13:48:49 +08:00
Code Issues Projects Releases Wiki Activity

NOISSUE - Refactor provision tool (#1189)

Browse Source 
* Use bulk sdk functions for generating Things and Channels
Add prefix option

Signed-off-by: Ivan Milošević <iva@blokovi.com>

* Update readme
Remove dead code
Rename variable

Signed-off-by: Ivan Milošević <iva@blokovi.com>
This commit is contained in:
Ivan Milošević 2020-06-01 17:34:10 +02:00 committed by GitHub
parent 8906943d1d
commit a5fb55c328
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 23 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
tools/provision/README.md
View File

@ -23,6 +23,7 @@ Flags:
-p, --password string mainflux users password
--ssl create certificates for mTLS access
-u, --username string mainflux user
--prefix string name prefix for things and channels
```
Example:

1
tools/provision/cmd/main.go
View File

@ -30,6 +30,7 @@ Complete documentation is available at https://mainflux.readthedocs.io`,
// Root Flags
rootCmd.PersistentFlags().StringVarP(&pconf.Host, "host", "", "https://localhost", "address for mainflux instance")
rootCmd.PersistentFlags().StringVarP(&pconf.Prefix, "prefix", "", "", "name prefix for things and channels")
rootCmd.PersistentFlags().StringVarP(&pconf.Username, "username", "u", "", "mainflux user")
rootCmd.PersistentFlags().StringVarP(&pconf.Password, "password", "p", "", "mainflux users password")
rootCmd.PersistentFlags().IntVarP(&pconf.Num, "num", "", 10, "number of channels and things to create and connect")

38
tools/provision/provision.go
View File

@ -120,32 +120,36 @@ func Provision(conf Config) {
// Create things and channels
things := make([]sdk.Thing, conf.Num)
channels := make([]sdk.Channel, conf.Num)
cIDs := []string{}
tIDs := []string{}
fmt.Println("# List of things that can be connected to MQTT broker")
for i := 0; i < conf.Num; i++ {
tid, err := s.CreateThing(sdk.Thing{Name: fmt.Sprintf("%s-thing-%d", conf.Prefix, i)}, token)
if err != nil {
log.Fatalf("Failed to create the thing: %s", err.Error())
}
things[i] = sdk.Thing{Name: fmt.Sprintf("%s-thing-%d", conf.Prefix, i)}
channels[i] = sdk.Channel{Name: fmt.Sprintf("%s-channel-%d", conf.Prefix, i)}
}
thing, err := s.Thing(tid, token)
things[i] = thing
tIDs = append(tIDs, tid)
things, err = s.CreateThings(things, token)
if err != nil {
log.Fatalf("Failed to create the things: %s", err.Error())
}
if err != nil {
log.Fatalf("Failed to fetch the thing: %s", err.Error())
}
channels, err = s.CreateChannels(channels, token)
if err != nil {
log.Fatalf("Failed to create the chennels: %s", err.Error())
}
cid, err := s.CreateChannel(sdk.Channel{Name: fmt.Sprintf("%s-channel-%d", conf.Prefix, i)}, token)
if err != nil {
log.Fatalf("Failed to create the channel: %s", err.Error())
}
for _, t := range things {
tIDs = append(tIDs, t.ID)
}
cIDs = append(cIDs, cid)
for _, c := range channels {
cIDs = append(cIDs, c.ID)
}
for i := 0; i < conf.Num; i++ {
cert := ""
key := ""
@ -170,7 +174,7 @@ func Provision(conf Config) {
SerialNumber: serialNumber,
Subject: pkix.Name{
Organization: []string{"Mainflux"},
CommonName: thing.Key,
CommonName: things[i].Key,
OrganizationalUnit: []string{"mainflux"},
},
NotBefore: notBefore,
@ -204,7 +208,7 @@ func Provision(conf Config) {
}
// Print output
fmt.Printf("[[things]]\nthing_id = \"%s\"\nthing_key = \"%s\"\n", tid, thing.Key)
fmt.Printf("[[things]]\nthing_id = \"%s\"\nthing_key = \"%s\"\n", things[i].ID, things[i].Key)
if conf.SSL {
fmt.Printf("mtls_cert = \"\"\"%s\"\"\"\n", cert)
fmt.Printf("mtls_key = \"\"\"%s\"\"\"\n", key)