package main

import (
    "log"
    //"strconv"
    s "strings"

    "github.com/SevereCloud/vksdk/api"
    longpoll "github.com/SevereCloud/vksdk/longpoll-user"
    wrapper "github.com/SevereCloud/vksdk/longpoll-user/v3"
)

var (
    appeal string = "?"

    BotID int
)

func main() {
    vk := api.NewVK("")

    users, err := vk.UsersGet(api.Params{})
    if err != nil {
        log.Fatal(err)
    }
    BotID = users[0].ID

    log.Printf("Инициализация бота с ID %v\n", BotID)

    lp, err := longpoll.NewLongpoll(vk, 3)
    if err != nil {
        log.Fatal(err)
    }

    w := wrapper.NewWrapper(lp)

    w.OnNewMessage(func(m wrapper.NewMessage) {
        mess, err := vk.MessagesGetByIDExtended(api.Params{
            "message_ids": m.MessageID,
        })
        if err != nil {
            log.Fatal(err)
        }

        if BotID == mess.Items[0].FromID {
            if s.HasPrefix(s.ToLower(m.Text), s.ToLower(appeal)) {
                command := s.Replace(m.Text, "?", "", 1)
                log.Printf(command)
                if command == "пинг" {
                    vk.MessagesEdit(api.Params{
                        "message_id": m.MessageID,
                        "peer_id": m.PeerID,
                        "message": "ПОНГ!",
                    })
                }
            }
        }
    })

    if err := lp.Run(); err != nil {
        log.Fatal(err)
    }

    // Безопасное завершение
    // Ждет пока соединение закроется и события обработаются
    lp.Shutdown()

    // Закрыть соединение
    // Требует lp.Client.Transport = &http.Transport{DisableKeepAlives: true}
    lp.Client.CloseIdleConnections()
}