drop main app, upd fixlayout app

update with main
added validate
2025-06-30 11:29:58 +03:00 · 2025-06-30 11:16:09 +03:00 · 2025-02-25 17:07:46 +03:00 · 2025-02-25 16:30:14 +03:00 · 2025-02-24 21:38:49 +03:00 · 2025-02-24 21:11:05 +03:00
23 changed files with 753 additions and 333 deletions
--- a/app/app.go
+++ b/app/app.go
@ -1,232 +0,0 @@
-package app
-
-import (
-	"context"
-	"errors"
-	"fmt"
-	"gitea.pena/PenaSide/common/log_mw"
-	"gitea.pena/PenaSide/hlog"
-	"gitea.pena/PenaSide/trashlog/wrappers/zaptrashlog"
-	"gitea.pena/SQuiz/answerer/clients"
-	dalBS "gitea.pena/SQuiz/answerer/dal"
-	"gitea.pena/SQuiz/answerer/models"
-	"gitea.pena/SQuiz/answerer/savewc"
-	"gitea.pena/SQuiz/answerer/service"
-	"gitea.pena/SQuiz/common/dal"
-	"gitea.pena/SQuiz/common/healthchecks"
-	"gitea.pena/SQuiz/common/middleware"
-	"gitea.pena/SQuiz/common/model"
-	"gitea.pena/SQuiz/common/utils"
-	"github.com/go-redis/redis/v8"
-	"github.com/gofiber/fiber/v2"
-	"github.com/minio/minio-go/v7"
-	"github.com/minio/minio-go/v7/pkg/credentials"
-	"github.com/skeris/appInit"
-	"go.uber.org/zap"
-	"go.uber.org/zap/zapcore"
-	"time"
-)
-
-type App struct {
-	logger *zap.Logger
-	err    chan error
-}
-
-func (a App) GetLogger() *zap.Logger {
-	return a.logger
-}
-
-func (a App) GetErr() chan error {
-	return a.err
-}
-
-var (
-	errInvalidOptions = errors.New("invalid options")
-)
-
-var zapOptions = []zap.Option{
-	zap.AddCaller(),
-	zap.AddCallerSkip(2),
-	zap.AddStacktrace(zap.ErrorLevel),
-}
-
-var _ appInit.CommonApp = (*App)(nil)
-
-type Options struct {
-	LoggerProdMode      bool   `env:"IS_PROD_LOG" default:"false"`
-	IsProd              bool   `env:"IS_PROD" default:"false"`
-	MinioEP             string `env:"MINIO_EP" default:"localhost:3002"`
-	MinioAK             string `env:"MINIO_AK" default:"minio"`
-	MinioSK             string `env:"MINIO_SK" default:"miniostorage"`
-	NumberPort          string `env:"PORT" default:"1490"`
-	CrtFile             string `env:"CRT" default:"server.crt"`
-	KeyFile             string `env:"KEY" default:"server.key"`
-	PostgresCredentials string `env:"PG_CRED" default:"host=localhost port=5432 user=squiz password=Redalert2 dbname=squiz sslmode=disable"`
-	RedisHost           string `env:"REDIS_HOST"`
-	RedisPassword       string `env:"REDIS_PASSWORD"`
-	RedisDB             uint64 `env:"REDIS_DB"`
-	RedirectURL         string `env:"REDIRECT_URL" default:"https://squiz.pena.digital"`
-	PubKey              string `env:"PUBLIC_KEY"`
-	PrivKey             string `env:"PRIVATE_KEY"`
-	TrashLogHost        string `env:"TRASH_LOG_HOST" default:"localhost:7113"`
-	ModuleLogger        string `env:"MODULE_LOGGER" default:"answerer-local"`
-}
-
-func New(ctx context.Context, opts interface{}, ver appInit.Version) (appInit.CommonApp, error) {
-	var (
-		err, workerErr error
-		zapLogger      *zap.Logger
-		errChan        = make(chan error)
-		options        Options
-		ok             bool
-	)
-
-	if options, ok = opts.(Options); !ok {
-		return App{}, errInvalidOptions
-	}
-
-	if options.LoggerProdMode {
-		zapLogger, err = zap.NewProduction(zapOptions...)
-		if err != nil {
-			return nil, err
-		}
-	} else {
-		zapLogger, err = zap.NewDevelopment(zapOptions...)
-		if err != nil {
-			return nil, err
-		}
-	}
-
-	zapLogger = zapLogger.With(
-		zap.String("SvcCommit", ver.Commit),
-		zap.String("SvcVersion", ver.Release),
-		zap.String("SvcBuildTime", ver.BuildTime),
-	)
-	clickHouseLogger, err := zaptrashlog.NewCore(ctx, zap.InfoLevel, options.TrashLogHost, ver.Release, ver.Commit, time.Now().Unix())
-	if err != nil {
-		panic(err)
-	}
-
-	loggerForHlog := zapLogger.WithOptions(zap.WrapCore(func(core zapcore.Core) zapcore.Core {
-		return zapcore.NewTee(core, clickHouseLogger)
-	}))
-
-	loggerHlog := hlog.New(loggerForHlog).Module(options.ModuleLogger)
-
-	loggerHlog.With(models.AllFields{})
-	loggerHlog.Emit(InfoSvcStarted{})
-
-	// Initialize minio client object.
-	minioClient, err := minio.New(options.MinioEP, &minio.Options{
-		Creds:  credentials.NewStaticV4(options.MinioAK, options.MinioSK, ""),
-		Secure: options.IsProd,
-	})
-	if err != nil {
-		fmt.Println("MINIOERR", options.MinioEP, err)
-		return nil, err
-	}
-	pgdal, err := dal.New(ctx, options.PostgresCredentials, minioClient)
-	if err != nil {
-		return nil, err
-	}
-
-	zapLogger.Info("config", zap.Any("options", options))
-	//init redis
-	redisClient := redis.NewClient(&redis.Options{
-		Addr:     options.RedisHost,
-		Password: options.RedisPassword,
-		DB:       int(options.RedisDB),
-	})
-
-	encrypt := utils.NewEncrypt(options.PubKey, options.PrivKey)
-
-	workerSendClientCh := make(chan model.Answer, 50)
-	workerRespondentCh := make(chan []model.Answer, 50)
-	blobstore, err := dalBS.New(ctx, minioClient)
-	if err != nil {
-		return nil, err
-	}
-	//svc := service.New(blobstore, pgdal, workerRespondentCh, workerSendClientCh)
-	svc := service.New(service.ServiceDeps{
-		Store:              blobstore,
-		Dal:                pgdal,
-		WorkerSendClientCh: workerSendClientCh,
-		WorkerRespondentCh: workerRespondentCh,
-		Encrypt:            encrypt,
-		RedirectURl:        options.RedirectURL,
-    AiClient:           clients.NewAiClient("https://alvatar.com/api/engine/send_answer/"),
-	})
-
-	saveRespWcData := savewc.DepsForResp{
-		WorkerRespondentCh: workerRespondentCh,
-		Redis:              redisClient,
-	}
-
-	saveClientWcData := savewc.DepsForClient{
-		WorkerSendClientCh: workerSendClientCh,
-		Redis:              redisClient,
-	}
-
-	saveRespWorker := savewc.NewSaveRespWorker(saveRespWcData, errChan, loggerHlog)
-
-	saveClientWorker := savewc.NewSaveClientWorker(saveClientWcData, errChan, loggerHlog)
-
-	go saveRespWorker.Start(ctx)
-	go saveClientWorker.Start(ctx)
-
-	app := fiber.New(fiber.Config{BodyLimit: 70 * 1024 * 1024})
-
-	app.Use(func(c *fiber.Ctx) error {
-		defer func() {
-			if err := recover(); err != nil {
-				c.Status(fiber.StatusInternalServerError).SendString("internal server error")
-			}
-		}()
-		return c.Next()
-	})
-
-	app.Use(middleware.AnswererChain())
-	app.Use(log_mw.ContextLogger(loggerHlog))
-	app.Get("/liveness", healthchecks.Liveness)
-	app.Get("/readiness", healthchecks.Readiness(&workerErr)) //todo parametrized readiness. should discuss ready reason
-	app = svc.Register(app)
-
-	fmt.Println("SERVERSTART", fmt.Sprintf(":%s", options.NumberPort))
-
-	loggerHlog.Emit(InfoSvcReady{})
-
-	go func() {
-		defer func() {
-			//if pgdal != nil {
-			//	pgdal.CloseAnswerer()
-			//}
-			err := app.Shutdown()
-			if err != nil {
-				loggerHlog.Emit(InfoSvcShutdown{Signal: err.Error()})
-			}
-		}()
-
-		if options.IsProd {
-			if err := app.ListenTLS(fmt.Sprintf(":%s", options.NumberPort), options.CrtFile, options.KeyFile); err != nil {
-				loggerHlog.Emit(ErrorCanNotServe{
-					Err: err,
-				})
-				errChan <- err
-			}
-		} else {
-			if err := app.Listen(fmt.Sprintf(":%s", options.NumberPort)); err != nil {
-				loggerHlog.Emit(ErrorCanNotServe{
-					Err: err,
-				})
-				errChan <- err
-			}
-		}
-
-		errChan <- nil
-	}()
-	// todo implement helper func for service app type. such as server preparing, logger preparing, healthchecks and etc.
-	return &App{
-		logger: zapLogger,
-		err:    errChan,
-	}, err
-}
--- a/cmd/main.go
+++ b/cmd/main.go
@ -0,0 +1,35 @@
+package main
+
+import (
+	"context"
+	"go.uber.org/zap"
+	"log"
+	"os"
+	"os/signal"
+	"gitea.pena/SQuiz/answerer/internal/app"
+	"gitea.pena/SQuiz/answerer/internal/initialize"
+	"syscall"
+)
+
+var (
+	commit    string = os.Getenv("COMMIT")
+	buildTime string = os.Getenv("BUILD_TIME")
+	version   string = os.Getenv("VERSION")
+)
+
+func main() {
+	config, err := initialize.LoadConfig()
+	if err != nil {
+		log.Fatal("Failed to load config", zap.Error(err))
+	}
+
+	ctx, stop := signal.NotifyContext(context.Background(), syscall.SIGINT, syscall.SIGTERM)
+	defer stop()
+
+	if err = app.New(ctx, *config, app.Build{
+		Commit:  commit,
+		Version: version,
+	}); err != nil {
+		log.Fatal("App exited with error", zap.Error(err))
+	}
+}
--- a/cmd/validator/main.go
+++ b/cmd/validator/main.go
@ -0,0 +1,85 @@
+package main
+
+import (
+	"context"
+	"errors"
+	"gitea.pena/PenaSide/common/validate"
+	dalBS "gitea.pena/SQuiz/answerer/internal/dal"
+	"gitea.pena/SQuiz/answerer/internal/initialize"
+	"gitea.pena/SQuiz/common/dal"
+	"github.com/caarlos0/env/v8"
+	"log"
+)
+
+func main() {
+	cfg, err := loadConfig()
+	if err != nil {
+		log.Fatalf("error loading config: %v", err)
+	}
+
+	err = validateNotEmpty(cfg)
+	if err != nil {
+		log.Fatalf("error validating config: %v", err)
+	}
+
+	err = validate.ValidateEncryptKeys(&cfg.ExternalCfg.EncryptCommon)
+	if err != nil {
+		log.Fatalf("error validating EncryptKeys: %v", err)
+	}
+
+	err = validate.ValidateS3(validate.ValidateS3Deps{
+		S3Endpoint:  cfg.S3Endpoint,
+		S3SecretKey: cfg.S3SecretKey,
+		S3AccessKey: cfg.S3AccessKey,
+		IsProd:      cfg.IsProd,
+		BucketName:  dalBS.Bucket,
+	})
+	if err != nil {
+		log.Fatalf("error validating S3: %v", err)
+	}
+
+	_, err = dal.New(context.TODO(), cfg.PostgresURL, nil)
+	if err != nil {
+		log.Fatalf("error connecting to postgres: %v", err)
+	}
+
+	err = validate.ValidateRedis(cfg.RedisHost, cfg.RedisPassword, int(cfg.RedisDB))
+	if err != nil {
+		log.Fatalf("error validating Redis: %v", err)
+	}
+
+	return
+}
+
+func loadConfig() (initialize.Config, error) {
+	var cfg initialize.Config
+
+	if err := env.Parse(&cfg); err != nil {
+		return cfg, err
+	}
+	return cfg, nil
+}
+
+func validateNotEmpty(cfg initialize.Config) error {
+	if cfg.ClientHttpURL == "" {
+		return errors.New("client http url cannot be empty")
+	}
+
+	if cfg.RedirectURL == "" {
+		return errors.New("redirect url cannot be empty")
+	}
+
+	if cfg.TrashLogHost == "" {
+		return errors.New("trash log host cannot be empty")
+	}
+
+	if cfg.ExternalCfg.EncryptCommon.PrivKey == "" {
+		return errors.New("private key cannot be empty")
+	}
+
+	if cfg.ExternalCfg.EncryptCommon.PubKey == "" {
+		return errors.New("public key cannot be empty")
+	}
+
+	return nil
+}
--- a/go.mod
+++ b/go.mod
@ -7,48 +7,62 @@ toolchain go1.23.4
 require (
 	gitea.pena/PenaSide/common v0.0.0-20250103085335-91ea31fee517
 	gitea.pena/PenaSide/hlog v0.0.0-20241125221102-a54c29c002a9
-	gitea.pena/PenaSide/trashlog v0.0.0-20250224122049-ddb4d72e9d07
-	gitea.pena/SQuiz/common v0.0.0-20250610213406-ac5c9d667dc7
+	gitea.pena/PenaSide/trashlog v0.0.0-20250222101337-a43552caae6f
+	gitea.pena/SQuiz/common v0.0.0-20250629151736-5656e784ba68
+	github.com/caarlos0/env/v8 v8.0.0
 	github.com/go-redis/redis/v8 v8.11.5
-	github.com/gofiber/fiber/v2 v2.52.5
-	github.com/minio/minio-go/v7 v7.0.81
+	github.com/gofiber/fiber/v2 v2.52.6
+	github.com/joho/godotenv v1.5.1
+	github.com/minio/minio-go/v7 v7.0.87
 	github.com/rs/xid v1.6.0
-	github.com/skeris/appInit v1.0.2
 	go.uber.org/zap v1.27.0
 )

 require (
 	gitea.pena/PenaSide/linters-golang v0.0.0-20241207122018-933207374735 // indirect
 	github.com/ClickHouse/clickhouse-go v1.5.4 // indirect
-	github.com/andybalholm/brotli v1.1.0 // indirect
-	github.com/cespare/xxhash/v2 v2.2.0 // indirect
-	github.com/cloudflare/golz4 v0.0.0-20150217214814-ef862a3cdc58 // indirect
+	github.com/andybalholm/brotli v1.1.1 // indirect
+	github.com/cespare/xxhash/v2 v2.3.0 // indirect
+	github.com/cloudflare/golz4 v0.0.0-20240916140612-caecf3c00c06 // indirect
 	github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f // indirect
 	github.com/dustin/go-humanize v1.0.1 // indirect
 	github.com/go-ini/ini v1.67.0 // indirect
-	github.com/goccy/go-json v0.10.3 // indirect
+	github.com/goccy/go-json v0.10.5 // indirect
 	github.com/golang-jwt/jwt/v5 v5.2.1 // indirect
 	github.com/golang/protobuf v1.5.4 // indirect
+	github.com/golang/snappy v0.0.1 // indirect
 	github.com/google/uuid v1.6.0 // indirect
-	github.com/klauspost/compress v1.17.11 // indirect
+	github.com/klauspost/compress v1.18.0 // indirect
 	github.com/klauspost/cpuid/v2 v2.2.9 // indirect
 	github.com/lib/pq v1.10.9 // indirect
-	github.com/mattn/go-colorable v0.1.13 // indirect
+	github.com/mattn/go-colorable v0.1.14 // indirect
 	github.com/mattn/go-isatty v0.0.20 // indirect
 	github.com/mattn/go-runewidth v0.0.16 // indirect
+	github.com/minio/crc64nvme v1.0.1 // indirect
 	github.com/minio/md5-simd v1.1.2 // indirect
-	github.com/rivo/uniseg v0.2.0 // indirect
-	github.com/tealeg/xlsx v1.0.5 // indirect
+	github.com/montanaflynn/stats v0.0.0-20171201202039-1bf9dbcd8cbe // indirect
+	github.com/pierrec/lz4/v4 v4.1.21 // indirect
+	github.com/pioz/faker v1.7.3 // indirect
+	github.com/rivo/uniseg v0.4.7 // indirect
+	github.com/stretchr/testify v1.10.0 // indirect
+	github.com/themakers/hlog v0.0.0-20191205140925-235e0e4baddf // indirect
+	github.com/twmb/franz-go v1.18.0 // indirect
+	github.com/twmb/franz-go/pkg/kmsg v1.9.0 // indirect
 	github.com/valyala/bytebufferpool v1.0.0 // indirect
-	github.com/valyala/fasthttp v1.51.0 // indirect
-	github.com/valyala/tcplisten v1.0.0 // indirect
+	github.com/valyala/fasthttp v1.59.0 // indirect
+	github.com/xdg-go/pbkdf2 v1.0.0 // indirect
+	github.com/xdg-go/scram v1.1.2 // indirect
+	github.com/xdg-go/stringprep v1.0.4 // indirect
+	github.com/youmark/pkcs8 v0.0.0-20181117223130-1be2e3e5546d // indirect
 	go.etcd.io/bbolt v1.3.10 // indirect
+	go.mongodb.org/mongo-driver v1.13.1 // indirect
 	go.uber.org/multierr v1.11.0 // indirect
-	golang.org/x/crypto v0.28.0 // indirect
-	golang.org/x/net v0.30.0 // indirect
-	golang.org/x/sys v0.28.0 // indirect
-	golang.org/x/text v0.19.0 // indirect
-	google.golang.org/genproto/googleapis/rpc v0.0.0-20240610135401-a8a62080eff3 // indirect
-	google.golang.org/grpc v1.64.0 // indirect
-	google.golang.org/protobuf v1.34.2 // indirect
+	golang.org/x/crypto v0.35.0 // indirect
+	golang.org/x/net v0.35.0 // indirect
+	golang.org/x/sync v0.11.0 // indirect
+	golang.org/x/sys v0.30.0 // indirect
+	golang.org/x/text v0.22.0 // indirect
+	google.golang.org/genproto/googleapis/rpc v0.0.0-20250224174004-546df14abb99 // indirect
+	google.golang.org/grpc v1.70.0 // indirect
+	google.golang.org/protobuf v1.36.5 // indirect
 )
