TheRaven/RavenNetListener.csharp

84 lines
3.2 KiB
Plaintext

using System;
using System.Linq;
using System.Net;
using System.Net.Sockets;
using System.Threading;
using AniNIX.Shared;
namespace AniNIX.TheRaven {
//TODO Add comments
//IRC messages are a primitive data type for us to use.
public class RavenNetListener {
private String _key;
private int _port;
private Connection _ircdConnection;
private void _RavenSend(Connection ircdConnection, String channel, String message) {
IRCClientMessage ircMessage = new IRCClientMessage();
ircMessage.PrivMsg(message,channel);
ircdConnection.Write(ircMessage);
}
private void _netThread() {
while (true) {
try
{
// Open a new listener on port
IPAddress ipAddress = IPAddress.Parse("0.0.0.0");
TcpListener listener = new TcpListener(ipAddress, this._port );
listener.Start();
// Accept all connections
while (true)
{
Socket client = listener.AcceptSocket();
byte[] data = new byte[512];
int size = client.Receive(data);
// Receive and parse string.
string received = "";
for (int i = 0; i < size; i++)
received += Convert.ToChar(data[i]);
ReportMessage.Log(Verbosity.Verbose,String.Format("RavenNetListener received: [{0}]",received));
String[] bySpace = received.Split(' ');
// If the key matches, ...
if (this._key.Equals(bySpace[0])) {
ReportMessage.Log(Verbosity.Verbose,"Accepted passphrase -- sending message.");
String channel = bySpace[1];
String message = String.Join(" ",bySpace.Skip(2).ToArray());
// Send to IRC
_RavenSend(_ircdConnection,channel,message);
} else {
ReportMessage.Log(Verbosity.Error,"Passphrase rejected for NetListener connection.");
}
//Clean up
client.Close();
}
}
// If we got here, something went wrong. Log.
catch (Exception e)
{
ReportMessage.Log(Verbosity.Error,String.Format("RavenNetListener died for unknown reason: {0}",e.Message));
}
}
}
public void NetListener(Connection ircdConnection) {
this._ircdConnection = ircdConnection;
ReportMessage.Log(Verbosity.Verbose,"Starting NetListener thread...");
ThreadStart netListenerWorker = _netThread;
Thread netListenerThread = new Thread(netListenerWorker);
netListenerThread.Start();
ReportMessage.Log(Verbosity.Verbose,"Started.");
}
public RavenNetListener(String key, int port) {
this._key = key;
this._port = port;
}
}
}