Fixed some bugs caused from gofumpt

TUM-Dev · Jan 11, 2024 · 033666d · 033666d
1 parent f4552ba
commit 033666d
Show file tree

Hide file tree

Showing 11 changed files with 15 additions and 17 deletions.
diff --git a/api/worker_grpc.go b/api/worker_grpc.go
@@ -882,7 +882,7 @@ func getLivePreviewFromWorker(s *model.Stream, workerID string, client pb.ToWork
 		return err
 	}
 
-	if err := os.MkdirAll(pathprovider.TUMLiveTemporary, 0o750); err != nil {
+	if err := os.MkdirAll(pathprovider.TUMLiveTemporary, 0750); err != nil {
 		return err
 	}
 

diff --git a/cmd/modelGen/modelGen.go b/cmd/modelGen/modelGen.go
@@ -28,7 +28,7 @@ func main() {
 	}
 
 	fmt.Println("Generating model...")
-	model_file, err := os.OpenFile(fmt.Sprintf("model/%s.go", d.NamePrivate), os.O_WRONLY|os.O_CREATE, 0o644)
+	model_file, err := os.OpenFile(fmt.Sprintf("model/%s.go", d.NamePrivate), os.O_WRONLY|os.O_CREATE, 0644)
 	if err != nil {
 		fmt.Println(err)
 		os.Exit(1)
@@ -46,7 +46,7 @@ func main() {
 
 	fmt.Println("Generating dao...")
 
-	dao_file, err := os.OpenFile(fmt.Sprintf("dao/%s.go", d.NamePrivate), os.O_WRONLY|os.O_CREATE, 0o644)
+	dao_file, err := os.OpenFile(fmt.Sprintf("dao/%s.go", d.NamePrivate), os.O_WRONLY|os.O_CREATE, 0644)
 	if err != nil {
 		fmt.Println(err)
 		os.Exit(1)

diff --git a/tools/config.go b/tools/config.go
@@ -15,10 +15,8 @@ import (
 	"github.com/spf13/viper"
 )
 
-var (
-	Cfg Config
-	Loc *time.Location
-)
+var Cfg Config
+var Loc *time.Location
 
 func LoadConfig() {
 	initCache()

diff --git a/worker/cfg/cfg.go b/worker/cfg/cfg.go
@@ -77,11 +77,11 @@ func SetConfig() {
 	if PersistDir == "" {
 		PersistDir = "."
 	}
-	err := os.MkdirAll(PersistDir, 0o755)
+	err := os.MkdirAll(PersistDir, 0755)
 	if err != nil {
 		log.Error(err)
 	}
-	err = os.MkdirAll(LogDir, 0o755)
+	err = os.MkdirAll(LogDir, 0755)
 	if err != nil {
 		log.Warn("Could not create log directory: ", err)
 	}

diff --git a/worker/edge/edge.go b/worker/edge/edge.go
@@ -374,7 +374,7 @@ func fetchFile(host, file string) error {
 		return fmt.Errorf("parse file path: %s", file)
 	}
 	d := filepath.Dir(diskDir)
-	err = os.MkdirAll(d, 0o755)
+	err = os.MkdirAll(d, 0755)
 	if err != nil {
 		return err
 	}

diff --git a/worker/worker/persist.go b/worker/worker/persist.go
@@ -26,7 +26,7 @@ const persistFileName = "/persist.gob"
 
 // writeOut writes out the persistable object to disk
 func (p *Persistable) writeOut() error {
-	f, err := os.OpenFile(cfg.PersistDir+persistFileName, os.O_RDWR|os.O_CREATE, 0o666)
+	f, err := os.OpenFile(cfg.PersistDir+persistFileName, os.O_RDWR|os.O_CREATE, 0666)
 	if err != nil {
 		return err
 	}

diff --git a/worker/worker/premiere.go b/worker/worker/premiere.go
@@ -20,7 +20,7 @@ func streamPremiere(ctx *StreamContext) {
 		"-acodec", "aac", "-b:a", "128k", "-ac", "2", "-ar", "48000", "-af", "aresample=async=1:min_hard_comp=0.100000:first_pts=0",
 		"-f", "flv", fmt.Sprintf("%s%s", ctx.ingestServer, ctx.streamName))
 	log.WithField("cmd", cmd.String()).Info("Starting premiere")
-	ffmpegErr, errFfmpegErrFile := os.OpenFile(fmt.Sprintf("%s/ffmpeg_%s.log", cfg.LogDir, ctx.getStreamName()), os.O_APPEND|os.O_WRONLY|os.O_CREATE, 0o644)
+	ffmpegErr, errFfmpegErrFile := os.OpenFile(fmt.Sprintf("%s/ffmpeg_%s.log", cfg.LogDir, ctx.getStreamName()), os.O_APPEND|os.O_WRONLY|os.O_CREATE, 0644)
 	if errFfmpegErrFile == nil {
 		cmd.Stderr = ffmpegErr
 	} else {

diff --git a/worker/worker/stream.go b/worker/worker/stream.go
@@ -45,7 +45,7 @@ func stream(streamCtx *StreamContext) {
 		// persist stream command in context, so it can be killed later
 		streamCtx.streamCmd = cmd
 		log.WithField("cmd", cmd.String()).Info("Starting stream")
-		ffmpegErr, errFfmpegErrFile := os.OpenFile(fmt.Sprintf("%s/ffmpeg_%s.log", cfg.LogDir, streamCtx.getStreamName()), os.O_APPEND|os.O_WRONLY|os.O_CREATE, 0o644)
+		ffmpegErr, errFfmpegErrFile := os.OpenFile(fmt.Sprintf("%s/ffmpeg_%s.log", cfg.LogDir, streamCtx.getStreamName()), os.O_APPEND|os.O_WRONLY|os.O_CREATE, 0644)
 		if errFfmpegErrFile == nil {
 			cmd.Stderr = ffmpegErr
 		} else {

diff --git a/worker/worker/thumbnails.go b/worker/worker/thumbnails.go
@@ -50,7 +50,7 @@ func createVideoThumbnail(ctx *StreamContext, source string) error {
 	if err != nil {
 		return err
 	}
-	file, err := os.OpenFile(ctx.getLargeThumbnailSpriteFileName(), os.O_CREATE|os.O_WRONLY, 0o644)
+	file, err := os.OpenFile(ctx.getLargeThumbnailSpriteFileName(), os.O_CREATE|os.O_WRONLY, 0644)
 	if err != nil {
 		return err
 	}

diff --git a/worker/worker/transcode.go b/worker/worker/transcode.go
@@ -149,7 +149,7 @@ func handleTranscodingOutput(stderr io.ReadCloser, inputTime float64, progressCh
 // creates folder for output file if it doesn't exist
 func prepare(out string) error {
 	dir := filepath.Dir(out)
-	err := os.MkdirAll(dir, 0o750)
+	err := os.MkdirAll(dir, 0750)
 	if err != nil {
 		return fmt.Errorf("create output directory for transcoding: %s", err)
 	}
@@ -159,7 +159,7 @@ func prepare(out string) error {
 // markForDeletion moves the file to $recfolder/.trash/
 func markForDeletion(ctx *StreamContext) error {
 	trashName := ctx.getRecordingTrashName()
-	err := os.MkdirAll(filepath.Dir(trashName), 0o750)
+	err := os.MkdirAll(filepath.Dir(trashName), 0	750)
 	if err != nil {
 		return fmt.Errorf("create trash directory: %s", err)
 	}

diff --git a/worker/worker/upload_test.go b/worker/worker/upload_test.go
@@ -72,7 +72,7 @@ func createDummyFile(filesize uint) (string, error) {
 	if err != nil {
 		return "", err
 	}
-	f, err := os.OpenFile(file.Name(), os.O_APPEND|os.O_WRONLY, 0o600)
+	f, err := os.OpenFile(file.Name(), os.O_APPEND|os.O_WRONLY, 0600)
 	if err != nil {
 		return "", err
 	}