--- a/go.sum
+++ b/go.sum
@ -4,27 +4,37 @@ gitea.pena/PenaSide/hlog v0.0.0-20241125221102-a54c29c002a9 h1:tBkXWNIt8icmkMMnq
 gitea.pena/PenaSide/hlog v0.0.0-20241125221102-a54c29c002a9/go.mod h1:sanhSL8aEsfcq21P+eItYiAnKAre+B67nGJmDfk2cf0=
 gitea.pena/PenaSide/linters-golang v0.0.0-20241207122018-933207374735 h1:jDVeUhGBTXBibmW5dmtJg2m2+z5z2Rf6J4G0LpjVoJ0=
 gitea.pena/PenaSide/linters-golang v0.0.0-20241207122018-933207374735/go.mod h1:gdd+vOT6up9STkEbxa2qESLIMZFjCmRbkcheFQCVgZU=
+gitea.pena/PenaSide/trashlog v0.0.0-20250222101337-a43552caae6f h1:KbZU49A8tGnqWZiDwerKx2LVT7LD69Y13bwHkuyIjrM=
+gitea.pena/PenaSide/trashlog v0.0.0-20250222101337-a43552caae6f/go.mod h1:GRfWJerTUlgy82CiYAxE4tVYSVV54zEJJQy17Fx46E4=
 gitea.pena/PenaSide/trashlog v0.0.0-20250224122049-ddb4d72e9d07 h1:bUIUgzXQt16aBqSccI//BaODpRCTIaqlddSepM98QSc=
 gitea.pena/PenaSide/trashlog v0.0.0-20250224122049-ddb4d72e9d07/go.mod h1:GRfWJerTUlgy82CiYAxE4tVYSVV54zEJJQy17Fx46E4=
+gitea.pena/SQuiz/common v0.0.0-20250221135056-f98c45e04909 h1:iCiqaJ6a7rGESAEUgtVA9IqhVn0oKiwRk7bryTWPV5w=
+gitea.pena/SQuiz/common v0.0.0-20250221135056-f98c45e04909/go.mod h1:rQRjqLlLyM71FZcvbM95Nv3ciq44F9DFtUHPZmDK3T8=
 gitea.pena/SQuiz/common v0.0.0-20250514124515-870e52266ca5 h1:C+iCsGMSUJonOTNNk8wWYOfzZ0Jjw+2IQ5FaEGwRVT0=
 gitea.pena/SQuiz/common v0.0.0-20250514124515-870e52266ca5/go.mod h1:zCrUwDh0APpztKk6NUqTZv+zhjVbWpGBJiJ5z9dAH0U=
 gitea.pena/SQuiz/common v0.0.0-20250610192732-9f01faa53ea9 h1:y97VEguCy1Qf/hl/XT9IfX3EgwLgAkn2+1sBDuxjo7Q=
 gitea.pena/SQuiz/common v0.0.0-20250610192732-9f01faa53ea9/go.mod h1:zCrUwDh0APpztKk6NUqTZv+zhjVbWpGBJiJ5z9dAH0U=
 gitea.pena/SQuiz/common v0.0.0-20250610213406-ac5c9d667dc7 h1:LdL8G958qTeDNNsLbqhnlnFbbiSMoqqULnNqxIR4c/w=
 gitea.pena/SQuiz/common v0.0.0-20250610213406-ac5c9d667dc7/go.mod h1:zCrUwDh0APpztKk6NUqTZv+zhjVbWpGBJiJ5z9dAH0U=
+gitea.pena/SQuiz/common v0.0.0-20250629151736-5656e784ba68 h1:U+rO77EY1Cp7RAEtDjLIl1Z2tFcEouUuQ+J4LnFUe6g=
+gitea.pena/SQuiz/common v0.0.0-20250629151736-5656e784ba68/go.mod h1:zCrUwDh0APpztKk6NUqTZv+zhjVbWpGBJiJ5z9dAH0U=
 github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU=
 github.com/ClickHouse/clickhouse-go v1.5.4 h1:cKjXeYLNWVJIx2J1K6H2CqyRmfwVJVY1OV1coaaFcI0=
 github.com/ClickHouse/clickhouse-go v1.5.4/go.mod h1:EaI/sW7Azgz9UATzd5ZdZHRUhHgv5+JMS9NSr2smCJI=
