ViewVC Help
View File | Revision Log | Show Annotations | Revision Graph | Root Listing
root/i-scream/projects/cms/source/server/uk/org/iscream/cms/server/client/alerters/IRC__Alerter.java
(Generate patch)

Comparing projects/cms/source/server/uk/org/iscream/cms/server/client/alerters/IRC__Alerter.java (file contents):
Revision 1.30.2.2 by tdb, Mon Feb 4 23:14:38 2002 UTC vs.
Revision 1.30.2.6 by tdb, Wed Feb 6 22:59:06 2002 UTC

# Line 43 | Line 43 | public class IRC__Alerter extends AlerterSkeleton {
43          super();
44          // construct and initialise the bot
45          _ircbot = new IRCBot();
46 <        //_ircbot.setVerbose(true);
46 >        _ircbot.setVerbose(false);
47          Thread ircThread = new Thread(_ircbot);
48          // set it's name and start it
49          ircThread.setName("client.IRC__Alerter$IRCBot");
# Line 77 | Line 77 | public class IRC__Alerter extends AlerterSkeleton {
77          if(_active) {          
78              // send the message
79              _logger.write(toString(), Logger.DEBUG, "Sending " + _name + " at "+ alertType + " level");
80 <            _ircbot.sendMsg(message);
80 >            _ircbot.sendMessage(message);
81              // count sent alerts
82              _alertCount++;
83          } else {
# Line 195 | Line 195 | public class IRC__Alerter extends AlerterSkeleton {
195           */
196          public final int DEFAULT_RECONNECT_DELAY = 30;
197          
198 +        /**
199 +         * Attempt to kick-start the IRCBot into action. Will
200 +         * keep calling init() until it doesn't throw an
201 +         * an IOException (which will only be thrown if there
202 +         * is an error initialising). After a successful call
203 +         * to init() the method finishes.
204 +         */
205          public void run() {
206              while(true) {
207                  try {
# Line 203 | Line 210 | public class IRC__Alerter extends AlerterSkeleton {
210                  }
211                  catch (IOException e) {
212                      _logger.write(this.toString(), Logger.ERROR, "Error initialising IRCBot: "+e);
213 +                    // wait for a while, defined in the config
214                      reconnectSleep();
215                  }
216              }
209            //System.out.println("falling out!");
217          }
218          
219 <        public void init() throws IOException {
219 >        /**
220 >         * Connects the bot to an irc server and joins a channel,
221 >         * using details supplied from the i-scream configuration
222 >         * system. If this method completes without an exception
223 >         * one can presume the bot is ready for use.
224 >         *
225 >         * @throws IOException if there is any problem initialising
226 >         */
227 >        private void init() throws IOException {
228              _logger.write(this.toString(), Logger.DEBUG, "Initialising IRCBot...");
229 +            
230 +            // get a hook on the configuration system
231              ConfigurationProxy cp = ConfigurationProxy.getInstance();
232 +            
233 +            // get hold of the server details
234              String server;
235              int port;
236              try {
# Line 224 | Line 243 | public class IRC__Alerter extends AlerterSkeleton {
243                  _logger.write(this.toString(), Logger.ERROR, "Configuration error: "+e);
244                  throw new IOException("Can't get irc server details due to malformed configuration");
245              }
246 <            String user, comment;
246 >            
247 >            // get hold of the user details and nickname list
248 >            String user, nickList;
249              try {
250                  user = cp.getProperty(_name, "Alerter.IRC.user");
251 <                comment = cp.getProperty(_name, "Alerter.IRC.comment");
251 >                nickList = cp.getProperty(_name, "Alerter.IRC.nickList");
252              } catch (PropertyNotFoundException e) {
253                  _logger.write(this.toString(), Logger.ERROR, "Configuration error: "+e);
254 <                throw new IOException("Can't get user details due to configuration error");
254 >                throw new IOException("Can't get user/nickname details due to configuration error");
255              }
256 <            this.setLogin(user);
257 <            this.setVersion(comment);
258 <            this.setFinger(comment); // ?
259 <            String nickList;
256 >            
257 >            // get hold of comment and finger information
258 >            //  -- we're not too fussed if these aren't set
259 >            String comment = "Alerter.IRC.comment is undefined";
260 >            String finger = "Alerter.IRC.finger is undefined";
261              try {
262 <                nickList = cp.getProperty(_name, "Alerter.IRC.nickList");
262 >                comment = cp.getProperty(_name, "Alerter.IRC.comment");
263 >                finger = cp.getProperty(_name, "Alerter.IRC.finger");
264              } catch (PropertyNotFoundException e) {
265 <                _logger.write(this.toString(), Logger.ERROR, "Configuration error: "+e);
243 <                throw new IOException("Can't get nickname due to configuration error");
265 >                _logger.write(this.toString(), Logger.WARNING, "Configuration warning, using default: "+e);
266              }
267 +            
268 +            // put these details into the bot
269 +            this.setLogin(user);
270 +            this.setVersion("[" + getRevision() + "] " + comment);
271 +            this.setFinger(finger);
272 +            
273 +            // attempt to connect, trying each nickname
274 +            // in turn until sucessfully connected
275              StringTokenizer st = new StringTokenizer(nickList, ";");
276              boolean ok = false;
277              while(!ok && st.hasMoreTokens()) {
278                  String nick = st.nextToken();
279                  try {
280 +                    // try to connect with a nickname
281                      _logger.write(this.toString(), Logger.DEBUG, "Trying nick: "+nick);
282                      this.setName(nick);
283                      this.connect(server, port);
284 <                    // must be ok if we get here
284 >                    // at this point we know the nickname was accepted
285                      _nickname = nick;
286                      ok = true;
287                  }
# Line 264 | Line 295 | public class IRC__Alerter extends AlerterSkeleton {
295                  }
296                  catch(NickAlreadyInUseException e) {
297                      _logger.write(this.toString(), Logger.ERROR, "Nickname "+nick+" is already in use: "+e);
298 <                    // just carry on around while loop
298 >                    // don't do anything, instead just loop round
299 >                    // and try the next nickname in the list
300                  }
301              }
302              if(!ok) {
303 <                // oh dear, we couldn't get on.
303 >                // must have tried all the nicknames, best bail out
304                  _logger.write(this.toString(), Logger.ERROR, "All nicknames already in use");
305                  throw new IOException("All nicknames already in use");
306              }
307 +            
308 +            // get hold of the channel details, and attempt
309 +            // to join the specified channel
310              try {
311                  _channel = cp.getProperty(_name, "Alerter.IRC.channel");
312                  this.joinChannel(_channel);
# Line 280 | Line 315 | public class IRC__Alerter extends AlerterSkeleton {
315                  throw new IOException("Can't get channel name due to configuration error");
316              }
317              
318 +            // get hold of the startup notice, and send
319 +            // it if it's defined
320              String startupNotice;
321              try {
322                  startupNotice = ConfigurationProxy.getInstance().getProperty(_name, "Alerter.IRC.startupNotice");
# Line 288 | Line 325 | public class IRC__Alerter extends AlerterSkeleton {
325                  _logger.write(this.toString(), Logger.DEBUG, "Startup notice not defined, so not sending: "+e);
326              }
327              
328 <            // we should set this when all is ready!
328 >            // at this point initialisation is complete, so
329 >            // we can return and set this flag to allow alerts
330              _active = true;
293            //System.out.println("leaving init");
331          }
332          
333 <        public void sendMsg(String msg) {
334 <            sendMessage(_channel, msg);
333 >        /**
334 >         * Send a message to the current channel.
335 >         *
336 >         * @param message The message to send
337 >         */
338 >        private void sendMessage(String message) {
339 >            sendMessage(_channel, message);
340          }
341          
342 +        /**
343 +         * If we get disconnected this method will be
344 +         * called, so we must take action. We'll simply
345 +         * keep trying to reinitialise, and thus
346 +         * reconnect to the server.
347 +         */
348          public void onDisconnect() {
349 +            // stop alerts being sent for now
350              _active = false;
351              while(true) {
352 +                // wait for a while, defined in the config
353                  reconnectSleep();
354                  try {
355                      init();
# Line 309 | Line 359 | public class IRC__Alerter extends AlerterSkeleton {
359                      _logger.write(this.toString(), Logger.ERROR, "Error initialising IRCBot: "+e);
360                  }
361              }
312            //System.out.println("falling out of disconnect!");
362          }
363          
364 +        /**
365 +         * If we receive a message this method will
366 +         * be called. We'll check if the message is
367 +         * for us, and call handleInput if it is.
368 +         *
369 +         * @param channel The channel the message came from
370 +         * @param sender The sender of the message
371 +         * @param login The login of the sender
372 +         * @param hostname The hostname of the sender
373 +         * @param message The message sent
374 +         */
375          public void onMessage(String channel, String sender, String login, String hostname, String message) {
376 <            if(isForMe(message)) {
377 <                handleInput(message, channel);
376 >            String trimmedMessage = isForMe(message);
377 >            // if trimmedMessage is null, it's not for us
378 >            if(trimmedMessage != null) {
379 >                handleInput(trimmedMessage, channel);
380              }
381          }
382          
383 +        /**
384 +         * If we receive a private message this method
385 +         * will be called. No need to check if it's for
386 +         * us -- it has to be if it's a private message.
387 +         *
388 +         * @param sender The sender of the message
389 +         * @param login The login of the sender
390 +         * @param hostname The hostname of the sender
391 +         * @param message The message sent
392 +         */
393          public void onPrivateMessage(String sender, String login, String hostname, String message) {
394              handleInput(message, sender);
395          }
396          
397 +        /**
398 +         * If we receive a nick change message, this
399 +         * method gets called. We don't care about
400 +         * other users changing their nick, so we only
401 +         * take notice if our nick changes. If it does
402 +         * we need to change our internal nickname
403 +         * state.
404 +         *
405 +         * @param oldNick the old nickname
406 +         * @param login the login of the nick changer
407 +         * @param hostname the hostname of the nick changer
408 +         * @param newNick the new nickname
409 +         */
410          public void onNickChange(String oldNick, String login, String hostname, String newNick) {
411              if(oldNick.equals(_nickname)) {
412                  _nickname = newNick;
413 +                // tell the underlying pircbot that our nick has changed too :)
414 +                setName(newNick);
415              }
416          }
417          
418 +        /**
419 +         * If we receive a kick message this method
420 +         * gets called. We only take notice if it's
421 +         * us getting kicked, and then we'll rejoin
422 +         * the channel after a short wait.
423 +         *
424 +         * @param channel the channel the kick happened on
425 +         * @param kickerNick the person who performed the kick
426 +         * @param kickerLogin the login of the person who performed the kick
427 +         * @param kickerHostname the hostname of the person who performed the kick
428 +         * @param recipientNick the nickname of the person being kicked
429 +         * @param reason the reason for the kick
430 +         */
431          public void onKick(String channel, String kickerNick, String kickerLogin, String kickerHostname, String recipientNick, String reason) {
432              if(recipientNick.equals(_nickname) && channel.equals(_channel)) {
433 +                // remind the person it's not very nice :)
434                  sendMessage(kickerNick, "That wasn't a nice thing to do...");
435 +                // get hold of the channel details, in case they've changed
436                  try {
437                      _channel = ConfigurationProxy.getInstance().getProperty(_name, "Alerter.IRC.channel");
438                  } catch(PropertyNotFoundException e) {
439 <                    _logger.write(this.toString(), Logger.ERROR, "Configuration error: "+e);
439 >                    _logger.write(this.toString(), Logger.ERROR, "Can't get channel name due to configuration error: "+e);
440                  }
441 <                // should this be in the try?
441 >                // wait for a while, defined in the config
442 >                reconnectSleep();
443 >                // we'll try and rejoin the channel regardless
444 >                // otherwise we might end up doing nothing!
445                  joinChannel(_channel);
446              }
447          }
448          
449 +        /**
450 +         * This method handles input directed to us, and
451 +         * responds accordingly if required.
452 +         *
453 +         * @param message the message from someone
454 +         * @param source where the message came from, so we know where to send the response
455 +         */
456          private void handleInput(String message, String source) {
457 <            System.out.println("message: "+message);
346 <            System.out.println("from: "+source);
457 >            // get hold of the configuration system
458              ConfigurationProxy cp = ConfigurationProxy.getInstance();
459              // setup some String's
460              String stopCommand, startCommand, timeSinceLastAlertCommand, lastAlertCommand, joinCommand;
461              String nickChangeCommand, versionCommand, helpCommand, statCommand, uptimeCommand;
462 <            // get the command set
462 >            // get the command set from the configuration
463              try {
464                  stopCommand = cp.getProperty(_name, "Alerter.IRC.stopCommand");
465                  startCommand = cp.getProperty(_name, "Alerter.IRC.startCommand");
# Line 367 | Line 478 | public class IRC__Alerter extends AlerterSkeleton {
478                  return;
479              }
480              
481 <            if(message.indexOf(stopCommand) != -1) {
481 >            if(message.equalsIgnoreCase(stopCommand)) {
482                  _active = false;
483                  sendMessage(source, "alerts have been stopped");
484              }
485 <            else if(message.indexOf(startCommand) != -1) {
485 >            else if(message.equalsIgnoreCase(startCommand)) {
486                  _active = true;
487                  sendMessage(source, "alerts have been activated");
488              }
489 <            // this needs to go here if it contains the same words as the lastAlertCommand
490 <            else if(message.indexOf(timeSinceLastAlertCommand) != -1) {
489 >            // this needs to go before lastAlertCommand if it contains
490 >            // the same words as the lastAlertCommand.
491 >            else if(message.equalsIgnoreCase(timeSinceLastAlertCommand)) {
492                  if(_lastAlertTime != -1) {
493                      long uptime = (System.currentTimeMillis() - _lastAlertTime) / 1000;
494                      String uptimeText = DateUtils.formatTime(uptime, "%DAYS% days, %HOURS% hours, %MINS% mins, and %SECS% secs");
# Line 386 | Line 498 | public class IRC__Alerter extends AlerterSkeleton {
498                      sendMessage(source, "I've never sent an alert!");
499                  }
500              }
501 <            else if(message.indexOf(lastAlertCommand) != -1) {
501 >            else if(message.equalsIgnoreCase(lastAlertCommand)) {
502                  if(_lastAlertTime != -1) {
503                      String date = DateFormat.getDateTimeInstance(DateFormat.SHORT, DateFormat.SHORT, Locale.UK).format(new Date(_lastAlertTime));
504                      sendMessage(source, "last alert was at "+date+"; "+_lastAlert);
# Line 396 | Line 508 | public class IRC__Alerter extends AlerterSkeleton {
508                  }
509                  
510              }
511 <            else if(message.indexOf(joinCommand) != -1) {
511 >            else if(message.toLowerCase().startsWith(joinCommand.toLowerCase())) {
512                  String joinCmd = joinCommand;
513                  String newChan = message.substring(message.indexOf(joinCmd) + joinCmd.length() + 1);
514                  int endOfChan = newChan.indexOf(" ");
# Line 410 | Line 522 | public class IRC__Alerter extends AlerterSkeleton {
522                      partChannel(_channel);
523                      joinChannel(newChan);
524                      _channel = newChan;
413                    //return null; // ???
525                  }
526              }
527 <            else if(message.indexOf(nickChangeCommand) != -1) {
527 >            else if(message.toLowerCase().startsWith(nickChangeCommand.toLowerCase())) {
528                  String nickChangeCmd = nickChangeCommand;
529                  String newNick = message.substring(message.indexOf(nickChangeCmd) + nickChangeCmd.length() + 1);
530                  int endOfNick = newNick.indexOf(" ");
# Line 422 | Line 533 | public class IRC__Alerter extends AlerterSkeleton {
533                  }
534                  newNick = newNick.substring(0, endOfNick);
535                  changeNick(newNick);
425                // should we check this worked?
426                //_nickname = newNick;
427                //return null; // ???
536              }
537 <            else if(message.indexOf(versionCommand) != -1) {
538 <                sendMessage(source, "I am version "+REVISION.substring(11, REVISION.length() -2)+" of the i-scream alerting bot");
537 >            else if(message.equalsIgnoreCase(versionCommand)) {
538 >                sendMessage(source, "I am version " + getRevision() + " of the i-scream alerting bot");
539              }
540 <            else if(message.indexOf(helpCommand) != -1) {
433 <                //System.out.println("--starting help");
540 >            else if(message.equalsIgnoreCase(helpCommand)) {
541                  sendMessage(source, "Hello, I am the i-scream alerting bot version "+REVISION.substring(11, REVISION.length() -2));
542                  sendMessage(source, "I understand the following commands;");
543                  sendMessage(source, stopCommand);
# Line 442 | Line 549 | public class IRC__Alerter extends AlerterSkeleton {
549                  sendMessage(source, uptimeCommand);
550                  sendMessage(source, timeSinceLastAlertCommand);
551                  sendMessage(source, helpCommand);
445                //System.out.println("--ending help");
552              }
553 <            else if(message.indexOf(statCommand) != -1) {
553 >            else if(message.equalsIgnoreCase(statCommand)) {
554                  sendMessage(source, "I have sent a total of "+_alertCount+" alerts, and ignored a total of "+_ignoredCount+"!");
555              }
556 <            else if(message.indexOf(uptimeCommand) != -1) {
556 >            else if(message.equalsIgnoreCase(uptimeCommand)) {
557                  long uptime = (System.currentTimeMillis() - _startTime) / 1000;
558                  String uptimeText = DateUtils.formatTime(uptime, "%DAYS% days, %HOURS% hours, %MINS% mins, and %SECS% secs");
559                  sendMessage(source, "I have been running for "+uptimeText);
560              }
561 <            else if(message.indexOf("ping") != -1) {
561 >            else if(message.equalsIgnoreCase("ping")) {
562                  sendMessage(source, "pong");
563              }
564 <            else if(message.indexOf("do a jibble dance") != -1) {
564 >            else if(message.equalsIgnoreCase("do a jibble dance")) {
565                  // little joke :)
566                  sendAction(source, "jives to the funky beat shouting \"ii--screeeaaammm\"");
567              }
462            
568              else {
569                  String rejectMessage = NOT_CONFIGURED;
570                  try {
# Line 471 | Line 576 | public class IRC__Alerter extends AlerterSkeleton {
576              }
577          }
578          
579 <        private boolean isForMe(String message) {
580 <            // change this!
579 >        /**
580 >         * Quick method to check if the message appears
581 >         * to be directed at us. We simply check to see
582 >         * if it starts with our nick in some fashion.
583 >         * This will return null if the message is not
584 >         * for us - thus allowing this method to perform
585 >         * two tasks at once.
586 >         *
587 >         * @param message the message to check
588 >         * @return the message (with our nick removed), or null if it's not for us.
589 >         */
590 >        private String isForMe(String message) {
591 >            // change to lower case to remove
592 >            // case ambiguities
593              String nick = _nickname.toLowerCase();
594              String msg = message.toLowerCase();
595              if(msg.startsWith(nick + ", ") ||
596                 msg.startsWith(nick + ": ") ||
597                 msg.startsWith(nick + " ")) {
598 <                return true;
598 >                // NOTE that the 1 here is hardcoded to be the length
599 >                // of the above 'extra' character (eg , or :)
600 >                return message.substring(nick.length()+1).trim();
601              }
602              else {
603 <                return false;
603 >                return null;
604              }
605          }
606          
607 +        /**
608 +         * Sleep for a configurable amount of time and
609 +         * then return. This is used when reconnecting
610 +         * to the server or a channel.
611 +         */
612          private void reconnectSleep() {
613              int delayTime = 0;
614              try {
# Line 500 | Line 624 | public class IRC__Alerter extends AlerterSkeleton {
624              try {
625                  Thread.sleep(delayTime * 1000);
626              } catch (InterruptedException e) {}
627 +        }
628 +        
629 +        /**
630 +         * Returns the revision of the bot.
631 +         *
632 +         * @return the revision of this bot
633 +         */
634 +        private String getRevision() {
635 +            return REVISION.substring(11, REVISION.length()-2);
636          }
637          
638          /**

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines