Class: Irc::Bot

Inherits:
Object show all
Defined in:
lib/rbot/ircbot.rb,
lib/rbot/botuser.rb,
lib/rbot/botuser.rb,
lib/rbot/message.rb,
lib/rbot/plugins.rb,
lib/rbot/language.rb,
lib/rbot/registry.rb,
lib/rbot/rbotconfig.rb,
lib/rbot/core/remote.rb,
lib/rbot/messagemapper.rb,
lib/rbot/core/utils/extends.rb,
lib/rbot/core/utils/filters.rb,
lib/rbot/config.rb

Overview

Main bot class, which manages the various components, receives messages, handles them or passes them to plugins, and contains core functionality.

Defined Under Namespace

Modules: Auth, Config, Plugins Classes: DataFilter, DataStream, Language, MessageMapper, MessageParameter, MessageTemplate, Registry, RemoteDispatcher, RemoteMessage, RemoteObject

Constant Summary collapse 

"(c) Tom Gilbert and the rbot development team"
SOURCE_URL = 
"http://ruby-rbot.org"

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(botclass, params = {}) ⇒ Bot

create a new Bot with botclass botclass



259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
646
647
648
649
650
651
652
653
654
655
656
657
658
659
660
661
662
663
664
665
666
667
668
669
670
671
672
673
674
675
676
677
678
679
680
681
682
683
684
685
686
687
688
689
690
691
692
693
694
695
696
697
698
699
700
701
702
703
704
705
706
707
708
709
710
711
712
713
714
715
716
717
718
719
720
721
722
723
724
725
726
727
728
729
730
731
732
733
734
735
736
737
738
739
740
741
742
743
744
745
746
747
748
749
750
751
752
753
754
 
# File 'lib/rbot/ircbot.rb', line 259