-github.com/andybalholm/brotli v1.1.0 h1:eLKJA0d02Lf0mVpIDgYnqXcUn0GqVmEFny3VuID1U3M=
-github.com/andybalholm/brotli v1.1.0/go.mod h1:sms7XGricyQI9K10gOSf56VKKWS4oLer58Q+mhRPtnY=
+github.com/andybalholm/brotli v1.1.1 h1:PR2pgnyFznKEugtsUo0xLdDop5SKXd5Qf5ysW+7XdTA=
+github.com/andybalholm/brotli v1.1.1/go.mod h1:05ib4cKhjx3OQYUY22hTVd34Bc8upXjOLL2rKwwZBoA=
 github.com/bkaradzic/go-lz4 v1.0.0 h1:RXc4wYsyz985CkXXeX04y4VnZFGG8Rd43pRaHsOXAKk=
 github.com/bkaradzic/go-lz4 v1.0.0/go.mod h1:0YdlkowM3VswSROI7qDxhRvJ3sLhlFrRRwjwegp5jy4=
 github.com/caarlos0/env/v8 v8.0.0 h1:POhxHhSpuxrLMIdvTGARuZqR4Jjm8AYmoi/JKlcScs0=
 github.com/caarlos0/env/v8 v8.0.0/go.mod h1:7K4wMY9bH0esiXSSHlfHLX5xKGQMnkH5Fk4TDSSSzfo=
 github.com/cespare/xxhash/v2 v2.2.0 h1:DC2CZ1Ep5Y4k3ZQ899DldepgrayRUGE6BBZ/cd9Cj44=
 github.com/cespare/xxhash/v2 v2.2.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
+github.com/cespare/xxhash/v2 v2.3.0 h1:UL815xU9SqsFlibzuggzjXhog7bL6oX9BbNZnL2UFvs=
+github.com/cespare/xxhash/v2 v2.3.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
 github.com/cloudflare/golz4 v0.0.0-20150217214814-ef862a3cdc58 h1:F1EaeKL/ta07PY/k9Os/UFtwERei2/XzGemhpGnBKNg=
 github.com/cloudflare/golz4 v0.0.0-20150217214814-ef862a3cdc58/go.mod h1:EOBUe0h4xcZ5GoxqC5SDxFQ8gwyZPKQoEzownBlhI80=
+github.com/cloudflare/golz4 v0.0.0-20240916140612-caecf3c00c06 h1:6aQNgrBLzcUBaJHQjMk4X+jDo9rQtu5E0XNLhRV6pOk=
+github.com/cloudflare/golz4 v0.0.0-20240916140612-caecf3c00c06/go.mod h1:EOBUe0h4xcZ5GoxqC5SDxFQ8gwyZPKQoEzownBlhI80=
 github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
 github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
@ -38,26 +48,41 @@ github.com/fsnotify/fsnotify v1.4.9 h1:hsms1Qyu0jgnwNXIxa+/V/PDsU6CfLf6CNO8H7IWo
 github.com/fsnotify/fsnotify v1.4.9/go.mod h1:znqG4EE+3YCdAaPaxE2ZRY/06pZUdp0tY4IgpuI1SZQ=
 github.com/go-ini/ini v1.67.0 h1:z6ZrTEZqSWOTyH2FlglNbNgARyHG8oLW9gMELqKr06A=
 github.com/go-ini/ini v1.67.0/go.mod h1:ByCAeIL28uOIIG0E3PJtZPDL8WnHpFKFOtgjp+3Ies8=
+github.com/go-logr/logr v1.4.2 h1:6pFjapn8bFcIbiKo3XT4j/BhANplGihG6tvd+8rYgrY=
+github.com/go-logr/logr v1.4.2/go.mod h1:9T104GzyrTigFIr8wt5mBrctHMim0Nb2HLGrmQ40KvY=
+github.com/go-logr/stdr v1.2.2 h1:hSWxHoqTgW2S2qGc0LTAI563KZ5YKYRhT3MFKZMbjag=
+github.com/go-logr/stdr v1.2.2/go.mod h1:mMo/vtBO5dYbehREoey6XUKy/eSumjCCveDpRre4VKE=
 github.com/go-redis/redis/v8 v8.11.5 h1:AcZZR7igkdvfVmQTPnu9WE37LRrO/YrBH5zWyjDC0oI=
 github.com/go-redis/redis/v8 v8.11.5/go.mod h1:gREzHqY1hg6oD9ngVRbLStwAWKhA0FEgq8Jd4h5lpwo=
 github.com/go-sql-driver/mysql v1.4.0/go.mod h1:zAC/RDZ24gD3HViQzih4MyKcchzm+sOG5ZlKdlhCg5w=
 github.com/goccy/go-json v0.10.3 h1:KZ5WoDbxAIgm2HNbYckL0se1fHD6rz5j4ywS6ebzDqA=
 github.com/goccy/go-json v0.10.3/go.mod h1:oq7eo15ShAhp70Anwd5lgX2pLfOS3QCiwU/PULtXL6M=
+github.com/goccy/go-json v0.10.5 h1:Fq85nIqj+gXn/S5ahsiTlK3TmC85qgirsdTP/+DeaC4=
+github.com/goccy/go-json v0.10.5/go.mod h1:oq7eo15ShAhp70Anwd5lgX2pLfOS3QCiwU/PULtXL6M=
 github.com/gofiber/fiber/v2 v2.52.5 h1:tWoP1MJQjGEe4GB5TUGOi7P2E0ZMMRx5ZTG4rT+yGMo=
 github.com/gofiber/fiber/v2 v2.52.5/go.mod h1:KEOE+cXMhXG0zHc9d8+E38hoX+ZN7bhOtgeF2oT6jrQ=
+github.com/gofiber/fiber/v2 v2.52.6 h1:Rfp+ILPiYSvvVuIPvxrBns+HJp8qGLDnLJawAu27XVI=
+github.com/gofiber/fiber/v2 v2.52.6/go.mod h1:YEcBbO/FB+5M1IZNBP9FO3J9281zgPAreiI1oqg8nDw=
 github.com/golang-jwt/jwt/v5 v5.2.1 h1:OuVbFODueb089Lh128TAcimifWaLhJwVflnrgM17wHk=
 github.com/golang-jwt/jwt/v5 v5.2.1/go.mod h1:pqrtFR0X4osieyHYxtmOUWsAWrfe1Q5UVIyoH402zdk=
 github.com/golang/protobuf v1.5.4 h1:i7eJL8qZTpSEXOPTxNKhASYpMn+8e5Q6AdndVa1dWek=
 github.com/golang/protobuf v1.5.4/go.mod h1:lnTiLA8Wa4RWRcIUkrtSVa5nRhsEGBg48fD6rSs7xps=
+github.com/golang/snappy v0.0.1 h1:Qgr9rKW7uDUkrbSmQeiDsGa8SjGyCOGtuasMWwvp2P4=
+github.com/golang/snappy v0.0.1/go.mod h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEWrmP2Q=
+github.com/google/go-cmp v0.5.2/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
 github.com/google/go-cmp v0.6.0 h1:ofyhxvXcZhMsU5ulbFiLKl/XBFqE1GSq7atu8tAmTRI=
 github.com/google/go-cmp v0.6.0/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY=
-github.com/google/renameio v0.1.0/go.mod h1:KWCgfxg9yswjAJkECMjeO8J8rahYeXnNhOm40UhjYkI=
 github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
 github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
 github.com/jmoiron/sqlx v1.2.0/go.mod h1:1FEQNm3xlJgrMD+FBdI9+xvCksHtbpVBBw5dYhBSsks=
+github.com/joho/godotenv v1.5.1 h1:7eLL/+HRGLY0ldzfGMeQkb7vMd0as4CfYvUVzLqw0N0=
+github.com/joho/godotenv v1.5.1/go.mod h1:f4LDr5Voq0i2e/R5DDNOoa2zzDfwtkZa6DnEwAbqwq4=
 github.com/kisielk/gotool v1.0.0/go.mod h1:XhKaO+MFFWcvkIS/tQcRk01m1F5IRFswLeQ+oQHNcck=
+github.com/klauspost/compress v1.13.6/go.mod h1:/3/Vjq9QcHkK5uEr5lBEmyoZ1iFhe47etQ6QUkpK6sk=
 github.com/klauspost/compress v1.17.11 h1:In6xLpyWOi1+C7tXUUWv2ot1QvBjxevKAaI6IXrJmUc=
 github.com/klauspost/compress v1.17.11/go.mod h1:pMDklpSncoRMuLFrf1W9Ss9KT+0rH90U12bZKk7uwG0=
+github.com/klauspost/compress v1.18.0 h1:c/Cqfb0r+Yi+JtIEq73FWXVkRonBlf0CRNYc8Zttxdo=
+github.com/klauspost/compress v1.18.0/go.mod h1:2Pp+KzxcywXVXMr50+X0Q/Lsb43OQHYWRCY2AiWywWQ=
 github.com/klauspost/cpuid/v2 v2.0.1/go.mod h1:FInQzS24/EEf25PyTYn52gqo7WaD8xa0213Md/qVLRg=
 github.com/klauspost/cpuid/v2 v2.2.9 h1:66ze0taIn2H33fBvCkXuv9BmCwDfafmiIVpKV9kKGuY=
 github.com/klauspost/cpuid/v2 v2.2.9/go.mod h1:rqkxqrZ1EhYM9G+hXH7YdowN5R5RGN6NK4QwQ3WMXF8=
@ -70,18 +95,23 @@ github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE=
 github.com/lib/pq v1.0.0/go.mod h1:5WUZQaWbwv1U+lTReE5YruASi9Al49XbQIvNi/34Woo=
 github.com/lib/pq v1.10.9 h1:YXG7RB+JIjhP29X+OtkiDnYaXQwpS4JEWq7dtCCRUEw=
 github.com/lib/pq v1.10.9/go.mod h1:AlVN5x4E4T544tWzH6hKfbfQvm3HdbOxrmggDNAPY9o=
-github.com/mattn/go-colorable v0.1.13 h1:fFA4WZxdEF4tXPZVKMLwD8oUnCTTo08duU7wxecdEvA=
-github.com/mattn/go-colorable v0.1.13/go.mod h1:7S9/ev0klgBDR4GtXTXX8a3vIGJpMovkB8vQcUbaXHg=
-github.com/mattn/go-isatty v0.0.16/go.mod h1:kYGgaQfpe5nmfYZH+SKPsOc2e4SrIfOl2e/yFXSvRLM=
+github.com/mattn/go-colorable v0.1.14 h1:9A9LHSqF/7dyVVX6g0U9cwm9pG3kP9gSzcuIPHPsaIE=
+github.com/mattn/go-colorable v0.1.14/go.mod h1:6LmQG8QLFO4G5z1gPvYEzlUgJ2wF+stgPZH1UqBm1s8=
 github.com/mattn/go-isatty v0.0.20 h1:xfD0iDuEKnDkl03q4limB+vH+GxLEtL/jb4xVJSWWEY=
 github.com/mattn/go-isatty v0.0.20/go.mod h1:W+V8PltTTMOvKvAeJH7IuucS94S2C6jfK/D7dTCTo3Y=
 github.com/mattn/go-runewidth v0.0.16 h1:E5ScNMtiwvlvB5paMFdw9p4kSQzbXFikJ5SQO6TULQc=
 github.com/mattn/go-runewidth v0.0.16/go.mod h1:Jdepj2loyihRzMpdS35Xk/zdY8IAYHsh153qUoGf23w=
 github.com/mattn/go-sqlite3 v1.9.0/go.mod h1:FPy6KqzDD04eiIsT53CuJW3U88zkxoIYsOqkbpncsNc=
