1
0
mirror of https://github.com/shirou/mqttcli.git synced 2025-04-24 13:48:57 +08:00

feat: remove h flag for help

This commit is contained in:
shirou 2022-08-14 02:36:39 +00:00
parent 56d64e7a99
commit f948a31c03
3 changed files with 19 additions and 7 deletions

View File

@ -120,7 +120,7 @@ func getSettingsFromFile(confPath string, opts *MQTT.ClientOptions) error {
scheme = "ssl"
}
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)
}

13
main.go
View File

@ -106,16 +106,21 @@ func main() {
app.Usage = usage
app.Version = version
cli.HelpFlag = &cli.BoolFlag{
Name: "help",
Usage: usage,
}
commonFlags := []cli.Flag{
&cli.StringFlag{
Name: "host",
Value: "localhost",
Usage: "mqtt host to connect to. Defaults to localhost",
Name: "h,host",
Value: "",
Usage: "mqtt host to connect to. Defaults is localhost",
EnvVars: []string{"MQTT_HOST"}},
&cli.IntFlag{
Name: "p, port",
Value: 1883,
Usage: "network port to connect to. Defaults to 1883",
Usage: "network port to connect to. Defaults is 1883",
EnvVars: []string{"MQTT_PORT"}},
&cli.StringFlag{
Name: "u,user",

11
mqtt.go
View File

@ -30,7 +30,7 @@ func (m *MQTTClient) Connect() (MQTT.Client, error) {
m.Client = MQTT.NewClient(m.Opts)
log.Info("connecting...")
log.Infof("connecting...")
if token := m.Client.Connect(); token.Wait() && token.Error() != nil {
return nil, token.Error()
@ -130,6 +130,10 @@ func NewOption(c *cli.Context) (*MQTT.ClientOptions, error) {
opts.SetClientID(clientId)
scheme := "tcp"
if port == 8883 {
scheme = "ssl"
}
cafile := c.String("cafile")
key := c.String("key")
cert := c.String("cert")
@ -155,7 +159,10 @@ func NewOption(c *cli.Context) (*MQTT.ClientOptions, error) {
opts.SetPassword(password)
}
if host != "" {
if host == "" {
host = "localhost"
}
if len(opts.Servers) == 0 {
brokerUri := fmt.Sprintf("%s://%s:%d", scheme, host, port)
log.Infof("Broker URI: %s", brokerUri)