155 lines
No EOL
6 KiB
C#
155 lines
No EOL
6 KiB
C#
using Mirror;
|
|
using Newtonsoft.Json;
|
|
using System.Collections;
|
|
using System.Collections.Generic;
|
|
using UnityEngine;
|
|
using UnityEngine.Networking;
|
|
|
|
namespace LightReflectiveMirror
|
|
{
|
|
public partial class LightReflectiveMirrorTransport : Transport
|
|
{
|
|
|
|
public void RequestServerList()
|
|
{
|
|
if (_isAuthenticated && _connectedToRelay)
|
|
StartCoroutine(GetServerList());
|
|
else
|
|
Debug.Log("You must be connected to Relay to request server list!");
|
|
}
|
|
|
|
IEnumerator RelayConnect()
|
|
{
|
|
string url = $"http://{loadBalancerAddress}:{loadBalancerPort}/api/join/";
|
|
|
|
using (UnityWebRequest webRequest = UnityWebRequest.Get(url))
|
|
{
|
|
// Request and wait for the desired page.
|
|
yield return webRequest.SendWebRequest();
|
|
var result = webRequest.downloadHandler.text;
|
|
#if UNITY_2020_1_OR_NEWER
|
|
switch (webRequest.result)
|
|
{
|
|
case UnityWebRequest.Result.ConnectionError:
|
|
case UnityWebRequest.Result.DataProcessingError:
|
|
case UnityWebRequest.Result.ProtocolError:
|
|
Debug.LogWarning("LRM | Network Error while getting a relay to join from Load Balancer.");
|
|
break;
|
|
|
|
case UnityWebRequest.Result.Success:
|
|
var parsedAddress = JsonConvert.DeserializeObject<RelayAddress>(result);
|
|
Connect(parsedAddress.Address, parsedAddress.Port);
|
|
endpointServerPort = parsedAddress.EndpointPort;
|
|
break;
|
|
}
|
|
#else
|
|
if (webRequest.isNetworkError || webRequest.isHttpError)
|
|
{
|
|
Debug.LogWarning("LRM | Network Error while getting a relay to join from Load Balancer.");
|
|
}
|
|
else
|
|
{
|
|
// join here
|
|
var parsedAddress = JsonConvert.DeserializeObject<RelayAddress>(result);
|
|
Connect(parsedAddress.Address, parsedAddress.Port);
|
|
endpointServerPort = parsedAddress.EndpointPort;
|
|
}
|
|
#endif
|
|
}
|
|
}
|
|
|
|
IEnumerator GetServerList()
|
|
{
|
|
if (!useLoadBalancer)
|
|
{
|
|
string uri = $"http://{serverIP}:{endpointServerPort}/api/compressed/servers";
|
|
|
|
using (UnityWebRequest webRequest = UnityWebRequest.Get(uri))
|
|
{
|
|
// Request and wait for the desired page.
|
|
yield return webRequest.SendWebRequest();
|
|
var result = webRequest.downloadHandler.text;
|
|
|
|
#if UNITY_2020_1_OR_NEWER
|
|
switch (webRequest.result)
|
|
{
|
|
case UnityWebRequest.Result.ConnectionError:
|
|
case UnityWebRequest.Result.DataProcessingError:
|
|
case UnityWebRequest.Result.ProtocolError:
|
|
Debug.LogWarning("LRM | Network Error while retreiving the server list!");
|
|
break;
|
|
|
|
case UnityWebRequest.Result.Success:
|
|
relayServerList?.Clear();
|
|
relayServerList = JsonConvert.DeserializeObject<List<Room>>(result.Decompress());
|
|
serverListUpdated?.Invoke();
|
|
break;
|
|
}
|
|
#else
|
|
if (webRequest.isNetworkError || webRequest.isHttpError)
|
|
{
|
|
Debug.LogWarning("LRM | Network Error while retreiving the server list!");
|
|
}
|
|
else
|
|
{
|
|
relayServerList?.Clear();
|
|
relayServerList = JsonConvert.DeserializeObject<List<Room>>(result.Decompress());
|
|
serverListUpdated?.Invoke();
|
|
}
|
|
#endif
|
|
}
|
|
}
|
|
else // get master list from load balancer
|
|
{
|
|
yield return StartCoroutine(RetrieveMasterServerListFromLoadBalancer());
|
|
}
|
|
|
|
}
|
|
|
|
/// <summary>
|
|
/// Gets master list from the LB.
|
|
/// This can be optimized but for now it is it's
|
|
/// own separate method, so i can understand wtf is going on :D
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
IEnumerator RetrieveMasterServerListFromLoadBalancer()
|
|
{
|
|
string uri = $"http://{loadBalancerAddress}:{loadBalancerPort}/api/masterlist/";
|
|
|
|
using (UnityWebRequest webRequest = UnityWebRequest.Get(uri))
|
|
{
|
|
// Request and wait for the desired page.
|
|
yield return webRequest.SendWebRequest();
|
|
var result = webRequest.downloadHandler.text;
|
|
|
|
#if UNITY_2020_1_OR_NEWER
|
|
switch (webRequest.result)
|
|
{
|
|
case UnityWebRequest.Result.ConnectionError:
|
|
case UnityWebRequest.Result.DataProcessingError:
|
|
case UnityWebRequest.Result.ProtocolError:
|
|
Debug.LogWarning("LRM | Network Error while retreiving the server list!");
|
|
break;
|
|
|
|
case UnityWebRequest.Result.Success:
|
|
relayServerList?.Clear();
|
|
relayServerList = JsonConvert.DeserializeObject<List<Room>>(result);
|
|
serverListUpdated?.Invoke();
|
|
break;
|
|
}
|
|
#else
|
|
if (webRequest.isNetworkError || webRequest.isHttpError)
|
|
{
|
|
Debug.LogWarning("LRM | Network Error while retreiving the server list!");
|
|
}
|
|
else
|
|
{
|
|
relayServerList?.Clear();
|
|
relayServerList = JsonConvert.DeserializeObject<List<Room>>(result);
|
|
serverListUpdated?.Invoke();
|
|
}
|
|
#endif
|
|
}
|
|
}
|
|
}
|
|
} |