+github.com/minio/crc64nvme v1.0.1 h1:DHQPrYPdqK7jQG/Ls5CTBZWeex/2FMS3G5XGkycuFrY=
+github.com/minio/crc64nvme v1.0.1/go.mod h1:eVfm2fAzLlxMdUGc0EEBGSMmPwmXD5XiNRpnu9J3bvg=
 github.com/minio/md5-simd v1.1.2 h1:Gdi1DZK69+ZVMoNHRXJyNcxrMA4dSxoYHZSQbirFg34=
 github.com/minio/md5-simd v1.1.2/go.mod h1:MzdKDxYpY2BT9XQFocsiZf/NKVtR7nkE4RoEpN+20RM=
 github.com/minio/minio-go/v7 v7.0.81 h1:SzhMN0TQ6T/xSBu6Nvw3M5M8voM+Ht8RH3hE8S7zxaA=
 github.com/minio/minio-go/v7 v7.0.81/go.mod h1:84gmIilaX4zcvAWWzJ5Z1WI5axN+hAbM5w25xf8xvC0=
+github.com/minio/minio-go/v7 v7.0.87 h1:nkr9x0u53PespfxfUqxP3UYWiE2a41gaofgNnC4Y8WQ=
+github.com/minio/minio-go/v7 v7.0.87/go.mod h1:33+O8h0tO7pCeCWwBVa07RhVVfB/3vS4kEX7rwYKmIg=
+github.com/montanaflynn/stats v0.0.0-20171201202039-1bf9dbcd8cbe h1:iruDEfMl2E6fbMZ9s0scYfZQ84/6SPL6zC8ACM2oIL0=
+github.com/montanaflynn/stats v0.0.0-20171201202039-1bf9dbcd8cbe/go.mod h1:wL8QJuTMNUDYhXwkmfOly8iTdp5TEcJFWZD2D7SIkUc=
 github.com/nxadm/tail v1.4.8 h1:nPr65rt6Y5JFSKQO7qToXr7pePgD6Gwiw05lkbyAQTE=
 github.com/nxadm/tail v1.4.8/go.mod h1:+ncqLTQzXmGhMZNUePPaPqPvBxHAIsmXswZKocGu+AU=
 github.com/onsi/ginkgo v1.16.5 h1:8xi0RTUf59SOSfEtZMvwTvXYMzG4gV23XVHOZiXNtnE=
@ -90,6 +120,8 @@ github.com/onsi/gomega v1.18.1 h1:M1GfJqGRrBrrGGsbxzV5dqM2U2ApXefZCQpkukxYRLE=
 github.com/onsi/gomega v1.18.1/go.mod h1:0q+aL8jAiMXy9hbwj2mr5GziHiwhAIQpFmmtT5hitRs=
 github.com/pierrec/lz4 v2.0.5+incompatible h1:2xWsjqPFWcplujydGg4WmhC/6fZqK42wMM8aXeqhl0I=
 github.com/pierrec/lz4 v2.0.5+incompatible/go.mod h1:pdkljMzZIN41W+lC3N2tnIh5sFi+IEE17M5jbnwPHcY=
+github.com/pierrec/lz4/v4 v4.1.21 h1:yOVMLb6qSIDP67pl/5F7RepeKYu/VmTyEXvuMI5d9mQ=
+github.com/pierrec/lz4/v4 v4.1.21/go.mod h1:gZWDp/Ze/IJXGXf23ltt2EXimqmTUXEy0GFuRQyBid4=
 github.com/pioz/faker v1.7.3 h1:Tez8Emuq0UN+/d6mo3a9m/9ZZ/zdfJk0c5RtRatrceM=
 github.com/pioz/faker v1.7.3/go.mod h1:xSpay5w/oz1a6+ww0M3vfpe40pSIykeUPeWEc3TvVlc=
 github.com/pkg/errors v0.8.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
@ -99,6 +131,8 @@ github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZb
 github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
 github.com/rivo/uniseg v0.2.0 h1:S1pD9weZBuJdFmowNwbpi7BJ8TNftyUImj/0WQi72jY=
 github.com/rivo/uniseg v0.2.0/go.mod h1:J6wj4VEh+S6ZtnVlnTBMWIodfgj8LQOQFoIToxlJtxc=
+github.com/rivo/uniseg v0.4.7 h1:WUdvkW8uEhrYfLC4ZzdpI2ztxP1I582+49Oc5Mq64VQ=
+github.com/rivo/uniseg v0.4.7/go.mod h1:FN3SvrM+Zdj16jyLfmOkMNblXMcoc8DfTHruCPUcx88=
 github.com/rogpeppe/go-internal v1.3.0/go.mod h1:M8bDsm7K2OlrFYOpmOWEs/qY81heoFRclV5y23lUDJ4=
 github.com/rs/xid v1.6.0 h1:fV591PaemRlL6JfRxGDEPl69wICngIQ3shQtzfy2gxU=
 github.com/rs/xid v1.6.0/go.mod h1:7XoLgs4eV+QndskICGsho+ADou8ySMSjJKDIan90Nz0=
@ -107,64 +141,127 @@ github.com/skeris/appInit v1.0.2/go.mod h1:4ElEeXWVGzU3dlYq/eMWJ/U5hd+LKisc1z3+y
 github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
 github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI=
 github.com/stretchr/testify v1.4.0/go.mod h1:j7eGeouHqKxXV5pUuKE4zz7dFj8WfuZ+81PSLYec5m4=
+github.com/stretchr/testify v1.6.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
 github.com/stretchr/testify v1.9.0 h1:HtqpIVDClZ4nwg75+f6Lvsy/wHu+3BoSGCbBAcpTsTg=
 github.com/stretchr/testify v1.9.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY=
+github.com/stretchr/testify v1.10.0 h1:Xv5erBjTwe/5IxqUQTdXv5kgmIvbHo3QQyRwhJsOfJA=
+github.com/stretchr/testify v1.10.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY=
 github.com/tealeg/xlsx v1.0.5 h1:+f8oFmvY8Gw1iUXzPk+kz+4GpbDZPK1FhPiQRd+ypgE=
 github.com/tealeg/xlsx v1.0.5/go.mod h1:btRS8dz54TDnvKNosuAqxrM1QgN1udgk9O34bDCnORM=
 github.com/themakers/bdd v0.0.0-20210316111417-6b1dfe326f33 h1:N9f/Q+2Ssa+yDcbfaoLTYvXmdeyUUxsJKdPUVsjSmiA=
 github.com/themakers/bdd v0.0.0-20210316111417-6b1dfe326f33/go.mod h1:rpcH99JknBh8seZmlOlUg51gasZH6QH34oXNsIwYT6E=
+github.com/themakers/hlog v0.0.0-20191205140925-235e0e4baddf h1:TJJm6KcBssmbWzplF5lzixXl1RBAi/ViPs1GaSOkhwo=
+github.com/themakers/hlog v0.0.0-20191205140925-235e0e4baddf/go.mod h1:1FsorU3vnXO9xS9SrhUp8fRb/6H/Zfll0rPt1i4GWaA=
+github.com/twmb/franz-go v1.18.0 h1:25FjMZfdozBywVX+5xrWC2W+W76i0xykKjTdEeD2ejw=
+github.com/twmb/franz-go v1.18.0/go.mod h1:zXCGy74M0p5FbXsLeASdyvfLFsBvTubVqctIaa5wQ+I=
+github.com/twmb/franz-go/pkg/kmsg v1.9.0 h1:JojYUph2TKAau6SBtErXpXGC7E3gg4vGZMv9xFU/B6M=
+github.com/twmb/franz-go/pkg/kmsg v1.9.0/go.mod h1:CMbfazviCyY6HM0SXuG5t9vOwYDHRCSrJJyBAe5paqg=
 github.com/valyala/bytebufferpool v1.0.0 h1:GqA5TC/0021Y/b9FG4Oi9Mr3q7XYx6KllzawFIhcdPw=
 github.com/valyala/bytebufferpool v1.0.0/go.mod h1:6bBcMArwyJ5K/AmCkWv1jt77kVWyCJ6HpOuEn7z0Csc=
 github.com/valyala/fasthttp v1.51.0 h1:8b30A5JlZ6C7AS81RsWjYMQmrZG6feChmgAolCl1SqA=
 github.com/valyala/fasthttp v1.51.0/go.mod h1:oI2XroL+lI7vdXyYoQk03bXBThfFl2cVdIA3Xl7cH8g=
+github.com/valyala/fasthttp v1.59.0 h1:Qu0qYHfXvPk1mSLNqcFtEk6DpxgA26hy6bmydotDpRI=
+github.com/valyala/fasthttp v1.59.0/go.mod h1:GTxNb9Bc6r2a9D0TWNSPwDz78UxnTGBViY3xZNEqyYU=
 github.com/valyala/tcplisten v1.0.0 h1:rBHj/Xf+E1tRGZyWIWwJDiRY0zc1Js+CV5DqwacVSA8=
 github.com/valyala/tcplisten v1.0.0/go.mod h1:T0xQ8SeCZGxckz9qRXTfG43PvQ/mcWh7FwZEA7Ioqkc=
+github.com/xdg-go/pbkdf2 v1.0.0 h1:Su7DPu48wXMwC3bs7MCNG+z4FhcyEuz5dlvchbq0B0c=
+github.com/xdg-go/pbkdf2 v1.0.0/go.mod h1:jrpuAogTd400dnrH08LKmI/xc1MbPOebTwRqcT5RDeI=
+github.com/xdg-go/scram v1.1.2 h1:FHX5I5B4i4hKRVRBCFRxq1iQRej7WO3hhBuJf+UUySY=
+github.com/xdg-go/scram v1.1.2/go.mod h1:RT/sEzTbU5y00aCK8UOx6R7YryM0iF1N2MOmC3kKLN4=
+github.com/xdg-go/stringprep v1.0.4 h1:XLI/Ng3O1Atzq0oBs3TWm+5ZVgkq2aqdlvP9JtoZ6c8=
+github.com/xdg-go/stringprep v1.0.4/go.mod h1:mPGuuIYwz7CmR2bT9j4GbQqutWS1zV24gijq1dTyGkM=
+github.com/xyproto/randomstring v1.0.5 h1:YtlWPoRdgMu3NZtP45drfy1GKoojuR7hmRcnhZqKjWU=
+github.com/xyproto/randomstring v1.0.5/go.mod h1:rgmS5DeNXLivK7YprL0pY+lTuhNQW3iGxZ18UQApw/E=
+github.com/youmark/pkcs8 v0.0.0-20181117223130-1be2e3e5546d h1:splanxYIlg+5LfHAM6xpdFEAYOk8iySO56hMFq6uLyA=
+github.com/youmark/pkcs8 v0.0.0-20181117223130-1be2e3e5546d/go.mod h1:rHwXgn7JulP+udvsHwJoVG1YGAP6VLg4y9I5dyZdqmA=
+github.com/yuin/goldmark v1.4.13/go.mod h1:6yULJ656Px+3vBD8DxQVa3kxgyrAnzto9xy5taEt/CY=
 go.etcd.io/bbolt v1.3.10 h1:+BqfJTcCzTItrop8mq/lbzL8wSGtj94UO/3U31shqG0=
 go.etcd.io/bbolt v1.3.10/go.mod h1:bK3UQLPJZly7IlNmV7uVHJDxfe5aK9Ll93e/74Y9oEQ=