def initialize(botclass, params = {})
  # Config for the core bot
  # TODO should we split socket stuff into ircsocket, etc?
  Config.register Config::ArrayValue.new('server.list',
    :default => ['irc://localhost'], :wizard => true,
    :requires_restart => true,
    :desc => "List of irc servers rbot should try to connect to. Use comma to separate values. Servers are in format 'server.doma.in:port'. If port is not specified, default value (6667) is used.")
  Config.register Config::BooleanValue.new('server.ssl',
    :default => false, :requires_restart => true, :wizard => true,
    :desc => "Use SSL to connect to this server?")
  Config.register Config::StringValue.new('server.password',
    :default => false, :requires_restart => true,
    :desc => "Password for connecting to this server (if required)",
    :wizard => true)
  Config.register Config::StringValue.new('server.bindhost',
    :default => false, :requires_restart => true,
    :desc => "Specific local host or IP for the bot to bind to (if required)",
    :wizard => true)
  Config.register Config::IntegerValue.new('server.reconnect_wait',
    :default => 5, :validate => Proc.new{|v| v >= 0},
    :desc => "Seconds to wait before attempting to reconnect, on disconnect")
  Config.register Config::FloatValue.new('server.sendq_delay',
    :default => 2.0, :validate => Proc.new{|v| v >= 0},
    :desc => "(flood prevention) the delay between sending messages to the server (in seconds)",
    :on_change => Proc.new {|bot, v| bot.socket.sendq_delay = v })
  Config.register Config::IntegerValue.new('server.sendq_burst',
    :default => 4, :validate => Proc.new{|v| v >= 0},
    :desc => "(flood prevention) max lines to burst to the server before throttling. Most ircd's allow bursts of up 5 lines",
    :on_change => Proc.new {|bot, v| bot.socket.sendq_burst = v })
  Config.register Config::IntegerValue.new('server.ping_timeout',
    :default => 30, :validate => Proc.new{|v| v >= 0},
    :desc => "reconnect if server doesn't respond to PING within this many seconds (set to 0 to disable)")
  Config.register Config::ArrayValue.new('server.nocolor_modes',
    :default => ['c'], :wizard => false,
    :requires_restart => false,
    :desc => "List of channel modes that require messages to be without colors")

  Config.register Config::StringValue.new('irc.nick', :default => "rbot",
    :desc => "IRC nickname the bot should attempt to use", :wizard => true,
    :on_change => Proc.new{|bot, v| bot.sendq "NICK #{v}" })
  Config.register Config::StringValue.new('irc.name',
    :default => "Ruby bot", :requires_restart => true,
    :desc => "IRC realname the bot should use")
  Config.register Config::BooleanValue.new('irc.name_copyright',
    :default => true, :requires_restart => true,
    :desc => "Append copyright notice to bot realname? (please don't disable unless it's really necessary)")
  Config.register Config::StringValue.new('irc.user', :default => "rbot",
    :requires_restart => true,
    :desc => "local user the bot should appear to be", :wizard => true)
  Config.register Config::ArrayValue.new('irc.join_channels',
    :default => [], :wizard => true,
    :desc => "What channels the bot should always join at startup. List multiple channels using commas to separate. If a channel requires a password, use a space after the channel name. e.g: '#chan1, #chan2, #secretchan secritpass, #chan3'")
  Config.register Config::ArrayValue.new('irc.ignore_users',
    :default => [],
    :desc => "Which users to ignore input from. This is mainly to avoid bot-wars triggered by creative people")

  Config.register Config::IntegerValue.new('core.save_every',
    :default => 60, :validate => Proc.new{|v| v >= 0},
    :on_change => Proc.new { |bot, v|
      if @save_timer
        if v > 0
          @timer.reschedule(@save_timer, v)
          @timer.unblock(@save_timer)
        else
          @timer.block(@save_timer)
        end
      else
        if v > 0
          @save_timer = @timer.add(v) { bot.save }
        end
        # Nothing to do when v == 0
      end
    },
    :desc => "How often the bot should persist all configuration to disk (in case of a server crash, for example)")

  Config.register Config::BooleanValue.new('core.run_as_daemon',
    :default => false, :requires_restart => true,
    :desc => "Should the bot run as a daemon?")

  Config.register Config::StringValue.new('log.file',
    :default => false, :requires_restart => true,
    :desc => "Name of the logfile to which console messages will be redirected when the bot is run as a daemon")
  Config.register Config::IntegerValue.new('log.level',
    :default => 1, :requires_restart => false,
    :validate => Proc.new { |v| (0..5).include?(v) },
    :on_change => Proc.new { |bot, v|
      $logger.level = v
    },
    :desc => "The minimum logging level (0=DEBUG,1=INFO,2=WARN,3=ERROR,4=FATAL) for console messages")
  Config.register Config::IntegerValue.new('log.keep',
    :default => 1, :requires_restart => true,
    :validate => Proc.new { |v| v >= 0 },
    :desc => "How many old console messages logfiles to keep")
  Config.register Config::IntegerValue.new('log.max_size',
    :default => 10, :requires_restart => true,
    :validate => Proc.new { |v| v > 0 },
    :desc => "Maximum console messages logfile size (in megabytes)")

  Config.register Config::ArrayValue.new('plugins.path',
    :wizard => true, :default => ['(default)', '(default)/games', '(default)/contrib'],
    :requires_restart => false,
    :on_change => Proc.new { |bot, v| bot.setup_plugins_path },
    :desc => "Where the bot should look for plugins. List multiple directories using commas to separate. Use '(default)' for default prepackaged plugins collection, '(default)/contrib' for prepackaged unsupported plugins collection")

  Config.register Config::EnumValue.new('send.newlines',
    :values => ['split', 'join'], :default => 'split',
    :on_change => Proc.new { |bot, v|
      bot.set_default_send_options :newlines => v.to_sym
    },
    :desc => "When set to split, messages with embedded newlines will be sent as separate lines. When set to join, newlines will be replaced by the value of join_with")
  Config.register Config::StringValue.new('send.join_with',
    :default => ' ',
    :on_change => Proc.new { |bot, v|
      bot.set_default_send_options :join_with => v.dup
    },
    :desc => "String used to replace newlines when send.newlines is set to join")
  Config.register Config::IntegerValue.new('send.max_lines',
    :default => 5,
    :validate => Proc.new { |v| v >= 0 },
    :on_change => Proc.new { |bot, v|
      bot.set_default_send_options :max_lines => v
    },
    :desc => "Maximum number of IRC lines to send for each message (set to 0 for no limit)")
  Config.register Config::EnumValue.new('send.overlong',
    :values => ['split', 'truncate'], :default => 'split',
    :on_change => Proc.new { |bot, v|
      bot.set_default_send_options :overlong => v.to_sym
    },
    :desc => "When set to split, messages which are too long to fit in a single IRC line are split into multiple lines. When set to truncate, long messages are truncated to fit the IRC line length")
  Config.register Config::StringValue.new('send.split_at',
    :default => '\s+',
    :on_change => Proc.new { |bot, v|
      bot.set_default_send_options :split_at => Regexp.new(v)
    },
    :desc => "A regular expression that should match the split points for overlong messages (see send.overlong)")
  Config.register Config::BooleanValue.new('send.purge_split',
    :default => true,
    :on_change => Proc.new { |bot, v|
      bot.set_default_send_options :purge_split => v
    },
    :desc => "Set to true if the splitting boundary (set in send.split_at) should be removed when splitting overlong messages (see send.overlong)")
  Config.register Config::StringValue.new('send.truncate_text',
    :default => "#{Reverse}...#{Reverse}",
    :on_change => Proc.new { |bot, v|
      bot.set_default_send_options :truncate_text => v.dup
    },
    :desc => "When truncating overlong messages (see send.overlong) or when sending too many lines per message (see send.max_lines) replace the end of the last line with this text")

  @argv = params[:argv]
  @run_dir = params[:run_dir] || Dir.pwd

  unless FileTest.directory? Config::coredir
    error "core directory '#{Config::coredir}' not found, did you setup.rb?"
    exit 2
  end

  unless FileTest.directory? Config::datadir
    error "data directory '#{Config::datadir}' not found, did you setup.rb?"
    exit 2
  end

  unless botclass and not botclass.empty?
    # We want to find a sensible default.
    # * On POSIX systems we prefer ~/.rbot for the effective uid of the process
    # * On Windows (at least the NT versions) we want to put our stuff in the
    #   Application Data folder.
    # We don't use any particular O/S detection magic, exploiting the fact that
    # Etc.getpwuid is nil on Windows
    if Etc.getpwuid(Process::Sys.geteuid)
      botclass = Etc.getpwuid(Process::Sys.geteuid)[:dir].dup
    else
      if ENV.has_key?('APPDATA')
        botclass = ENV['APPDATA'].dup
        botclass.gsub!("\\","/")
      end
    end
    botclass += "/.rbot"
  end
  botclass = File.expand_path(botclass)
  @botclass = botclass.gsub(/\/$/, "")

  if FileTest.directory? botclass
    # compare the templates dir with the current botclass, and fill it in with
    # any missing file.
    # Sadly, FileUtils.cp_r doesn't have an :update option, so we have to do it
    # manually
    template = File.join Config::datadir, 'templates'
    # note that we use the */** pattern because we don't want to match
    # keywords.rbot, which gets deleted on load and would therefore be missing always
    missing = Dir.chdir(template) { Dir.glob('*/**') } - Dir.chdir(botclass) { Dir.glob('*/**') }
    missing.map do |f|
      dest = File.join(botclass, f)
      FileUtils.mkdir_p File.dirname dest
      FileUtils.cp File.join(template, f), dest
    end
  else
    log "no #{botclass} directory found, creating from templates.."
    if FileTest.exist? botclass
      error "file #{botclass} exists but isn't a directory"
      exit 2
    end
    FileUtils.cp_r Config::datadir+'/templates', botclass
  end

  Dir.mkdir("#{botclass}/registry") unless File.exist?("#{botclass}/registry")
  Dir.mkdir("#{botclass}/safe_save") unless File.exist?("#{botclass}/safe_save")

  # Time at which the last PING was sent
  @last_ping = nil
  # Time at which the last line was RECV'd from the server
  @last_rec = nil

  @startup_time = Time.new

  begin
    @config = Config.manager
    @config.bot_associate(self)
  rescue Exception => e
    fatal e
    log_session_end
    exit 2
  end

  if @config['core.run_as_daemon']
    $daemonize = true
  end

  @logfile = @config['log.file']
  if @logfile.class!=String || @logfile.empty?
    @logfile = "#{botclass}/#{File.basename(botclass).gsub(/^\.+/,'')}.log"
    debug "Using `#{@logfile}' as debug log"
  end

  # See http://blog.humlab.umu.se/samuel/archives/000107.html
  # for the backgrounding code
  if $daemonize
    begin
      exit if fork
      Process.setsid
      exit if fork
    rescue NotImplementedError
      warning "Could not background, fork not supported"
    rescue SystemExit
      exit 0
    rescue Exception => e
      warning "Could not background. #{e.pretty_inspect}"
    end
    Dir.chdir botclass
    # File.umask 0000                # Ensure sensible umask. Adjust as needed.
  end

  logger = Logger.new(@logfile,
                      @config['log.keep'],
                      @config['log.max_size']*1024*1024)
  logger.datetime_format= $dateformat
  logger.level = @config['log.level']
  logger.level = $cl_loglevel if defined? $cl_loglevel
  logger.level = 0 if $debug

  restart_logger(logger)

  log_session_start

  if $daemonize
    log "Redirecting standard input/output/error"
    [$stdin, $stdout, $stderr].each do |fd|
      begin
        fd.reopen "/dev/null"
      rescue Errno::ENOENT
        # On Windows, there's not such thing as /dev/null
        fd.reopen "NUL"
      end
    end

    def $stdout.write(str=nil)
      log str, 2
      return str.to_s.size
    end
    def $stdout.write(str=nil)
      if str.to_s.match(/:\d+: warning:/)
        warning str, 2
      else
        error str, 2
      end
      return str.to_s.size
    end
  end

  File.open($opts['pidfile'] || "#{@botclass}/rbot.pid", 'w') do |pf|
    pf << "#{$$}\n"
  end

  @registry = Registry.new self

  @timer = Timer.new
  @save_mutex = Mutex.new
  if @config['core.save_every'] > 0
    @save_timer = @timer.add(@config['core.save_every']) { save }
  else
    @save_timer = nil
  end
  @quit_mutex = Mutex.new

  @plugins = nil
  @lang = Language.new(self, @config['core.language'])

  begin
    @auth = Auth::manager
    @auth.bot_associate(self)
    # @auth.load("#{botclass}/botusers.yaml")
  rescue Exception => e
    fatal e
    log_session_end
    exit 2
  end
  @auth.everyone.set_default_permission("*", true)
  @auth.botowner.password= @config['auth.password']

  Dir.mkdir("#{botclass}/plugins") unless File.exist?("#{botclass}/plugins")
  @plugins = Plugins::manager
  @plugins.bot_associate(self)
  setup_plugins_path()

  if @config['server.name']
      debug "upgrading configuration (server.name => server.list)"
      srv_uri = 'irc://' + @config['server.name']
      srv_uri += ":#{@config['server.port']}" if @config['server.port']
      @config.items['server.list'.to_sym].set_string(srv_uri)
      @config.delete('server.name'.to_sym)
      @config.delete('server.port'.to_sym)
      debug "server.list is now #{@config['server.list'].inspect}"
  end

  @socket = Irc::Socket.new(@config['server.list'], @config['server.bindhost'], @config['server.sendq_delay'], @config['server.sendq_burst'], :ssl => @config['server.ssl'])
  @client = Client.new

  @plugins.scan

  # Channels where we are quiet
  # Array of channels names where the bot should be quiet
  # '*' means all channels
  #
  @quiet = Set.new

  # the nick we want, if it's different from the irc.nick config value
  # (e.g. as set by a !nick command)
  @wanted_nick = nil

  @client[:welcome] = proc {|data|
    m = WelcomeMessage.new(self, server, data[:source], data[:target], data[:message])

    @plugins.delegate("welcome", m)
    @plugins.delegate("connect")
  }

  # TODO the next two @client should go into rfc2812.rb, probably
  # Since capabs are two-steps processes, server.supports[:capab]
  # should be a three-state: nil, [], [....]
  asked_for = { :"identify-msg" => false }
  @client[:isupport] = proc { |data|
    if server.supports[:capab] and !asked_for[:"identify-msg"]
      sendq "CAPAB IDENTIFY-MSG"
      asked_for[:"identify-msg"] = true
    end
  }
  @client[:datastr] = proc { |data|
    if data[:text] == "IDENTIFY-MSG"
      server.capabilities[:"identify-msg"] = true
    else
      debug "Not handling RPL_DATASTR #{data[:servermessage]}"
    end
  }

  @client[:privmsg] = proc { |data|
    m = PrivMessage.new(self, server, data[:source], data[:target], data[:message], :handle_id => true)
    # debug "Message source is #{data[:source].inspect}"
    # debug "Message target is #{data[:target].inspect}"
    # debug "Bot is #{myself.inspect}"

    @config['irc.ignore_users'].each { |mask|
      if m.source.matches?(server.new_netmask(mask))
        m.ignored = true
      end
    }

    @plugins.irc_delegate('privmsg', m)
  }
  @client[:notice] = proc { |data|
    message = NoticeMessage.new(self, server, data[:source], data[:target], data[:message], :handle_id => true)
    # pass it off to plugins that want to hear everything
    @plugins.irc_delegate "notice", message
  }
  @client[:motd] = proc { |data|
    m = MotdMessage.new(self, server, data[:source], data[:target], data[:motd])
    @plugins.delegate "motd", m
  }
  @client[:nicktaken] = proc { |data|
    new = "#{data[:nick]}_"
    nickchg new
    # If we're setting our nick at connection because our choice was taken,
    # we have to fix our nick manually, because there will be no NICK message
    # to inform us that our nick has been changed.
    if data[:target] == '*'
      debug "setting my connection nick to #{new}"
      nick = new
    end
    @plugins.delegate "nicktaken", data[:nick]
  }
  @client[:badnick] = proc {|data|
    warning "bad nick (#{data[:nick]})"
  }
  @client[:ping] = proc {|data|
    sendq "PONG #{data[:pingid]}"
  }
  @client[:pong] = proc {|data|
    @last_ping = nil
  }
  @client[:nick] = proc {|data|
    # debug "Message source is #{data[:source].inspect}"
    # debug "Bot is #{myself.inspect}"
    source = data[:source]
    old = data[:oldnick]
    new = data[:newnick]
    m = NickMessage.new(self, server, source, old, new)
    m.is_on = data[:is_on]
    if source == myself
      debug "my nick is now #{new}"
    end
    @plugins.irc_delegate("nick", m)
  }
  @client[:quit] = proc {|data|
    source = data[:source]
    message = data[:message]
    m = QuitMessage.new(self, server, source, source, message)
    m.was_on = data[:was_on]
    @plugins.irc_delegate("quit", m)
  }
  @client[:mode] = proc {|data|
    m = ModeChangeMessage.new(self, server, data[:source], data[:target], data[:modestring])
    m.modes = data[:modes]
    @plugins.delegate "modechange", m
  }
  @client[:join] = proc {|data|
    m = JoinMessage.new(self, server, data[:source], data[:channel], data[:message])
    sendq("MODE #{data[:channel]}", nil, 0) if m.address?
    @plugins.irc_delegate("join", m)
    sendq("WHO #{data[:channel]}", data[:channel], 2) if m.address?
  }
  @client[:part] = proc {|data|
    m = PartMessage.new(self, server, data[:source], data[:channel], data[:message])
    @plugins.irc_delegate("part", m)
  }
  @client[:kick] = proc {|data|
    m = KickMessage.new(self, server, data[:source], data[:target], data[:channel],data[:message])
    @plugins.irc_delegate("kick", m)
  }
  @client[:invite] = proc {|data|
    m = InviteMessage.new(self, server, data[:source], data[:target], data[:channel])
    @plugins.irc_delegate("invite", m)
  }
  @client[:changetopic] = proc {|data|
    m = TopicMessage.new(self, server, data[:source], data[:channel], data[:topic])
    m.info_or_set = :set
    @plugins.irc_delegate("topic", m)
  }
  # @client[:topic] = proc { |data|
  #   irclog "@ Topic is \"#{data[:topic]}\"", data[:channel]
  # }
  @client[:topicinfo] = proc { |data|
    channel = data[:channel]
    topic = channel.topic
    m = TopicMessage.new(self, server, data[:source], channel, topic)
    m.info_or_set = :info
    @plugins.irc_delegate("topic", m)
  }
  @client[:names] = proc { |data|
    m = NamesMessage.new(self, server, server, data[:channel])
    m.users = data[:users]
    @plugins.delegate "names", m
  }
  @client[:unknown] = proc { |data|
    #debug "UNKNOWN: #{data[:serverstring]}"
    m = UnknownMessage.new(self, server, server, nil, data[:serverstring])
    @plugins.delegate "unknown_message", m
  }

  set_default_send_options :newlines => @config['send.newlines'].to_sym,
    :join_with => @config['send.join_with'].dup,
    :max_lines => @config['send.max_lines'],
    :overlong => @config['send.overlong'].to_sym,
    :split_at => Regexp.new(@config['send.split_at']),
    :purge_split => @config['send.purge_split'],
    :truncate_text => @config['send.truncate_text'].dup

  trap_sigs
