fix: process panic recover correctly in duplex conn (#94)

Author: jjeffcaii

go.mod

@@ -6,7 +6,7 @@ require (
 	github.com/golang/mock v1.4.3
 	github.com/google/uuid v1.1.2
 	github.com/gorilla/websocket v1.4.2
-	github.com/jjeffcaii/reactor-go v0.4.4
+	github.com/jjeffcaii/reactor-go v0.4.5
 	github.com/pkg/errors v0.9.1
 	github.com/pkg/profile v1.5.0
 	github.com/stretchr/testify v1.6.1

go.sum

@@ -10,8 +10,8 @@ github.com/google/uuid v1.1.2 h1:EVhdT+1Kseyi1/pUmXKaFxYsDNy9RQYkMWRH68J/W7Y=
 github.com/google/uuid v1.1.2/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
 github.com/gorilla/websocket v1.4.2 h1:+/TMaTYc4QFitKJxsQ7Yye35DkWvkdLcvGKqM+x0Ufc=
 github.com/gorilla/websocket v1.4.2/go.mod h1:YR8l580nyteQvAITg2hZ9XVh4b55+EU/adAjf1fMHhE=
-github.com/jjeffcaii/reactor-go v0.4.4 h1:s5zOwQ7hut6ICL/jucFoHiAwDx/ugOJpS/Ncp8Cc4Ko=
-github.com/jjeffcaii/reactor-go v0.4.4/go.mod h1:2ZzeNFnQ2c55NHRh0KJ4k5yMvmrcpx1APzh7BKkRNQE=
+github.com/jjeffcaii/reactor-go v0.4.5 h1:FOc3ICOIxPHzJBLYmA6Hf1jpPduX0Czzh4i62Wz17A4=
+github.com/jjeffcaii/reactor-go v0.4.5/go.mod h1:2ZzeNFnQ2c55NHRh0KJ4k5yMvmrcpx1APzh7BKkRNQE=
 github.com/panjf2000/ants/v2 v2.4.3 h1:wHghL17YKFanB62QjPQ9o+DuM4q7WrQ7zAhoX8+eBXU=
 github.com/panjf2000/ants/v2 v2.4.3/go.mod h1:f6F0NZVFsGCp5A7QW/Zj/m92atWwOkY0OIhFxRNFr4A=
 github.com/pkg/errors v0.9.1 h1:FEBLx1zS214owpjy7qsBeixbURkuhQAwrK5UwLGTwt4=

internal/socket/duplex.go

@@ -523,7 +523,7 @@ func (dc *DuplexConnection) respondRequestResponse(receiving fragmentation.Heade
 			if e, ok := rec.(error); ok {
 				err = errors.WithStack(e)
 			} else {
-				err = errors.Errorf("%v", e)
+				err = errors.Errorf("%v", rec)
 			}
 			logger.Errorf("handle request-response failed: %+v\n", err)
 		}()
@@ -618,7 +618,7 @@ func (dc *DuplexConnection) respondRequestChannel(req fragmentation.HeaderAndPay
 			if e, ok := rec.(error); ok {
 				err = errors.WithStack(e)
 			} else {
-				err = errors.Errorf("%v", e)
+				err = errors.Errorf("%v", rec)
 			}
 			logger.Errorf("handle request-channel failed: %+v\n", err)
 		}()
@@ -672,7 +672,7 @@ func (dc *DuplexConnection) respondMetadataPush(input core.BufferedFrame) error
 			if e, ok := rec.(error); ok {
 				err = errors.WithStack(e)
 			} else {
-				err = errors.Errorf("%v", e)
+				err = errors.Errorf("%v", rec)
 			}
 			logger.Errorf("handle metadata-push failed: %+v\n", err)
 		}()
@@ -701,7 +701,7 @@ func (dc *DuplexConnection) respondFireAndForget(receiving fragmentation.HeaderA
 			if e, ok := rec.(error); ok {
 				err = errors.WithStack(e)
 			} else {
-				err = errors.Errorf("%v", e)
+				err = errors.Errorf("%v", rec)
 			}
 			logger.Errorf("handle fire-and-forget failed: %+v\n", err)
 		}()
@@ -733,7 +733,7 @@ func (dc *DuplexConnection) respondRequestStream(receiving fragmentation.HeaderA
 			if e, ok := rec.(error); ok {
 				err = errors.WithStack(e)
 			} else {
-				err = errors.Errorf("%v", err)
+				err = errors.Errorf("%v", rec)
 			}
 			logger.Errorf("handle request-stream failed: %+v\n", err)
 		}()