verification/internal/app/app_verification.go

package app

import (
	"context"
	tgbotapi "github.com/go-telegram-bot-api/telegram-bot-api/v5"
	"github.com/minio/minio-go/v7"
	"github.com/minio/minio-go/v7/pkg/credentials"
	"go.uber.org/zap"
	"go.uber.org/zap/zapcore"
	mongo "penahub.gitlab.yandexcloud.net/backend/penahub_common/mongo"
	"penahub.gitlab.yandexcloud.net/backend/verification/internal/client"
	"penahub.gitlab.yandexcloud.net/backend/verification/internal/config"
	"penahub.gitlab.yandexcloud.net/backend/verification/internal/initialize"
	"penahub.gitlab.yandexcloud.net/backend/verification/internal/server"
	"penahub.gitlab.yandexcloud.net/pena-services/customer/pkg/customer_clients"
	"time"
)

func Run(cfg *config.Config) {
	cfgLogger := zap.NewDevelopmentConfig()
	cfgLogger.EncoderConfig.EncodeLevel = zapcore.CapitalColorLevelEncoder
	cfgLogger.EncoderConfig.ConsoleSeparator = "    "

	logger, err := cfgLogger.Build()
	if err != nil {
		panic(err)
	}

	logger.Info("RUN", zap.Any("ENV", cfg))

	ctx := context.Background()

	mongoDB, err := mongo.Connect(ctx, &mongo.ConnectDeps{
		Configuration: &mongo.Configuration{
			Host:         cfg.MongoHost,
			Port:         cfg.MongoPort,
			User:         cfg.MongoUser,
			Password:     cfg.MongoPassword,
			Auth:         cfg.MongoAuth,
			DatabaseName: cfg.DatabaseName,
		},
		Timeout: 5 * time.Second,
	})

	if err != nil {
		logger.Fatal("MongoClient", zap.Error(err))
	}

	minioClient, err := minio.New(cfg.S3Endpoint, &minio.Options{
		Creds:  credentials.NewStaticV4(cfg.S3AccessKeyID, cfg.S3SecretKey, ""),
		Secure: true,
	})
	if err != nil {
		logger.Fatal("MinioClient", zap.Error(err))
	}

	reps, err := initialize.NewRepositories(ctx, logger, mongoDB, minioClient, cfg.S3Folder, cfg.S3FileUrl)
	if err != nil {
		logger.Fatal("Repositories", zap.Error(err))
	}

	tgBot, err := tgbotapi.NewBotAPI(cfg.TelegramToken)
	if err != nil {
		logger.Fatal("TelegramBotApi", zap.Error(err))
	}

	telegram := client.NewTelegram(client.Deps{
		Logger:     logger,
		Bot:        tgBot,
		ChatID:     cfg.TelegramChannelID,
		StagingURL: cfg.StagingURL,
	})
	cons := initialize.NewControllers(reps, telegram, customer_clients.NewCustomersClient(customer_clients.CustomersClientDeps{
		Logger:              logger,
		CustomerServiceHost: cfg.CustomerRPCHost,
	}))

	httpSrv := server.NewHTTP(server.ServerConfig{
		Logger:      logger,
		Controllers: []server.Controller{cons.VerificationUser, cons.VerificationAdmin},
	})

	go func() {
		if err := httpSrv.Start(cfg.HttpAddress); err != nil {
			logger.Fatal("Server startup error", zap.Error(err))
		}
	}()

	gracefulShutdown(ctx, logger, httpSrv, mongoDB)
}