Remove unnecessary newline in log text.

3 files changed, 23 insertions, 23 deletions

diff --git a/common/retry.go b/common/retry.go
index 435d407..1b28e1b 100644
--- a/common/retry.go
+++ b/common/retry.go
@@ -21,7 +21,7 @@ func AutoRetry[T any](
 		ret, err := supplier()
 		if err != nil {
 			if logger != nil {
-				logger.Printf("Try %v/%v (sleep %vs): %v\n",
+				logger.Printf("Try %v/%v (sleep %vs): %v",
 					i, maxRetryTimes, retryInterval, err)
 			}
 			timer := time.NewTimer(retryInterval)
diff --git a/recording/runner.go b/recording/runner.go
index 487cab8..4fd9b46 100644
--- a/recording/runner.go
+++ b/recording/runner.go
@@ -33,9 +33,9 @@ func RunTask(ctx context.Context, wg *sync.WaitGroup, task *TaskConfig) {
 	err := doTask(ctx, task)
 	logger := log.Default()
 	if err != nil && !errors.Is(err, context.Canceled) {
-		logger.Printf("A task stopped with an error (room %v): %v\n", task.RoomId, err)
+		logger.Printf("A task stopped with an error (room %v): %v", task.RoomId, err)
 	} else {
-		logger.Printf("Task stopped (room %v): %v\n", task.RoomId, task.String())
+		logger.Printf("Task stopped (room %v): %v", task.RoomId, task.String())
 	}
 }
 
@@ -43,7 +43,7 @@ func RunTask(ctx context.Context, wg *sync.WaitGroup, task *TaskConfig) {
 func doTask(ctx context.Context, task *TaskConfig) error {
 	logger := log.Default()
 	bi := bilibili.NewBilibili()
-	logger.Printf("Start task: room %v\n", task.RoomId)
+	logger.Printf("Start task: room %v", task.RoomId)
 
 	authKey, url, err := getStreamingServer(task, logger, bi)
 	if err != nil {
@@ -73,7 +73,7 @@ func doTask(ctx context.Context, task *TaskConfig) error {
 	for {
 		select {
 		case <-ctx.Done():
-			logger.Printf("Task (room %v) is stopped.\n", task.RoomId)
+			logger.Printf("Task (room %v) is stopped.", task.RoomId)
 			return nil
 		case <-chWatcherDown:
 			// watcher is down and unrecoverable, stop this task
@@ -99,12 +99,12 @@ func doTask(ctx context.Context, task *TaskConfig) error {
 								time.Sleep(3 * time.Second)
 							}
 							if sec > 0 {
-								logger.Printf("Sleep for %vs before restart recording.\n", sec)
+								logger.Printf("Sleep for %vs before restart recording.", sec)
 								time.Sleep(time.Duration(sec) * time.Second)
 							}
 						}
 					}
-					logger.Printf("Task is cancelled. Stop recording. (room %v)\n", task.RoomId)
+					logger.Printf("Task is cancelled. Stop recording. (room %v)", task.RoomId)
 				}()
 				lastStatusIsLiving = true
 			case WatcherLiveStop:
@@ -121,7 +121,7 @@ func record(
 	task *TaskConfig,
 ) (cancelled bool, err error) {
 	logger := log.Default()
-	logger.Printf("INFO: Getting room profile...\n")
+	logger.Printf("INFO: Getting room profile...")
 
 	profile, err := common.AutoRetry(
 		ctx,
@@ -138,7 +138,7 @@ func record(
 	}
 	if err != nil {
 		// still error, abort
-		logger.Printf("ERROR: Cannot get room information: %v. Stopping current task.\n", err)
+		logger.Printf("ERROR: Cannot get room information: %v. Stopping current task.", err)
 		cancelled = true
 		return
 	}
@@ -192,17 +192,17 @@ func record(
 		err := fWriter.Flush()
 		if err != nil {
 			logger := log.Default()
-			logger.Printf("Failed to flush buffered file write data: %v\n", err)
+			logger.Printf("Failed to flush buffered file write data: %v", err)
 		}
 	}()
-	logger.Printf("Write buffer size: %v byte\n", fWriter.Size())
+	logger.Printf("Write buffer size: %v byte", fWriter.Size())
 
 	logger.Printf("Recording live stream to file \"%v\"...", filePath)
 	err = bi.CopyLiveStream(ctx, task.RoomId, streamSource, fWriter)
 	cancelled = err == nil || errors.Is(err, context.Canceled)
 	if !cancelled {
 		// real error happens
-		logger.Printf("Error when copying live stream: %v\n", err)
+		logger.Printf("Error when copying live stream: %v", err)
 	}
 	return
 }
@@ -248,12 +248,12 @@ func watcherRecoverableLoop(
 			// stop normally, the context is closed
 			return
 		case ErrProtocol:
-			logger.Printf("FATAL: Watcher stopped due to an unrecoverable error: %v\n", err)
+			logger.Printf("FATAL: Watcher stopped due to an unrecoverable error: %v", err)
 			// shutdown the whole task
 			chWatcherDown <- struct{}{}
 			return
 		case ErrTransport:
-			logger.Printf("ERROR: Watcher stopped due to an I/O error: %v\n", err)
+			logger.Printf("ERROR: Watcher stopped due to an I/O error: %v", err)
 			waitSeconds := task.Transport.RetryIntervalSeconds
 			logger.Printf(
 				"WARNING: Sleep for %v second(s) before restarting watcher.\n",
diff --git a/recording/watcher.go b/recording/watcher.go
index 1c7ef84..afc7ab5 100644
--- a/recording/watcher.go
+++ b/recording/watcher.go
@@ -128,7 +128,7 @@ func watch(
 
 			switch msg.Operation {
 			case dmpkg.OpLayer7Data:
-				//logger.Printf("server message: op %v, body %v\n", msg.Operation, string(msg.Body))
+				//logger.Printf("server message: op %v, body %v", msg.Operation, string(msg.Body))
 				var info liveInfo
 				err := json.Unmarshal(msg.Body, &info)
 				if err != nil {
@@ -158,7 +158,7 @@ func watch(
 						fallthrough
 					case "HOT_RANK_CHANGED_V2":
 						// useless message
-						logger.Printf("Ignore message: %v\n", info.Command)
+						logger.Printf("Ignore message: %v", info.Command)
 					case "WATCHED_CHANGE":
 						// number of watched people changed
 						obj, exists := info.Data["num"]
@@ -167,7 +167,7 @@ func watch(
 						}
 						viewersNum, ok := obj.(float64)
 						if !ok {
-							logger.Printf("Cannot parse watched people number: %v\n", obj)
+							logger.Printf("Cannot parse watched people number: %v", obj)
 							continue
 						}
 						logger.Printf("The number of viewers (room: %v): %v", roomId, viewersNum)
@@ -175,7 +175,7 @@ func watch(
 						var raw dmmsg.RawInteractWordMessage
 						err = json.Unmarshal(msg.Body, &raw)
 						if err != nil {
-							logger.Printf("Cannot parse RawInteractWordMessage JSON: %v\n", err)
+							logger.Printf("Cannot parse RawInteractWordMessage JSON: %v", err)
 							continue
 						}
 						logger.Printf("Interact word message: user: %v medal: %v",
@@ -184,22 +184,22 @@ func watch(
 						var raw dmmsg.RawDanMuMessage
 						err = json.Unmarshal(msg.Body, &raw)
 						if err != nil {
-							logger.Printf("Cannot parse Dan Mu message as JSON: %v\n", err)
+							logger.Printf("Cannot parse Dan Mu message as JSON: %v", err)
 							continue
 						}
 						dmm, err := dmmsg.ParseDanmakuMessage(raw)
 						if err != nil {
-							logger.Printf("Cannot parse Dan Mu message JSON: %v\n", err)
+							logger.Printf("Cannot parse Dan Mu message JSON: %v", err)
 							continue
 						}
-						logger.Printf("Dan Mu: %v\n", dmm.String())
+						logger.Printf("Dan Mu: %v", dmm.String())
 					default:
-						logger.Printf("Ignore unhandled server message %v %v %v\n",
+						logger.Printf("Ignore unhandled server message %v %v %v",
 							info.Command, msg.Operation, string(msg.Body))
 					}
 				}
 			default:
-				logger.Printf("Server message: %v\n", msg.String())
+				logger.Printf("Server message: %v", msg.String())
 			}
 
 		}