package main

import (
    "flag"
    "log"
    "time"

    "github.com/gopherjs/websocket"
)

var addr = flag.String("addr", "localhost:8080", "http service address")
var buf = make([]byte, 1024)

func main() {
    log.Println("HeeeeeeLLLLOooo JS")
    flag.Parse()
    log.SetFlags(0)

    c, err := websocket.Dial("ws://127.0.0.1:8080")
    if err != nil {
        log.Fatal("dial:", err)
    }
    defer c.Close()

    done := make(chan struct{})

    go func() {
        defer close(done)
        for {
            _, err := c.Read(buf)
            if err != nil {
                log.Println("read:", err)
                return
            }
            log.Printf("recv: %s", buf)
        }
    }()

    ticker := time.NewTicker(time.Second)
    defer ticker.Stop()

    for {
        select {
        case <-done:
            return
        case t := <-ticker.C:
            buf = []byte(t.String())
            _, err = c.Write(buf)
            if err != nil {
                log.Println("write:", err)
                return
            }
        }
    }
}