-go.uber.org/atomic v1.6.0/go.mod h1:sABNBOSYdrvTF6hTgEIbc7YasKWGhgEQZyfxyTvoXHQ=
+go.mongodb.org/mongo-driver v1.13.1 h1:YIc7HTYsKndGK4RFzJ3covLz1byri52x0IoMB0Pt/vk=
+go.mongodb.org/mongo-driver v1.13.1/go.mod h1:wcDf1JBCXy2mOW0bWHwO/IOYqdca1MPCwDtFu/Z9+eo=
+go.opentelemetry.io/otel v1.32.0 h1:WnBN+Xjcteh0zdk01SVqV55d/m62NJLJdIyb4y/WO5U=
+go.opentelemetry.io/otel v1.32.0/go.mod h1:00DCVSB0RQcnzlwyTfqtxSm+DRr9hpYrHjNGiBHVQIg=
+go.opentelemetry.io/otel/metric v1.32.0 h1:xV2umtmNcThh2/a/aCP+h64Xx5wsj8qqnkYZktzNa0M=
+go.opentelemetry.io/otel/metric v1.32.0/go.mod h1:jH7CIbbK6SH2V2wE16W05BHCtIDzauciCRLoc/SyMv8=
+go.opentelemetry.io/otel/sdk v1.32.0 h1:RNxepc9vK59A8XsgZQouW8ue8Gkb4jpWtJm9ge5lEG4=
+go.opentelemetry.io/otel/sdk v1.32.0/go.mod h1:LqgegDBjKMmb2GC6/PrTnteJG39I8/vJCAP9LlJXEjU=
+go.opentelemetry.io/otel/sdk/metric v1.32.0 h1:rZvFnvmvawYb0alrYkjraqJq0Z4ZUJAiyYCU9snn1CU=
+go.opentelemetry.io/otel/sdk/metric v1.32.0/go.mod h1:PWeZlq0zt9YkYAp3gjKZ0eicRYvOh1Gd+X99x6GHpCQ=
+go.opentelemetry.io/otel/trace v1.32.0 h1:WIC9mYrXf8TmY/EXuULKc8hR17vE+Hjv2cssQDe03fM=
+go.opentelemetry.io/otel/trace v1.32.0/go.mod h1:+i4rkvCraA+tG6AzwloGaCtkx53Fa+L+V8e9a7YvhT8=
 go.uber.org/goleak v1.3.0 h1:2K3zAYmnTNqV73imy9J1T3WC+gmCePx2hEGkimedGto=
 go.uber.org/goleak v1.3.0/go.mod h1:CoHD4mav9JJNrW/WLlf7HGZPjdw8EucARQHekz1X6bE=
-go.uber.org/multierr v1.5.0/go.mod h1:FeouvMocqHpRaaGuG9EjoKcStLC43Zu/fmqdUMPcKYU=
 go.uber.org/multierr v1.11.0 h1:blXXJkSxSSfBVBlC76pxqeO+LN3aDfLQo+309xJstO0=
 go.uber.org/multierr v1.11.0/go.mod h1:20+QtiLqy0Nd6FdQB9TLXag12DsQkrbs3htMFfDN80Y=
-go.uber.org/tools v0.0.0-20190618225709-2cfd321de3ee/go.mod h1:vJERXedbb3MVM5f9Ejo0C68/HhF8uaILCdgjnY+goOA=
-go.uber.org/zap v1.16.0/go.mod h1:MA8QOfq0BHJwdXa996Y4dYkAqRKB8/1K1QMMZVaNZjQ=
 go.uber.org/zap v1.27.0 h1:aJMhYGrd5QSmlpLMr2MftRKl7t8J8PTZPA732ud/XR8=
 go.uber.org/zap v1.27.0/go.mod h1:GB2qFLM7cTU87MWRP2mPIjqfIDnGu+VIO4V/SdhGo2E=
 golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
 golang.org/x/crypto v0.0.0-20190510104115-cbcb75029529/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI=
+golang.org/x/crypto v0.0.0-20210921155107-089bfa567519/go.mod h1:GvvjBRRGRdwPK5ydBHafDWAxML/pGHZbMvKqRZ5+Abc=
+golang.org/x/crypto v0.0.0-20220622213112-05595931fe9d/go.mod h1:IxCIyHEi3zRg3s0A5j5BB6A9Jmi73HwBIUl50j+osU4=
 golang.org/x/crypto v0.28.0 h1:GBDwsMXVQi34v5CCYUm2jkJvu4cbtru2U4TN2PSyQnw=
 golang.org/x/crypto v0.28.0/go.mod h1:rmgy+3RHxRZMyY0jjAJShp2zgEdOqj2AO7U0pYmeQ7U=
+golang.org/x/crypto v0.35.0 h1:b15kiHdrGCHrP6LvwaQ3c03kgNhhiMgvlhxHQhmg2Xs=
+golang.org/x/crypto v0.35.0/go.mod h1:dy7dXNW32cAb/6/PRuTNsix8T+vJAqvuIy5Bli/x0YQ=
 golang.org/x/lint v0.0.0-20190930215403-16217165b5de/go.mod h1:6SW0HCj/g11FgYtHlgUYUwCkIfeOF89ocIRzGO/8vkc=
 golang.org/x/mod v0.0.0-20190513183733-4bf6d317e70e/go.mod h1:mXi4GBBbnImb6dmsKGUJ2LatrhH/nqhxcFungHvyanc=
+golang.org/x/mod v0.6.0-dev.0.20220419223038-86c51ed26bb4/go.mod h1:jJ57K6gSWd91VN4djpZkiMVwK6gcyfeH4XE8wZrZaV4=
 golang.org/x/net v0.0.0-20190311183353-d8887717615a/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
 golang.org/x/net v0.0.0-20190404232315-eb5bcb51f2a3/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
 golang.org/x/net v0.0.0-20190620200207-3b0461eec859/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
+golang.org/x/net v0.0.0-20210226172049-e18ecbb05110/go.mod h1:m0MpNAwzfU5UDzcl9v0D8zg8gWTRqZa9RBIspLL5mdg=
+golang.org/x/net v0.0.0-20211112202133-69e39bad7dc2/go.mod h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y=
+golang.org/x/net v0.0.0-20220722155237-a158d28d115b/go.mod h1:XRhObCWvk6IyKnWLug+ECip1KBveYUHfp+8e9klMJ9c=
 golang.org/x/net v0.30.0 h1:AcW1SDZMkb8IpzCdQUaIq2sP4sZ4zw+55h6ynffypl4=
 golang.org/x/net v0.30.0/go.mod h1:2wGyMJ5iFasEhkwi13ChkO/t1ECNC4X4eBKkVFyYFlU=
+golang.org/x/net v0.35.0 h1:T5GQRQb2y08kTAByq9L4/bz8cipCdA8FbRTXewonqY8=
+golang.org/x/net v0.35.0/go.mod h1:EglIi67kWsHKlRzzVMUD93VMSWGFOMSZgxFjparz1Qk=
 golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
+golang.org/x/sync v0.0.0-20220722155255-886fb9371eb4/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
 golang.org/x/sync v0.8.0 h1:3NFvSEYkUoMifnESzZl15y791HH1qU2xm6eCJU5ZPXQ=
 golang.org/x/sync v0.8.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk=
+golang.org/x/sync v0.11.0 h1:GGz8+XQP4FvTTrjZPzNKTMFtSXH80RAzG+5ghFPgK9w=
+golang.org/x/sync v0.11.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk=
 golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
 golang.org/x/sys v0.0.0-20190412213103-97732733099d/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20201119102817-f84b799fce68/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20210423082822-04245dca01da/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20210615035016-665e8c7367d1/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.0.0-20220520151302-bc2c85ada10a/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.0.0-20220722155257-8c9f86f7a55f/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.0.0-20220811171246-fbc7d0a398ab/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.28.0 h1:Fksou7UEQUWlKvIdsqzJmUmCX3cZuD2+P3XyyzwMhlA=
 golang.org/x/sys v0.28.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
+golang.org/x/sys v0.30.0 h1:QjkSwP/36a20jFYWkSue1YwXzLmsV5Gfq7Eiy72C1uc=
+golang.org/x/sys v0.30.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
+golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo=
+golang.org/x/term v0.0.0-20210927222741-03fcf44c2211/go.mod h1:jbD1KX2456YbFQfuXm/mYQcufACuNUgVhRMnK/tPxf8=
 golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
+golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
+golang.org/x/text v0.3.6/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
+golang.org/x/text v0.3.7/go.mod h1:u+2+/6zg+i71rQMx5EYifcz6MCKuco9NR6JIITiCfzQ=
+golang.org/x/text v0.3.8/go.mod h1:E6s5w1FMmriuDzIBO73fBruAKo1PCIq6d2Q6DHfQ8WQ=
+golang.org/x/text v0.7.0/go.mod h1:mrYo+phRRbMaCq/xk9113O4dZlRixOauAjOtrjsXDZ8=
 golang.org/x/text v0.19.0 h1:kTxAhCbGbxhK0IwgSKiMO5awPoDQ0RpfiVYBfK860YM=
 golang.org/x/text v0.19.0/go.mod h1:BuEKDfySbSR4drPmRPG/7iBdf8hvFMuRexcpahXilzY=
+golang.org/x/text v0.22.0 h1:bofq7m3/HAFvbF51jz3Q9wLg3jkvSPuiZu/pD1XwgtM=
+golang.org/x/text v0.22.0/go.mod h1:YRoo4H8PVmsu+E3Ou7cqLVH8oXWIHVoX0jqUWALQhfY=
+golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
 golang.org/x/tools v0.0.0-20190311212946-11955173bddd/go.mod h1:LCzVGOaR6xXOjkQ3onu1FJEFr0SW1gC7cKk1uF8kGRs=
 golang.org/x/tools v0.0.0-20190621195816-6e04913cbbac/go.mod h1:/rFqwRUd4F7ZHNgwSSTFct+R/Kf4OFW1sUzUTQQTgfc=
 golang.org/x/tools v0.0.0-20191029041327-9cc4af7d6b2c/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=
 golang.org/x/tools v0.0.0-20191029190741-b9c20aec41a5/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=
+golang.org/x/tools v0.0.0-20191119224855-298f0cb1881e/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=
+golang.org/x/tools v0.1.12/go.mod h1:hNGJHUnrk76NpqgfD5Aqm5Crs+Hm0VOH/i9J2+nxYbc=
 golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
