main.go

package main

import (
	"encoding/json"
	"github.com/docker/docker/client"
	"github.com/petuhovskiy/telegram"
	"github.com/petuhovskiy/telegram/updates"
	"log"

	"github.com/rwlist/ovpn-bot/app"
	"github.com/rwlist/ovpn-bot/conf"
)

func main() {
	cfg, err := conf.ParseEnv()
	if err != nil {
		log.Fatal(err)
	}

	dockerClient, err := client.NewEnvClient()
	if err != nil {
		log.Fatal(err)
	}

	bot := telegram.NewBotWithOpts(cfg.BotToken, &telegram.Opts{
		Middleware: func(handler telegram.RequestHandler) telegram.RequestHandler {
			return func(methodName string, req interface{}) (message json.RawMessage, err error) {
				res, err := handler(methodName, req)
				if err != nil {
					log.Println("Telegram response error: ", err)
				}

				return res, err
			}
		},
	})

	ch, err := updates.StartPolling(bot, telegram.GetUpdatesRequest{
		Offset:  0,
		Limit:   50,
		Timeout: 10,
	})
	if err != nil {
		log.Fatal(err)
	}

	l := app.NewLogic(dockerClient)
	h := app.NewHandler(bot, l, cfg.AdminIDs)

	for upd := range ch {
		h.Handle(upd)
	}
}