Enhance sendLogFallback with reason parameter

Author: ChristopherHX

protocol/logger/job_logger.go

@@ -193,14 +193,14 @@ func (logger *WebsocketLiveloggerWithFallback) Close() error {
 	return logger.replace(&errorLogger{})
 }
 
-func (logger *WebsocketLiveloggerWithFallback) sendLogFallback(err error, wrapper *protocol.TimelineRecordFeedLinesWrapper) {
+func (logger *WebsocketLiveloggerWithFallback) sendLogFallback(err error, reason string, wrapper *protocol.TimelineRecordFeedLinesWrapper) {
 	if !logger.ForceWebsock {
 		if logger.Connection.Trace {
-			fmt.Printf("Failed to reconnect to websocket %s, fallback to vsslogger\n", err.Error())
+			fmt.Printf("Failed to %s to websocket %s, fallback to vsslogger\n", reason, err.Error())
 		}
-		currentLogger = logger.initializeVssLogger()
+		currentLogger := logger.initializeVssLogger()
 		if currentLogger == nil {
-			return fmt.Errorf("failed to initialize VSS logger after websocket reconnect failure: %w", err)
+			return fmt.Errorf("failed to initialize VSS logger after websocket %s failure: %w", reason, err)
 		}
 		return currentLogger.SendLog(wrapper)
 	}
@@ -222,11 +222,11 @@ func (logger *WebsocketLiveloggerWithFallback) SendLog(wrapper *protocol.Timelin
 		}
 		if wslogger, ok := currentLogger.(*WebsocketLivelogger); ok {
 			if err = wslogger.Connect(); err != nil {
-				return logger.sendLogFallback(err, wrapper)
+				return logger.sendLogFallback(err, "reconnect", wrapper)
 			}
 			err = currentLogger.SendLog(wrapper)
 			if err != nil {
-				return logger.sendLogFallback(err, wrapper)
+				return logger.sendLogFallback(err, "send", wrapper)
 			}
 			return nil
 		}