66using JetBrains . Annotations ;
77using Flow . Launcher . Infrastructure . Logger ;
88using Flow . Launcher . Infrastructure . UserSettings ;
9+ using System ;
10+ using System . ComponentModel ;
911
1012namespace Flow . Launcher . Infrastructure . Http
1113{
1214 public static class Http
1315 {
1416 private const string UserAgent = @"Mozilla/5.0 (Trident/7.0; rv:11.0) like Gecko" ;
1517
18+ private static HttpClient client ;
19+
20+ private static SocketsHttpHandler socketsHttpHandler = new SocketsHttpHandler ( )
21+ {
22+ UseProxy = true ,
23+ Proxy = WebProxy
24+ } ;
25+
1626 static Http ( )
1727 {
1828 // need to be added so it would work on a win10 machine
1929 ServicePointManager . Expect100Continue = true ;
2030 ServicePointManager . SecurityProtocol |= SecurityProtocolType . Tls
2131 | SecurityProtocolType . Tls11
2232 | SecurityProtocolType . Tls12 ;
33+
34+ client = new HttpClient ( socketsHttpHandler , false ) ;
35+ client . DefaultRequestHeaders . Add ( "User-Agent" , UserAgent ) ;
2336 }
2437
25- public static HttpProxy Proxy { private get ; set ; }
26- public static IWebProxy WebProxy ( )
38+ private static HttpProxy proxy ;
39+
40+ public static HttpProxy Proxy
2741 {
28- if ( Proxy != null && Proxy . Enabled && ! string . IsNullOrEmpty ( Proxy . Server ) )
42+ private get { return proxy ; }
43+ set
2944 {
30- if ( string . IsNullOrEmpty ( Proxy . UserName ) || string . IsNullOrEmpty ( Proxy . Password ) )
31- {
32- var webProxy = new WebProxy ( Proxy . Server , Proxy . Port ) ;
33- return webProxy ;
34- }
35- else
45+ proxy = value ;
46+ proxy . PropertyChanged += UpdateProxy ;
47+ }
48+ }
49+
50+ public static WebProxy WebProxy { get ; } = new WebProxy ( ) ;
51+
52+ /// <summary>
53+ /// Update the Address of the Proxy to modify the client Proxy
54+ /// </summary>
55+ public static void UpdateProxy ( ProxyProperty property )
56+ {
57+ ( WebProxy . Address , WebProxy . Credentials ) = property switch
58+ {
59+ ProxyProperty . Enabled => Proxy . Enabled switch
3660 {
37- var webProxy = new WebProxy ( Proxy . Server , Proxy . Port )
61+ true => Proxy . UserName switch
3862 {
39- Credentials = new NetworkCredential ( Proxy . UserName , Proxy . Password )
40- } ;
41- return webProxy ;
42- }
63+ var userName when ! string . IsNullOrEmpty ( userName ) =>
64+ ( new Uri ( $ "http://{ Proxy . Server } :{ Proxy . Port } ") , null ) ,
65+ _ => ( new Uri ( $ "http://{ Proxy . Server } :{ Proxy . Port } ") ,
66+ new NetworkCredential ( Proxy . UserName , Proxy . Password ) )
67+ } ,
68+ false => ( null , null )
69+ } ,
70+ ProxyProperty . Server => ( new Uri ( $ "http://{ Proxy . Server } :{ Proxy . Port } ") , WebProxy . Credentials ) ,
71+ ProxyProperty . Port => ( new Uri ( $ "http://{ Proxy . Server } :{ Proxy . Port } ") , WebProxy . Credentials ) ,
72+ ProxyProperty . UserName => ( WebProxy . Address , new NetworkCredential ( Proxy . UserName , Proxy . Password ) ) ,
73+ ProxyProperty . Password => ( WebProxy . Address , new NetworkCredential ( Proxy . UserName , Proxy . Password ) ) ,
74+ _ => throw new ArgumentOutOfRangeException ( )
75+ } ;
76+ }
77+
78+ public static async Task Download ( [ NotNull ] string url , [ NotNull ] string filePath )
79+ {
80+ using var response = await client . GetAsync ( url ) ;
81+ if ( response . StatusCode == HttpStatusCode . OK )
82+ {
83+ await using var fileStream = new FileStream ( filePath , FileMode . CreateNew ) ;
84+ await response . Content . CopyToAsync ( fileStream ) ;
4385 }
4486 else
4587 {
46- return WebRequest . GetSystemWebProxy ( ) ;
88+ throw new HttpRequestException ( $ "Error code < { response . StatusCode } > returned from < { url } >" ) ;
4789 }
4890 }
4991
50- public static void Download ( [ NotNull ] string url , [ NotNull ] string filePath )
92+ /// <summary>
93+ /// Asynchrously get the result as string from url.
94+ /// When supposing the result is long and large, try using GetStreamAsync to avoid reading as string
95+ /// </summary>
96+ /// <param name="url"></param>
97+ /// <returns></returns>
98+ public static Task < string > GetAsync ( [ NotNull ] string url )
5199 {
52- var client = new WebClient { Proxy = WebProxy ( ) } ;
53- client . Headers . Add ( "user-agent" , UserAgent ) ;
54- client . DownloadFile ( url , filePath ) ;
100+ Log . Debug ( $ "|Http.Get|Url <{ url } >") ;
101+ return GetAsync ( new Uri ( url . Replace ( "#" , "%23" ) ) ) ;
55102 }
56103
57- public static async Task < string > Get ( [ NotNull ] string url , string encoding = "UTF-8" )
104+ public static async Task < string > GetAsync ( [ NotNull ] Uri url )
58105 {
59106 Log . Debug ( $ "|Http.Get|Url <{ url } >") ;
60- var request = WebRequest . CreateHttp ( url ) ;
61- request . Method = "GET" ;
62- request . Timeout = 1000 ;
63- request . Proxy = WebProxy ( ) ;
64- request . UserAgent = UserAgent ;
65- var response = await request . GetResponseAsync ( ) as HttpWebResponse ;
66- response = response . NonNull ( ) ;
67- var stream = response . GetResponseStream ( ) . NonNull ( ) ;
107+ using var response = await client . GetAsync ( url ) ;
108+ var content = await response . Content . ReadAsStringAsync ( ) ;
109+ if ( response . StatusCode == HttpStatusCode . OK )
110+ {
111+ return content ;
112+ }
113+ else
114+ {
115+ throw new HttpRequestException (
116+ $ "Error code <{ response . StatusCode } > with content <{ content } > returned from <{ url } >") ;
117+ }
118+ }
68119
69- using var reader = new StreamReader ( stream , Encoding . GetEncoding ( encoding ) ) ;
70- var content = await reader . ReadToEndAsync ( ) ;
71- if ( response . StatusCode != HttpStatusCode . OK )
72- throw new HttpRequestException ( $ "Error code <{ response . StatusCode } > with content <{ content } > returned from <{ url } >") ;
73-
74- return content ;
120+ /// <summary>
121+ /// Asynchrously get the result as stream from url.
122+ /// </summary>
123+ /// <param name="url"></param>
124+ /// <returns></returns>
125+ public static async Task < Stream > GetStreamAsync ( [ NotNull ] string url )
126+ {
127+ Log . Debug ( $ "|Http.Get|Url <{ url } >") ;
128+ var response = await client . GetAsync ( url ) ;
129+ return await response . Content . ReadAsStreamAsync ( ) ;
75130 }
76131 }
77- }
132+ }
0 commit comments