fork download

copy

package main
 
import (
	"flag"
	"fmt"
	"github.com/gorilla/websocket"
	"io/ioutil"
	"log"
	"net/url"
	"os"
	"os/signal"
	"time"
)
 
var (
	argv struct {
		host string
		key  string
		help bool
	}
)
 
func processArgs() (needStop bool) {
	needStop = true
 
	if argv.help {
		flag.Usage()
	} else if len(argv.host) == 0 {
		fmt.Fprintln(os.Stderr, "Hey! -host is required")
		flag.Usage()
	} else if len(argv.key) == 0 {
		fmt.Fprintln(os.Stderr, "Hey! -key is required")
		flag.Usage()
	} else {
		needStop = false
	}
 
	return
}
 
func init() {
	flag.StringVar(&argv.host, `host`, ``, `streaming api host. REQUIRED`)
	flag.StringVar(&argv.key, `key`, ``, `client key. REQUIRED`)
	flag.BoolVar(&argv.help, `h`, false, `show this help`)
 
	flag.Parse()
}
 
func main() {
	if processArgs() {
		return
	}
 
	u := url.URL{Scheme: "wss", Host: argv.host, Path: "/stream/", RawQuery: "key=" + argv.key}
	log.Printf("connecting to %s\n", u.String())
	c, wsResp, err := websocket.DefaultDialer.Dial(u.String(), nil)
	if err != nil {
		if err == websocket.ErrBadHandshake {
			log.Printf("handshake failed with status %d\n", wsResp.StatusCode)
			bodyBuf, _ := ioutil.ReadAll(wsResp.Body)
			log.Println("respBody:", string(bodyBuf))
		}
		log.Fatal("dial error:", err)
	}
	log.Println("connection established")
	defer c.Close()
 
	done := make(chan struct{})
	defer close(done)
 
	go func() {
		for {
			_, message, err := c.ReadMessage()
			if err != nil {
				log.Println("read error:", err)
				done <- struct{}{}
				return
			}
			log.Printf("recv: %s", string(message))
		}
	}()
 
	interrupt := make(chan os.Signal, 1)
	signal.Notify(interrupt, os.Interrupt)
	select {
	case <-interrupt:
		log.Println("interrupt")
		err := c.WriteMessage(websocket.CloseMessage, websocket.FormatCloseMessage(websocket.CloseNormalClosure, ""))
		if err != nil {
			log.Println("write close error: ", err)
			return
		}
		select {
		case <-done:
		case <-time.After(time.Second):
		}
	case <-done:
	}
}

Main.java:1: error: ';' expected
package main
            ^
Main.java:3: error: <identifier> expected
import (
      ^
Main.java:3: error: <identifier> expected
import (
        ^
Main.java:4: error: ';' expected
	"flag"
	      ^
Main.java:6: error: class, interface, or enum expected
	"github.com/gorilla/websocket"
	^
Main.java:7: error: class, interface, or enum expected
	"io/ioutil"
	^
Main.java:8: error: class, interface, or enum expected
	"log"
	^
Main.java:9: error: class, interface, or enum expected
	"net/url"
	^
Main.java:10: error: class, interface, or enum expected
	"os"
	^
Main.java:11: error: class, interface, or enum expected
	"os/signal"
	^
Main.java:12: error: class, interface, or enum expected
	"time"
	^
Main.java:13: error: class, interface, or enum expected
)
^
Main.java:15: error: class, interface, or enum expected
var (
^
Main.java:42: error: illegal character: '`'
	flag.StringVar(&argv.host, `host`, ``, `streaming api host. REQUIRED`)
	                           ^
Main.java:42: error: illegal character: '`'
	flag.StringVar(&argv.host, `host`, ``, `streaming api host. REQUIRED`)
	                                ^
Main.java:42: error: illegal character: '`'
	flag.StringVar(&argv.host, `host`, ``, `streaming api host. REQUIRED`)
	                                   ^
Main.java:42: error: illegal character: '`'
	flag.StringVar(&argv.host, `host`, ``, `streaming api host. REQUIRED`)
	                                    ^
Main.java:42: error: illegal character: '`'
	flag.StringVar(&argv.host, `host`, ``, `streaming api host. REQUIRED`)
	                                       ^
Main.java:42: error: illegal character: '`'
	flag.StringVar(&argv.host, `host`, ``, `streaming api host. REQUIRED`)
	                                                                    ^
Main.java:43: error: illegal character: '`'
	flag.StringVar(&argv.key, `key`, ``, `client key. REQUIRED`)
	                          ^
Main.java:43: error: illegal character: '`'
	flag.StringVar(&argv.key, `key`, ``, `client key. REQUIRED`)
	                              ^
Main.java:43: error: illegal character: '`'
	flag.StringVar(&argv.key, `key`, ``, `client key. REQUIRED`)
	                                 ^
Main.java:43: error: illegal character: '`'
	flag.StringVar(&argv.key, `key`, ``, `client key. REQUIRED`)
	                                  ^
Main.java:43: error: illegal character: '`'
	flag.StringVar(&argv.key, `key`, ``, `client key. REQUIRED`)
	                                     ^
Main.java:43: error: illegal character: '`'
	flag.StringVar(&argv.key, `key`, ``, `client key. REQUIRED`)
	                                                          ^
Main.java:44: error: illegal character: '`'
	flag.BoolVar(&argv.help, `h`, false, `show this help`)
	                         ^
Main.java:44: error: illegal character: '`'
	flag.BoolVar(&argv.help, `h`, false, `show this help`)
	                           ^
Main.java:44: error: illegal character: '`'
	flag.BoolVar(&argv.help, `h`, false, `show this help`)
	                                     ^
Main.java:44: error: illegal character: '`'
	flag.BoolVar(&argv.help, `h`, false, `show this help`)
	                                                    ^
29 errors

Standard output is empty