Files
yandex-quest/Assets/Scripts/Services/NetworkService.cs
T
2023-07-09 23:43:19 +05:00

247 lines
7.8 KiB
C#

using System;
using System.Text;
using Newtonsoft.Json;
using System.Threading.Tasks;
using UnityEngine;
using UnityEngine.Networking;
using System.Collections.Generic;
using Cysharp.Threading.Tasks;
public struct Response<T>
{
public long responseCode { get; set; }
public string responseText { get; set; }
public T responseData { get; set; }
}
public class NetworkService
{
#if !UNITY_EDITOR
private string _apiUrl = "https://yandexquest.graff.tech/";
#else
private string _apiUrl = "http://localhost:5000/";
#endif
public async UniTask<Response<TValue>> GetAsync<TValue>(string requestString)
{
Response<TValue> responseStruct = new Response<TValue>();
using var getRequest = UnityWebRequest.Get(_apiUrl + requestString);
getRequest.SetRequestHeader("Content-type", "application/json");
UnityWebRequest operation = new UnityWebRequest();
try
{
operation = await getRequest.SendWebRequest();
}
catch { }
responseStruct.responseCode = getRequest.responseCode;
if (getRequest.responseCode != 200)
{
responseStruct.responseText = getRequest.downloadHandler.text;
return responseStruct;
}
try
{
TValue result = JsonConvert.DeserializeObject<TValue>(operation.downloadHandler.text);
responseStruct.responseData = result;
return responseStruct;
}
catch (Exception ex)
{
responseStruct.responseCode = -1;
responseStruct.responseText = ex.Message;
return responseStruct;
}
}
public async UniTask<Response<TValue>> GetAsync<TValue>(string requestString, params string[] query)
{
Response<TValue> responseStruct = new Response<TValue>();
StringBuilder stringBuilder = new StringBuilder();
stringBuilder.Append(requestString);
stringBuilder.Append("?");
for (int i = 0; i < query.Length; i++)
{
stringBuilder.Append(query[i]);
if (i != query.Length - 1)
stringBuilder.Append("&");
}
using var getRequest = UnityWebRequest.Get(_apiUrl + stringBuilder.ToString());
getRequest.SetRequestHeader("Content-type", "application/json");
UnityWebRequest operation = new UnityWebRequest();
try
{
operation = await getRequest.SendWebRequest();
}
catch { }
responseStruct.responseCode = getRequest.responseCode;
if (getRequest.responseCode != 200)
{
responseStruct.responseText = getRequest.downloadHandler.text;
return responseStruct;
}
try
{
TValue result = JsonConvert.DeserializeObject<TValue>(operation.downloadHandler.text);
responseStruct.responseData = result;
return responseStruct;
}
catch (Exception ex)
{
responseStruct.responseCode = -1;
responseStruct.responseText = ex.Message;
return responseStruct;
}
}
public async UniTask<Response<TValue>> GetAsync<TValue>(string requestString, Dictionary<string, string> headers = null, params string[] query)
{
Response<TValue> responseStruct = new Response<TValue>();
StringBuilder stringBuilder = new StringBuilder();
stringBuilder.Append(requestString);
stringBuilder.Append("?");
for (int i = 0; i < query.Length; i++)
{
stringBuilder.Append(query[i]);
if (i != query.Length - 1)
stringBuilder.Append("&");
}
using var getRequest = UnityWebRequest.Get(_apiUrl + stringBuilder.ToString());
if (headers != null)
foreach (var header in headers)
getRequest.SetRequestHeader(header.Key, header.Value);
getRequest.SetRequestHeader("Content-type", "application/json");
UnityWebRequest operation = new UnityWebRequest();
try
{
operation = await getRequest.SendWebRequest();
}
catch { }
responseStruct.responseCode = getRequest.responseCode;
if (getRequest.responseCode != 200)
{
responseStruct.responseText = getRequest.downloadHandler.text;
return responseStruct;
}
try
{
TValue result = JsonConvert.DeserializeObject<TValue>(operation.downloadHandler.text);
responseStruct.responseData = result;
return responseStruct;
}
catch (Exception ex)
{
responseStruct.responseCode = -1;
responseStruct.responseText = ex.Message;
return default;
}
}
public async UniTask PostAsync<TValue>(string requestString, TValue data, Dictionary<string, string> headers = null)
{
string sendingData = JsonConvert.SerializeObject(data);
using var postRequest = new UnityWebRequest(_apiUrl + requestString, "POST");
byte[] dataBytes = new UTF8Encoding().GetBytes(sendingData);
postRequest.uploadHandler = (UploadHandler)new UploadHandlerRaw(dataBytes);
postRequest.downloadHandler = (DownloadHandler)new DownloadHandlerBuffer();
postRequest.SetRequestHeader("Content-Type", "application/json");
if (headers != null)
{
foreach (var header in headers)
postRequest.SetRequestHeader(header.Key, header.Value);
}
UnityWebRequest operation = new UnityWebRequest();
try
{
operation = await postRequest.SendWebRequest();
}
catch { }
}
public async UniTask<Response<TResponseValue>> PostAsync<TSendingValue, TResponseValue>(string requestString, TSendingValue data)
{
Response<TResponseValue> responseStruct = new Response<TResponseValue>();
string sendingData = JsonConvert.SerializeObject(data);
using var postRequest = new UnityWebRequest(_apiUrl + requestString, "POST");
byte[] dataBytes = new UTF8Encoding().GetBytes(sendingData);
postRequest.uploadHandler = (UploadHandler)new UploadHandlerRaw(dataBytes);
postRequest.downloadHandler = (DownloadHandler)new DownloadHandlerBuffer();
postRequest.SetRequestHeader("Content-Type", "application/json");
UnityWebRequest operation = new UnityWebRequest();
try
{
operation = await postRequest.SendWebRequest();
}
catch { }
responseStruct.responseCode = postRequest.responseCode;
if (postRequest.responseCode != 200)
{
responseStruct.responseText = postRequest.downloadHandler.text;
return responseStruct;
}
try
{
TResponseValue result = JsonConvert.DeserializeObject<TResponseValue>(operation.downloadHandler.text);
responseStruct.responseData = result;
return responseStruct;
}
catch (Exception ex)
{
responseStruct.responseCode = -1;
responseStruct.responseText = ex.Message;
return responseStruct;
}
}
public async UniTask PutAsync<TValue>(string requestString, TValue data)
{
string sendingData = JsonConvert.SerializeObject(data);
using var putRequest = UnityWebRequest.Put(_apiUrl + requestString, sendingData);
byte[] dataBytes = new UTF8Encoding().GetBytes(sendingData);
putRequest.uploadHandler = new UploadHandlerRaw(dataBytes);
putRequest.downloadHandler = new DownloadHandlerBuffer();
putRequest.SetRequestHeader("Content-Type", "application/json");
UnityWebRequest operation = new UnityWebRequest();
try
{
operation = await putRequest.SendWebRequest();
}
catch { }
}
}