vlad.os/LuaCsForBarotraumaEP
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Added ability to include custom headers when sending http requests and made use of the new HttpClient

Browse Source
This commit is contained in:
EvilFactory
2023-02-07 17:08:37 -03:00
parent 4b206ada3e
commit 3e1c0ca9af
1 changed files with 31 additions and 29 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Barotrauma/BarotraumaShared/SharedSource/LuaCs/LuaCsNetworking.cs
+31 -29
View File
@@ -1,13 +1,15 @@
using System; using System;
using System.Collections.Generic; using System.Collections.Generic;
using System.IO; using System.Net.Http;
using System.Net; using System.Text;
using Barotrauma.Networking; using Barotrauma.Networking;
namespace Barotrauma namespace Barotrauma
{ {
partial class LuaCsNetworking partial class LuaCsNetworking
{ {
private static readonly HttpClient client = new HttpClient();
private enum LuaCsClientToServer private enum LuaCsClientToServer
{ {
NetMessageId, NetMessageId,
@@ -94,53 +96,53 @@ namespace Barotrauma
HandleNetMessage(netMessage, name, client); HandleNetMessage(netMessage, name, client);
} }
public void HttpRequest(string url, LuaCsAction callback, string data = null, string method = "POST", string contentType = "application/json") public async void HttpRequest(string url, LuaCsAction callback, string data = null, string method = "POST", string contentType = "application/json", Dictionary<string, string> headers = null)
{ {
try try
{ {
var httpWebRequest = (HttpWebRequest)WebRequest.Create(url); HttpRequestMessage request = new HttpRequestMessage(new HttpMethod(method), url);
httpWebRequest.ContentType = contentType;
httpWebRequest.Method = method; if (headers != null)
{
foreach (var header in headers)
{
request.Headers.Add(header.Key, header.Value);
}
}
if (data != null) if (data != null)
{ {
using (var streamWriter = new StreamWriter(httpWebRequest.GetRequestStream())) request.Content = new StringContent(data, Encoding.UTF8, contentType);
streamWriter.Write(data);
} }
httpWebRequest.BeginGetResponse(new AsyncCallback((IAsyncResult result) => HttpResponseMessage response = await client.SendAsync(request);
{
try
{
var httpResponse = httpWebRequest.EndGetResponse(result);
using (var streamReader = new StreamReader(httpResponse.GetResponseStream()))
{
string responseResult = streamReader.ReadToEnd();
GameMain.LuaCs.Timer.Wait((object[] par) => { callback(responseResult); }, 0);
}
}
catch (Exception e)
{
GameMain.LuaCs.Timer.Wait((object[] par) => { callback(e.Message); }, 0);
}
}), null);
string responseBody = await response.Content.ReadAsStringAsync();
GameMain.LuaCs.Timer.Wait((object[] par) =>
{
callback(responseBody, (int)response.StatusCode, response.Headers);
}, 0);
}
catch (HttpRequestException e)
{
GameMain.LuaCs.Timer.Wait((object[] par) => { callback(e.Message, e.StatusCode, null); }, 0);
} }
catch (Exception e) catch (Exception e)
{ {
GameMain.LuaCs.Timer.Wait((object[] par) => { callback(e.Message); }, 0); GameMain.LuaCs.Timer.Wait((object[] par) => { callback(e.Message, null, null); }, 0);
} }
} }
public void HttpPost(string url, LuaCsAction callback, string data, string contentType = "application/json") public void HttpPost(string url, LuaCsAction callback, string data, string contentType = "application/json", Dictionary<string, string> headers = null)
{ {
HttpRequest(url, callback, data, "POST", contentType); HttpRequest(url, callback, data, "POST", contentType, headers);
} }
public void HttpGet(string url, LuaCsAction callback) public void HttpGet(string url, LuaCsAction callback, Dictionary<string, string> headers = null)
{ {
HttpRequest(url, callback, null, "GET"); HttpRequest(url, callback, null, "GET", null, headers);
} }
public void CreateEntityEvent(INetSerializable entity, NetEntityEvent.IData extraData) public void CreateEntityEvent(INetSerializable entity, NetEntityEvent.IData extraData)