mirror of
https://github.com/shirou/mqttcli.git
synced 2025-04-28 13:48:50 +08:00
Merge pull request #47 from shirou/feature/remove_h_flag_on_help
feat: remove h flag for help
This commit is contained in:
commit
7a3d709204
@ -120,7 +120,7 @@ func getSettingsFromFile(confPath string, opts *MQTT.ClientOptions) error {
|
|||||||
scheme = "ssl"
|
scheme = "ssl"
|
||||||
}
|
}
|
||||||
brokerUri := fmt.Sprintf("%s://%s:%d", scheme, ret.Host, ret.Port)
|
brokerUri := fmt.Sprintf("%s://%s:%d", scheme, ret.Host, ret.Port)
|
||||||
log.Infof("Broker URI: %s", brokerUri)
|
log.Infof("Broker URI(from config): %s", brokerUri)
|
||||||
opts.AddBroker(brokerUri)
|
opts.AddBroker(brokerUri)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
13
main.go
13
main.go
@ -106,16 +106,21 @@ func main() {
|
|||||||
app.Usage = usage
|
app.Usage = usage
|
||||||
app.Version = version
|
app.Version = version
|
||||||
|
|
||||||
|
cli.HelpFlag = &cli.BoolFlag{
|
||||||
|
Name: "help",
|
||||||
|
Usage: usage,
|
||||||
|
}
|
||||||
|
|
||||||
commonFlags := []cli.Flag{
|
commonFlags := []cli.Flag{
|
||||||
&cli.StringFlag{
|
&cli.StringFlag{
|
||||||
Name: "host",
|
Name: "h,host",
|
||||||
Value: "localhost",
|
Value: "",
|
||||||
Usage: "mqtt host to connect to. Defaults to localhost",
|
Usage: "mqtt host to connect to. Defaults is localhost",
|
||||||
EnvVars: []string{"MQTT_HOST"}},
|
EnvVars: []string{"MQTT_HOST"}},
|
||||||
&cli.IntFlag{
|
&cli.IntFlag{
|
||||||
Name: "p, port",
|
Name: "p, port",
|
||||||
Value: 1883,
|
Value: 1883,
|
||||||
Usage: "network port to connect to. Defaults to 1883",
|
Usage: "network port to connect to. Defaults is 1883",
|
||||||
EnvVars: []string{"MQTT_PORT"}},
|
EnvVars: []string{"MQTT_PORT"}},
|
||||||
&cli.StringFlag{
|
&cli.StringFlag{
|
||||||
Name: "u,user",
|
Name: "u,user",
|
||||||
|
11
mqtt.go
11
mqtt.go
@ -30,7 +30,7 @@ func (m *MQTTClient) Connect() (MQTT.Client, error) {
|
|||||||
|
|
||||||
m.Client = MQTT.NewClient(m.Opts)
|
m.Client = MQTT.NewClient(m.Opts)
|
||||||
|
|
||||||
log.Info("connecting...")
|
log.Infof("connecting...")
|
||||||
|
|
||||||
if token := m.Client.Connect(); token.Wait() && token.Error() != nil {
|
if token := m.Client.Connect(); token.Wait() && token.Error() != nil {
|
||||||
return nil, token.Error()
|
return nil, token.Error()
|
||||||
@ -130,6 +130,10 @@ func NewOption(c *cli.Context) (*MQTT.ClientOptions, error) {
|
|||||||
opts.SetClientID(clientId)
|
opts.SetClientID(clientId)
|
||||||
|
|
||||||
scheme := "tcp"
|
scheme := "tcp"
|
||||||
|
if port == 8883 {
|
||||||
|
scheme = "ssl"
|
||||||
|
}
|
||||||
|
|
||||||
cafile := c.String("cafile")
|
cafile := c.String("cafile")
|
||||||
key := c.String("key")
|
key := c.String("key")
|
||||||
cert := c.String("cert")
|
cert := c.String("cert")
|
||||||
@ -155,7 +159,10 @@ func NewOption(c *cli.Context) (*MQTT.ClientOptions, error) {
|
|||||||
opts.SetPassword(password)
|
opts.SetPassword(password)
|
||||||
}
|
}
|
||||||
|
|
||||||
if host != "" {
|
if host == "" {
|
||||||
|
host = "localhost"
|
||||||
|
}
|
||||||
|
if len(opts.Servers) == 0 {
|
||||||
brokerUri := fmt.Sprintf("%s://%s:%d", scheme, host, port)
|
brokerUri := fmt.Sprintf("%s://%s:%d", scheme, host, port)
|
||||||
log.Infof("Broker URI: %s", brokerUri)
|
log.Infof("Broker URI: %s", brokerUri)
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user