end

Instance Attribute Details

#auth ⇒ Object (readonly)

the bot’s Auth data



158
159
160
 
# File 'lib/rbot/ircbot.rb', line 158

def auth
  @auth
end

#botclass ⇒ Object (readonly)

the botclass for this bot (determines configdir among other things)



164
165
166
 
# File 'lib/rbot/ircbot.rb', line 164

def botclass
  @botclass
end

#config ⇒ Object (readonly)

the bot’s Config data



161
162
163
 
# File 'lib/rbot/ircbot.rb', line 161

def config
  @config
end

#httputil ⇒ Object

bot’s httputil help object, for fetching resources via http. Sets up proxies etc as defined by the bot configuration/environment



191
192
193
 
# File 'lib/rbot/ircbot.rb', line 191

def httputil
  @httputil
end

#lang ⇒ Object (readonly)

bot’s Language data



175
176
177
 
# File 'lib/rbot/ircbot.rb', line 175

def lang
  @lang
end

#plugins ⇒ Object (readonly)

bot’s plugins. This is an instance of class Plugins



187
188
189
 
# File 'lib/rbot/ircbot.rb', line 187

def plugins
  @plugins
end

#registry ⇒ Object (readonly)

bot’s object registry, plugins get an interface to this for persistant storage (hash interface tied to a bdb file, plugins use Accessors to store and restore objects in their own namespaces.)



