terraria-source-code/Terraria/Netplay.cs
TheVamp 0462173018 Version 1.2.0.3.1
Decompiled with IlSpy
Fixes Source Code
2013-10-12 11:25:17 +02:00

740 lines
18 KiB
C#

using System;
using System.IO;
using System.Net;
using System.Net.Sockets;
using System.Threading;
namespace Terraria
{
public class Netplay
{
public const int bufferSize = 1024;
public const int maxConnections = 256;
public static bool stopListen = false;
public static ServerSock[] serverSock = new ServerSock[256];
public static ClientSock clientSock = new ClientSock();
public static TcpListener tcpListener;
public static IPAddress serverListenIP;
public static IPAddress serverIP;
public static int serverPort = 7777;
public static bool disconnect = false;
public static string password = "";
public static string banFile = "banlist.txt";
public static bool spamCheck = false;
public static bool anyClients = false;
public static string portForwardIP;
public static int portForwardPort;
public static bool portForwardOpen;
public static bool uPNP = true;
public static bool ServerUp = false;
public static void openPort()
{
Netplay.portForwardIP = Netplay.LocalIPAddress();
Netplay.portForwardPort = Netplay.serverPort;
}
public static void closePort()
{
}
public static string LocalIPAddress()
{
string result = "";
IPHostEntry hostEntry = Dns.GetHostEntry(Dns.GetHostName());
IPAddress[] addressList = hostEntry.AddressList;
for (int i = 0; i < addressList.Length; i++)
{
IPAddress iPAddress = addressList[i];
if (iPAddress.AddressFamily == AddressFamily.InterNetwork)
{
result = iPAddress.ToString();
break;
}
}
return result;
}
public static void ResetNetDiag()
{
Main.rxMsg = 0;
Main.rxData = 0;
Main.txMsg = 0;
Main.txData = 0;
for (int i = 0; i < Main.maxMsg; i++)
{
Main.rxMsgType[i] = 0;
Main.rxDataType[i] = 0;
Main.txMsgType[i] = 0;
Main.txDataType[i] = 0;
}
}
public static void ResetSections()
{
for (int i = 0; i < 256; i++)
{
for (int j = 0; j < Main.maxSectionsX; j++)
{
for (int k = 0; k < Main.maxSectionsY; k++)
{
Netplay.serverSock[i].tileSection[j, k] = false;
}
}
}
}
public static void AddBan(int plr)
{
string text = Netplay.serverSock[plr].tcpClient.Client.RemoteEndPoint.ToString();
string value = text;
for (int i = 0; i < text.Length; i++)
{
if (text.Substring(i, 1) == ":")
{
value = text.Substring(0, i);
}
}
using (StreamWriter streamWriter = new StreamWriter(Netplay.banFile, true))
{
streamWriter.WriteLine("//" + Main.player[plr].name);
streamWriter.WriteLine(value);
}
}
public static bool CheckBan(string ip)
{
try
{
string b = ip;
for (int i = 0; i < ip.Length; i++)
{
if (ip.Substring(i, 1) == ":")
{
b = ip.Substring(0, i);
}
}
if (File.Exists(Netplay.banFile))
{
using (StreamReader streamReader = new StreamReader(Netplay.banFile))
{
string a;
while ((a = streamReader.ReadLine()) != null)
{
if (a == b)
{
return true;
}
}
}
}
}
catch
{
}
return false;
}
public static void newRecent()
{
for (int i = 0; i < Main.maxMP; i++)
{
if (Main.recentIP[i] == Netplay.serverIP.ToString() && Main.recentPort[i] == Netplay.serverPort)
{
for (int j = i; j < Main.maxMP - 1; j++)
{
Main.recentIP[j] = Main.recentIP[j + 1];
Main.recentPort[j] = Main.recentPort[j + 1];
Main.recentWorld[j] = Main.recentWorld[j + 1];
}
}
}
for (int k = Main.maxMP - 1; k > 0; k--)
{
Main.recentIP[k] = Main.recentIP[k - 1];
Main.recentPort[k] = Main.recentPort[k - 1];
Main.recentWorld[k] = Main.recentWorld[k - 1];
}
Main.recentIP[0] = Netplay.serverIP.ToString();
Main.recentPort[0] = Netplay.serverPort;
Main.recentWorld[0] = Main.worldName;
Main.SaveRecent();
}
public static void ClientLoop(object threadContext)
{
Netplay.ResetNetDiag();
Main.ServerSideCharacter = false;
if (Main.rand == null)
{
Main.rand = new Random((int)DateTime.Now.Ticks);
}
if (WorldGen.genRand == null)
{
WorldGen.genRand = new Random((int)DateTime.Now.Ticks);
}
Main.player[Main.myPlayer].hostile = false;
Main.clientPlayer = (Player)Main.player[Main.myPlayer].clientClone();
for (int i = 0; i < 255; i++)
{
if (i != Main.myPlayer)
{
Main.player[i] = new Player();
}
}
Main.menuMode = 10;
Main.menuMode = 14;
if (!Main.autoPass)
{
Main.statusText = "Connecting to " + Netplay.serverIP;
}
Main.netMode = 1;
Netplay.disconnect = false;
Netplay.clientSock = new ClientSock();
Netplay.clientSock.tcpClient.NoDelay = true;
Netplay.clientSock.readBuffer = new byte[1024];
Netplay.clientSock.writeBuffer = new byte[1024];
bool flag = true;
while (flag)
{
flag = false;
try
{
Netplay.clientSock.tcpClient.Connect(Netplay.serverIP, Netplay.serverPort);
Netplay.clientSock.networkStream = Netplay.clientSock.tcpClient.GetStream();
flag = false;
}
catch
{
if (!Netplay.disconnect && Main.gameMenu)
{
flag = true;
}
}
}
NetMessage.buffer[256].Reset();
int num = -1;
while (!Netplay.disconnect)
{
if (Netplay.clientSock.tcpClient.Connected)
{
if (NetMessage.buffer[256].checkBytes)
{
NetMessage.CheckBytes(256);
}
Netplay.clientSock.active = true;
if (Netplay.clientSock.state == 0)
{
Main.statusText = "Found server";
Netplay.clientSock.state = 1;
NetMessage.SendData(1, -1, -1, "", 0, 0f, 0f, 0f, 0);
}
if (Netplay.clientSock.state == 2 && num != Netplay.clientSock.state)
{
Main.statusText = "Sending player data...";
}
if (Netplay.clientSock.state == 3 && num != Netplay.clientSock.state)
{
Main.statusText = "Requesting world information";
}
if (Netplay.clientSock.state == 4)
{
WorldGen.worldCleared = false;
Netplay.clientSock.state = 5;
if (Main.cloudBGActive >= 1f)
{
Main.cloudBGAlpha = 1f;
}
else
{
Main.cloudBGAlpha = 0f;
}
Main.windSpeed = Main.windSpeedSet;
Cloud.resetClouds();
Main.cloudAlpha = Main.maxRaining;
WorldGen.clearWorld();
if (Main.mapEnabled)
{
Map.loadMap();
}
}
if (Netplay.clientSock.state == 5 && Main.loadMapLock)
{
float num2 = (float)Main.loadMapLastX / (float)Main.maxTilesX;
Main.statusText = string.Concat(new object[]
{
Lang.gen[68],
" ",
(int)(num2 * 100f + 1f),
"%"
});
}
else
{
if (Netplay.clientSock.state == 5 && WorldGen.worldCleared)
{
Netplay.clientSock.state = 6;
Main.player[Main.myPlayer].FindSpawn();
NetMessage.SendData(8, -1, -1, "", Main.player[Main.myPlayer].SpawnX, (float)Main.player[Main.myPlayer].SpawnY, 0f, 0f, 0);
}
}
if (Netplay.clientSock.state == 6 && num != Netplay.clientSock.state)
{
Main.statusText = "Requesting tile data";
}
if (!Netplay.clientSock.locked && !Netplay.disconnect && Netplay.clientSock.networkStream.DataAvailable)
{
Netplay.clientSock.locked = true;
Netplay.clientSock.networkStream.BeginRead(Netplay.clientSock.readBuffer, 0, Netplay.clientSock.readBuffer.Length, new AsyncCallback(Netplay.clientSock.ClientReadCallBack), Netplay.clientSock.networkStream);
}
if (Netplay.clientSock.statusMax > 0 && Netplay.clientSock.statusText != "")
{
if (Netplay.clientSock.statusCount >= Netplay.clientSock.statusMax)
{
Main.statusText = Netplay.clientSock.statusText + ": Complete!";
Netplay.clientSock.statusText = "";
Netplay.clientSock.statusMax = 0;
Netplay.clientSock.statusCount = 0;
}
else
{
Main.statusText = string.Concat(new object[]
{
Netplay.clientSock.statusText,
": ",
(int)((float)Netplay.clientSock.statusCount / (float)Netplay.clientSock.statusMax * 100f),
"%"
});
}
}
Thread.Sleep(1);
}
else
{
if (Netplay.clientSock.active)
{
Main.statusText = "Lost connection";
Netplay.disconnect = true;
}
}
num = Netplay.clientSock.state;
}
try
{
Netplay.clientSock.networkStream.Close();
Netplay.clientSock.networkStream = Netplay.clientSock.tcpClient.GetStream();
}
catch
{
}
if (!Main.gameMenu)
{
Main.netMode = 0;
Player.SavePlayer(Main.player[Main.myPlayer], Main.playerPathName);
Main.gameMenu = true;
Main.menuMode = 14;
}
NetMessage.buffer[256].Reset();
if (Main.menuMode == 15 && Main.statusText == "Lost connection")
{
Main.menuMode = 14;
}
if (Netplay.clientSock.statusText != "" && Netplay.clientSock.statusText != null)
{
Main.statusText = "Lost connection";
}
Netplay.clientSock.statusCount = 0;
Netplay.clientSock.statusMax = 0;
Netplay.clientSock.statusText = "";
Main.netMode = 0;
}
public static void ServerLoop(object threadContext)
{
Netplay.ResetNetDiag();
if (Main.rand == null)
{
Main.rand = new Random((int)DateTime.Now.Ticks);
}
if (WorldGen.genRand == null)
{
WorldGen.genRand = new Random((int)DateTime.Now.Ticks);
}
Main.myPlayer = 255;
Netplay.serverIP = IPAddress.Any;
Netplay.serverListenIP = Netplay.serverIP;
Main.menuMode = 14;
Main.statusText = "Starting server...";
Main.netMode = 2;
Netplay.disconnect = false;
for (int i = 0; i < 256; i++)
{
Netplay.serverSock[i] = new ServerSock();
Netplay.serverSock[i].Reset();
Netplay.serverSock[i].whoAmI = i;
Netplay.serverSock[i].tcpClient = new TcpClient();
Netplay.serverSock[i].tcpClient.NoDelay = true;
Netplay.serverSock[i].readBuffer = new byte[1024];
Netplay.serverSock[i].writeBuffer = new byte[1024];
}
Netplay.tcpListener = new TcpListener(Netplay.serverListenIP, Netplay.serverPort);
try
{
Netplay.tcpListener.Start();
}
catch (Exception ex)
{
Main.menuMode = 15;
Main.statusText = ex.ToString();
Netplay.disconnect = true;
}
if (!Netplay.disconnect)
{
ThreadPool.QueueUserWorkItem(new WaitCallback(Netplay.ListenForClients), 1);
Main.statusText = "Server started";
}
if (Netplay.uPNP)
{
try
{
Netplay.openPort();
}
catch
{
}
}
int num = 0;
while (!Netplay.disconnect)
{
if (Netplay.stopListen)
{
int num2 = -1;
for (int j = 0; j < Main.maxNetPlayers; j++)
{
if (!Netplay.serverSock[j].tcpClient.Connected)
{
num2 = j;
break;
}
}
if (num2 >= 0)
{
if (Main.ignoreErrors)
{
try
{
Netplay.tcpListener.Start();
Netplay.stopListen = false;
ThreadPool.QueueUserWorkItem(new WaitCallback(Netplay.ListenForClients), 1);
goto IL_219;
}
catch
{
goto IL_219;
}
}
Netplay.tcpListener.Start();
Netplay.stopListen = false;
ThreadPool.QueueUserWorkItem(new WaitCallback(Netplay.ListenForClients), 1);
}
}
IL_219:
int num3 = 0;
for (int k = 0; k < 256; k++)
{
if (NetMessage.buffer[k].checkBytes)
{
NetMessage.CheckBytes(k);
}
if (Netplay.serverSock[k].kill)
{
Netplay.serverSock[k].Reset();
NetMessage.syncPlayers();
}
else
{
if (Netplay.serverSock[k].tcpClient.Connected)
{
if (!Netplay.serverSock[k].active)
{
Netplay.serverSock[k].state = 0;
}
Netplay.serverSock[k].active = true;
num3++;
if (!Netplay.serverSock[k].locked)
{
try
{
Netplay.serverSock[k].networkStream = Netplay.serverSock[k].tcpClient.GetStream();
if (Netplay.serverSock[k].networkStream.DataAvailable)
{
Netplay.serverSock[k].locked = true;
Netplay.serverSock[k].networkStream.BeginRead(Netplay.serverSock[k].readBuffer, 0, Netplay.serverSock[k].readBuffer.Length, new AsyncCallback(Netplay.serverSock[k].ServerReadCallBack), Netplay.serverSock[k].networkStream);
}
}
catch
{
Netplay.serverSock[k].kill = true;
}
}
if (Netplay.serverSock[k].statusMax > 0 && Netplay.serverSock[k].statusText2 != "")
{
if (Netplay.serverSock[k].statusCount >= Netplay.serverSock[k].statusMax)
{
Netplay.serverSock[k].statusText = string.Concat(new object[]
{
"(",
Netplay.serverSock[k].tcpClient.Client.RemoteEndPoint,
") ",
Netplay.serverSock[k].name,
" ",
Netplay.serverSock[k].statusText2,
": Complete!"
});
Netplay.serverSock[k].statusText2 = "";
Netplay.serverSock[k].statusMax = 0;
Netplay.serverSock[k].statusCount = 0;
}
else
{
Netplay.serverSock[k].statusText = string.Concat(new object[]
{
"(",
Netplay.serverSock[k].tcpClient.Client.RemoteEndPoint,
") ",
Netplay.serverSock[k].name,
" ",
Netplay.serverSock[k].statusText2,
": ",
(int)((float)Netplay.serverSock[k].statusCount / (float)Netplay.serverSock[k].statusMax * 100f),
"%"
});
}
}
else
{
if (Netplay.serverSock[k].state == 0)
{
Netplay.serverSock[k].statusText = string.Concat(new object[]
{
"(",
Netplay.serverSock[k].tcpClient.Client.RemoteEndPoint,
") ",
Netplay.serverSock[k].name,
" is connecting..."
});
}
else
{
if (Netplay.serverSock[k].state == 1)
{
Netplay.serverSock[k].statusText = string.Concat(new object[]
{
"(",
Netplay.serverSock[k].tcpClient.Client.RemoteEndPoint,
") ",
Netplay.serverSock[k].name,
" is sending player data..."
});
}
else
{
if (Netplay.serverSock[k].state == 2)
{
Netplay.serverSock[k].statusText = string.Concat(new object[]
{
"(",
Netplay.serverSock[k].tcpClient.Client.RemoteEndPoint,
") ",
Netplay.serverSock[k].name,
" requested world information"
});
}
else
{
if (Netplay.serverSock[k].state != 3 && Netplay.serverSock[k].state == 10)
{
Netplay.serverSock[k].statusText = string.Concat(new object[]
{
"(",
Netplay.serverSock[k].tcpClient.Client.RemoteEndPoint,
") ",
Netplay.serverSock[k].name,
" is playing"
});
}
}
}
}
}
}
else
{
if (Netplay.serverSock[k].active)
{
Netplay.serverSock[k].kill = true;
}
else
{
Netplay.serverSock[k].statusText2 = "";
if (k < 255)
{
Main.player[k].active = false;
}
}
}
}
}
num++;
if (num > 10)
{
Thread.Sleep(1);
num = 0;
}
else
{
Thread.Sleep(0);
}
if (!WorldGen.saveLock && !Main.dedServ)
{
if (num3 == 0)
{
Main.statusText = "Waiting for clients...";
}
else
{
Main.statusText = num3 + " clients connected";
}
}
if (num3 == 0)
{
Netplay.anyClients = false;
}
else
{
Netplay.anyClients = true;
}
Netplay.ServerUp = true;
}
Netplay.tcpListener.Stop();
try
{
Netplay.closePort();
}
catch
{
}
for (int l = 0; l < 256; l++)
{
Netplay.serverSock[l].Reset();
}
if (Main.menuMode != 15)
{
Main.netMode = 0;
Main.menuMode = 10;
WorldGen.saveWorld(false);
while (WorldGen.saveLock)
{
}
Main.menuMode = 0;
}
else
{
Main.netMode = 0;
}
Main.myPlayer = 0;
}
public static void ListenForClients(object threadContext)
{
while (!Netplay.disconnect && !Netplay.stopListen)
{
int num = -1;
for (int i = 0; i < Main.maxNetPlayers; i++)
{
if (!Netplay.serverSock[i].tcpClient.Connected)
{
num = i;
break;
}
}
if (num >= 0)
{
try
{
Netplay.serverSock[num].tcpClient = Netplay.tcpListener.AcceptTcpClient();
Netplay.serverSock[num].tcpClient.NoDelay = true;
Console.WriteLine(Netplay.serverSock[num].tcpClient.Client.RemoteEndPoint + " is connecting...");
continue;
}
catch (Exception ex)
{
if (!Netplay.disconnect)
{
Main.menuMode = 15;
Main.statusText = ex.ToString();
Netplay.disconnect = true;
}
continue;
}
}
Netplay.stopListen = true;
Netplay.tcpListener.Stop();
}
}
public static void StartClient()
{
ThreadPool.QueueUserWorkItem(new WaitCallback(Netplay.ClientLoop), 1);
}
public static void StartServer()
{
ThreadPool.QueueUserWorkItem(new WaitCallback(Netplay.ServerLoop), 1);
}
public static bool SetIP(string newIP)
{
try
{
Netplay.serverIP = IPAddress.Parse(newIP);
}
catch
{
return false;
}
return true;
}
public static bool SetIP2(string newIP)
{
bool result;
try
{
IPHostEntry hostEntry = Dns.GetHostEntry(newIP);
IPAddress[] addressList = hostEntry.AddressList;
for (int i = 0; i < addressList.Length; i++)
{
if (addressList[i].AddressFamily == AddressFamily.InterNetwork)
{
Netplay.serverIP = addressList[i];
result = true;
return result;
}
}
result = false;
}
catch
{
result = false;
}
return result;
}
public static void Init()
{
for (int i = 0; i < 257; i++)
{
if (i < 256)
{
Netplay.serverSock[i] = new ServerSock();
Netplay.serverSock[i].tcpClient.NoDelay = true;
}
NetMessage.buffer[i] = new messageBuffer();
NetMessage.buffer[i].whoAmI = i;
}
Netplay.clientSock.tcpClient.NoDelay = true;
}
public static int GetSectionX(int x)
{
return x / 200;
}
public static int GetSectionY(int y)
{
return y / 150;
}
}
}