Done.

cmd/fsb/run.go

@@ -17,16 +17,17 @@ import (
 	"go.uber.org/zap"
 )
 
-var runCmd = &cobra.Command{
-	Use:                "run",
-	Short:              "Run the bot with the given configuration.",
-	DisableSuggestions: false,
-	Run:                runApp,
-}
-
-var startTime time.Time = time.Now()
+var (
+	runCmd = &cobra.Command{
+		Use:                "run",
+		Short:              "Run the bot with the given configuration.",
+		DisableSuggestions: false,
+		Run:                runApp,
+	}
+	startTime = time.Now()
+)
 
-func runApp(cmd *cobra.Command, args []string) {
+func runApp(cmd *cobra.Command, _ []string) {
 	utils.InitLogger()
 	log := utils.Logger
 	mainLogger := log.Named("Main")

cmd/fsb/session.go

@@ -23,7 +23,7 @@ func init() {
 	sessionCmd.MarkFlagRequired("api-hash")
 }
 
-func generateSession(cmd *cobra.Command, args []string) {
+func generateSession(cmd *cobra.Command, _ []string) {
 	loginType, _ := cmd.Flags().GetString("login-type")
 	apiId, _ := cmd.Flags().GetInt32("api-id")
 	apiHash, _ := cmd.Flags().GetString("api-hash")

config/config.go

@@ -14,24 +14,25 @@ import (
 	"go.uber.org/zap"
 )
 
-var ValueOf = &config{}
+var (
+	ValueOf       = &config{}
+	botTokenRegex = regexp.MustCompile(`MULTI_TOKEN\d+=(.*)`)
+)
 
 type config struct {
-	ApiID          int32  `envconfig:"API_ID" required:"true"`
-	ApiHash        string `envconfig:"API_HASH" required:"true"`
-	BotToken       string `envconfig:"BOT_TOKEN" required:"true"`
-	LogChannelID   int64  `envconfig:"LOG_CHANNEL" required:"true"`
-	Dev            bool   `envconfig:"DEV" default:"false"`
-	Port           int    `envconfig:"PORT" default:"8080"`
-	Host           string `envconfig:"HOST" default:"http://localhost:8080"`
-	HashLength     int    `envconfig:"HASH_LENGTH" default:"6"`
-	UseSessionFile bool   `envconfig:"USE_SESSION_FILE" default:"true"`
-	UserSession    string `envconfig:"USER_SESSION"`
-	MultiTokens    []string
+	Dev            bool     `envconfig:"DEV" default:"false"`
+	UseSessionFile bool     `envconfig:"USE_SESSION_FILE" default:"true"`
+	ApiID          int32    `envconfig:"API_ID" required:"true"`
+	HashLength     int      `envconfig:"HASH_LENGTH" default:"6"`
+	Port           int      `envconfig:"PORT" default:"8080"`
+	ApiHash        string   `envconfig:"API_HASH" required:"true"`
+	UserSession    string   `envconfig:"USER_SESSION"`
+	BotToken       string   `envconfig:"BOT_TOKEN" required:"true"`
+	LogChannelID   int64    `envconfig:"LOG_CHANNEL" required:"true"`
+	MultiTokens    []string `envconfig:"MULTI_TOKENS"`
+	Host           string   `envconfig:"HOST" default:"http://localhost:8080"`
 }
 
-var botTokenRegex = regexp.MustCompile(`MULTI\_TOKEN\d+=(.*)`)
-
 func (c *config) loadFromEnvFile(log *zap.Logger) {
 	envPath := filepath.Clean("fsb.env")
 	log.Sugar().Infof("Trying to load ENV vars from %s", envPath)

go.mod

@@ -1,6 +1,6 @@
 module EverythingSuckz/fsb
 
-go 1.21.3
+go 1.21.5
 
 require (
 	github.com/celestix/gotgproto v1.0.0-beta13.0.20231201105236-366763b5cc2e

internal/bot/middleware.go

@@ -10,7 +10,7 @@ import (
 	"golang.org/x/time/rate"
 )
 
-func GetFloodMiddleware(log *zap.Logger) []telegram.Middleware {
+func GetFloodMiddleware(_ *zap.Logger) []telegram.Middleware {
 	waiter := floodwait.NewSimpleWaiter().WithMaxRetries(10)
 	ratelimiter := ratelimit.New(rate.Every(time.Millisecond*100), 5)
 	return []telegram.Middleware{

internal/bot/userbot.go

@@ -15,7 +15,7 @@ type UserBotStruct struct {
 	client *gotgproto.Client
 }
 
-var UserBot *UserBotStruct = &UserBotStruct{}
+var UserBot = &UserBotStruct{}
 
 func StartUserBot(l *zap.Logger) {
 	log := l.Named("USERBOT")
@@ -42,7 +42,7 @@ func StartUserBot(l *zap.Logger) {
 	UserBot.log = log
 	UserBot.client = client
 	log.Info("Userbot started", zap.String("username", client.Self.Username), zap.String("FirstName", client.Self.FirstName), zap.String("LastName", client.Self.LastName))
-	if err := UserBot.AddBotsAsAdmins(); err != nil {
+	if err = UserBot.AddBotsAsAdmins(); err != nil {
 		log.Error("Failed to add bots as admins", zap.Error(err))
 		return
 	}
@@ -68,7 +68,7 @@ func (u *UserBotStruct) AddBotsAsAdmins() error {
 		return errors.New("no channels found")
 	}
 	inputChannel := channelInfos.GetChats()[0].(*tg.Channel).AsInput()
-	currentAdmins := []int64{}
+	var currentAdmins []int64
 	admins, err := u.client.API().ChannelsGetParticipants(ctx, &tg.ChannelsGetParticipantsRequest{
 		Channel: inputChannel,
 		Filter:  &tg.ChannelParticipantsAdmins{},

internal/bot/workers.go

@@ -35,7 +35,7 @@ type BotWorkers struct {
 	log      *zap.Logger
 }
 
-var Workers *BotWorkers = &BotWorkers{
+var Workers = &BotWorkers{
 	log:  nil,
 	Bots: make([]*Worker, 0),
 }
@@ -66,7 +66,7 @@ func (w *BotWorkers) incStarting() {
 
 func (w *BotWorkers) Add(token string) (err error) {
 	w.incStarting()
-	var botID int = w.starting
+	var botID = w.starting
 	client, err := startWorker(w.log, token, botID)
 	if err != nil {
 		return err

internal/cache/cache.go

@@ -51,12 +51,10 @@ func (c *Cache) Set(key string, value *types.File, expireSeconds int) error {
 	defer c.mu.Unlock()
 	var buf bytes.Buffer
 	enc := gob.NewEncoder(&buf)
-	err := enc.Encode(value)
-	if err != nil {
+	if err := enc.Encode(value); err != nil {
 		return err
 	}
-	cache.cache.Set([]byte(key), buf.Bytes(), expireSeconds)
-	return nil
+	return cache.cache.Set([]byte(key), buf.Bytes(), expireSeconds)
 }
 
 func (c *Cache) Delete(key string) error {

internal/routes/stream.go

@@ -8,7 +8,7 @@ import (
 	"net/http"
 	"strconv"
 
-	range_parser "github.com/quantumsheep/range-parser"
+	rangeparser "github.com/quantumsheep/range-parser"
 	"go.uber.org/zap"
 
 	"github.com/gin-gonic/gin"
@@ -67,7 +67,7 @@ func getStreamRoute(ctx *gin.Context) {
 		end = file.FileSize - 1
 		w.WriteHeader(http.StatusOK)
 	} else {
-		ranges, err := range_parser.Parse(file.FileSize, r.Header.Get("Range"))
+		ranges, err := rangeparser.Parse(file.FileSize, r.Header.Get("Range"))
 		if err != nil {
 			http.Error(w, err.Error(), http.StatusBadRequest)
 			return
@@ -103,7 +103,7 @@ func getStreamRoute(ctx *gin.Context) {
 			return
 		}
 		lr, _ := utils.NewTelegramReader(ctx, worker.Client, file.Location, start, end, contentLength)
-		if _, err := io.CopyN(w, lr, contentLength); err != nil {
+		if _, err = io.CopyN(w, lr, contentLength); err != nil {
 			log.Error("Error while copying stream", zap.Error(err))
 		}
 	}

internal/types/file.go

@@ -10,11 +10,11 @@ import (
 )
 
 type File struct {
-	Location *tg.InputDocumentFileLocation
+	ID       int64
 	FileSize int64
 	FileName string
 	MimeType string
-	ID       int64
+	Location *tg.InputDocumentFileLocation
 }
 
 type HashableFileStruct struct {