@@ -21,13 +21,13 @@ public class ProxyTestController : IDisposable
21
21
private ExplicitProxyEndPoint explicitEndPoint ;
22
22
23
23
private CancellationTokenSource cancellationTokenSource = new CancellationTokenSource ( ) ;
24
- private CancellationToken cancellationToken => cancellationTokenSource . Token ;
24
+ private CancellationToken CancellationToken => cancellationTokenSource . Token ;
25
25
private ConcurrentQueue < Tuple < ConsoleColor ? , string > > consoleMessageQueue
26
26
= new ConcurrentQueue < Tuple < ConsoleColor ? , string > > ( ) ;
27
27
28
28
public ProxyTestController ( )
29
29
{
30
- Task . Run ( ( ) => listenToConsole ( ) ) ;
30
+ Task . Run ( ( ) => ListenToConsole ( ) ) ;
31
31
32
32
proxyServer = new ProxyServer ( ) ;
33
33
@@ -43,11 +43,11 @@ public ProxyTestController()
43
43
{
44
44
if ( exception is ProxyHttpException phex )
45
45
{
46
- writeToConsole ( exception . Message + ": " + phex . InnerException ? . Message , ConsoleColor . Red ) ;
46
+ WriteToConsole ( exception . Message + ": " + phex . InnerException ? . Message , ConsoleColor . Red ) ;
47
47
}
48
48
else
49
49
{
50
- writeToConsole ( exception . Message , ConsoleColor . Red ) ;
50
+ WriteToConsole ( exception . Message , ConsoleColor . Red ) ;
51
51
}
52
52
} ;
53
53
@@ -76,9 +76,9 @@ public ProxyTestController()
76
76
77
77
public void StartProxy ( )
78
78
{
79
- proxyServer . BeforeRequest += onRequest ;
80
- proxyServer . BeforeResponse += onResponse ;
81
- proxyServer . AfterResponse += onAfterResponse ;
79
+ proxyServer . BeforeRequest += OnRequest ;
80
+ proxyServer . BeforeResponse += OnResponse ;
81
+ proxyServer . AfterResponse += OnAfterResponse ;
82
82
83
83
proxyServer . ServerCertificateValidationCallback += OnCertificateValidation ;
84
84
proxyServer . ClientCertificateSelectionCallback += OnCertificateSelection ;
@@ -88,8 +88,8 @@ public void StartProxy()
88
88
explicitEndPoint = new ExplicitProxyEndPoint ( IPAddress . Any , 8000 ) ;
89
89
90
90
// Fired when a CONNECT request is received
91
- explicitEndPoint . BeforeTunnelConnectRequest += onBeforeTunnelConnectRequest ;
92
- explicitEndPoint . BeforeTunnelConnectResponse += onBeforeTunnelConnectResponse ;
91
+ explicitEndPoint . BeforeTunnelConnectRequest += OnBeforeTunnelConnectRequest ;
92
+ explicitEndPoint . BeforeTunnelConnectResponse += OnBeforeTunnelConnectResponse ;
93
93
94
94
// An explicit endpoint is where the client knows about the existence of a proxy
95
95
// So client sends request in a proxy friendly manner
@@ -143,11 +143,11 @@ public void StartProxy()
143
143
144
144
public void Stop ( )
145
145
{
146
- explicitEndPoint . BeforeTunnelConnectRequest -= onBeforeTunnelConnectRequest ;
147
- explicitEndPoint . BeforeTunnelConnectResponse -= onBeforeTunnelConnectResponse ;
146
+ explicitEndPoint . BeforeTunnelConnectRequest -= OnBeforeTunnelConnectRequest ;
147
+ explicitEndPoint . BeforeTunnelConnectResponse -= OnBeforeTunnelConnectResponse ;
148
148
149
- proxyServer . BeforeRequest -= onRequest ;
150
- proxyServer . BeforeResponse -= onResponse ;
149
+ proxyServer . BeforeRequest -= OnRequest ;
150
+ proxyServer . BeforeResponse -= OnResponse ;
151
151
proxyServer . ServerCertificateValidationCallback -= OnCertificateValidation ;
152
152
proxyServer . ClientCertificateSelectionCallback -= OnCertificateSelection ;
153
153
@@ -157,9 +157,9 @@ public void Stop()
157
157
//proxyServer.CertificateManager.RemoveTrustedRootCertificates();
158
158
}
159
159
160
- private async Task < IExternalProxy > onGetCustomUpStreamProxyFunc ( SessionEventArgsBase arg )
160
+ private async Task < IExternalProxy > OnGetCustomUpStreamProxyFunc ( SessionEventArgsBase arg )
161
161
{
162
- arg . GetState ( ) . PipelineInfo . AppendLine ( nameof ( onGetCustomUpStreamProxyFunc ) ) ;
162
+ arg . GetState ( ) . PipelineInfo . AppendLine ( nameof ( OnGetCustomUpStreamProxyFunc ) ) ;
163
163
164
164
// this is just to show the functionality, provided values are junk
165
165
return new ExternalProxy
@@ -173,9 +173,9 @@ private async Task<IExternalProxy> onGetCustomUpStreamProxyFunc(SessionEventArgs
173
173
} ;
174
174
}
175
175
176
- private async Task < IExternalProxy > onCustomUpStreamProxyFailureFunc ( SessionEventArgsBase arg )
176
+ private async Task < IExternalProxy > OnCustomUpStreamProxyFailureFunc ( SessionEventArgsBase arg )
177
177
{
178
- arg . GetState ( ) . PipelineInfo . AppendLine ( nameof ( onCustomUpStreamProxyFailureFunc ) ) ;
178
+ arg . GetState ( ) . PipelineInfo . AppendLine ( nameof ( OnCustomUpStreamProxyFailureFunc ) ) ;
179
179
180
180
// this is just to show the functionality, provided values are junk
181
181
return new ExternalProxy
@@ -189,11 +189,11 @@ private async Task<IExternalProxy> onCustomUpStreamProxyFailureFunc(SessionEvent
189
189
} ;
190
190
}
191
191
192
- private async Task onBeforeTunnelConnectRequest ( object sender , TunnelConnectSessionEventArgs e )
192
+ private async Task OnBeforeTunnelConnectRequest ( object sender , TunnelConnectSessionEventArgs e )
193
193
{
194
194
string hostname = e . HttpClient . Request . RequestUri . Host ;
195
- e . GetState ( ) . PipelineInfo . AppendLine ( nameof ( onBeforeTunnelConnectRequest ) + ":" + hostname ) ;
196
- writeToConsole ( "Tunnel to: " + hostname ) ;
195
+ e . GetState ( ) . PipelineInfo . AppendLine ( nameof ( OnBeforeTunnelConnectRequest ) + ":" + hostname ) ;
196
+ WriteToConsole ( "Tunnel to: " + hostname ) ;
197
197
198
198
var clientLocalIp = e . ClientLocalEndPoint . Address ;
199
199
if ( ! clientLocalIp . Equals ( IPAddress . Loopback ) && ! clientLocalIp . Equals ( IPAddress . IPv6Loopback ) )
@@ -232,27 +232,27 @@ private void WebSocketDataSentReceived(SessionEventArgs args, DataEventArgs e, b
232
232
{
233
233
var data = frame . Data . ToArray ( ) ;
234
234
string str = string . Join ( "," , data . ToArray ( ) . Select ( x => x . ToString ( "X2" ) ) ) ;
235
- writeToConsole ( str , color ) ;
235
+ WriteToConsole ( str , color ) ;
236
236
}
237
237
238
238
if ( frame . OpCode == WebsocketOpCode . Text )
239
239
{
240
- writeToConsole ( frame . GetText ( ) , color ) ;
240
+ WriteToConsole ( frame . GetText ( ) , color ) ;
241
241
}
242
242
}
243
243
}
244
244
245
- private Task onBeforeTunnelConnectResponse ( object sender , TunnelConnectSessionEventArgs e )
245
+ private Task OnBeforeTunnelConnectResponse ( object sender , TunnelConnectSessionEventArgs e )
246
246
{
247
- e . GetState ( ) . PipelineInfo . AppendLine ( nameof ( onBeforeTunnelConnectResponse ) + ":" + e . HttpClient . Request . RequestUri ) ;
247
+ e . GetState ( ) . PipelineInfo . AppendLine ( nameof ( OnBeforeTunnelConnectResponse ) + ":" + e . HttpClient . Request . RequestUri ) ;
248
248
249
249
return Task . CompletedTask ;
250
250
}
251
251
252
252
// intercept & cancel redirect or update requests
253
- private async Task onRequest ( object sender , SessionEventArgs e )
253
+ private async Task OnRequest ( object sender , SessionEventArgs e )
254
254
{
255
- e . GetState ( ) . PipelineInfo . AppendLine ( nameof ( onRequest ) + ":" + e . HttpClient . Request . RequestUri ) ;
255
+ e . GetState ( ) . PipelineInfo . AppendLine ( nameof ( OnRequest ) + ":" + e . HttpClient . Request . RequestUri ) ;
256
256
257
257
var clientLocalIp = e . ClientLocalEndPoint . Address ;
258
258
if ( ! clientLocalIp . Equals ( IPAddress . Loopback ) && ! clientLocalIp . Equals ( IPAddress . IPv6Loopback ) )
@@ -265,8 +265,8 @@ private async Task onRequest(object sender, SessionEventArgs e)
265
265
e . CustomUpStreamProxy = new ExternalProxy ( "localhost" , 8888 ) ;
266
266
}
267
267
268
- writeToConsole ( "Active Client Connections:" + ( ( ProxyServer ) sender ) . ClientConnectionCount ) ;
269
- writeToConsole ( e . HttpClient . Request . Url ) ;
268
+ WriteToConsole ( "Active Client Connections:" + ( ( ProxyServer ) sender ) . ClientConnectionCount ) ;
269
+ WriteToConsole ( e . HttpClient . Request . Url ) ;
270
270
271
271
// store it in the UserData property
272
272
// It can be a simple integer, Guid, or any type
@@ -304,29 +304,29 @@ private async Task onRequest(object sender, SessionEventArgs e)
304
304
}
305
305
306
306
// Modify response
307
- private async Task multipartRequestPartSent ( object sender , MultipartRequestPartSentEventArgs e )
307
+ private async Task MultipartRequestPartSent ( object sender , MultipartRequestPartSentEventArgs e )
308
308
{
309
- e . GetState ( ) . PipelineInfo . AppendLine ( nameof ( multipartRequestPartSent ) ) ;
309
+ e . GetState ( ) . PipelineInfo . AppendLine ( nameof ( MultipartRequestPartSent ) ) ;
310
310
311
311
var session = ( SessionEventArgs ) sender ;
312
- writeToConsole ( "Multipart form data headers:" ) ;
312
+ WriteToConsole ( "Multipart form data headers:" ) ;
313
313
foreach ( var header in e . Headers )
314
314
{
315
- writeToConsole ( header . ToString ( ) ) ;
315
+ WriteToConsole ( header . ToString ( ) ) ;
316
316
}
317
317
}
318
318
319
- private async Task onResponse ( object sender , SessionEventArgs e )
319
+ private async Task OnResponse ( object sender , SessionEventArgs e )
320
320
{
321
- e . GetState ( ) . PipelineInfo . AppendLine ( nameof ( onResponse ) ) ;
321
+ e . GetState ( ) . PipelineInfo . AppendLine ( nameof ( OnResponse ) ) ;
322
322
323
323
if ( e . HttpClient . ConnectRequest ? . TunnelType == TunnelType . Websocket )
324
324
{
325
325
e . DataSent += WebSocket_DataSent ;
326
326
e . DataReceived += WebSocket_DataReceived ;
327
327
}
328
328
329
- writeToConsole ( "Active Server Connections:" + ( ( ProxyServer ) sender ) . ServerConnectionCount ) ;
329
+ WriteToConsole ( "Active Server Connections:" + ( ( ProxyServer ) sender ) . ServerConnectionCount ) ;
330
330
331
331
string ext = System . IO . Path . GetExtension ( e . HttpClient . Request . RequestUri . AbsolutePath ) ;
332
332
@@ -370,9 +370,9 @@ private async Task onResponse(object sender, SessionEventArgs e)
370
370
//}
371
371
}
372
372
373
- private async Task onAfterResponse ( object sender , SessionEventArgs e )
373
+ private async Task OnAfterResponse ( object sender , SessionEventArgs e )
374
374
{
375
- writeToConsole ( $ "Pipelineinfo: { e . GetState ( ) . PipelineInfo } ", ConsoleColor . Yellow ) ;
375
+ WriteToConsole ( $ "Pipelineinfo: { e . GetState ( ) . PipelineInfo } ", ConsoleColor . Yellow ) ;
376
376
}
377
377
378
378
/// <summary>
@@ -407,14 +407,14 @@ public Task OnCertificateSelection(object sender, CertificateSelectionEventArgs
407
407
return Task . CompletedTask ;
408
408
}
409
409
410
- private void writeToConsole ( string message , ConsoleColor ? consoleColor = null )
410
+ private void WriteToConsole ( string message , ConsoleColor ? consoleColor = null )
411
411
{
412
412
consoleMessageQueue . Enqueue ( new Tuple < ConsoleColor ? , string > ( consoleColor , message ) ) ;
413
413
}
414
414
415
- private async Task listenToConsole ( )
415
+ private async Task ListenToConsole ( )
416
416
{
417
- while ( ! cancellationToken . IsCancellationRequested )
417
+ while ( ! CancellationToken . IsCancellationRequested )
418
418
{
419
419
while ( consoleMessageQueue . TryDequeue ( out var item ) )
420
420
{
0 commit comments