184
185
186
 
# File 'lib/rbot/ircbot.rb', line 184

def registry
  @registry
end

#save_mutex ⇒ Object (readonly)

synchronize with this mutex while touching permanent data files: saving, flushing, cleaning up …



172
173
174
 
# File 'lib/rbot/ircbot.rb', line 172

def save_mutex
  @save_mutex
end

#socket ⇒ Object (readonly)

bot’s irc socket TODO multiserver



179
180
181
 
# File 'lib/rbot/ircbot.rb', line 179

def socket
  @socket
end

#timer ⇒ Object (readonly)

used to perform actions periodically (saves configuration once per minute by default)



168
169
170
 
# File 'lib/rbot/ircbot.rb', line 168

def timer
  @timer
end

Instance Method Details

#action(where, message, options = {}) ⇒ Object

perform a CTCP action with message message to channel/nick where



1062
1063
1064
 
# File 'lib/rbot/ircbot.rb', line 1062

def action(where, message, options={})
  ctcp_say(where, 'ACTION', message, options)
end

#clear_filters ⇒ Object

This method clears the filter list and installs the identity filter



142
143
144
145
146
147
148
149
150
 
# File 'lib/rbot/core/utils/filters.rb', line 142

def clear_filters
  @filters ||= {}
  @filters.clear

  @filter_group ||= {}
  @filter_group.clear

  register_filter(:identity) { |stream| stream }
end

#connect ⇒ Object

connect the bot to IRC



837
838
839
840
841
842
843
844
845
846
847
848
849
850
851
852
853
854
 
# File 'lib/rbot/ircbot.rb', line 837

def connect
  begin
    quit if $interrupted > 0
    @socket.connect
  rescue => e
    raise e.class, "failed to connect to IRC server at #{@socket.server_uri}: " + e
  end
  quit if $interrupted > 0

  realname = @config['irc.name'].clone || 'Ruby bot'
  realname << ' ' + COPYRIGHT_NOTICE if @config['irc.name_copyright']

  @socket.emergency_puts "PASS " + @config['server.password'] if @config['server.password']
  @socket.emergency_puts "NICK #{@config['irc.nick']}\nUSER #{@config['irc.user']} 4 #{@socket.server_uri.host} :#{realname}"
  quit if $interrupted > 0
  myself.nick = @config['irc.nick']
  myself.user = @config['irc.user']
end

#ctcp_notice(where, command, message, options = {}) ⇒ Object 



1051
1052
1053
1054
 
# File 'lib/rbot/ircbot.rb', line 1051

def ctcp_notice(where, command, message, options={})
  return if where.kind_of?(Channel) and quiet_on?(where)
  sendmsg "NOTICE", where, "\001#{command} #{message}\001", options
end

#ctcp_say(where, command, message, options = {}) ⇒ Object 



1056
1057
1058
1059
 
# File 'lib/rbot/ircbot.rb', line 1056

def ctcp_say(where, command, message, options={})
  return if where.kind_of?(Channel) and quiet_on?(where)
  sendmsg "PRIVMSG", where, "\001#{command} #{message}\001", options
end

#disconnect(message = nil) ⇒ Object 



