ADD root dir to main

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
 }