main.go

package main

import (
	"context"
	bot_admin "github.com/kbats183/CTStickersBot/pkg/bot-server"
	"github.com/kbats183/CTStickersBot/pkg/core/config"
	botcontext "github.com/kbats183/CTStickersBot/pkg/core/context"
	external_server_ticker "github.com/kbats183/CTStickersBot/pkg/external-server-ticker"
	"github.com/kbats183/CTStickersBot/pkg/ocrapi"
	"go.uber.org/zap/zapcore"
	"os"

	"github.com/jinzhu/configor"
	"github.com/kbats183/CTStickersBot/pkg/storage"
	"github.com/kbats183/CTStickersBot/pkg/tgbot"
	"go.uber.org/zap"
)

func main() {
	loggerConfig := zap.Config{
		Level:            zap.NewAtomicLevelAt(zap.DebugLevel),
		Encoding:         "json",
		OutputPaths:      []string{"stdout"},
		ErrorOutputPaths: []string{"stderr"},
		EncoderConfig: zapcore.EncoderConfig{
			MessageKey:  "message",
			LevelKey:    "level",
			EncodeLevel: zapcore.LowercaseLevelEncoder,
		},
	}
	logger, _ := loggerConfig.Build()
	defer func() { _ = logger.Sync() }()

	var appConfig config.AppConfig
	err := configor.Load(&appConfig, "config_dev.yaml")
	if err != nil {
		logger.Error("Can't parse app config", zap.Error(err))
	}

	if os.Getenv("DISABLE") == "true" {
		logger.Info("Server disable")
		select {}
	}

	ctx := botcontext.Context{Context: context.Background(), Logger: logger, OCRClient: ocrapi.NewOCRClient(appConfig.OCR)}

	st, err := storage.NewStorage(ctx, appConfig.DB)
	if err != nil {
		ctx.Logger.Fatal("Can't create storage", zap.Error(err))
	}

	bot, err := tgbot.NewBot(appConfig.TelegramBot, st)
	if err != nil {
		logger.Fatal("Can't login a telegram bot", zap.Error(err))
	}

	server := bot_admin.NewBotAdminServer(appConfig.ServerConfig, ctx, st)

	serverTicker := external_server_ticker.NewServerTicker(&appConfig.ServerTicker, logger)

	logger.Info("Bot user name", zap.String("bot_login", bot.GetBotUserName()))

	go func() {
		logger.Fatal("Telegram bot failed", zap.Error(bot.StartListening(ctx)))
	}()
	go func() { logger.Fatal("Server failed", zap.Error(server.Listen())) }()
	serverTicker.Start()
	select {}
}