From 8df3679e6fedad06446a31a95da9483a6646f6af Mon Sep 17 00:00:00 2001 From: maximo tejeda Date: Sun, 23 Feb 2025 10:00:15 -0400 Subject: [PATCH] ADD root dir to main --- cmd/bot/main.go | 36 +++++++++++++++++++++++++----------- 1 file changed, 25 insertions(+), 11 deletions(-) diff --git a/cmd/bot/main.go b/cmd/bot/main.go index daee055..a75e8c8 100644 --- a/cmd/bot/main.go +++ b/cmd/bot/main.go @@ -10,6 +10,7 @@ import ( "git.maximotejeda.com/maximo/telegram-base-bot/config" "git.maximotejeda.com/maximo/telegram-base-bot/internal/adapters/grpc/tgbuser" "git.maximotejeda.com/maximo/telegram-base-bot/internal/application/commands" + "git.maximotejeda.com/maximo/telegram-base-bot/internal/application/helpers" "git.maximotejeda.com/maximo/telegram-base-bot/internal/application/messages" "git.maximotejeda.com/maximo/telegram-base-bot/internal/application/middlewares" "git.maximotejeda.com/maximo/telegram-base-bot/internal/application/queries" @@ -19,24 +20,33 @@ import ( "google.golang.org/grpc/credentials/insecure" ) - var log *slog.Logger func main() { - lvelEnv:= config.GetEnvironment() + lvelEnv := config.GetEnvironment() var lvel slog.Level - if lvelEnv == "dev" || lvelEnv == "development"{ + if lvelEnv == "dev" || lvelEnv == "development" { lvel = slog.LevelDebug - }else { + } else { lvel = slog.LevelInfo } log = slog.New(slog.NewJSONHandler(os.Stderr, &slog.HandlerOptions{ AddSource: true, - Level: lvel, + Level: lvel, })) - + ctx, cancel := signal.NotifyContext(context.Background(), os.Interrupt) defer cancel() + + // a folder will be mounted and save dirs will be created on them + // assets for the bot + // assets sent from users for temp use + r, err := helpers.OpenBotDir(ctx, log, nil, "bot_media/", 0777) + if err != nil { + panic(err) + } + defer r.Close() + userSVC, conn := CreateAdaptersGRPC() defer conn.Close() authRequired := middlewares.SetAuthRequired(userSVC, log) @@ -51,17 +61,16 @@ func main() { "callback_query", "id", }), - // bot.WithDefaultHandler(api.Handler), } b, err := bot.New(config.GetToken(), opts...) if err != nil { panic(err) } - bInfo , err := b.GetMe(ctx) + bInfo, err := b.GetMe(ctx) if err != nil { panic(err) } - + // attempt to add bot to db err = userSVC.CreateBot(bInfo.Username) if err != nil { @@ -71,11 +80,16 @@ func main() { panic(err) } } - + commands.RegisterCommands(ctx, log, b) messages.RegisterMessageHandler(ctx, log, b) queries.RegisterQueries(ctx, log, b) messages.RegisterMessageReactionHandler(ctx, log, b) + messages.RegisterLocationHandler(ctx, log, b) + messages.RegisterVoiceHandler(ctx, log, b, r) + messages.RegisterDocumentHandler(ctx, log, b, r) + messages.RegisterPhotosHandler(ctx, log, b, r) + b.Start(ctx) } @@ -99,6 +113,6 @@ func CreateAdaptersGRPC() (ports.UserService, *grpc.ClientConn) { log.Error("creating service adapter", "error", err) panic(err) } - log.Info("success creating svc ", "error", err) + log.Info("success creating svc ", "error", err) return user, userConn }