From b2514955eca18e8a4a3526cd750412c760b37f76 Mon Sep 17 00:00:00 2001
From: Eli Yukelzon <reflog@gmail.com>
Date: Thu, 14 Nov 2024 17:50:07 +0100
Subject: [PATCH] add cli param to disable panicwrap

---
 http-proxy/main.go | 97 ++++++++++++++++++++++++----------------------
 1 file changed, 51 insertions(+), 46 deletions(-)

diff --git a/http-proxy/main.go b/http-proxy/main.go
index 8357a913..2e2a7afb 100644
--- a/http-proxy/main.go
+++ b/http-proxy/main.go
@@ -5,6 +5,7 @@ import (
 	"crypto/sha1"
 	"encoding/binary"
 	"encoding/hex"
+	"errors"
 	"flag"
 	"fmt"
 	"net/http"
@@ -17,6 +18,7 @@ import (
 	"time"
 
 	"github.com/go-redis/redis/v8"
+	"github.com/mitchellh/panicwrap"
 	"github.com/vharitonsky/iniflags"
 
 	"github.com/getlantern/geo"
@@ -193,6 +195,8 @@ var (
 	vmessAddr  = flag.String("vmess-addr", "", "Address at which to listen for vmess connections.")
 	vmessUUIDs = flag.String("vmess-uuids", "", "Comma separated list of UUIDs for vmess connections.")
 
+	disablePanicWrap = flag.Bool("disable-panicwrap", false, "Disable panicwrap (for debugging)")
+
 	track = flag.String("track", "", "The track this proxy is running on")
 )
 
@@ -220,52 +224,53 @@ func main() {
 		}
 	}
 
-	// panicwrap works by re-executing the running program (retaining arguments,
-	// environmental variables, etc.) and monitoring the stderr of the program.
-	//exitStatus, panicWrapErr := panicwrap.Wrap(
-	//	&panicwrap.WrapConfig{
-	//		DetectDuration: time.Second,
-	//		Handler: func(msg string) {
-	//			if reporter != nil {
-	//				// heuristically separate the error message from the stack trace
-	//				separator := "\ngoroutine "
-	//				splitted := strings.SplitN(msg, separator, 2)
-	//				err := errors.New(splitted[0])
-	//				var maybeStack []byte
-	//				if len(splitted) > 1 {
-	//					maybeStack = []byte(separator + splitted[1])
-	//				}
-	//				reporter.Report(golog.FATAL, err, maybeStack)
-	//			}
-	//			if strings.Contains(msg, "maxmind") {
-	//				log.Debugf("Panic possibly related to maxmind, delete maxmind database files")
-	//				if err := os.Remove(cityDBFile); err != nil {
-	//					log.Errorf("Unable to delete city DB file %v: %v", cityDBFile, err)
-	//				}
-	//				if err := os.Remove(*geoip2ISPDBFile); err != nil {
-	//					log.Errorf("Unable to delete ISP DB file %v: %v", *geoip2ISPDBFile, err)
-	//				}
-	//			}
-	//			os.Exit(1)
-	//		},
-	//		// Just forward signals to the child process
-	//		ForwardSignals: []os.Signal{
-	//			syscall.SIGHUP,
-	//			syscall.SIGTERM,
-	//			syscall.SIGQUIT,
-	//			syscall.SIGINT,
-	//			syscall.SIGUSR1,
-	//		},
-	//	})
-	//if panicWrapErr != nil {
-	//	log.Fatalf("Error setting up panic wrapper: %v", panicWrapErr)
-	//} else {
-	//	// If exitStatus >= 0, then we're the parent process.
-	//	if exitStatus >= 0 {
-	//		os.Exit(exitStatus)
-	//	}
-	//}
-
+	if !*disablePanicWrap {
+		// panicwrap works by re-executing the running program (retaining arguments,
+		// environmental variables, etc.) and monitoring the stderr of the program.
+		exitStatus, panicWrapErr := panicwrap.Wrap(
+			&panicwrap.WrapConfig{
+				DetectDuration: time.Second,
+				Handler: func(msg string) {
+					if reporter != nil {
+						// heuristically separate the error message from the stack trace
+						separator := "\ngoroutine "
+						splitted := strings.SplitN(msg, separator, 2)
+						err := errors.New(splitted[0])
+						var maybeStack []byte
+						if len(splitted) > 1 {
+							maybeStack = []byte(separator + splitted[1])
+						}
+						reporter.Report(golog.FATAL, err, maybeStack)
+					}
+					if strings.Contains(msg, "maxmind") {
+						log.Debugf("Panic possibly related to maxmind, delete maxmind database files")
+						if err := os.Remove(cityDBFile); err != nil {
+							log.Errorf("Unable to delete city DB file %v: %v", cityDBFile, err)
+						}
+						if err := os.Remove(*geoip2ISPDBFile); err != nil {
+							log.Errorf("Unable to delete ISP DB file %v: %v", *geoip2ISPDBFile, err)
+						}
+					}
+					os.Exit(1)
+				},
+				// Just forward signals to the child process
+				ForwardSignals: []os.Signal{
+					syscall.SIGHUP,
+					syscall.SIGTERM,
+					syscall.SIGQUIT,
+					syscall.SIGINT,
+					syscall.SIGUSR1,
+				},
+			})
+		if panicWrapErr != nil {
+			log.Fatalf("Error setting up panic wrapper: %v", panicWrapErr)
+		} else {
+			// If exitStatus >= 0, then we're the parent process.
+			if exitStatus >= 0 {
+				os.Exit(exitStatus)
+			}
+		}
+	}
 	// We're in the child (wrapped) process now
 
 	// Capture signals and exit normally because when relying on the default