mirror of
https://github.com/opensim/opensim.git
synced 2026-08-05 17:05:55 +08:00
cleaning up IRCBridgeModule to allow for configuration from in-world,
chat relaying via private channels, and old IRCBridgeModule behaviour. also cleaning up IRCBridgeModule's OpenSim.ini configuration variable names (still supporting "old" variable names). refactored IRCChatModule into IRCConnector and incorporating watchdog from IRCBridgeModule into IRCConnector. enabling ChatModule to be used as a super-class and utilizing it in ConciergeModule.
This commit is contained in:
Dr Scofield
@@ -48,10 +48,8 @@ namespace OpenSim.Region.Environment.Modules.Avatar.Chat
|
||||
|
||||
private const int DEBUG_CHANNEL = 2147483647;
|
||||
|
||||
private string m_defaultzone = null;
|
||||
|
||||
private IRCChatModule m_irc = null;
|
||||
private Thread m_irc_connector = null;
|
||||
private IRCConnector m_irc = null;
|
||||
|
||||
private string m_last_leaving_user = null;
|
||||
private string m_last_new_user = null;
|
||||
@@ -61,6 +59,12 @@ namespace OpenSim.Region.Environment.Modules.Avatar.Chat
|
||||
internal object m_syncLogout = new object();
|
||||
|
||||
private IConfig m_config;
|
||||
private string m_defaultzone = null;
|
||||
private bool m_commandsEnabled = false;
|
||||
private int m_commandChannel = -1;
|
||||
private bool m_relayPrivateChannels = false;
|
||||
private int m_relayChannelOut = -1;
|
||||
private bool m_clientReporting = true;
|
||||
|
||||
#region IRegionModule Members
|
||||
|
||||
@@ -86,6 +90,15 @@ namespace OpenSim.Region.Environment.Modules.Avatar.Chat
|
||||
return;
|
||||
}
|
||||
|
||||
m_commandsEnabled = m_config.GetBoolean("commands_enabled", m_commandsEnabled);
|
||||
m_commandChannel = m_config.GetInt("commandchannel", m_commandChannel); // compat
|
||||
m_commandChannel = m_config.GetInt("command_channel", m_commandChannel);
|
||||
|
||||
m_relayPrivateChannels = m_config.GetBoolean("relay_private_channels", m_relayPrivateChannels);
|
||||
m_relayChannelOut = m_config.GetInt("relay_private_channel_out", m_relayChannelOut);
|
||||
|
||||
m_clientReporting = m_config.GetBoolean("report_clients", m_clientReporting);
|
||||
|
||||
lock (m_syncInit)
|
||||
{
|
||||
|
||||
@@ -110,43 +123,21 @@ namespace OpenSim.Region.Environment.Modules.Avatar.Chat
|
||||
// setup IRC Relay
|
||||
if (m_irc == null)
|
||||
{
|
||||
m_irc = new IRCChatModule(config);
|
||||
m_irc = new IRCConnector(config);
|
||||
}
|
||||
|
||||
if (m_irc_connector == null)
|
||||
{
|
||||
m_irc_connector = new Thread(IRCConnectRun);
|
||||
m_irc_connector.Name = "IRCConnectorThread";
|
||||
m_irc_connector.IsBackground = true;
|
||||
}
|
||||
m_log.InfoFormat("[IRC] initialized for {0}, nick: {1} ", scene.RegionInfo.RegionName,
|
||||
m_defaultzone);
|
||||
m_irc.AddScene(scene);
|
||||
|
||||
m_log.InfoFormat("[IRC] initialized for {0}, nick: {1}, commands {2}, private channels {3}",
|
||||
scene.RegionInfo.RegionName, m_defaultzone,
|
||||
m_commandsEnabled ? "enabled" : "not enabled",
|
||||
m_relayPrivateChannels ? "relayed" : "not relayed");
|
||||
}
|
||||
}
|
||||
|
||||
public void PostInitialise()
|
||||
{
|
||||
if (null == m_irc || !m_irc.Enabled) return;
|
||||
|
||||
try
|
||||
{
|
||||
//m_irc.Connect(m_scenes);
|
||||
if (m_irc_connector == null)
|
||||
{
|
||||
m_irc_connector = new Thread(IRCConnectRun);
|
||||
m_irc_connector.Name = "IRCConnectorThread";
|
||||
m_irc_connector.IsBackground = true;
|
||||
}
|
||||
|
||||
if (!m_irc_connector.IsAlive)
|
||||
{
|
||||
m_irc_connector.Start();
|
||||
ThreadTracker.Add(m_irc_connector);
|
||||
}
|
||||
}
|
||||
catch (Exception)
|
||||
{
|
||||
}
|
||||
m_irc.Start();
|
||||
}
|
||||
|
||||
public void Close()
|
||||
@@ -172,14 +163,21 @@ namespace OpenSim.Region.Environment.Modules.Avatar.Chat
|
||||
|
||||
#region ISimChat Members
|
||||
|
||||
public void OnSimChat(Object sender, OSChatMessage e)
|
||||
public void OnSimChat(Object sender, OSChatMessage c)
|
||||
{
|
||||
m_log.DebugFormat("[IRC] heard on channel {0}: {1}", e.Channel.ToString(), e.Message);
|
||||
// early return if nothing to forward
|
||||
if (c.Message.Length == 0) return;
|
||||
|
||||
// We only want to relay stuff on channel 0
|
||||
if (e.Channel == m_irc.m_commandChannel)
|
||||
// early return if this comes from the IRC forwarder
|
||||
if (m_irc.Equals(sender)) return;
|
||||
|
||||
m_log.DebugFormat("[IRC] heard on channel {0}: {1}", c.Channel, c.Message);
|
||||
|
||||
// check for commands coming from avatars or in-world
|
||||
// object (if commands are enabled)
|
||||
if (m_commandsEnabled && c.Channel == m_commandChannel)
|
||||
{
|
||||
string[] messages = e.Message.Split(' ');
|
||||
string[] messages = c.Message.Split(' ');
|
||||
string command = messages[0].ToLower();
|
||||
|
||||
try
|
||||
@@ -187,146 +185,135 @@ namespace OpenSim.Region.Environment.Modules.Avatar.Chat
|
||||
switch (command)
|
||||
{
|
||||
case "channel":
|
||||
m_irc.m_channel = messages[1];
|
||||
m_irc.IrcChannel = messages[1];
|
||||
break;
|
||||
case "close":
|
||||
m_irc.Close();
|
||||
break;
|
||||
case "connect":
|
||||
m_irc.Connect(m_scenes);
|
||||
m_irc.Connect();
|
||||
break;
|
||||
case "nick":
|
||||
m_irc.m_nick = messages[1];
|
||||
m_irc.Nick = messages[1];
|
||||
break;
|
||||
case "port":
|
||||
m_irc.m_port = Convert.ToUInt32(messages[1]);
|
||||
m_irc.Port = Convert.ToUInt32(messages[1]);
|
||||
break;
|
||||
case "reconnect":
|
||||
m_irc.Reconnect();
|
||||
break;
|
||||
case "server":
|
||||
m_irc.m_server = messages[1];
|
||||
m_irc.Server = messages[1];
|
||||
break;
|
||||
case "verbosity":
|
||||
m_irc.m_verbosity = Convert.ToInt32(messages[1]);
|
||||
case "client-reporting":
|
||||
m_irc.ClientReporting = Convert.ToBoolean(messages[1]);
|
||||
|
||||
break;
|
||||
case "in-channel":
|
||||
m_irc.m_messageOutChannel = Convert.ToInt32(messages[1]);
|
||||
m_irc.RelayChannel = Convert.ToInt32(messages[1]);
|
||||
break;
|
||||
case "out-channel":
|
||||
m_irc.m_messageInChannel = Convert.ToInt32(messages[1]);
|
||||
m_relayChannelOut = Convert.ToInt32(messages[1]);
|
||||
break;
|
||||
|
||||
default:
|
||||
m_irc.Send(e.Message);
|
||||
m_irc.Send(c.Message);
|
||||
break;
|
||||
}
|
||||
}
|
||||
catch
|
||||
{ }
|
||||
catch(Exception ex)
|
||||
{
|
||||
m_log.DebugFormat("[IRC] error processing in-world command channel input: {0}", ex);
|
||||
}
|
||||
}
|
||||
|
||||
if (e.Channel != m_irc.m_messageOutChannel) return;
|
||||
if (e.Message.Length == 0) return;
|
||||
|
||||
// not interested in our own babblings
|
||||
if (m_irc.Equals(sender)) return;
|
||||
// drop all messages coming in on a private channel,
|
||||
// except if we are relaying private channels, in which
|
||||
// case we drop if the private channel is not the
|
||||
// configured m_relayChannelOut
|
||||
if (m_relayPrivateChannels)
|
||||
{
|
||||
if (c.Channel != 0 && c.Channel != DEBUG_CHANNEL && c.Channel != m_relayChannelOut)
|
||||
{
|
||||
m_log.DebugFormat("[IRC] dropping message {0} on channel {1}", c, c.Channel);
|
||||
return;
|
||||
}
|
||||
}
|
||||
else if (c.Channel != 0 && c.Channel != DEBUG_CHANNEL)
|
||||
{
|
||||
m_log.DebugFormat("[IRC] dropping message {0} on channel {1}", c, c.Channel);
|
||||
return;
|
||||
}
|
||||
|
||||
ScenePresence avatar = null;
|
||||
Scene scene = (Scene)e.Scene;
|
||||
Scene scene = (Scene)c.Scene;
|
||||
|
||||
if (scene == null)
|
||||
scene = m_scenes[0];
|
||||
|
||||
// Filled in since it's easier than rewriting right now.
|
||||
string fromName = e.From;
|
||||
string fromName = c.From;
|
||||
|
||||
if (e.Sender != null)
|
||||
if (c.Sender != null)
|
||||
{
|
||||
avatar = scene.GetScenePresence(e.Sender.AgentId);
|
||||
avatar = scene.GetScenePresence(c.Sender.AgentId);
|
||||
if (avatar != null) fromName = avatar.Name;
|
||||
}
|
||||
|
||||
if (avatar != null)
|
||||
if (!m_irc.Connected)
|
||||
{
|
||||
fromName = avatar.Name;
|
||||
m_log.WarnFormat("[IRC] IRCConnector not connected: dropping message from {0}", fromName);
|
||||
return;
|
||||
}
|
||||
|
||||
// Try to reconnect to server if not connected
|
||||
if (m_irc.Enabled && !m_irc.Connected)
|
||||
if (null != avatar)
|
||||
{
|
||||
// In a non-blocking way. Eventually the connector will get it started
|
||||
try
|
||||
string msg = c.Message;
|
||||
if (msg.StartsWith("/me "))
|
||||
msg = String.Format("{0} {1}", fromName, c.Message.Substring(4));
|
||||
|
||||
m_irc.PrivMsg(fromName, scene.RegionInfo.RegionName, msg);
|
||||
}
|
||||
else
|
||||
{
|
||||
//Message came from an object
|
||||
char[] splits = { ',' };
|
||||
string[] tokens = c.Message.Split(splits,3); // This is certainly wrong
|
||||
if (tokens.Length == 3)
|
||||
{
|
||||
if (m_irc_connector == null)
|
||||
if (tokens[0] == m_irc.m_accessPassword) // This is my really simple check
|
||||
{
|
||||
m_irc_connector = new Thread(IRCConnectRun);
|
||||
m_irc_connector.Name = "IRCConnectorThread";
|
||||
m_irc_connector.IsBackground = true;
|
||||
m_log.DebugFormat("[IRC] message from object {0}, {1}", tokens[0], tokens[1]);
|
||||
m_irc.PrivMsg(tokens[1], scene.RegionInfo.RegionName, tokens[2]);
|
||||
}
|
||||
|
||||
if (!m_irc_connector.IsAlive)
|
||||
else
|
||||
{
|
||||
m_irc_connector.Start();
|
||||
ThreadTracker.Add(m_irc_connector);
|
||||
m_log.WarnFormat("[IRC] prim security key mismatch <{0}> not <{1}>", tokens[0], m_irc.m_accessPassword);
|
||||
}
|
||||
}
|
||||
catch (Exception)
|
||||
{
|
||||
}
|
||||
}
|
||||
|
||||
if (e.Message.StartsWith("/me ") && (null != avatar))
|
||||
e.Message = String.Format("{0} {1}", fromName, e.Message.Substring(4));
|
||||
|
||||
// this is to keep objects from talking to IRC
|
||||
if (m_irc.Connected && (avatar != null))
|
||||
m_irc.PrivMsg(fromName, scene.RegionInfo.RegionName, e.Message);
|
||||
|
||||
// Handle messages from objects
|
||||
if (m_irc.Connected && (null == avatar))
|
||||
{
|
||||
//Message came from an object
|
||||
char[] splits = { ',' };
|
||||
string[] tokens = e.Message.Split(splits,3); // This is certainly wrong
|
||||
if (tokens.Length == 3)
|
||||
{
|
||||
if (tokens[0] == m_irc.m_accessPassword) // This is my really simple check
|
||||
{
|
||||
m_log.DebugFormat("[IRC] message from object {0}, {1}", tokens[0], tokens[1]);
|
||||
m_irc.PrivMsg(tokens[1], scene.RegionInfo.RegionName, tokens[2]);
|
||||
}
|
||||
else
|
||||
{
|
||||
m_log.WarnFormat("[IRC] prim security key mismatch <{0}> not <{1}>", tokens[0], m_irc.m_accessPassword);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
#endregion
|
||||
|
||||
public void OnNewClient(IClientAPI client)
|
||||
{
|
||||
try
|
||||
{
|
||||
// client.OnChatFromViewer += OnSimChat;
|
||||
client.OnLogout += OnClientLoggedOut;
|
||||
client.OnConnectionClosed += OnClientLoggedOut;
|
||||
|
||||
if (client.Name != m_last_new_user)
|
||||
{
|
||||
if ((m_irc.Enabled) && (m_irc.Connected) && (m_irc.m_verbosity >= 1))
|
||||
if ((m_irc.Enabled) && (m_irc.Connected) && (m_clientReporting))
|
||||
{
|
||||
m_log.DebugFormat("[IRC] {0} logging on", client.Name);
|
||||
m_irc.PrivMsg(m_irc.Nick, "Sim",
|
||||
String.Format("notices {0} logging on", client.Name));
|
||||
m_irc.PrivMsg(m_irc.Nick, "Sim", String.Format("notices {0} logging on", client.Name));
|
||||
}
|
||||
m_last_new_user = client.Name;
|
||||
}
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
m_log.Error("[IRC]: NewClient exception trap:" + ex.ToString());
|
||||
m_log.Error("[IRC]: OnNewClient exception trap:" + ex.ToString());
|
||||
}
|
||||
}
|
||||
|
||||
@@ -334,7 +321,7 @@ namespace OpenSim.Region.Environment.Modules.Avatar.Chat
|
||||
{
|
||||
try
|
||||
{
|
||||
if ((m_irc.Enabled) && (m_irc.Connected) && (m_irc.m_verbosity >= 2))
|
||||
if ((m_irc.Enabled) && (m_irc.Connected) && (m_clientReporting))
|
||||
{
|
||||
string regionName = presence.Scene.RegionInfo.RegionName;
|
||||
string clientName = String.Format("{0} {1}", presence.Firstname, presence.Lastname);
|
||||
@@ -351,7 +338,7 @@ namespace OpenSim.Region.Environment.Modules.Avatar.Chat
|
||||
{
|
||||
try
|
||||
{
|
||||
if ((m_irc.Enabled) && (m_irc.Connected) && (m_irc.m_verbosity >= 2))
|
||||
if ((m_irc.Enabled) && (m_irc.Connected) && (m_clientReporting))
|
||||
{
|
||||
string regionName = presence.Scene.RegionInfo.RegionName;
|
||||
string clientName = String.Format("{0} {1}", presence.Firstname, presence.Lastname);
|
||||
@@ -371,16 +358,14 @@ namespace OpenSim.Region.Environment.Modules.Avatar.Chat
|
||||
{
|
||||
try
|
||||
{
|
||||
if ((m_irc.Enabled) && (m_irc.Connected) && (m_irc.m_verbosity >= 1))
|
||||
if ((m_irc.Enabled) && (m_irc.Connected) && (m_clientReporting))
|
||||
{
|
||||
// handles simple case. May not work for hundred connecting in per second.
|
||||
// and the NewClients calles getting interleved
|
||||
// but filters out multiple reports
|
||||
// handles simple case. May not work for
|
||||
// hundred connecting in per second. and
|
||||
// OnNewClients calle getting interleaved but
|
||||
// filters out multiple reports
|
||||
if (client.Name != m_last_leaving_user)
|
||||
{
|
||||
// Console.WriteLine("Avatar was seen logging out.");
|
||||
// Console.ReadLine();
|
||||
// Console.WriteLine();
|
||||
m_last_leaving_user = client.Name;
|
||||
m_irc.PrivMsg(m_irc.Nick, "Sim", String.Format("notices {0} logging out", client.Name));
|
||||
m_log.InfoFormat("[IRC]: {0} logging out", client.Name);
|
||||
@@ -396,623 +381,5 @@ namespace OpenSim.Region.Environment.Modules.Avatar.Chat
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// if IRC is enabled then just keep trying using a monitor thread
|
||||
public void IRCConnectRun()
|
||||
{
|
||||
while (m_irc.Enabled)
|
||||
{
|
||||
if (!m_irc.Connected)
|
||||
{
|
||||
m_irc.Connect(m_scenes);
|
||||
}
|
||||
Thread.Sleep(15000);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
internal class IRCChatModule
|
||||
{
|
||||
#region ErrorReplies enum
|
||||
|
||||
public enum ErrorReplies
|
||||
{
|
||||
NotRegistered = 451, // ":You have not registered"
|
||||
NicknameInUse = 433 // "<nick> :Nickname is already in use"
|
||||
}
|
||||
|
||||
#endregion
|
||||
|
||||
#region Replies enum
|
||||
|
||||
public enum Replies
|
||||
{
|
||||
MotdStart = 375, // ":- <server> Message of the day - "
|
||||
Motd = 372, // ":- <text>"
|
||||
EndOfMotd = 376 // ":End of /MOTD command"
|
||||
}
|
||||
|
||||
#endregion
|
||||
|
||||
private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
|
||||
private Thread listener;
|
||||
|
||||
private string m_basenick = null;
|
||||
public string m_channel = null;
|
||||
private bool m_nrnick = false;
|
||||
private bool m_connected = false;
|
||||
private bool m_enabled = false;
|
||||
public int m_commandChannel = -1;
|
||||
|
||||
public int m_verbosity = 1;
|
||||
public int m_messageOutChannel = 0; // Will be the message channel we listen to
|
||||
public int m_messageInChannel = 0; // Will be the message channel where we forward msgs
|
||||
public string m_accessPassword = "badkitty";
|
||||
public bool m_useWorldComm = false; // true if we want chat to be localized, false if we want to broadcast to the entire region
|
||||
|
||||
public List<Scene> m_last_scenes = null;
|
||||
public string m_nick = null;
|
||||
public uint m_port = 6668;
|
||||
private string m_privmsgformat = "PRIVMSG {0} :<{1} in {2}>: {3}";
|
||||
private StreamReader m_reader;
|
||||
private List<Scene> m_scenes = null;
|
||||
public string m_server = null;
|
||||
|
||||
private NetworkStream m_stream = null;
|
||||
internal object m_syncConnect = new object();
|
||||
private TcpClient m_tcp;
|
||||
private string m_user = "USER OpenSimBot 8 * :I'm an OpenSim to IRC bot";
|
||||
private StreamWriter m_writer;
|
||||
|
||||
private Thread pingSender;
|
||||
|
||||
public IRCChatModule(IConfigSource config)
|
||||
{
|
||||
m_nick = "OSimBot" + Util.RandomClass.Next(1, 99);
|
||||
m_tcp = null;
|
||||
m_writer = null;
|
||||
m_reader = null;
|
||||
|
||||
// configuration in OpenSim.ini
|
||||
// [IRC]
|
||||
// server = chat.freenode.net
|
||||
// nick = OSimBot_mysim
|
||||
// nicknum = true
|
||||
// ;nicknum set to true appends a 2 digit random number to the nick
|
||||
// ;username = USER OpenSimBot 8 * :I'm a OpenSim to irc bot
|
||||
// ; username is the IRC command line sent
|
||||
// ; USER <irc_user> <visible=8,invisible=0> * : <IRC_realname>
|
||||
// channel = #opensim-regions
|
||||
// port = 6667
|
||||
// ;MSGformat fields : 0=botnick, 1=user, 2=region, 3=message
|
||||
// ;for <bot>:<user in region> :<message>
|
||||
// ;msgformat = "PRIVMSG {0} :<{1} in {2}>: {3}"
|
||||
// ;for <bot>:<message> - <user of region> :
|
||||
// ;msgformat = "PRIVMSG {0} : {3} - {1} of {2}"
|
||||
// ;for <bot>:<message> - from <user> :
|
||||
// ;msgformat = "PRIVMSG {0} : {3} - from {1}"
|
||||
// Traps I/O disconnects so it does not crash the sim
|
||||
// Trys to reconnect if disconnected and someone says something
|
||||
// Tells IRC server "QUIT" when doing a close (just to be nice)
|
||||
// Default port back to 6667
|
||||
|
||||
try
|
||||
{
|
||||
m_server = config.Configs["IRC"].GetString("server");
|
||||
m_nick = config.Configs["IRC"].GetString("nick");
|
||||
m_basenick = m_nick;
|
||||
m_nrnick = config.Configs["IRC"].GetBoolean("nicknum", true);
|
||||
m_channel = config.Configs["IRC"].GetString("channel");
|
||||
m_port = (uint)config.Configs["IRC"].GetInt("port", (int)m_port);
|
||||
m_user = config.Configs["IRC"].GetString("username", m_user);
|
||||
m_privmsgformat = config.Configs["IRC"].GetString("msgformat", m_privmsgformat);
|
||||
m_commandChannel = config.Configs["IRC"].GetInt("commandchannel", m_commandChannel);
|
||||
|
||||
m_verbosity = config.Configs["IRC"].GetInt("verbosity", m_verbosity);
|
||||
m_messageOutChannel = config.Configs["IRC"].GetInt("outchannel", m_messageOutChannel);
|
||||
m_messageInChannel = config.Configs["IRC"].GetInt("inchannel", m_messageInChannel);
|
||||
m_accessPassword = config.Configs["IRC"].GetString("access_password",m_accessPassword);
|
||||
m_useWorldComm = config.Configs["IRC"].GetBoolean("useworldcomm", m_useWorldComm);
|
||||
|
||||
if (m_server != null && m_nick != null && m_channel != null)
|
||||
{
|
||||
if (m_nrnick == true)
|
||||
{
|
||||
m_nick = m_nick + Util.RandomClass.Next(1, 99);
|
||||
}
|
||||
m_enabled = true;
|
||||
}
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
m_log.Error("[IRC]: Incomplete IRC configuration, skipping IRC bridge configuration");
|
||||
m_log.DebugFormat("[IRC] Incomplete IRC configuration: {0}", ex.ToString());
|
||||
}
|
||||
}
|
||||
|
||||
public bool Enabled
|
||||
{
|
||||
get { return m_enabled; }
|
||||
}
|
||||
|
||||
public bool Connected
|
||||
{
|
||||
get { return m_connected; }
|
||||
}
|
||||
|
||||
public string Nick
|
||||
{
|
||||
get { return m_nick; }
|
||||
}
|
||||
|
||||
public bool Connect(List<Scene> scenes)
|
||||
{
|
||||
lock (m_syncConnect)
|
||||
{
|
||||
try
|
||||
{
|
||||
if (m_connected) return true;
|
||||
|
||||
m_scenes = scenes;
|
||||
if (m_last_scenes == null)
|
||||
{
|
||||
m_last_scenes = scenes;
|
||||
}
|
||||
|
||||
m_tcp = new TcpClient(m_server, (int)m_port);
|
||||
m_stream = m_tcp.GetStream();
|
||||
m_reader = new StreamReader(m_stream);
|
||||
m_writer = new StreamWriter(m_stream);
|
||||
|
||||
m_log.DebugFormat("[IRC]: Connected to {0}:{1}", m_server, m_port);
|
||||
|
||||
pingSender = new Thread(new ThreadStart(PingRun));
|
||||
pingSender.Name = "PingSenderThread";
|
||||
pingSender.IsBackground = true;
|
||||
pingSender.Start();
|
||||
ThreadTracker.Add(pingSender);
|
||||
|
||||
listener = new Thread(new ThreadStart(ListenerRun));
|
||||
listener.Name = "IRCChatModuleListenerThread";
|
||||
listener.IsBackground = true;
|
||||
listener.Start();
|
||||
ThreadTracker.Add(listener);
|
||||
|
||||
m_writer.WriteLine(m_user);
|
||||
m_writer.Flush();
|
||||
m_writer.WriteLine(String.Format("NICK {0}", m_nick));
|
||||
m_writer.Flush();
|
||||
m_writer.WriteLine(String.Format("JOIN {0}", m_channel));
|
||||
m_writer.Flush();
|
||||
m_log.Info("[IRC]: Connection fully established");
|
||||
m_connected = true;
|
||||
}
|
||||
catch (Exception e)
|
||||
{
|
||||
m_log.ErrorFormat("[IRC] cannot connect to {0}:{1}: {2}",
|
||||
m_server, m_port, e.Message);
|
||||
}
|
||||
m_log.Debug("[IRC] Connected");
|
||||
return m_connected;
|
||||
}
|
||||
}
|
||||
|
||||
public void Reconnect()
|
||||
{
|
||||
m_connected = false;
|
||||
try
|
||||
{
|
||||
listener.Abort();
|
||||
pingSender.Abort();
|
||||
m_writer.Close();
|
||||
m_reader.Close();
|
||||
m_tcp.Close();
|
||||
}
|
||||
catch (Exception)
|
||||
{
|
||||
}
|
||||
|
||||
if (m_enabled)
|
||||
{
|
||||
Connect(m_last_scenes);
|
||||
}
|
||||
}
|
||||
|
||||
public void PrivMsg(string from, string region, string msg)
|
||||
{
|
||||
m_log.DebugFormat("[IRC] Sending message to IRC from {0}: {1}", from, msg);
|
||||
|
||||
// One message to the IRC server
|
||||
try
|
||||
{
|
||||
m_writer.WriteLine(m_privmsgformat, m_channel, from, region, msg);
|
||||
m_writer.Flush();
|
||||
m_log.InfoFormat("[IRC]: PrivMsg {0} in {1}: {2}", from, region, msg);
|
||||
}
|
||||
catch (IOException)
|
||||
{
|
||||
m_log.Error("[IRC]: Disconnected from IRC server.(PrivMsg)");
|
||||
Reconnect();
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
m_log.ErrorFormat("[IRC]: PrivMsg exception trap: {0}", ex.ToString());
|
||||
}
|
||||
}
|
||||
|
||||
public void Send(string msg)
|
||||
{
|
||||
try
|
||||
{
|
||||
m_writer.WriteLine(msg);
|
||||
m_writer.Flush();
|
||||
m_log.Info("IRC: Sent command string: " + msg);
|
||||
}
|
||||
catch (IOException)
|
||||
{
|
||||
m_log.Error("[IRC]: Disconnected from IRC server.(PrivMsg)");
|
||||
Reconnect();
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
m_log.ErrorFormat("[IRC]: PrivMsg exception trap: {0}", ex.ToString());
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
|
||||
private Dictionary<string, string> ExtractMsg(string input)
|
||||
{
|
||||
//examines IRC commands and extracts any private messages
|
||||
// which will then be reboadcast in the Sim
|
||||
|
||||
m_log.Info("[IRC]: ExtractMsg: " + input);
|
||||
Dictionary<string, string> result = null;
|
||||
//string regex = @":(?<nick>\w*)!~(?<user>\S*) PRIVMSG (?<channel>\S+) :(?<msg>.*)";
|
||||
string regex = @":(?<nick>[\w-]*)!(?<user>\S*) PRIVMSG (?<channel>\S+) :(?<msg>.*)";
|
||||
Regex RE = new Regex(regex, RegexOptions.Multiline);
|
||||
MatchCollection matches = RE.Matches(input);
|
||||
|
||||
// Get some direct matches $1 $4 is a
|
||||
if ((matches.Count == 0) || (matches.Count != 1) || (matches[0].Groups.Count != 5))
|
||||
{
|
||||
m_log.Info("[IRC]: Number of matches: " + matches.Count);
|
||||
if (matches.Count > 0)
|
||||
{
|
||||
m_log.Info("[IRC]: Number of groups: " + matches[0].Groups.Count);
|
||||
}
|
||||
return null;
|
||||
}
|
||||
|
||||
result = new Dictionary<string, string>();
|
||||
result.Add("nick", matches[0].Groups[1].Value);
|
||||
result.Add("user", matches[0].Groups[2].Value);
|
||||
result.Add("channel", matches[0].Groups[3].Value);
|
||||
result.Add("msg", matches[0].Groups[4].Value);
|
||||
|
||||
return result;
|
||||
}
|
||||
|
||||
public void PingRun()
|
||||
{
|
||||
// IRC keep alive thread
|
||||
// send PING ever 15 seconds
|
||||
while (m_enabled)
|
||||
{
|
||||
try
|
||||
{
|
||||
if (m_connected == true)
|
||||
{
|
||||
m_writer.WriteLine(String.Format("PING :{0}", m_server));
|
||||
m_writer.Flush();
|
||||
Thread.Sleep(15000);
|
||||
}
|
||||
}
|
||||
catch (IOException)
|
||||
{
|
||||
if (m_enabled)
|
||||
{
|
||||
m_log.Error("[IRC]: Disconnected from IRC server.(PingRun)");
|
||||
Reconnect();
|
||||
}
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
m_log.ErrorFormat("[IRC]: PingRun exception trap: {0}\n{1}", ex.ToString(), ex.StackTrace);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
static private Vector3 pos = new Vector3(128, 128, 20);
|
||||
public void ListenerRun()
|
||||
{
|
||||
string inputLine;
|
||||
|
||||
while (m_enabled)
|
||||
{
|
||||
try
|
||||
{
|
||||
while ((m_connected == true) && ((inputLine = m_reader.ReadLine()) != null))
|
||||
{
|
||||
m_log.Info("[IRC]: " + inputLine);
|
||||
if (inputLine.Contains(m_channel))
|
||||
{
|
||||
Dictionary<string, string> data = ExtractMsg(inputLine);
|
||||
// Any chat ???
|
||||
if (data != null)
|
||||
{
|
||||
OSChatMessage c = new OSChatMessage();
|
||||
c.Message = data["msg"];
|
||||
c.Type = ChatTypeEnum.Say;
|
||||
c.Channel = m_messageInChannel;
|
||||
c.Position = pos;
|
||||
c.From = data["nick"];
|
||||
c.Sender = null;
|
||||
c.SenderUUID = UUID.Zero;
|
||||
|
||||
// is message "\001ACTION foo
|
||||
// bar\001"? -> "/me foo bar"
|
||||
if ((1 == c.Message[0]) && c.Message.Substring(1).StartsWith("ACTION"))
|
||||
c.Message = String.Format("/me {0}", c.Message.Substring(8, c.Message.Length - 9));
|
||||
|
||||
m_log.DebugFormat("[IRC] ListenerRun from: {0}, {1}", c.From, c.Message);
|
||||
|
||||
foreach (Scene scene in m_scenes)
|
||||
{
|
||||
if (m_useWorldComm)
|
||||
{
|
||||
IWorldComm wComm = scene.RequestModuleInterface<IWorldComm>();
|
||||
wComm.DeliverMessage(ChatTypeEnum.Region, m_messageInChannel, c.From, UUID.Zero, c.Message);
|
||||
}
|
||||
else
|
||||
{
|
||||
c.Scene = scene;
|
||||
scene.EventManager.TriggerOnChatBroadcast(this, c);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
Thread.Sleep(150);
|
||||
continue;
|
||||
}
|
||||
|
||||
ProcessIRCCommand(inputLine);
|
||||
Thread.Sleep(150);
|
||||
}
|
||||
}
|
||||
catch (IOException)
|
||||
{
|
||||
if (m_enabled)
|
||||
{
|
||||
m_log.Error("[IRC]: ListenerRun IOException. Disconnected from IRC server ??? (ListenerRun)");
|
||||
Reconnect();
|
||||
}
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
m_log.ErrorFormat("[IRC]: ListenerRun exception trap: {0}\n{1}", ex.ToString(), ex.StackTrace);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
public void BroadcastSim(string sender, string format, params string[] args)
|
||||
{
|
||||
try
|
||||
{
|
||||
OSChatMessage c = new OSChatMessage();
|
||||
c.From = sender;
|
||||
c.Message = String.Format(format, args);
|
||||
c.Type = ChatTypeEnum.Region; // ChatTypeEnum.Say;
|
||||
c.Channel = m_messageInChannel;
|
||||
c.Position = new Vector3(128, 128, 20);
|
||||
c.Sender = null;
|
||||
c.SenderUUID = UUID.Zero;
|
||||
|
||||
m_log.DebugFormat("[IRC] BroadcastSim from {0}: {1}", c.From, c.Message);
|
||||
|
||||
foreach (Scene m_scene in m_scenes)
|
||||
{
|
||||
c.Scene = m_scene;
|
||||
// m_scene.EventManager.TriggerOnChatBroadcast(this, c);
|
||||
// m_scene.EventManager.TriggerOnChatFromWorld(this, c);
|
||||
IWorldComm wComm = m_scene.RequestModuleInterface<IWorldComm>();
|
||||
wComm.DeliverMessage(ChatTypeEnum.Region, m_messageInChannel, sender, UUID.Zero, c.Message);
|
||||
//IWorldComm wComm = m_ScriptEngine.World.RequestModuleInterface<IWorldComm>();
|
||||
//wComm.DeliverMessage(ChatTypeEnum.Region, channelID, m_host.Name, m_host.UUID, text);
|
||||
|
||||
}
|
||||
}
|
||||
catch (Exception ex) // IRC gate should not crash Sim
|
||||
{
|
||||
m_log.ErrorFormat("[IRC]: BroadcastSim Exception Trap: {0}\n{1}", ex.ToString(), ex.StackTrace);
|
||||
}
|
||||
}
|
||||
|
||||
public void ProcessIRCCommand(string command)
|
||||
{
|
||||
m_log.Debug("[IRC]: ProcessIRCCommand:" + command);
|
||||
|
||||
string[] commArgs = new string[command.Split(' ').Length];
|
||||
string c_server = m_server;
|
||||
|
||||
commArgs = command.Split(' ');
|
||||
if (commArgs[0].Substring(0, 1) == ":")
|
||||
{
|
||||
commArgs[0] = commArgs[0].Remove(0, 1);
|
||||
}
|
||||
|
||||
if (commArgs[1] == "002")
|
||||
{
|
||||
// fetch the correct servername
|
||||
// ex: irc.freenode.net -> brown.freenode.net/kornbluth.freenode.net/...
|
||||
// irc.bluewin.ch -> irc1.bluewin.ch/irc2.bluewin.ch
|
||||
|
||||
c_server = (commArgs[6].Split('['))[0];
|
||||
m_server = c_server;
|
||||
}
|
||||
|
||||
if (commArgs[0] == "ERROR")
|
||||
{
|
||||
m_log.ErrorFormat("[IRC]: IRC SERVER ERROR: {0}", command);
|
||||
}
|
||||
|
||||
if (commArgs[0] == "PING")
|
||||
{
|
||||
string p_reply = "";
|
||||
|
||||
for (int i = 1; i < commArgs.Length; i++)
|
||||
{
|
||||
p_reply += commArgs[i] + " ";
|
||||
}
|
||||
|
||||
m_writer.WriteLine(String.Format("PONG {0}", p_reply));
|
||||
m_writer.Flush();
|
||||
}
|
||||
else if (commArgs[0] == c_server)
|
||||
{
|
||||
// server message
|
||||
try
|
||||
{
|
||||
Int32 commandCode = Int32.Parse(commArgs[1]);
|
||||
switch (commandCode)
|
||||
{
|
||||
case (int)ErrorReplies.NicknameInUse:
|
||||
// Gen a new name
|
||||
m_nick = m_basenick + Util.RandomClass.Next(1, 99);
|
||||
m_log.ErrorFormat("[IRC]: IRC SERVER reports NicknameInUse, trying {0}", m_nick);
|
||||
// Retry
|
||||
m_writer.WriteLine(String.Format("NICK {0}", m_nick));
|
||||
m_writer.Flush();
|
||||
m_writer.WriteLine(String.Format("JOIN {0}", m_channel));
|
||||
m_writer.Flush();
|
||||
break;
|
||||
case (int)ErrorReplies.NotRegistered:
|
||||
break;
|
||||
case (int)Replies.EndOfMotd:
|
||||
break;
|
||||
}
|
||||
}
|
||||
catch (Exception)
|
||||
{
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
// Normal message
|
||||
string commAct = commArgs[1];
|
||||
switch (commAct)
|
||||
{
|
||||
case "JOIN":
|
||||
eventIrcJoin(commArgs);
|
||||
break;
|
||||
case "PART":
|
||||
eventIrcPart(commArgs);
|
||||
break;
|
||||
case "MODE":
|
||||
eventIrcMode(commArgs);
|
||||
break;
|
||||
case "NICK":
|
||||
eventIrcNickChange(commArgs);
|
||||
break;
|
||||
case "KICK":
|
||||
eventIrcKick(commArgs);
|
||||
break;
|
||||
case "QUIT":
|
||||
eventIrcQuit(commArgs);
|
||||
break;
|
||||
case "PONG":
|
||||
break; // that's nice
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
public void eventIrcJoin(string[] commArgs)
|
||||
{
|
||||
string IrcChannel = commArgs[2];
|
||||
if (IrcChannel.StartsWith(":"))
|
||||
IrcChannel = IrcChannel.Substring(1);
|
||||
string IrcUser = commArgs[0].Split('!')[0];
|
||||
if (m_verbosity >= 1)
|
||||
BroadcastSim(IrcUser, "/me joins {0}", IrcChannel);
|
||||
}
|
||||
|
||||
public void eventIrcPart(string[] commArgs)
|
||||
{
|
||||
string IrcChannel = commArgs[2];
|
||||
string IrcUser = commArgs[0].Split('!')[0];
|
||||
if (m_verbosity >= 2)
|
||||
BroadcastSim(IrcUser, "/me parts {0}", IrcChannel);
|
||||
}
|
||||
|
||||
public void eventIrcMode(string[] commArgs)
|
||||
{
|
||||
string UserMode = "";
|
||||
for (int i = 3; i < commArgs.Length; i++)
|
||||
{
|
||||
UserMode += commArgs[i] + " ";
|
||||
}
|
||||
|
||||
if (UserMode.Substring(0, 1) == ":")
|
||||
{
|
||||
UserMode = UserMode.Remove(0, 1);
|
||||
}
|
||||
}
|
||||
|
||||
public void eventIrcNickChange(string[] commArgs)
|
||||
{
|
||||
string UserOldNick = commArgs[0].Split('!')[0];
|
||||
string UserNewNick = commArgs[2].Remove(0, 1);
|
||||
if (m_verbosity >= 2)
|
||||
BroadcastSim(UserOldNick, "/me is now known as {0}", UserNewNick);
|
||||
}
|
||||
|
||||
public void eventIrcKick(string[] commArgs)
|
||||
{
|
||||
string UserKicker = commArgs[0].Split('!')[0];
|
||||
string UserKicked = commArgs[3];
|
||||
string IrcChannel = commArgs[2];
|
||||
string KickMessage = "";
|
||||
for (int i = 4; i < commArgs.Length; i++)
|
||||
{
|
||||
KickMessage += commArgs[i] + " ";
|
||||
}
|
||||
if (m_verbosity >= 1)
|
||||
BroadcastSim(UserKicker, "/me kicks kicks {0} off {1} saying \"{2}\"", UserKicked, IrcChannel, KickMessage);
|
||||
if (UserKicked == m_nick)
|
||||
{
|
||||
BroadcastSim(m_nick, "Hey, that was me!!!");
|
||||
}
|
||||
}
|
||||
|
||||
public void eventIrcQuit(string[] commArgs)
|
||||
{
|
||||
string IrcUser = commArgs[0].Split('!')[0];
|
||||
string QuitMessage = "";
|
||||
|
||||
for (int i = 2; i < commArgs.Length; i++)
|
||||
{
|
||||
QuitMessage += commArgs[i] + " ";
|
||||
}
|
||||
if (m_verbosity >= 1)
|
||||
BroadcastSim(IrcUser, "/me quits saying \"{0}\"", QuitMessage);
|
||||
}
|
||||
|
||||
public void Close()
|
||||
{
|
||||
m_writer.WriteLine(String.Format("QUIT :{0} to {1} wormhole to {2} closing",
|
||||
m_nick, m_channel, m_server));
|
||||
m_writer.Flush();
|
||||
|
||||
m_connected = false;
|
||||
m_enabled = false;
|
||||
|
||||
//listener.Abort();
|
||||
//pingSender.Abort();
|
||||
|
||||
m_writer.Close();
|
||||
m_reader.Close();
|
||||
m_stream.Close();
|
||||
m_tcp.Close();
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user