ProxyAccept now handles server-speak-first protocols well

pajama-coder · pajama-coder · commit b9d28ec2d7f1 · 2025-03-12T10:29:35.000+08:00
diff --git a/src/filters/tcp/ProxyAccept.js b/src/filters/tcp/ProxyAccept.js
@@ -25,7 +25,7 @@ export default function () {
                       $ctx.originalTarget = req.head.path
                       return new Message({ status: 200 })
                     }
-                  ).to($=>$.pipeNext())
+                  ).to($=>$.onStart(new Data).pipeNext())
                 ),
                 'forward': ($=>$
                   .handleMessageStart(
@@ -47,7 +47,7 @@ export default function () {
               $ctx.originalTarget = `${req.domain || req.ip}:${req.port}`
               return true
             }
-          ).to($=>$.pipeNext())
+          ).to($=>$.onStart(new Data).pipeNext())
         )
       }
     )

Original file line number	Diff line number	Diff line change
`@@ -25,7 +25,7 @@ export default function () {`
`25`	`25`	`$ctx.originalTarget = req.head.path`
`26`	`26`	`return new Message({ status: 200 })`
`27`	`27`	`}`
`28`		`- ).to($=>$.pipeNext())`
	`28`	`+ ).to($=>$.onStart(new Data).pipeNext())`
`29`	`29`	`),`
`30`	`30`	`'forward': ($=>$`
`31`	`31`	`.handleMessageStart(`
`@@ -47,7 +47,7 @@ export default function () {`
`47`	`47`	$ctx.originalTarget = `${req.domain \|\| req.ip}:${req.port}`
`48`	`48`	`return true`
`49`	`49`	`}`
`50`		`- ).to($=>$.pipeNext())`
	`50`	`+ ).to($=>$.onStart(new Data).pipeNext())`
`51`	`51`	`)`
`52`	`52`	`}`
`53`	`53`	`)`