telegram.go

package vdlog

//https://stackoverflow.com/a/36623663/1885921
//https://stackoverflow.com/questions/33126743/how-do-i-join-my-bot-to-the-channel/36623663#36623663

import (
	"fmt"
	"net/http"
	"net/url"
)

const telegramURLTemplate = "https://api.telegram.org/bot%s/sendMessage"

func createTelegramSink(botToken, chatID string, level EventLevel) func(e Event) error {
	return func(e Event) error {
		if e.Level > level {
			return nil
		}
		telegramURL := fmt.Sprintf(telegramURLTemplate, botToken)
		body := url.Values{}
		body.Set("text", string(e.ToIndentedJSON())) //TODO better formating
		body.Set("chat_id", chatID)
		resp, err := http.PostForm(telegramURL, body)
		if err != nil {
			return err
		}
		defer resp.Body.Close()
		return nil
	}
}

//LogToTelegram allows to send events to telegram channel/chat using telegram bot api
func LogToTelegram(botToken, chatID string, level EventLevel) {
	AddSink("telegram", createTelegramSink(botToken, chatID, level))
}