-google.golang.org/genproto/googleapis/rpc v0.0.0-20240610135401-a8a62080eff3 h1:9Xyg6I9IWQZhRVfCWjKK+l6kI0jHcPesVlMnT//aHNo=
-google.golang.org/genproto/googleapis/rpc v0.0.0-20240610135401-a8a62080eff3/go.mod h1:EfXuqaE1J41VCDicxHzUDm+8rk+7ZdXzHV0IhO/I6s0=
-google.golang.org/grpc v1.64.0 h1:KH3VH9y/MgNQg1dE7b3XfVK0GsPSIzJwdF617gUSbvY=
-google.golang.org/grpc v1.64.0/go.mod h1:oxjF8E3FBnjp+/gVFYdWacaLDx9na1aqy9oovLpxQYg=
-google.golang.org/protobuf v1.34.2 h1:6xV6lTsCfpGD21XK49h7MhtcApnLqkfYgPcdHftf6hg=
-google.golang.org/protobuf v1.34.2/go.mod h1:qYOHts0dSfpeUzUFpOMr/WGzszTmLH+DiWniOlNbLDw=
+golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
+google.golang.org/genproto/googleapis/rpc v0.0.0-20250224174004-546df14abb99 h1:ZSlhAUqC4r8TPzqLXQ0m3upBNZeF+Y8jQ3c4CR3Ujms=
+google.golang.org/genproto/googleapis/rpc v0.0.0-20250224174004-546df14abb99/go.mod h1:LuRYeWDFV6WOn90g357N17oMCaxpgCnbi/44qJvDn2I=
+google.golang.org/grpc v1.70.0 h1:pWFv03aZoHzlRKHWicjsZytKAiYCtNS0dHbXnIdq7jQ=
+google.golang.org/grpc v1.70.0/go.mod h1:ofIJqVKDXx/JiXrwr2IG4/zwdH9txy3IlF40RmcJSQw=
+google.golang.org/protobuf v1.36.5 h1:tPhr+woSbjfYvY6/GPufUoYizxw1cF/yFoxJ2fmpwlM=
+google.golang.org/protobuf v1.36.5/go.mod h1:9fA7Ob0pmnwhb644+1+CVWFRbNajQ6iRojtC/QF5bRE=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
 gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
 gopkg.in/check.v1 v1.0.0-20190902080502-41f04d3bba15 h1:YR8cESwS4TdDjEe65xsg0ogRM/Nc3DYOhEAlW+xobZo=
@ -174,9 +271,9 @@ gopkg.in/tomb.v1 v1.0.0-20141024135613-dd632973f1e7 h1:uRGJdciOHaEIrze2W8Q3AKkep
 gopkg.in/tomb.v1 v1.0.0-20141024135613-dd632973f1e7/go.mod h1:dt/ZhP58zS4L8KSrWDmTeBkI65Dw0HsyUHuEVlX15mw=
 gopkg.in/tucnak/telebot.v2 v2.5.0 h1:i+NynLo443Vp+Zn3Gv9JBjh3Z/PaiKAQwcnhNI7y6Po=
 gopkg.in/tucnak/telebot.v2 v2.5.0/go.mod h1:BgaIIx50PSRS9pG59JH+geT82cfvoJU/IaI5TJdN3v8=
-gopkg.in/yaml.v2 v2.2.2/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
 gopkg.in/yaml.v2 v2.4.0 h1:D8xgwECY7CYvx+Y2n4sBz93Jn9JRvxdiyyo8CTfuKaY=
 gopkg.in/yaml.v2 v2.4.0/go.mod h1:RDklbk79AGWmwhnvt/jBztapEOGDOx6ZbXqjP6csGnQ=
+gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
 gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
 gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
 honnef.co/go/tools v0.0.1-2019.2.3/go.mod h1:a3bituU0lyd329TUQxRnasdCoJDkEUEAqEt0JzvZhAg=
--- a/internal/app/app.go
+++ b/internal/app/app.go
@ -0,0 +1,162 @@
+package app
+
+import (
+	"context"
+	"errors"
+	"gitea.pena/PenaSide/hlog"
+	"gitea.pena/PenaSide/trashlog/wrappers/zaptrashlog"
+	"gitea.pena/SQuiz/answerer/internal/clients"
+	"gitea.pena/SQuiz/answerer/internal/initialize"
+	"gitea.pena/SQuiz/answerer/internal/models"
+	savewc "gitea.pena/SQuiz/answerer/internal/savewc"
+	"gitea.pena/SQuiz/answerer/internal/server/http"
+	"gitea.pena/SQuiz/answerer/pkg/closer"
+	"gitea.pena/SQuiz/common/model"
+	"github.com/gofiber/fiber/v2/log"
+	"go.uber.org/zap"
+	"go.uber.org/zap/zapcore"
+	"time"
+)
+
+type Build struct {
+	Commit  string
+	Version string
+}
+
+var zapOptions = []zap.Option{
+	zap.AddCaller(),
+	zap.AddCallerSkip(2),
+	zap.AddStacktrace(zap.ErrorLevel),
+}
+
+func New(ctx context.Context, cfg initialize.Config, build Build) error {
+	var (
+		err       error
+		zapLogger *zap.Logger
+		errChan   = make(chan error)
+	)
+
+	defer func() {
+		if r := recover(); r != nil {
+			log.Error("Recovered from a panic", zap.Any("error", r))
+		}
+	}()
+
+	ctx, cancel := context.WithCancel(ctx)
+	defer cancel()
+
+	if cfg.LoggerProdMode {
+		zapLogger, err = zap.NewProduction(zapOptions...)
+		if err != nil {
+			return err
+		}
+	} else {
+		zapLogger, err = zap.NewDevelopment(zapOptions...)
+		if err != nil {
+			return err
+		}
+	}
+
+	zapLogger = zapLogger.With(
+		zap.String("SvcCommit", build.Commit),
+		zap.String("SvcVersion", build.Version),
+		zap.String("SvcBuildTime", time.Now().String()),
+	)
+
+	clickHouseLogger, err := zaptrashlog.NewCore(ctx, zap.InfoLevel, cfg.TrashLogHost, build.Version, build.Commit, time.Now().Unix())
+	if err != nil {
+		panic(err)
+	}
+
+	loggerForHlog := zapLogger.WithOptions(zap.WrapCore(func(core zapcore.Core) zapcore.Core {
+		return zapcore.NewTee(core, clickHouseLogger)
+	}))
+
+	loggerHlog := hlog.New(loggerForHlog).Module(initialize.ModuleLogger)
+	loggerHlog.With(models.AllFields{})
+	loggerHlog.Emit(InfoSvcStarted{})
+
+	shutdownGroup := closer.NewCloserGroup()
+
+	// Initialize minio client object.
+	minioClient, err := initialize.NewMinio(cfg)
+	if err != nil {
+		zapLogger.Error("failed to initialize minio client", zap.Error(err))
+		return err
+	}
+
+	dalS, err := initialize.NewDALs(ctx, cfg, minioClient)
+	if err != nil {
+		zapLogger.Error("failed to initialize dals", zap.Error(err))
+		return err
+	}
+
+	redisClient, err := initialize.Redis(ctx, cfg)
+	if err != nil {
+		zapLogger.Error("failed to initialize redis client", zap.Error(err))
+		return err
+	}
+
+	workerSendClientCh := make(chan model.Answer, 50)
+	workerRespondentCh := make(chan []model.Answer, 50)
+
+	saveRespWcData := savewc.DepsForResp{
+		WorkerRespondentCh: workerRespondentCh,
+		Redis:              redisClient,
+	}
+	saveClientWcData := savewc.DepsForClient{
+		WorkerSendClientCh: workerSendClientCh,
+		Redis:              redisClient,
+	}
+
+	saveRespWorker := savewc.NewSaveRespWorker(saveRespWcData, errChan, loggerHlog)
+	saveClientWorker := savewc.NewSaveClientWorker(saveClientWcData, errChan, loggerHlog)
+
+	go saveRespWorker.Start(ctx)
+	go saveClientWorker.Start(ctx)
+
+	controllers := initialize.NewControllers(initialize.ControllerDeps{
+		DALs:               dalS,
+		Config:             cfg,
+		RedisClient:        redisClient,
+		WorkerSendClientCh: workerSendClientCh,
+		WorkerRespondentCh: workerRespondentCh,
+		Encrypt:            &cfg.ExternalCfg.EncryptCommon,
+		AiClient:           clients.NewAiClient("https://alvatar.com/api/engine/send_answer/"),
+	})
+
+	srv := http.NewServer(http.ServerConfig{
+		Logger:      zapLogger,
+		Controllers: []http.Controller{controllers.HttpControllers.Common},
+		Hlogger:     loggerHlog,
+	})
+
+	go func() {
+		if err := srv.Start(cfg.ClientHttpURL); err != nil {
+			zapLogger.Error("HTTP server startup error", zap.Error(err))
+			cancel()
+		}
+	}()
+
+	srv.ListRoutes()
+	loggerHlog.Emit(InfoSvcReady{})
+
+	shutdownGroup.Add(closer.CloserFunc(srv.Shutdown))
+	shutdownGroup.Add(closer.CloserFunc(dalS.PgDAL.Close))
+
+	<-ctx.Done()
+
+	timeoutCtx, timeoutCancel := context.WithTimeout(context.Background(), 10*time.Second)
+	defer timeoutCancel()
+	if err := shutdownGroup.Call(timeoutCtx); err != nil {
+		if errors.Is(err, context.DeadlineExceeded) {
+			zapLogger.Error("Shutdown timed out", zap.Error(err))
+		} else {
+			zapLogger.Error("Failed to shutdown services gracefully", zap.Error(err))
+		}
+		return err
+	}
+
+	zapLogger.Info("Application has stopped")
+	return nil
+}
--- a/internal/app/logrecords.go
+++ b/internal/app/logrecords.go
--- a/internal/clients/aiClient.go
+++ b/internal/clients/aiClient.go
--- a/internal/clients/aiClient_test.go
+++ b/internal/clients/aiClient_test.go
--- a/internal/controllers/http_controllers/common/common.go
+++ b/internal/controllers/http_controllers/common/common.go
@ -1,55 +1,49 @@
-package service
+package common

 import (
 	"encoding/json"
 	"fmt"
+	"gitea.pena/PenaSide/common/encrypt"
 	"gitea.pena/PenaSide/common/log_mw"
-	"gitea.pena/SQuiz/answerer/clients"
-	"gitea.pena/SQuiz/answerer/dal"
-	"gitea.pena/SQuiz/answerer/models"
+	"gitea.pena/SQuiz/answerer/internal/clients"
+	"gitea.pena/SQuiz/answerer/internal/dal"
+	"gitea.pena/SQuiz/answerer/internal/models"
 	quizdal "gitea.pena/SQuiz/common/dal"
 	"gitea.pena/SQuiz/common/middleware"
 	"gitea.pena/SQuiz/common/model"
-	"gitea.pena/SQuiz/common/utils"
 	"github.com/gofiber/fiber/v2"
+	"github.com/rs/xid"
 	"net/url"
 	"strconv"
 	"strings"
 	"sync"
 	"time"
-
-	"github.com/rs/xid"
 )

-const (
-	quizIdCookie      = "qud"
-	fingerprintCookie = "fp"
-)
+type Deps struct {
+	Store              *dal.Storer
+	Dal                *quizdal.DAL
+	WorkerRespondentCh chan<- []model.Answer
+	WorkerSendClientCh chan<- model.Answer
+	Encrypt            *encrypt.Encrypt
+	RedirectURl        string
+	AiClient           *clients.AIClient
+}

