68 lines
1.8 KiB
Go
68 lines
1.8 KiB
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.mongodb.org/mongo-driver/mongo"
|
|
"go.mongodb.org/mongo-driver/mongo/options"
|
|
"go.uber.org/zap"
|
|
"go.uber.org/zap/zapcore"
|
|
"verification/internal/client"
|
|
"verification/internal/config"
|
|
"verification/internal/initialize"
|
|
"verification/internal/server"
|
|
)
|
|
|
|
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()
|
|
|
|
mongoClient, err := mongo.Connect(ctx, options.Client().ApplyURI(cfg.MongoUri))
|
|
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: false,
|
|
})
|
|
if err != nil {
|
|
logger.Fatal("MinioClient", zap.Error(err))
|
|
}
|
|
|
|
reps, err := initialize.NewRepositories(ctx, logger, mongoClient, cfg.DatabaseName, minioClient)
|
|
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(logger, tgBot, cfg.TelegramChannelID)
|
|
cons := initialize.NewControllers(reps, telegram, client.NewCustomer(logger, cfg.CustomerSvcAddress))
|
|
|
|
httpSrv := server.NewHTTP(cfg, logger).Register(cons.List()...)
|
|
|
|
go func() {
|
|
err := httpSrv.Start()
|
|
if err != nil {
|
|
logger.Fatal("CanNotServe", zap.Error(err))
|
|
}
|
|
}()
|
|
|
|
gracefulShutdown(ctx, logger, httpSrv, mongoClient)
|
|
}
|