1 // (c) Bernhard Tittelbach, 2013
15 // ---------- Main Code -------------
25 fmt.Fprintf(os.Stderr, "Usage: door_client_zmq\n")
30 flag.StringVar(&cmd_port_, "cmdport", "ipc:///run/tuer/door_cmd.ipc", "zmq command socket path")
31 flag.StringVar(&sub_port_, "pubport", "tcp://torwaechter.realraum.at:4242", "zmq subscribe/listen socket path")
32 flag.StringVar(&cmd_method_, "method", "", "zmq cmd method")
33 flag.StringVar(&cmd_user_, "usernick", "", "zmq cmd user identity")
38 func LineReader(out chan <- [][]byte, stdin * os.File) {
39 linescanner := bufio.NewScanner(stdin)
40 linescanner.Split(bufio.ScanLines)
42 for linescanner.Scan() {
43 if err := linescanner.Err(); err != nil {
47 //text := bytes.Fields(linescanner.Bytes()) //this returns a slice (aka pointer, no array deep-copy here)
48 text := bytes.Fields([]byte(linescanner.Text())) //this allocates a string and slices it -> no race-condition with overwriting any data
56 func ByteArrayToString(bb [][]byte) string {
57 b := bytes.Join(bb, []byte(" "))
62 zmqctx, cmd_chans, sub_chans := ZmqsInit(cmd_port_, sub_port_)
63 defer cmd_chans.Close()
64 defer sub_chans.Close()
67 var ignore_next uint = 0
69 user_input_chan := make(chan [][]byte, 1)
70 go LineReader(user_input_chan, os.Stdin)
71 defer os.Stdin.Close()
75 case input, input_open := (<- user_input_chan):
77 if len(input) == 0 { continue }
78 switch string(input[0]) {
80 fmt.Println("Available Commands: help, listen, quit. Everything else is passed through to door daemon")
83 fmt.Println("Now listening, @ are broadcasts")
88 cmd_chans.Out() <- input
89 reply := <- cmd_chans.In()
90 fmt.Println(">",ByteArrayToString(reply))
95 case pubsubstuff := <- sub_chans.In():
96 if len(pubsubstuff) == 0 { continue}
102 fmt.Println("@",ByteArrayToString(pubsubstuff))