mirror of
https://github.com/islehorse/HISP.git
synced 2025-06-16 07:45:11 +12:00
Add files via upload
This commit is contained in:
Bluzume
GitHub
parent
14ff669234
commit
b0652c2c83
23 changed files with 2422 additions and 2323 deletions
Horse Isle Server/Horse Isle Server
|
|
@ -1,154 +1,186 @@
|
|||
using System;
|
||||
using System.Collections.Generic;
|
||||
using System.Linq;
|
||||
using System.Net;
|
||||
using System.Net.Sockets;
|
||||
using System.Text;
|
||||
using System.Threading.Tasks;
|
||||
|
||||
namespace Horse_Isle_Server
|
||||
{
|
||||
class Server
|
||||
{
|
||||
|
||||
public static Socket ServerSocket;
|
||||
public static List<Client> ConnectedClients = new List<Client>();
|
||||
|
||||
public static void OnCrossdomainPolicyRequest(Client sender) // When a cross-domain-policy request is received.
|
||||
{
|
||||
Logger.DebugPrint("Cross-Domain-Policy request received from: " + sender.RemoteIp);
|
||||
|
||||
byte[] crossDomainPolicyResponse = CrossDomainPolicy.GetPolicy(); // Generate response packet
|
||||
|
||||
sender.SendPacket(crossDomainPolicyResponse); // Send to client.
|
||||
}
|
||||
|
||||
public static void OnUserInfoRequest(Client sender, byte[] packet)
|
||||
{
|
||||
if (!sender.LoggedIn)
|
||||
{
|
||||
Logger.ErrorPrint(sender.RemoteIp + " Requested user information when not logged in.");
|
||||
return;
|
||||
}
|
||||
Logger.DebugPrint(sender.LoggedinUser.Username + " Requesting user information.");
|
||||
byte[] userInfoPackets = PacketBuilder.CreateUserInfo(sender);
|
||||
sender.SendPacket(userInfoPackets);
|
||||
}
|
||||
|
||||
public static void OnMovementPacket(Client sender, byte[] packet)
|
||||
{
|
||||
if (!sender.LoggedIn)
|
||||
{
|
||||
Logger.ErrorPrint(sender.RemoteIp + " Sent movement packet when not logged in.");
|
||||
return;
|
||||
}
|
||||
|
||||
User loggedInUser = sender.LoggedinUser;
|
||||
byte movementDirection = packet[1];
|
||||
switch(movementDirection)
|
||||
{
|
||||
case PacketBuilder.MOVE_UP:
|
||||
if(Map.CheckPassable(loggedInUser.X, loggedInUser.Y+1))
|
||||
loggedInUser.Y -= 1;
|
||||
byte[] moveUpResponse = PacketBuilder.CreateMovementPacket(loggedInUser.X, loggedInUser.Y, loggedInUser.CharacterId, PacketBuilder.DIRECTION_UP, PacketBuilder.DIRECTION_UP, true);
|
||||
sender.SendPacket(moveUpResponse);
|
||||
break;
|
||||
case PacketBuilder.MOVE_LEFT:
|
||||
if (Map.CheckPassable(loggedInUser.X - 1, loggedInUser.Y))
|
||||
loggedInUser.X -= 1;
|
||||
byte[] moveLeftResponse = PacketBuilder.CreateMovementPacket(loggedInUser.X, loggedInUser.Y, loggedInUser.CharacterId, PacketBuilder.DIRECTION_LEFT, PacketBuilder.DIRECTION_LEFT, true);
|
||||
sender.SendPacket(moveLeftResponse);
|
||||
break;
|
||||
case PacketBuilder.MOVE_RIGHT:
|
||||
if (Map.CheckPassable(loggedInUser.X +1 , loggedInUser.Y))
|
||||
loggedInUser.X += 1;
|
||||
byte[] moveRightResponse = PacketBuilder.CreateMovementPacket(loggedInUser.X, loggedInUser.Y, loggedInUser.CharacterId, PacketBuilder.DIRECTION_RIGHT, PacketBuilder.DIRECTION_RIGHT, true);
|
||||
sender.SendPacket(moveRightResponse);
|
||||
break;
|
||||
case PacketBuilder.MOVE_DOWN:
|
||||
if (Map.CheckPassable(loggedInUser.X, loggedInUser.Y + 1))
|
||||
loggedInUser.Y += 1;
|
||||
byte[] moveDownResponse = PacketBuilder.CreateMovementPacket(loggedInUser.X, loggedInUser.Y, loggedInUser.CharacterId, PacketBuilder.DIRECTION_DOWN, PacketBuilder.DIRECTION_DOWN, true);
|
||||
sender.SendPacket(moveDownResponse);
|
||||
break;
|
||||
}
|
||||
|
||||
byte[] tileData = PacketBuilder.CreateAreaMessage(loggedInUser.X, loggedInUser.Y);
|
||||
sender.SendPacket(tileData);
|
||||
}
|
||||
public static void OnLoginRequest(Client sender, byte[] packet)
|
||||
{
|
||||
Logger.DebugPrint("Login request received from: " + sender.RemoteIp);
|
||||
|
||||
string loginRequestString = Encoding.UTF8.GetString(packet).Substring(1);
|
||||
|
||||
if (!loginRequestString.Contains('|') || packet.Length < 3)
|
||||
{
|
||||
Logger.ErrorPrint(sender.RemoteIp + " Sent an invalid login request");
|
||||
return;
|
||||
}
|
||||
|
||||
if(packet[1] != PacketBuilder.PACKET_A_TERMINATOR)
|
||||
{
|
||||
string[] loginParts = loginRequestString.Split('|');
|
||||
if (loginParts.Length < 3)
|
||||
{
|
||||
Logger.ErrorPrint(sender.RemoteIp + " Sent a login request of invalid length. " + loginRequestString);
|
||||
return;
|
||||
}
|
||||
|
||||
int version = int.Parse(loginParts[0]);
|
||||
string encryptedUsername = loginParts[1];
|
||||
string encryptedPassword = loginParts[2];
|
||||
string username = Authentication.DecryptLogin(encryptedUsername);
|
||||
string password = Authentication.DecryptLogin(encryptedPassword);
|
||||
|
||||
if (Authentication.CheckPassword(username, password))
|
||||
{
|
||||
// Obtain user information
|
||||
int userId = Database.GetUserid(username);
|
||||
sender.Login(userId);
|
||||
|
||||
byte[] ResponsePacket = PacketBuilder.CreateLoginPacket(true);
|
||||
sender.SendPacket(ResponsePacket);
|
||||
}
|
||||
else
|
||||
{
|
||||
Logger.WarnPrint(sender.RemoteIp + " Attempted to login to: " + username + " with incorrect password " + password);
|
||||
byte[] ResponsePacket = PacketBuilder.CreateLoginPacket(false);
|
||||
sender.SendPacket(ResponsePacket);
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
public static int GetNumberOfPlayers()
|
||||
{
|
||||
int count = 0;
|
||||
foreach(Client client in ConnectedClients)
|
||||
{
|
||||
if (client.LoggedIn)
|
||||
count++;
|
||||
}
|
||||
return count;
|
||||
}
|
||||
public static void StartServer()
|
||||
{
|
||||
ServerSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
|
||||
IPAddress hostIP = IPAddress.Parse(ConfigReader.BindIP);
|
||||
IPEndPoint ep = new IPEndPoint(hostIP, ConfigReader.Port);
|
||||
ServerSocket.Bind(ep);
|
||||
Logger.DebugPrint("Binding to ip: " + ConfigReader.BindIP + " On port: " + ConfigReader.Port.ToString());
|
||||
ServerSocket.Listen(10000);
|
||||
|
||||
while(true)
|
||||
{
|
||||
Logger.DebugPrint("Waiting for new connections...");
|
||||
|
||||
Socket cientSocket = ServerSocket.Accept();
|
||||
Client client = new Client(cientSocket);
|
||||
ConnectedClients.Add(client);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
using System;
|
||||
using System.Collections.Generic;
|
||||
using System.Linq;
|
||||
using System.Net;
|
||||
using System.Net.Sockets;
|
||||
using System.Text;
|
||||
using System.Threading.Tasks;
|
||||
|
||||
namespace Horse_Isle_Server
|
||||
{
|
||||
class Server
|
||||
{
|
||||
|
||||
public static Socket ServerSocket;
|
||||
public static List<Client> ConnectedClients = new List<Client>();
|
||||
|
||||
public static void OnCrossdomainPolicyRequest(Client sender) // When a cross-domain-policy request is received.
|
||||
{
|
||||
Logger.DebugPrint("Cross-Domain-Policy request received from: " + sender.RemoteIp);
|
||||
|
||||
byte[] crossDomainPolicyResponse = CrossDomainPolicy.GetPolicy(); // Generate response packet
|
||||
|
||||
sender.SendPacket(crossDomainPolicyResponse); // Send to client.
|
||||
}
|
||||
|
||||
public static void OnUserInfoRequest(Client sender, byte[] packet)
|
||||
{
|
||||
if (!sender.LoggedIn)
|
||||
{
|
||||
Logger.ErrorPrint(sender.RemoteIp + " Requested user information when not logged in.");
|
||||
return;
|
||||
}
|
||||
Logger.DebugPrint(sender.LoggedinUser.Username + " Requesting user information.");
|
||||
byte[] userInfoPackets = PacketBuilder.CreateUserInfo(sender);
|
||||
sender.SendPacket(userInfoPackets);
|
||||
}
|
||||
|
||||
public static void OnMovementPacket(Client sender, byte[] packet)
|
||||
{
|
||||
if (!sender.LoggedIn)
|
||||
{
|
||||
Logger.ErrorPrint(sender.RemoteIp + " Sent movement packet when not logged in.");
|
||||
return;
|
||||
}
|
||||
|
||||
User loggedInUser = sender.LoggedinUser;
|
||||
byte movementDirection = packet[1];
|
||||
|
||||
if(movementDirection == PacketBuilder.MOVE_UP)
|
||||
{
|
||||
if (Map.CheckPassable(loggedInUser.X, loggedInUser.Y - 1))
|
||||
{
|
||||
loggedInUser.Y -= 1;
|
||||
byte[] moveUpResponse = PacketBuilder.CreateMovementPacket(loggedInUser.X, loggedInUser.Y, loggedInUser.CharacterId, PacketBuilder.DIRECTION_UP, PacketBuilder.DIRECTION_UP, true);
|
||||
sender.SendPacket(moveUpResponse);
|
||||
}
|
||||
else
|
||||
{
|
||||
byte[] moveUpResponse = PacketBuilder.CreateMovementPacket(loggedInUser.X, loggedInUser.Y, loggedInUser.CharacterId, PacketBuilder.DIRECTION_UP, PacketBuilder.DIRECTION_NONE, false);
|
||||
sender.SendPacket(moveUpResponse);
|
||||
}
|
||||
}
|
||||
else if(movementDirection == PacketBuilder.MOVE_LEFT)
|
||||
{
|
||||
if (Map.CheckPassable(loggedInUser.X - 1, loggedInUser.Y))
|
||||
{
|
||||
loggedInUser.X -= 1;
|
||||
byte[] moveLeftResponse = PacketBuilder.CreateMovementPacket(loggedInUser.X, loggedInUser.Y, loggedInUser.CharacterId, PacketBuilder.DIRECTION_LEFT, PacketBuilder.DIRECTION_LEFT, true);
|
||||
sender.SendPacket(moveLeftResponse);
|
||||
}
|
||||
else
|
||||
{
|
||||
byte[] moveLeftResponse = PacketBuilder.CreateMovementPacket(loggedInUser.X, loggedInUser.Y, loggedInUser.CharacterId, PacketBuilder.DIRECTION_LEFT, PacketBuilder.DIRECTION_NONE, false);
|
||||
sender.SendPacket(moveLeftResponse);
|
||||
}
|
||||
}
|
||||
else if(movementDirection == PacketBuilder.MOVE_RIGHT)
|
||||
{
|
||||
if (Map.CheckPassable(loggedInUser.X + 1, loggedInUser.Y))
|
||||
{
|
||||
loggedInUser.X += 1;
|
||||
byte[] moveLeftResponse = PacketBuilder.CreateMovementPacket(loggedInUser.X, loggedInUser.Y, loggedInUser.CharacterId, PacketBuilder.DIRECTION_RIGHT, PacketBuilder.DIRECTION_RIGHT, true);
|
||||
sender.SendPacket(moveLeftResponse);
|
||||
}
|
||||
else
|
||||
{
|
||||
byte[] moveLeftResponse = PacketBuilder.CreateMovementPacket(loggedInUser.X, loggedInUser.Y, loggedInUser.CharacterId, PacketBuilder.DIRECTION_RIGHT, PacketBuilder.DIRECTION_NONE, false);
|
||||
sender.SendPacket(moveLeftResponse);
|
||||
}
|
||||
}
|
||||
else if(movementDirection == PacketBuilder.MOVE_DOWN)
|
||||
{
|
||||
if (Map.CheckPassable(loggedInUser.X, loggedInUser.Y + 1))
|
||||
{
|
||||
loggedInUser.Y += 1;
|
||||
byte[] moveDownResponse = PacketBuilder.CreateMovementPacket(loggedInUser.X, loggedInUser.Y, loggedInUser.CharacterId, PacketBuilder.DIRECTION_DOWN, PacketBuilder.DIRECTION_DOWN, true);
|
||||
sender.SendPacket(moveDownResponse);
|
||||
}
|
||||
else
|
||||
{
|
||||
byte[] moveDownResponse = PacketBuilder.CreateMovementPacket(loggedInUser.X, loggedInUser.Y, loggedInUser.CharacterId, PacketBuilder.DIRECTION_DOWN, PacketBuilder.DIRECTION_NONE, false);
|
||||
sender.SendPacket(moveDownResponse);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
|
||||
byte[] tileData = PacketBuilder.CreateAreaMessage(loggedInUser.X, loggedInUser.Y);
|
||||
sender.SendPacket(tileData);
|
||||
}
|
||||
public static void OnLoginRequest(Client sender, byte[] packet)
|
||||
{
|
||||
Logger.DebugPrint("Login request received from: " + sender.RemoteIp);
|
||||
|
||||
string loginRequestString = Encoding.UTF8.GetString(packet).Substring(1);
|
||||
|
||||
if (!loginRequestString.Contains('|') || packet.Length < 3)
|
||||
{
|
||||
Logger.ErrorPrint(sender.RemoteIp + " Sent an invalid login request");
|
||||
return;
|
||||
}
|
||||
|
||||
if(packet[1] != PacketBuilder.PACKET_A_TERMINATOR)
|
||||
{
|
||||
string[] loginParts = loginRequestString.Split('|');
|
||||
if (loginParts.Length < 3)
|
||||
{
|
||||
Logger.ErrorPrint(sender.RemoteIp + " Sent a login request of invalid length. " + loginRequestString);
|
||||
return;
|
||||
}
|
||||
|
||||
int version = int.Parse(loginParts[0]);
|
||||
string encryptedUsername = loginParts[1];
|
||||
string encryptedPassword = loginParts[2];
|
||||
string username = Authentication.DecryptLogin(encryptedUsername);
|
||||
string password = Authentication.DecryptLogin(encryptedPassword);
|
||||
|
||||
if (Authentication.CheckPassword(username, password))
|
||||
{
|
||||
// Obtain user information
|
||||
int userId = Database.GetUserid(username);
|
||||
sender.Login(userId);
|
||||
|
||||
byte[] ResponsePacket = PacketBuilder.CreateLoginPacket(true);
|
||||
sender.SendPacket(ResponsePacket);
|
||||
}
|
||||
else
|
||||
{
|
||||
Logger.WarnPrint(sender.RemoteIp + " Attempted to login to: " + username + " with incorrect password " + password);
|
||||
byte[] ResponsePacket = PacketBuilder.CreateLoginPacket(false);
|
||||
sender.SendPacket(ResponsePacket);
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
public static int GetNumberOfPlayers()
|
||||
{
|
||||
int count = 0;
|
||||
foreach(Client client in ConnectedClients)
|
||||
{
|
||||
if (client.LoggedIn)
|
||||
count++;
|
||||
}
|
||||
return count;
|
||||
}
|
||||
public static void StartServer()
|
||||
{
|
||||
ServerSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
|
||||
IPAddress hostIP = IPAddress.Parse(ConfigReader.BindIP);
|
||||
IPEndPoint ep = new IPEndPoint(hostIP, ConfigReader.Port);
|
||||
ServerSocket.Bind(ep);
|
||||
Logger.DebugPrint("Binding to ip: " + ConfigReader.BindIP + " On port: " + ConfigReader.Port.ToString());
|
||||
ServerSocket.Listen(10000);
|
||||
|
||||
while(true)
|
||||
{
|
||||
Logger.DebugPrint("Waiting for new connections...");
|
||||
|
||||
Socket cientSocket = ServerSocket.Accept();
|
||||
Client client = new Client(cientSocket);
|
||||
ConnectedClients.Add(client);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue