feat(logging): add runtime log capturing and retrieval functionality

Author: M03ED

backend/xray/core.go

@@ -32,11 +32,13 @@ type Core struct {
 	startupLogSize            int
 	startupFailure            string
 	startupDiagnosticsEnabled bool
+	runtimeLogs               *startupLogRing
 	unixSocketPaths           []string
 	logger                    *nodeLogger.Logger
 	cancelFunc                context.CancelFunc
 	mu                        sync.Mutex
 	startupMu                 sync.RWMutex
+	runtimeMu                 sync.RWMutex
 }
 
 func NewXRayCore(executablePath, assetsPath, configPath string, logBufferSize, startupLogTailSize int) (*Core, error) {
@@ -51,6 +53,7 @@ func NewXRayCore(executablePath, assetsPath, configPath string, logBufferSize, s
 		logsChan:       make(chan string, logBufferSize),
 		logPhase:       logPhaseRuntime,
 		startupLogSize: startupLogTailSize,
+		runtimeLogs:    newStartupLogRing(10),
 	}
 
 	version, err := core.refreshVersion()
@@ -190,6 +193,10 @@ func (c *Core) Start(xConfig *Config, debugMode bool) error {
 		return errors.New("xray is started already")
 	}
 
+	c.runtimeMu.Lock()
+	c.runtimeLogs.reset()
+	c.runtimeMu.Unlock()
+
 	c.EnableStartupDiagnostics(c.startupLogSize)
 	c.setStartupLogPhase()
 

backend/xray/jobs.go

@@ -9,6 +9,7 @@ import (
 	"time"
 )
 
+
 func (x *Xray) startupLogTailSize() int {
 	if x.cfg != nil && x.cfg.StartupLogTailSize > 0 {
 		return x.cfg.StartupLogTailSize
@@ -100,6 +101,9 @@ func (x *Xray) checkXrayHealth(baseCtx context.Context) {
 				// Only restart after multiple consecutive failures
 				if consecutiveFailures >= maxFailures {
 					log.Printf("xray health check failed %d times, restarting...", consecutiveFailures)
+					if tail := x.core.RuntimeLogTail(10); len(tail) > 0 {
+						log.Printf("last %d xray log lines before restart:\n%s", len(tail), strings.Join(tail, "\n"))
+					}
 					if err = x.Restart(); err != nil {
 						log.Println(err.Error())
 					} else {

backend/xray/log.go

@@ -56,6 +56,7 @@ func (c *Core) captureStartupLogLine(output string) {
 }
 
 func (c *Core) captureRuntimeLogLine(output string) {
+	c.RecordRuntimeLog(output)
 	// Non-blocking send: skip if channel is full to prevent deadlock
 	select {
 	case c.logsChan <- output:

backend/xray/startup_diagnostics.go

@@ -166,6 +166,21 @@ func (c *Core) StartupLogTail(n int) []string {
 	return c.startupLogs.tail(n)
 }
 
+func (c *Core) RecordRuntimeLog(line string) {
+	c.runtimeMu.Lock()
+	defer c.runtimeMu.Unlock()
+	c.runtimeLogs.add(line)
+}
+
+func (c *Core) RuntimeLogTail(n int) []string {
+	c.runtimeMu.RLock()
+	defer c.runtimeMu.RUnlock()
+	if c.runtimeLogs == nil {
+		return nil
+	}
+	return c.runtimeLogs.tail(n)
+}
+
 func isStartupFailureLog(line string) bool {
 	lower := strings.ToLower(line)