-type Service struct {
+type Common struct {
 	store              *dal.Storer
 	dal                *quizdal.DAL
 	batch              []model.Answer
 	m                  sync.Mutex
 	workerRespondentCh chan<- []model.Answer
 	workerSendClientCh chan<- model.Answer
-	encrypt            *utils.Encrypt
+	encrypt            *encrypt.Encrypt
 	redirectURl        string
 	aiClient           *clients.AIClient
 }

-type ServiceDeps struct {
-	Store              *dal.Storer
-	Dal                *quizdal.DAL
-	WorkerRespondentCh chan<- []model.Answer
-	WorkerSendClientCh chan<- model.Answer
-	Encrypt            *utils.Encrypt
-	RedirectURl        string
-	AiClient           *clients.AIClient
-}
-
-func New(deps ServiceDeps) *Service {
-	return &Service{
+func NewCommonController(deps Deps) *Common {
+	return &Common{
 		store:              deps.Store,
 		dal:                deps.Dal,
 		m:                  sync.Mutex{},
@ -62,12 +56,10 @@ func New(deps ServiceDeps) *Service {
 	}
 }

-func (s *Service) Register(app *fiber.App) *fiber.App {
-	app.Post("/answer", s.PutAnswersOnePiece)
-	app.Post("/settings", s.GetQuizData)
-	app.Get("/logo", s.MiniPart)
-	return app
-}
+const (
+	quizIdCookie      = "qud"
+	fingerprintCookie = "fp"
+)

 // GetQuizDataReq request data for get data for user
 type GetQuizDataReq struct {
@ -111,7 +103,7 @@ type ShavedQuestion struct {
 }

 // GetQuizData handler for obtaining data for quiz front rendering
-func (s *Service) GetQuizData(c *fiber.Ctx) error {
+func (receiver *Common) GetQuizData(c *fiber.Ctx) error {
 	cs, ok := c.Context().Value(middleware.ContextKey(middleware.SessionKey)).(string)
 	if !ok {
 		return c.Status(fiber.StatusUnauthorized).SendString("no session in cookie")
@ -131,7 +123,7 @@ func (s *Service) GetQuizData(c *fiber.Ctx) error {
 		return c.Status(fiber.StatusLengthRequired).SendString("no data requested")
 	}

-	quiz, err := s.dal.QuizRepo.GetQuizByQid(c.Context(), req.QuizId)
+	quiz, err := receiver.dal.QuizRepo.GetQuizByQid(c.Context(), req.QuizId)
 	if err != nil {
 		return c.Status(fiber.StatusInternalServerError).SendString(err.Error())
 	}
@ -158,7 +150,7 @@ func (s *Service) GetQuizData(c *fiber.Ctx) error {
 		return c.Status(fiber.StatusGone).SendString("quiz timeouted")
 	}

-	account, err := s.dal.AccountRepo.GetAccountByID(c.Context(), quiz.AccountId)
+	account, err := receiver.dal.AccountRepo.GetAccountByID(c.Context(), quiz.AccountId)

 	if err != nil {
 		return c.Status(fiber.StatusInternalServerError).SendString("can`t get account by quiz.AccountId")
@ -178,12 +170,12 @@ func (s *Service) GetQuizData(c *fiber.Ctx) error {
 	var cnt uint64

 	if quiz.Status == model.StatusAI {
-		questions, cnt, err = s.dal.QuestionRepo.GetQuestionsAI(c.Context(), int64(quiz.Id), cs, int32(req.Limit), int32(req.Page*req.Limit), req.Auditory)
+		questions, cnt, err = receiver.dal.QuestionRepo.GetQuestionsAI(c.Context(), int64(quiz.Id), cs, int32(req.Limit), int32(req.Page*req.Limit), req.Auditory)
 		if err != nil {
 			return c.Status(fiber.StatusInternalServerError).SendString(err.Error())
 		}
 	} else {
-		questions, cnt, err = s.dal.QuestionRepo.GetQuestionList(
+		questions, cnt, err = receiver.dal.QuestionRepo.GetQuestionList(
 			c.Context(),
 			req.Limit,
 			req.Page*req.Limit,
@ -250,7 +242,7 @@ func (s *Service) GetQuizData(c *fiber.Ctx) error {
 			return c.Status(fiber.StatusNotFound).SendString("question not found")
 		}

-		answers, errs := s.dal.AnswerRepo.CreateAnswers(c.Context(), []model.Answer{{
+		answers, errs := receiver.dal.AnswerRepo.CreateAnswers(c.Context(), []model.Answer{{
 			Content:    "start",
 			QuestionId: questions[0].Id,
 			QuizId:     quiz.Id,
@ -328,7 +320,7 @@ type PutAnswersResponse struct {
 // todo не отдавать ответы с типом start но сохранять брать из контента ответа
 // поле бул также в GetQuizdata не отдавать его, но по запросам идет GetQuizdata получаем данные квиза
 // аотом отправляем ответы в PutAnswers и сохраяняем их подумать как делать
-func (s *Service) PutAnswersOnePiece(c *fiber.Ctx) error {
+func (receiver *Common) PutAnswersOnePiece(c *fiber.Ctx) error {
 	cs, ok := c.Context().Value(middleware.ContextKey(middleware.SessionKey)).(string)
 	if !ok {
 		return c.Status(fiber.StatusUnauthorized).SendString("no session in cookie")
@ -382,7 +374,7 @@ func (s *Service) PutAnswersOnePiece(c *fiber.Ctx) error {
 		fp = cfp
 	}

-	quiz, err := s.dal.QuizRepo.GetQuizByQid(c.Context(), quizID[0])
+	quiz, err := receiver.dal.QuizRepo.GetQuizByQid(c.Context(), quizID[0])
 	if err != nil {
 		return c.Status(fiber.StatusInternalServerError).SendString("can not get quiz")
 	}
@ -401,7 +393,7 @@ func (s *Service) PutAnswersOnePiece(c *fiber.Ctx) error {
 				final = parsedFinal
 			}

-			question, err := s.dal.QuestionRepo.GetQuestionListByIDs(c.Context(), []int32{int32(ans.QuestionId)})
+			question, err := receiver.dal.QuestionRepo.GetQuestionListByIDs(c.Context(), []int32{int32(ans.QuestionId)})
 			if err != nil {
 				return c.Status(fiber.StatusInternalServerError).SendString("can not get questions")
 			}
@ -410,12 +402,12 @@ func (s *Service) PutAnswersOnePiece(c *fiber.Ctx) error {
 				return c.Status(fiber.StatusNotFound).SendString("no questions found")
 			}

-			questionText, err := s.aiClient.SendAnswerer(final, question[0].Type, ans.Content, cs)
+			questionText, err := receiver.aiClient.SendAnswerer(final, question[0].Type, ans.Content, cs)
 			if err != nil {
 				return c.Status(fiber.StatusInternalServerError).SendString(fmt.Sprintf("failed send answer to ai, err: %s", err.Error()))
 			}

-			_, err = s.dal.QuestionRepo.CreateQuestion(c.Context(), &model.Question{
+			_, err = receiver.dal.QuestionRepo.CreateQuestion(c.Context(), &model.Question{
 				QuizId:      quiz.Id,
 				Title:       " ",
 				Type:        model.TypeText,
@ -451,7 +443,7 @@ func (s *Service) PutAnswersOnePiece(c *fiber.Ctx) error {
 			}

 			fname := fmt.Sprintf("%s.%s", xid.New().String(), filetail)
-			if err := s.store.PutAnswer(c.Context(), r, quizID[0], fname, ans.QuestionId, fileparts[0].Size); err != nil {
+			if err := receiver.store.PutAnswer(c.Context(), r, quizID[0], fname, ans.QuestionId, fileparts[0].Size); err != nil {
 				return c.Status(fiber.StatusInternalServerError).SendString("can not upload file answers")
 			}
 			ans.Content = fname
@ -484,7 +476,7 @@ func (s *Service) PutAnswersOnePiece(c *fiber.Ctx) error {
 				CtxSession:    cs,
 			})

-			s.workerSendClientCh <- ans
+			receiver.workerSendClientCh <- ans
 			trueRes = append(trueRes, ans)
 		}
 	}
@ -496,10 +488,10 @@ func (s *Service) PutAnswersOnePiece(c *fiber.Ctx) error {
 	}

 	if quizConfig.Mailing.When == "email" && len(trueRes) > 0 {
-		s.workerRespondentCh <- trueRes
+		receiver.workerRespondentCh <- trueRes
 	}

-	stored, ers := s.dal.AnswerRepo.CreateAnswers(c.Context(), answers, cs, fp, quiz.Id)
+	stored, ers := receiver.dal.AnswerRepo.CreateAnswers(c.Context(), answers, cs, fp, quiz.Id)
 	if len(ers) != 0 {
 		for _, err := range ers {
 			if strings.Contains(err.Error(), "duplicate key value") {
@ -549,7 +541,7 @@ func (s *Service) PutAnswersOnePiece(c *fiber.Ctx) error {
 	return c.Status(fiber.StatusOK).JSON(response)
 }

-func (s *Service) MiniPart(ctx *fiber.Ctx) error {
+func (receiver *Common) MiniPart(ctx *fiber.Ctx) error {
 	qid := ctx.Query("q")
 	if qid == "" {
 		return ctx.Status(fiber.StatusBadRequest).SendString("qid is nil")
@ -559,12 +551,12 @@ func (s *Service) MiniPart(ctx *fiber.Ctx) error {
 		Value: qid,
 	})

-	userID, err := s.dal.AccountRepo.GetQidOwner(ctx.Context(), qid)
+	userID, err := receiver.dal.AccountRepo.GetQidOwner(ctx.Context(), qid)
 	if err != nil {
 		return ctx.Status(fiber.StatusInternalServerError).SendString(err.Error())
 	}

-	shifr, err := s.encrypt.EncryptStr(userID)
+	shifr, err := receiver.encrypt.EncryptStr(userID)
 	if err != nil {
 		return ctx.Status(fiber.StatusInternalServerError).SendString(err.Error())
 	}
@ -574,5 +566,5 @@ func (s *Service) MiniPart(ctx *fiber.Ctx) error {
 		Value: url.QueryEscape(string(shifr)),
 	})

-	return ctx.Redirect(s.redirectURl, fiber.StatusFound)
+	return ctx.Redirect(receiver.redirectURl, fiber.StatusFound)
 }
--- a/internal/controllers/http_controllers/common/route.go
+++ b/internal/controllers/http_controllers/common/route.go
@ -0,0 +1,13 @@
+package common
+
+import "github.com/gofiber/fiber/v2"
+
+func (receiver *Common) Register(router fiber.Router) {
+	router.Post("/answer", receiver.PutAnswersOnePiece)
+	router.Post("/settings", receiver.GetQuizData)
+	router.Get("/logo", receiver.MiniPart)
+}
+
+func (receiver *Common) Name() string {
+	return ""
+}
--- a/internal/dal/dal.go
+++ b/internal/dal/dal.go
@ -8,7 +8,7 @@ import (
 )

 const (
-	bucket = "3c580be9-cf31f296-d055-49cf-b39e-30c7959dc17b"
+	Bucket        = "3c580be9-cf31f296-d055-49cf-b39e-30c7959dc17b"
 	bucketAnswers = "squizanswer"
 )

@ -23,7 +23,7 @@ func New(ctx context.Context, minioClient *minio.Client) (*Storer, error) {
 }

 func (s *Storer) PutAnswer(ctx context.Context, file io.Reader, quizId, name string, question uint64, size int64) error {
-	if _, err := s.client.PutObject(ctx, bucket, bucketAnswers + "/" +fmt.Sprintf("%s/%d/%s", quizId, question, name), file, size,
+	if _, err := s.client.PutObject(ctx, Bucket, bucketAnswers+"/"+fmt.Sprintf("%s/%d/%s", quizId, question, name), file, size,
 		minio.PutObjectOptions{}); err != nil {
 		return err
 	}
--- a/internal/initialize/config.go
+++ b/internal/initialize/config.go
@ -0,0 +1,43 @@
+package initialize
+
+import (
+	"gitea.pena/PenaSide/common/encrypt"
+	"github.com/caarlos0/env/v8"
+	"github.com/joho/godotenv"
+	"log"
+)
+
+type Config struct {
+	LoggerProdMode bool   `env:"IS_PROD_LOG" envDefault:"false"`
+	IsProd         bool   `env:"IS_PROD" envDefault:"false"`
+	S3Endpoint     string `env:"S3_ENDPOINT" envDefault:"localhost:9005"`
+	S3AccessKey    string `env:"S3_ACCESS_KEY" envDefault:"admin"`
+	S3SecretKey    string `env:"S3_SECRET_KEY" envDefault:"admin123"`
+	ClientHttpURL  string `env:"CLIENT_HTTP_URL" envDefault:"0.0.0.0:1490"`
+	CrtFile        string `env:"CRT" envDefault:"server.crt"`
+	KeyFile        string `env:"KEY" envDefault:"server.key"`
+	PostgresURL    string `env:"POSTGRES_URL" envDefault:"host=localhost port=35432 user=squiz password=Redalert2 dbname=squiz sslmode=disable"`
+	RedisHost      string `env:"REDIS_HOST" envDefault:"localhost:6379"`
+	RedisPassword  string `env:"REDIS_PASSWORD" envDefault:"admin"`
+	RedisDB        uint64 `env:"REDIS_DB" envDefault:"2"`
+	RedirectURL    string `env:"REDIRECT_URL" envDefault:"https://squiz.pena.digital"`
+	TrashLogHost   string `env:"TRASH_LOG_HOST" envDefault:"localhost:7113"`
+	ExternalCfg    ExternalCfg
+}
+
+type ExternalCfg struct {
+	EncryptCommon encrypt.Encrypt
+}
+
+func LoadConfig() (*Config, error) {
+	if err := godotenv.Load(); err != nil {
+		log.Print("No .env file found")
+	}
+	var config Config
+	if err := env.Parse(&config); err != nil {
+		return nil, err
+	}
+	return &config, nil
+}
+
+const ModuleLogger = "answerer"
--- a/internal/initialize/controllers.go
+++ b/internal/initialize/controllers.go
@ -0,0 +1,43 @@
+package initialize
+
+import (
+	"gitea.pena/PenaSide/common/encrypt"
+	"gitea.pena/SQuiz/answerer/internal/clients"
+	"gitea.pena/SQuiz/answerer/internal/controllers/http_controllers/common"
+	"gitea.pena/SQuiz/common/model"
+	"github.com/go-redis/redis/v8"
+)
+
+type ControllerDeps struct {
+	DALs               *DALs
+	Config             Config
+	RedisClient        *redis.Client
+	WorkerRespondentCh chan<- []model.Answer
+	WorkerSendClientCh chan<- model.Answer
+	Encrypt            *encrypt.Encrypt
+	AiClient           *clients.AIClient
+}
+
+type Controller struct {
+	HttpControllers HttpControllers
+}
+
+type HttpControllers struct {
+	Common *common.Common
+}
+
+func NewControllers(deps ControllerDeps) *Controller {
+	return &Controller{
+		HttpControllers: HttpControllers{
+			Common: common.NewCommonController(common.Deps{
+				Store:              deps.DALs.BlobStore,
+				Dal:                deps.DALs.PgDAL,
+				WorkerRespondentCh: deps.WorkerRespondentCh,
+				WorkerSendClientCh: deps.WorkerSendClientCh,
+				Encrypt:            deps.Encrypt,
+				RedirectURl:        deps.Config.RedirectURL,
+				AiClient:           deps.AiClient,
+			}),
+		},
+	}
+}
--- a/internal/initialize/dals.go
+++ b/internal/initialize/dals.go
@ -0,0 +1,30 @@
+package initialize
+
+import (
+	"context"
+	dalBS "gitea.pena/SQuiz/answerer/internal/dal"
+	"gitea.pena/SQuiz/common/dal"
+	"github.com/minio/minio-go/v7"
+)
+
+type DALs struct {
+	PgDAL     *dal.DAL
+	BlobStore *dalBS.Storer
+}
+
+func NewDALs(ctx context.Context, cfg Config, minioClient *minio.Client) (*DALs, error) {
+	pgDAL, err := dal.New(ctx, cfg.PostgresURL, minioClient)
+	if err != nil {
+		return nil, err
+	}
+
+	blobStore, err := dalBS.New(ctx, minioClient)
+	if err != nil {
+		return nil, err
+	}
+
+	return &DALs{
+		PgDAL:     pgDAL,
+		BlobStore: blobStore,
+	}, nil
+}
--- a/internal/initialize/minio.go
+++ b/internal/initialize/minio.go
@ -0,0 +1,17 @@
+package initialize
+
+import (
+	"github.com/minio/minio-go/v7"
+	"github.com/minio/minio-go/v7/pkg/credentials"
+)
+
+func NewMinio(cfg Config) (*minio.Client, error) {
+	minioClient, err := minio.New(cfg.S3Endpoint, &minio.Options{
+		Creds:  credentials.NewStaticV4(cfg.S3AccessKey, cfg.S3SecretKey, ""),
+		Secure: cfg.IsProd,
+	})
+	if err != nil {
+		return nil, err
+	}
+	return minioClient, nil
+}
--- a/internal/initialize/redis.go
+++ b/internal/initialize/redis.go
@ -0,0 +1,21 @@
+package initialize
+
+import (
+	"context"
+	"github.com/go-redis/redis/v8"
+)
+
+func Redis(ctx context.Context, cfg Config) (*redis.Client, error) {
+	rdb := redis.NewClient(&redis.Options{
+		Addr:     cfg.RedisHost,
+		Password: cfg.RedisPassword,
+		DB:       int(cfg.RedisDB),
+	})
+
+	status := rdb.Ping(ctx)
+	if err := status.Err(); err != nil {
+		return nil, err
+	}
+
+	return rdb, nil
+}
--- a/internal/models/hlog_events.go
+++ b/internal/models/hlog_events.go
--- a/internal/savewc/for_client.go
+++ b/internal/savewc/for_client.go
--- a/internal/savewc/for_respondent.go
+++ b/internal/savewc/for_respondent.go
--- a/internal/server/http/http_server.go
+++ b/internal/server/http/http_server.go
@ -0,0 +1,73 @@
+package http
+
+import (
+	"context"
+	"fmt"
+	"gitea.pena/PenaSide/common/log_mw"
+	"gitea.pena/PenaSide/hlog"
+	"gitea.pena/SQuiz/common/middleware"
+	"github.com/gofiber/fiber/v2"
+	"go.uber.org/zap"
+)
+
+type ServerConfig struct {
+	Logger      *zap.Logger
+	Controllers []Controller
+	Hlogger     hlog.Logger
+}
+
+type Server struct {
+	Logger      *zap.Logger
+	Controllers []Controller
+	app         *fiber.App
+}
+
+func NewServer(config ServerConfig) *Server {
+	app := fiber.New(fiber.Config{BodyLimit: 70 * 1024 * 1024})
+	app.Use(middleware.AnswererChain())
+	app.Use(log_mw.ContextLogger(config.Hlogger))
+	//app.Get("/liveness", healthchecks.Liveness)
+	//app.Get("/readiness", healthchecks.Readiness(&workerErr)) //todo parametrized readiness. should discuss ready reason
+	s := &Server{
+		Logger:      config.Logger,
+		Controllers: config.Controllers,
+		app:         app,
+	}
+
+	s.registerRoutes()
+
+	return s
+}
+
+func (s *Server) Start(addr string) error {
+	if err := s.app.Listen(addr); err != nil {
+		s.Logger.Error("Failed to start server", zap.Error(err))
+		return err
+	}
+	return nil
+}
+
+func (s *Server) Shutdown(ctx context.Context) error {
+	return s.app.Shutdown()
+}
+
+func (s *Server) registerRoutes() {
+	for _, c := range s.Controllers {
+		router := s.app.Group(c.Name())
+		c.Register(router)
+	}
+}
+
+type Controller interface {
+	Register(router fiber.Router)
+	Name() string
+}
+
+func (s *Server) ListRoutes() {
+	fmt.Println("Registered routes:")
+	for _, stack := range s.app.Stack() {
+		for _, route := range stack {
+			fmt.Printf("%s %s\n", route.Method, route.Path)
+		}
+	}
+}
--- a/main.go
+++ b/main.go
@ -1,10 +0,0 @@
-package main
-
-import (
-	"gitea.pena/SQuiz/answerer/app"
-	"github.com/skeris/appInit"
-)
-
-func main() {
-	appInit.Initialize(app.New, app.Options{})
-}
--- a/pkg/closer/closer.go
+++ b/pkg/closer/closer.go
@ -0,0 +1,37 @@
+package closer
+
+import (
+	"context"
+)
+
+type Closer interface {
+	Close(ctx context.Context) error
+}
+
+type CloserFunc func(ctx context.Context) error
+
+func (cf CloserFunc) Close(ctx context.Context) error {
+	return cf(ctx)
+}
+
+type CloserGroup struct {
+	closers []Closer
+}
+
+func NewCloserGroup() *CloserGroup {
+	return &CloserGroup{}
+}
+
+func (cg *CloserGroup) Add(c Closer) {
+	cg.closers = append(cg.closers, c)
+}
+
+func (cg *CloserGroup) Call(ctx context.Context) error {
+	var closeErr error
+	for i := len(cg.closers) - 1; i >= 0; i-- {
+		if err := cg.closers[i].Close(ctx); err != nil && closeErr == nil {
+			closeErr = err
+		}
+	}
+	return closeErr
+}
Author	SHA1	Message	Date
pasha1coil	67deb74ffc	drop main app, upd fixlayout app	2025-06-30 11:29:58 +03:00
pasha1coil	de034e1ffa	update with main	2025-06-30 11:16:09 +03:00
Pasha	ba7603f45e	added validate	2025-02-25 17:07:46 +03:00
Pasha	fd5cc4484c	use external cfg for encrypt	2025-02-25 16:30:14 +03:00
Pasha	7c0eb873b0	optimize cfg	2025-02-24 21:38:49 +03:00
Pasha	b52103bf63	applied renamer	2025-02-24 21:11:05 +03:00
Pavel	e2386df0ad	fix layout	2024-11-01 15:23:11 +03:00
Pavel	ee87358441	fix layout	2024-11-01 15:11:17 +03:00