package main

import (
    "bufio"
    "github.com/zhouhui8915/go-socket.io-client"
    "log"
    "os"
    //"time"
)

func main() {

    opts := &socketio_client.Options{
        //Transport:"polling",
        Transport: "websocket",
        Query:     make(map[string]string),
    }
    client, err := socketio_client.NewClient("socket.donationalerts.ru:3001", opts)
    if err != nil {
        log.Printf("NewClient error:%v\n", err)
        return
    }

    client.On("error", func() {
        log.Printf("on error\n")
    })
    client.On("connection", func() {
        log.Printf("on connect\n")
    })
    client.On("donation", func(msg string) {
        log.Printf("on donation:%v\n", msg)
    })
    client.On("disconnection", func() {
        log.Printf("on disconnect\n")
    })
    authStr := "{\"token\":\"" + "bWttoPeGEO6LQGhBkL0O" + "\",\"type\":\"" + "minor" + "\"}"
    err = client.Emit("add-user", authStr)
    if err != nil {
        log.Printf("Emit error:%v\n", err)
    }

    reader := bufio.NewReader(os.Stdin)
    for {
        data, _, _ := reader.ReadLine()
        command := string(data)
        err := client.Emit("message", command)
        if err != nil {
            log.Printf("Emit message error:%v\n", err)
            continue
        }
        log.Printf("send message:%v\n", command)
    }
}