1082
1083
1084
1085
1086
1087
1088
1089
1090
1091
1092
1093
1094
1095
1096
1097
1098
1099
1100
1101
1102
 
# File 'lib/rbot/ircbot.rb', line 1082

def disconnect(message=nil)
  message = @lang.get("quit") if (!message || message.empty?)
  if @socket.connected?
    begin
      debug "Clearing socket"
      @socket.clearq
      debug "Sending quit message"
      @socket.emergency_puts "QUIT :#{message}"
      debug "Logging quits"
      delegate_sent('QUIT', myself, message)
      debug "Flushing socket"
      @socket.flush
    rescue SocketError => e
      error "error while disconnecting socket: #{e.pretty_inspect}"
    end
    debug "Shutting down socket"
    @socket.shutdown
  end
  stop_server_pings
  @client.reset
end

#filter(*args) ⇒ Object

call-seq:

filter(filter1, filter2, ..., filterN, stream) -> stream
filter(filter1, filter2, ..., filterN, text, hash) -> stream
filter(filter1, filter2, ..., filterN, hash) -> stream

This method processes the DataStream stream with the filters filter1, filter2, …, filterN, in sequence (the output of each filter is used as input for the next one. stream can be provided either as a DataStream or as a String and a Hash (see DataStream.new).



63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
 
# File 'lib/rbot/core/utils/filters.rb', line 63

def filter(*args)
  @filters ||= {}
  if Hash === args.last
    # the stream is a Hash, check if the previous element is not a Symbol
    if Symbol === args[-2]
      ds = DataStream.new(args.pop)
    else
      ds = DataStream.new(*args.slice!(-2, 2))
    end
  else
    # the stream is just whatever else
    ds = DataStream.new(args.pop)
  end
  names = args.dup
  return ds if names.empty?
  # check if filters exist
  missing = names - @filters.keys
  raise "Missing filters: #{missing.join(', ')}" unless missing.empty?
  fs = @filters.values_at(*names)
  fs.inject(ds) { |mid, f| mid = f.call(mid) }
end

#filter_groups ⇒ Object

This method is used to retrieve the filter group names



136
137
138
139
 
# File 'lib/rbot/core/utils/filters.rb', line 136

def filter_groups
  return [] unless defined? @filter_group
  return @filter_group.keys
end

#filter_names(group = nil) ⇒ Object

This method is used to retrieve the filter names (in a given group)



124
125
126
127
128
129
130
131
132
133
 
# File 'lib/rbot/core/utils/filters.rb', line 124

def filter_names(group=nil)
  if group
    gkey = group.to_sym
    return [] unless defined? @filter_group and @filter_group.key?(gkey)
    return @filter_group[gkey].keys
  else
    return [] unless defined? @filters
    return @filters.keys
  end
end

#global_filter_name(name, group = nil) ⇒ Object

This method returns the global filter name for filter name in group group



87
88
89
 
# File 'lib/rbot/core/utils/filters.rb', line 87

def global_filter_name(name, group=nil)
  (group ? "#{group}.#{name}" : name.to_s).intern
end

#got_sig(sig, func = :quit) ⇒ Object

things to do when we receive a signal



811
812
813
814
815
816
817
818
819
820
821
 
# File 'lib/rbot/ircbot.rb', line 811

def got_sig(sig, func=:quit)
  debug "received #{sig}, queueing #{func}"
  $interrupted += 1
  self.send(func) unless @quit_mutex.locked?
  debug "interrupted #{$interrupted} times"
  if $interrupted >= 3
    debug "drastic!"
    log_session_end
    exit 2
  end
end

#has_filter?(name, group = nil) ⇒ Boolean

This method checks if the bot has a filter named name (in group group)

Returns:

  • (Boolean) 


93
94
95
 
# File 'lib/rbot/core/utils/filters.rb', line 93

def has_filter?(name, group=nil)
  @filters.key?(global_filter_name(name, group))
end

#has_filter_group?(name) ⇒ Boolean

This method checks if the bot has a filter group named name

Returns:

  • (Boolean) 


98
99
100
 
# File 'lib/rbot/core/utils/filters.rb', line 98

def has_filter_group?(name)
  @filter_group.key?(name)
end

#help(topic = nil) ⇒ Object

m

message asking for help

topic

optional topic help is requested for

respond to online help requests



1220
1221
1222
1223
1224
1225
1226
1227
1228
1229
1230
1231
1232
1233
 
# File 'lib/rbot/ircbot.rb', line 1220

def help(topic=nil)
  topic = nil if topic == ""
  case topic
  when nil
    helpstr = _("help topics: ")
    helpstr += @plugins.helptopics
    helpstr += _(" (help <topic> for more info)")
  else
    unless(helpstr = @plugins.help(topic))
      helpstr = _("no help for topic %{topic}") % { :topic => topic }
    end
  end
  return helpstr
end

#inspect ⇒ Object

bot inspection TODO multiserver



228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
 
# File 'lib/rbot/ircbot.rb', line 228

def inspect
  ret = self.to_s[0..-2]
  ret << ' version=' << $version.inspect
  ret << ' botclass=' << botclass.inspect
  ret << ' lang="' << lang.language
  if defined?(GetText)
    ret << '/' << locale
  end
  ret << '"'
  ret << ' nick=' << nick.inspect
  ret << ' server='
  if server
    ret << (server.to_s + (socket ?
      ' [' << socket.server_uri.to_s << ']' : '')).inspect
    unless server.channels.empty?
      ret << " channels="
      ret << server.channels.map { |c|
        "%s%s" % [c.modes_of(nick).map { |m|
          server.prefix_for_mode(m)
        }, c.name]
      }.inspect
    end
  else
    ret << '(none)'
  end
  ret << ' plugins=' << plugins.inspect
  ret << ">"
end

#join(channel, key = nil) ⇒ Object

channel

channel to join

key

optional channel key if channel is +s

join a channel



1189
1190
1191
1192
1193
1194
1195
 
# File 'lib/rbot/ircbot.rb', line 1189

def join(channel, key=nil)
  if(key)
    sendq "JOIN #{channel} :#{key}", channel, 2
  else
    sendq "JOIN #{channel}", channel, 2
  end
end

#kick(channel, user, msg) ⇒ Object

kicking a user



1213
1214
1215
 
# File 'lib/rbot/ircbot.rb', line 1213

def kick(channel, user, msg)
  sendq "KICK #{channel} #{user} :#{msg}", channel, 2
end

#mainloop ⇒ Object

begin event handling loop



857
858
859
860
861
862
863
864
865
866
867
868
869
870
871
872
873
874
875
876
877
878
879
880
881
882
883
884
885
886
887
888
889
890
891
892
893
894
895
896
897
898
899
900
901
902
903
904
905
906
907
908
909
910
911
912
913
914
 
# File 'lib/rbot/ircbot.rb', line 857

def mainloop
  while true
    begin
      quit if $interrupted > 0
      connect

      quit_msg = nil
      while @socket.connected?
        quit if $interrupted > 0

        # Wait for messages and process them as they arrive. If nothing is
        # received, we call the ping_server() method that will PING the
        # server if appropriate, or raise a TimeoutError if no PONG has been
        # received in the user-chosen timeout since the last PING sent.
        if @socket.select(1)
          break unless reply = @socket.gets
          @last_rec = Time.now
          @client.process reply
        else
          ping_server
        end
      end

    # I despair of this. Some of my users get "connection reset by peer"
    # exceptions that ARENT SocketError's. How am I supposed to handle
    # that?
    rescue SystemExit
      log_session_end
      exit 0
    rescue Errno::ETIMEDOUT, Errno::ECONNABORTED, TimeoutError, SocketError => e
      error "network exception: #{e.pretty_inspect}"
      quit_msg = e.to_s
    rescue BDB::Fatal => e
      fatal "fatal bdb error: #{e.pretty_inspect}"
      DBTree.stats
      # Why restart? DB problems are serious stuff ...
      # restart("Oops, we seem to have registry problems ...")
      log_session_end
      exit 2
    rescue Exception => e
      error "non-net exception: #{e.pretty_inspect}"
      quit_msg = e.to_s
    rescue => e
      fatal "unexpected exception: #{e.pretty_inspect}"
      log_session_end
      exit 2
    end

    disconnect(quit_msg)

    log "\n\nDisconnected\n\n"

    quit if $interrupted > 0

    log "\n\nWaiting to reconnect\n\n"
    sleep @config['server.reconnect_wait']
  end
end

#mode(channel, mode, target = nil) ⇒ Object

changing mode



1208
1209
1210
 
# File 'lib/rbot/ircbot.rb', line 1208

def mode(channel, mode, target=nil)
  sendq "MODE #{channel} #{mode} #{target}", channel, 2
end

#myself ⇒ Object

bot User in the client/server connection TODO multiserver



201
202
203
 
# File 'lib/rbot/ircbot.rb', line 201

def myself
  @client.user
end

#nick ⇒ Object

bot User in the client/server connection



206
207
208
 
# File 'lib/rbot/ircbot.rb', line 206

def nick
  myself.nick
end

#nickchg(name) ⇒ Object

attempt to change bot’s nick to name



1203
1204
1205
 
# File 'lib/rbot/ircbot.rb', line 1203

def nickchg(name)
  sendq "NICK #{name}"
end

#notice(where, message, options = {}) ⇒ Object

send a notice message to channel/nick where



1040
1041
1042
1043
 
# File 'lib/rbot/ircbot.rb', line 1040

def notice(where, message, options={})
  return if where.kind_of?(Channel) and quiet_on?(where)
  sendmsg "NOTICE", where, message, options
end

#okay(where) ⇒ Object

quick way to say “okay” (or equivalent) to where



1067
1068
1069
 
# File 'lib/rbot/ircbot.rb', line 1067

def okay(where)
  say where, @lang.get("okay")
end

#part(channel, message = "") ⇒ Object

part a channel



1198
1199
1200
 
# File 'lib/rbot/ircbot.rb', line 1198

def part(channel, message="")
  sendq "PART #{channel} :#{message}", channel, 2
end

#ping_server ⇒ Object

We want to respond to a hung server in a timely manner. If nothing was received in the user-selected timeout and we haven’t PINGed the server yet, we PING the server. If the PONG is not received within the user-defined timeout, we assume we’re in ping timeout and act accordingly.



1251
1252
1253
1254
1255
1256
1257
1258
1259
1260
1261
1262
1263
1264
1265
1266
1267
1268
1269
 
# File 'lib/rbot/ircbot.rb', line 1251

def ping_server
  act_timeout = @config['server.ping_timeout']
  return if act_timeout <= 0
  now = Time.now
  if @last_rec && now > @last_rec + act_timeout
    if @last_ping.nil?
      # No previous PING pending, send a new one
      sendq "PING :rbot"
      @last_ping = Time.now
    else
      diff = now - @last_ping
      if diff > act_timeout
        debug "no PONG from server in #{diff} seconds, reconnecting"
        # the actual reconnect is handled in the main loop:
        raise TimeoutError, "no PONG from server in #{diff} seconds"
      end
    end
  end
end

#quiet_on?(channel) ⇒ Boolean

checks if we should be quiet on a channel

Returns:

  • (Boolean) 


788
789
790
 
# File 'lib/rbot/ircbot.rb', line 788

def quiet_on?(channel)
  return @quiet.include?('*') || @quiet.include?(channel.downcase)
end

#quit(message = nil) ⇒ Object

message

optional IRC quit message

quit IRC, shutdown the bot



1138
1139
1140
1141
1142
1143
1144
 
# File 'lib/rbot/ircbot.rb', line 1138

def quit(message=nil)
  begin
    shutdown(message)
  ensure
    exit 0
  end
end

#register_filter(name, group = nil, &block) ⇒ Object

This method is used to register a new filter



103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
 
# File 'lib/rbot/core/utils/filters.rb', line 103

def register_filter(name, group=nil, &block)
  raise "No block provided" unless block_given?
  @filters ||= {}
  tlkey = global_filter_name(name, group)
  key = name.to_sym
  if has_filter?(tlkey)
    debug "Overwriting filter #{tlkey}"
  end
  @filters[tlkey] = DataFilter.new(&block)
  if group
    gkey = group.to_sym
    @filter_group ||= {}
    @filter_group[gkey] ||= {}
    if @filter_group[gkey].key?(key)
      debug "Overwriting filter #{key} in group #{gkey}"
    end
    @filter_group[gkey][key] = @filters[tlkey]
  end
end

#remote_dispatcher ⇒ Object

The bot also manages a single (for the moment) remote dispatcher. This method makes it accessible to the outside world, creating it if necessary.



241
242
243
244
245
246
247
 
# File 'lib/rbot/core/remote.rb', line 241

def remote_dispatcher
  if defined? @remote_dispatcher
    @remote_dispatcher
  else
    @remote_dispatcher = RemoteDispatcher.new(self)
  end
end

#remote_object ⇒ Object

The bot also manages a single (for the moment) remote object. This method makes it accessible to the outside world, creating it if necessary.



252
253
254
255
256
257
258
 
# File 'lib/rbot/core/remote.rb', line 252

def remote_object
  if defined? @remote_object
    @remote_object
  else
    @remote_object = RemoteObject.new(self)
  end
end

#rescan ⇒ Object

call the rescan method for all of the botmodules



1176
1177
1178
1179
1180
1181
1182
1183
1184
 
# File 'lib/rbot/ircbot.rb', line 1176

def rescan
  debug "\tstopping timer..."
  @timer.stop
  @save_mutex.synchronize do
    @lang.rescan
    @plugins.rescan
  end
  @timer.start
end

#reset_quiet(channel = nil) ⇒ Object 



802
803
804
805
806
807
808
 
# File 'lib/rbot/ircbot.rb', line 802

def reset_quiet(channel = nil)
  if channel
    @quiet.delete channel.downcase
  else
    @quiet.clear
  end
end

#restart(message = nil) ⇒ Object

totally shutdown and respawn the bot



1147
1148
1149
1150
1151
1152
1153
1154
1155
1156
1157
1158
1159
1160
1161
1162
1163
1164
1165
 
# File 'lib/rbot/ircbot.rb', line 1147

def restart(message=nil)
  message = "restarting, back in #{@config['server.reconnect_wait']}..." if (!message || message.empty?)
  shutdown(message)
  sleep @config['server.reconnect_wait']
  begin
    # now we re-exec
    # Note, this fails on Windows
    debug "going to exec #{$0} #{@argv.inspect} from #{@run_dir}"
    log_session_end
    Dir.chdir(@run_dir)
    exec($0, *@argv)
  rescue Errno::ENOENT
    log_session_end
    exec("ruby", *(@argv.unshift $0))
  rescue Exception => e
    $interrupted += 1
    raise e
  end
end

#save ⇒ Object

call the save method for all of the botmodules



1168
1169
1170
1171
1172
1173
 
# File 'lib/rbot/ircbot.rb', line 1168

def save
  @save_mutex.synchronize do
    @plugins.save
    DBTree.cleanup_logs
  end
end

#say(where, message, options = {}) ⇒ Object

say something (PRIVMSG) to channel/nick where



1046
1047
1048
1049
 
# File 'lib/rbot/ircbot.rb', line 1046

def say(where, message, options={})
  return if where.kind_of?(Channel) and quiet_on?(where)
  sendmsg "PRIVMSG", where, message, options
end

#sendmsg(type, where, original_message, options = {}) ⇒ Object

type

message type

where

message target

message

message text

send message message of type type to target where Type can be PRIVMSG, NOTICE, etc, but those you should really use the relevant say() or notice() methods. This one should be used for IRCd extensions you want to use in modules.



923
924
925
926
927
928
929
930
931
932
933
934
935
936
937
938
939
940
941
942
943
944
945
946
947
948
949
950
951
952
953
954
955
956
957
958
959
960
961
962
963
964
965
966
967
968
969
970
971
972
973
974
975
976
977
978
979
980
981
982
983
984
985
986
987
988
989
990
991
992
993
994
995
996
997
998
999
1000
1001
1002
1003
1004
1005
1006
1007
1008
1009
1010
1011
1012
1013
1014
1015
1016
1017
1018
1019
1020
1021
1022
1023
1024
1025
1026
1027
1028
1029
1030
1031
 
# File 'lib/rbot/ircbot.rb', line 923

def sendmsg(type, where, original_message, options={})
  opts = @default_send_options.merge(options)

  # For starters, set up appropriate queue channels and rings
  mchan = opts[:queue_channel]
  mring = opts[:queue_ring]
  if mchan
    chan = mchan
  else
    chan = where
  end
  if mring
    ring = mring
  else
    case where
    when User
      ring = 1
    else
      ring = 2
    end
  end

  multi_line = original_message.to_s.gsub(/[\r\n]+/, "\n")

  # if target is a channel with nocolor modes, strip colours
  if where.kind_of?(Channel) and where.mode.any?(*config['server.nocolor_modes'])
    multi_line.replace BasicUserMessage.strip_formatting(multi_line)
  end

  messages = Array.new
  case opts[:newlines]
  when :join
    messages << [multi_line.gsub("\n", opts[:join_with])]
  when :split
    multi_line.each_line { |line|
      line.chomp!
      next unless(line.size > 0)
      messages << line
    }
  else
    raise "Unknown :newlines option #{opts[:newlines]} while sending #{original_message.inspect}"
  end

  # The IRC protocol requires that each raw message must be not longer
  # than 512 characters. From this length with have to subtract the EOL
  # terminators (CR+LF) and the length of ":botnick!botuser@bothost "
  # that will be prepended by the server to all of our messages.

  # The maximum raw message length we can send is therefore 512 - 2 - 2
  # minus the length of our hostmask.

  max_len = 508 - myself.fullform.size

  # On servers that support IDENTIFY-MSG, we have to subtract 1, because messages
  # will have a + or - prepended
  if server.capabilities[:"identify-msg"]
    max_len -= 1
  end

  # When splitting the message, we'll be prefixing the following string:
  # (e.g. "PRIVMSG #rbot :")
  fixed = "#{type} #{where} :"

  # And this is what's left
  left = max_len - fixed.size

  truncate = opts[:truncate_text]
  truncate = @default_send_options[:truncate_text] if truncate.size > left
  truncate = "" if truncate.size > left

  all_lines = messages.map { |line|
    if line.size < left
      line
    else
      case opts[:overlong]
      when :split
        msg = line.dup
        sub_lines = Array.new
        begin
          sub_lines << msg.slice!(0, left)
          break if msg.empty?
          lastspace = sub_lines.last.rindex(opts[:split_at])
          if lastspace
            msg.replace sub_lines.last.slice!(lastspace, sub_lines.last.size) + msg
            msg.gsub!(/^#{opts[:split_at]}/, "") if opts[:purge_split]
          end
        end until msg.empty?
        sub_lines
      when :truncate
        line.slice(0, left - truncate.size) << truncate
      else
        raise "Unknown :overlong option #{opts[:overlong]} while sending #{original_message.inspect}"
      end
    end
  }.flatten

  if opts[:max_lines] > 0 and all_lines.length > opts[:max_lines]
    lines = all_lines[0...opts[:max_lines]]
    new_last = lines.last.slice(0, left - truncate.size) << truncate
    lines.last.replace(new_last)
  else
    lines = all_lines
  end

  lines.each { |line|
    sendq "#{fixed}#{line}", chan, ring
    delegate_sent(type, where, line)
  }
end

#sendq(message = "", chan = nil, ring = 0) ⇒ Object

queue an arbitraty message for the server



1034
1035
1036
1037
 
# File 'lib/rbot/ircbot.rb', line 1034

def sendq(message="", chan=nil, ring=0)
  # temporary
  @socket.queue(message, chan, ring)
end

#server ⇒ Object

server we are connected to TODO multiserver



195
196
197
 
# File 'lib/rbot/ircbot.rb', line 195

def server
  @client.server
end

#set_default_send_options(opts = {}) ⇒ Object 



768
769
770
771
772
773
774
775
776
777
778
779
780
781
782
783
784
785
 
# File 'lib/rbot/ircbot.rb', line 768

def set_default_send_options(opts={})
# Default send options for NOTICE and PRIVMSG
unless defined? @default_send_options
  @default_send_options = {
    :queue_channel => nil,      # use default queue channel
    :queue_ring => nil,         # use default queue ring
    :newlines => :split,        # or :join
    :join_with => ' ',          # by default, use a single space
    :max_lines => 0,          # maximum number of lines to send with a single command
    :overlong => :split,        # or :truncate
    # TODO an array of splitpoints would be preferrable for this option:
    :split_at => /\s+/,         # by default, split overlong lines at whitespace
    :purge_split => true,       # should the split string be removed?
    :truncate_text => "#{Reverse}...#{Reverse}"  # text to be appened when truncating
  }
end
@default_send_options.update opts unless opts.empty?
end

#set_quiet(channel = nil) ⇒ Object 



792
793
794
795
796
797
798
799
800
 
# File 'lib/rbot/ircbot.rb', line 792

def set_quiet(channel = nil)
  if channel
    ch = channel.downcase.dup
    @quiet << ch
  else
    @quiet.clear
    @quiet << '*'
  end
end

#setup_plugins_path ⇒ Object 



756
757
758
759
760
761
762
763
764
765
766
 
# File 'lib/rbot/ircbot.rb', line 756

def setup_plugins_path
  @plugins.clear_botmodule_dirs
  @plugins.add_botmodule_dir(Config::coredir + "/utils")
  @plugins.add_botmodule_dir(Config::coredir)
  @plugins.add_botmodule_dir("#{botclass}/plugins")

  @config['plugins.path'].each do |_|
      path = _.sub(/^\(default\)/, Config::datadir + '/plugins')
      @plugins.add_botmodule_dir(path)
  end
end

#shutdown(message = nil) ⇒ Object

disconnect from the server and cleanup all plugins and modules



1105
1106
1107
1108
1109
1110
1111
1112
1113
1114
1115
1116
1117
1118
1119
1120
1121
1122
1123
1124
1125
1126
1127
1128
1129
1130
1131
1132
1133
1134
 
# File 'lib/rbot/ircbot.rb', line 1105

def shutdown(message=nil)
  @quit_mutex.synchronize do
    debug "Shutting down: #{message}"
    ## No we don't restore them ... let everything run through
    # begin
    #   trap("SIGINT", "DEFAULT")
    #   trap("SIGTERM", "DEFAULT")
    #   trap("SIGHUP", "DEFAULT")
    # rescue => e
    #   debug "failed to restore signals: #{e.inspect}\nProbably running on windows?"
    # end
    debug "\tdisconnecting..."
    disconnect(message)
    debug "\tstopping timer..."
    @timer.stop
    debug "\tsaving ..."
    save
    debug "\tcleaning up ..."
    @save_mutex.synchronize do
      @plugins.cleanup
    end
    # debug "\tstopping timers ..."
    # @timer.stop
    # debug "Closing registries"
    # @registry.close
    debug "\t\tcleaning up the db environment ..."
    DBTree.cleanup_env
    log "rbot quit (#{message})"
  end
end

#status ⇒ Object

returns a string describing the current status of the bot (uptime etc)



1236
1237
1238
1239
1240
1241
1242
1243
1244
1245
 
# File 'lib/rbot/ircbot.rb', line 1236

def status
  secs_up = Time.new - @startup_time
  uptime = Utils.secs_to_string secs_up
  # return "Uptime #{uptime}, #{@plugins.length} plugins active, #{@registry.length} items stored in registry, #{@socket.lines_sent} lines sent, #{@socket.lines_received} received."
  return (_("Uptime %{up}, %{plug} plugins active, %{sent} lines sent, %{recv} received.") %
           {
             :up => uptime, :plug => @plugins.length,
             :sent => @socket.lines_sent, :recv => @socket.lines_received
           })
end

#stop_server_pings ⇒ Object 



1271
1272
1273
1274
1275
 
# File 'lib/rbot/ircbot.rb', line 1271

def stop_server_pings
  # cancel previous PINGs and reset time of last RECV
  @last_ping = nil
  @last_rec = nil
end

#topic(where, topic = nil) ⇒ Object

set topic of channel where to topic can also be used to retrieve the topic of channel where by omitting the last argument



1074
1075
1076
1077
1078
1079
1080
 
# File 'lib/rbot/ircbot.rb', line 1074

def topic(where, topic=nil)
  if topic.nil?
    sendq "TOPIC #{where}", where, 2
  else
    sendq "TOPIC #{where} :#{topic}", where, 2
  end
end

#trap_sigs ⇒ Object

trap signals



824
825
826
827
828
829
830
831
832
833
834
 
# File 'lib/rbot/ircbot.rb', line 824

def trap_sigs
  begin
    trap("SIGINT") { got_sig("SIGINT") }
    trap("SIGTERM") { got_sig("SIGTERM") }
    trap("SIGHUP") { got_sig("SIGHUP", :restart) }
  rescue ArgumentError => e
    debug "failed to trap signals (#{e.pretty_inspect}): running on Windows?"
  rescue Exception => e
    debug "failed to trap signals: #{e.pretty_inspect}"
  end
end

#wanted_nick ⇒ Object

nick wanted by the bot. This defaults to the irc.nick config value, but may be overridden by a manual !nick command



212
213
214
 
# File 'lib/rbot/ircbot.rb', line 212

def wanted_nick
  @wanted_nick || config['irc.nick']
end

#wanted_nick=(wn) ⇒ Object

set the nick wanted by the bot



217
218
219
220
221
222
223
 
# File 'lib/rbot/ircbot.rb', line 217

def wanted_nick=(wn)
  if wn.nil? or wn.to_s.downcase == config['irc.nick'].downcase
    @wanted_nick = nil
  else
    @wanted_nick = wn.to_s.dup
  end
end