package main import ( "bufio" "crypto/tls" "flag" "fmt" "log" "os" "strings" "github.com/mattn/go-xmpp" ) var ( server = flag.String("server", "talk.google.com:443", "server") username = flag.String("username", "", "username") password = flag.String("password", "", "password") status = flag.String("status", "xa", "status") statusMessage = flag.String("status-msg", "I for one welcome our new codebot overlords.", "status message") notls = flag.Bool("notls", false, "No TLS") debug = flag.Bool("debug", false, "debug output") session = flag.Bool("session", false, "use server session") ) func serverName(host string) string { return strings.Split(host, ":")[0] } func main() { flag.Usage = func() { fmt.Fprintf(os.Stderr, "usage: example [options]\n") flag.PrintDefaults() os.Exit(2) } flag.Parse() if *username == "" || *password == "" { if *debug && *username == "" && *password == "" { fmt.Fprintf(os.Stderr, "no username or password were given; attempting ANONYMOUS auth\n") } else if *username != "" || *password != "" { flag.Usage() } } if !*notls { xmpp.DefaultConfig = tls.Config{ ServerName: serverName(*server), InsecureSkipVerify: false, } } var talk *xmpp.Client var err error options := xmpp.Options{ Host: *server, User: *username, Password: *password, NoTLS: *notls, Debug: *debug, Session: *session, Status: *status, StatusMessage: *statusMessage, } talk, err = options.NewClient() if err != nil { log.Fatal(err) } go func() { for { chat, err := talk.Recv() if err != nil { log.Fatal(err) } switch v := chat.(type) { case xmpp.Chat: fmt.Println(v.Remote, v.Text) case xmpp.Presence: fmt.Println(v.From, v.Show) } } }() for { in := bufio.NewReader(os.Stdin) line, err := in.ReadString('\n') if err != nil { continue } line = strings.TrimRight(line, "\n") tokens := strings.SplitN(line, " ", 2) if len(tokens) == 2 { talk.Send(xmpp.Chat{Remote: tokens[0], Type: "chat", Text: tokens[1]}) } } }